rabbitmq

package
v0.0.0-...-527e48b Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 7, 2022 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL