rabbitmq

Documentation

Index

• type Task
  • func NewTask(channel *amqp.Channel) (*Task, error)
  • 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(channel *amqp.Channel) (*Task, error)

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.