publisher

Documentation

Index

• type Task
  • func New(pubClient TaskPublisherClient) *Task
  • func (p *Task) Created(ctx context.Context, task internal.Task) error
  • func (p *Task) Deleted(ctx context.Context, id string) error
  • func (p *Task) Updated(ctx context.Context, task internal.Task) error
• type TaskPublisher
• type TaskPublisherClient

Types

type Task

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

func New

func New(pubClient TaskPublisherClient) *Task

func (*Task) Created

func (p *Task) Created(ctx context.Context, task internal.Task) error

func (*Task) Deleted

func (p *Task) Deleted(ctx context.Context, id string) error

func (*Task) Updated

func (p *Task) Updated(ctx context.Context, task internal.Task) error

type TaskPublisher

type TaskPublisher interface {
	Created(ctx context.Context, task internal.Task) error
	Deleted(ctx context.Context, id string) error
	Updated(ctx context.Context, task internal.Task) error
}

type TaskPublisherClient

type TaskPublisherClient interface {
	Publish(ctx context.Context, spanName, channel string, e interface{}) error
}