channelmanager

Documentation

Index

• type ChannelInput
• type ChannelManager
• type ChannelManagerServer
• type SchedulerChannelManager
  • func NewSchedulerChannelManager(cluster *raft.Raft, storage *storage.PqStorage, handler *channel.EventHandler) *SchedulerChannelManager
  • func (m *SchedulerChannelManager) AddChannel(channelInput channel.Channel) (*channel.Channel, error)
  • func (m *SchedulerChannelManager) BootChannelManager(cluster *raft.Raft, storage *storage.PqStorage, handler *channel.EventHandler) error
  • func (m *SchedulerChannelManager) DeleteChannel(ID string) error
  • func (m *SchedulerChannelManager) GetChannels() ([]channel.Channel, error)
  • func (m *SchedulerChannelManager) UpdateChannel(ID string, channelInput channel.Channel) (*channel.Channel, error)
• type SchedulerChannelManagerServer
  • func (m *SchedulerChannelManagerServer) AddChannel(ctx echo.Context) error
  • func (m *SchedulerChannelManagerServer) BootChannelManagerServer(manager ChannelManager, httpServer *echo.Echo) error
  • func (m *SchedulerChannelManagerServer) DeleteChannel(ctx echo.Context) error
  • func (m *SchedulerChannelManagerServer) ListChannels(ctx echo.Context) error
  • func (m *SchedulerChannelManagerServer) UpdateChannel(ctx echo.Context) error
• type SourceInput
• type TargetInput

Types

type ChannelInput

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

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

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

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

func NewSchedulerChannelManager

func NewSchedulerChannelManager(cluster *raft.Raft, storage *storage.PqStorage, handler *channel.EventHandler) *SchedulerChannelManager

func (*SchedulerChannelManager) AddChannel

func (m *SchedulerChannelManager) AddChannel(channelInput channel.Channel) (*channel.Channel, error)

func (*SchedulerChannelManager) BootChannelManager

func (m *SchedulerChannelManager) BootChannelManager(cluster *raft.Raft, storage *storage.PqStorage, handler *channel.EventHandler) error

func (*SchedulerChannelManager) DeleteChannel

func (m *SchedulerChannelManager) DeleteChannel(ID string) error

func (*SchedulerChannelManager) GetChannels

func (m *SchedulerChannelManager) GetChannels() ([]channel.Channel, error)

func (*SchedulerChannelManager) UpdateChannel

func (m *SchedulerChannelManager) UpdateChannel(ID string, channelInput channel.Channel) (*channel.Channel, error)

type SchedulerChannelManagerServer

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

func (*SchedulerChannelManagerServer) AddChannel

func (m *SchedulerChannelManagerServer) AddChannel(ctx echo.Context) error

func (*SchedulerChannelManagerServer) BootChannelManagerServer

func (m *SchedulerChannelManagerServer) BootChannelManagerServer(manager ChannelManager, httpServer *echo.Echo) error

func (*SchedulerChannelManagerServer) DeleteChannel

func (m *SchedulerChannelManagerServer) DeleteChannel(ctx echo.Context) error

func (*SchedulerChannelManagerServer) ListChannels

func (m *SchedulerChannelManagerServer) ListChannels(ctx echo.Context) error

func (*SchedulerChannelManagerServer) UpdateChannel

func (m *SchedulerChannelManagerServer) UpdateChannel(ctx echo.Context) error

type SourceInput

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

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"`
}