rabbitmq

package

v0.0.0-...-e52e0c3 Latest Latest Go to latest Published: Sep 14, 2025 License: MIT Imports: 6 Imported by: 0

Documentation ¶

This section is empty.

This section is empty.

This section is empty.

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

Task represents the repository used for publishing Task records.

func NewTask(channel *amqp.Channel) *Task

NewTask instantiates the Task repository.

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

Created publishes a message indicating a task was created.

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

Deleted publishes a message indicating a task was deleted.

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

Updated publishes a message indicating a task was updated.