Function makeEventStreamView

internal/display/event_streams.go:112–132

(eventStream *management.EventStream)

}

func makeEventStreamView(eventStream *management.EventStream) (*eventStreamView, error) {
	var subscriptions []string
	for _, subs := range eventStream.GetSubscriptions() {
		subscriptions = append(subscriptions, subs.GetEventStreamSubscriptionType())
	}

	configuration, err := toJSONString(eventStream.GetDestination().GetEventStreamDestinationConfiguration())
	if err != nil {
		return nil, err
	}

	return &eventStreamView{
		ID:            ansi.Faint(eventStream.GetID()),
		Name:          eventStream.GetName(),
		Type:          eventStream.Destination.GetEventStreamDestinationType(),
		Status:        eventStream.GetStatus(),
		Subscriptions: subscriptions,
		Configuration: configuration,
		raw:           eventStream,
	}, nil
}

/*----------------------------------------------- Delivery ------------------------------------------------.*/