sqs

Documentation

Index

• type Manager
  • func NewManager(cfg *settings.Config, eventRepo domain.EventSourceRepository) *Manager
  • func (m *Manager) StartAllEventSources(ctx context.Context) error
  • func (m *Manager) StartEventSource(ctx context.Context, eventSource *domain.EventSource) error

Types

type Manager

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

func NewManager

func NewManager(cfg *settings.Config, eventRepo domain.EventSourceRepository) *Manager

func (*Manager) StartAllEventSources

func (m *Manager) StartAllEventSources(ctx context.Context) error

func (*Manager) StartEventSource

func (m *Manager) StartEventSource(ctx context.Context, eventSource *domain.EventSource) error