channelmanager

type ChannelInput struct {
	Source      SourceInput `json:"source" form:"source" query:"source" validate:"required,dive"`
	Destination TargetInput `json:"destination" form:"destination" query:"destination" validate:"required,dive"`
}

type ChannelManager interface {
	GetChannels() ([]channel.Channel, error)
	AddChannel(channel channel.Channel) (*channel.Channel, error)
	DeleteChannel(id string) error
	UpdateChannel(id string, channel channel.Channel) (*channel.Channel, error)
}

type ChannelManagerServer interface {
	ListChannels(ctx echo.Context) error
	AddChannel(ctx echo.Context) error
	DeleteChannel(ctx echo.Context) error
	UpdateChannel(ctx echo.Context) error
}

type SchedulerChannelManager struct {
	// contains filtered or unexported fields
}

type SchedulerChannelManagerServer struct {
	// contains filtered or unexported fields
}

type SourceInput struct {
	Driver             string                            `json:"driver" form:"driver" query:"driver" validate:"required,oneof=pubsub"`
	PubsubSourceConfig pubsublistenerconfig.SourceConfig `json:"config" form:"config" query:"config" validate:"required_if=Driver pubsub"`
}

type TargetInput struct {
	Driver             string                                  `json:"driver" form:"driver" query:"driver" validate:"required,oneof=pubsub"`
	PubsubTargetConfig pubsubpublisherconfig.DestinationConfig `json:"config" form:"config" query:"config" validate:"required_if=Driver pubsub"`
}