producer

Documentation

Index

• type GenericTask
• type Option
  • func WithRunningTimeout(timeout time.Duration) Option
  • func WithTasksBuffer(buffer int) Option
• type Producer
  • func NewProducer(identity string, connectAddress string, actorOpts []actor.Option, ...) (*Producer, error)
  • func (s *Producer) Close()
  • func (s *Producer) Connect() error
  • func (s *Producer) Process(ctx context.Context, genericTask GenericTask, timeout time.Duration) ([]string, error)
  • func (s *Producer) Run(ctx context.Context, errors chan<- error, logs chan<- string)
• type RunningState
• type SendAnnounceState
• type StartState
• type Task
• type TaskChannels
• type WaitAnnounceAckState

Types

type GenericTask

type GenericTask interface {
	Function() string
	Args() []string
}

type Option

type Option func(*Producer)

func WithRunningTimeout

func WithRunningTimeout(timeout time.Duration) Option

func WithTasksBuffer

func WithTasksBuffer(buffer int) Option

type Producer

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

func NewProducer

func NewProducer(identity string, connectAddress string, actorOpts []actor.Option, opts ...Option) (*Producer, error)

func (*Producer) Close

func (s *Producer) Close()

func (*Producer) Connect

func (s *Producer) Connect() error

func (*Producer) Process

func (s *Producer) Process(ctx context.Context, genericTask GenericTask, timeout time.Duration) ([]string, error)

func (*Producer) Run

func (s *Producer) Run(ctx context.Context, errors chan<- error, logs chan<- string)

type RunningState

type RunningState struct{}

type SendAnnounceState

type SendAnnounceState struct{}

type StartState

type StartState struct{}

type Task

type Task struct {
	ID       string
	Function string
	Args     []string
}

type TaskChannels

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

type WaitAnnounceAckState

type WaitAnnounceAckState struct{}