kafka

Documentation

Index

• type Task
  • func NewTask(producer *kafka.Producer, topicName string) *Task
  • func (t *Task) Created(ctx context.Context, task internal.Task) error
  • func (t *Task) Deleted(ctx context.Context, id string) error
  • func (t *Task) Updated(ctx context.Context, task internal.Task) error

Types

type Task

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

Task represents the repository used for publishing Task records.

func NewTask

func NewTask(producer *kafka.Producer, topicName string) *Task

NewTask instantiates the Task repository.

func (*Task) Created

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

Created publishes a message indicating a task was created.

func (*Task) Deleted

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

Deleted publishes a message indicating a task was deleted.

func (*Task) Updated

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

Updated publishes a message indicating a task was updated.