dao

Documentation

Index

• func WithDB(ctx context.Context, db DB) context.Context
• type DB
  • func GetDB(ctx context.Context) DB
• type Message
  • func NewMessage() *Message
  • func (m *Message) Cancel(ctx context.Context, id int64, lease string) (int64, error)
  • func (m *Message) CleanUp(ctx context.Context) error
  • func (m *Message) Complete(ctx context.Context, id int64, lease string) (int64, error)
  • func (m *Message) Consume(ctx context.Context, id int64, lease string) (int64, error)
  • func (m *Message) Create(ctx context.Context, message model.Message) (int64, error)
  • func (m *Message) DeleteByID(ctx context.Context, id int64) error
  • func (m *Message) Failed(ctx context.Context, id int64, lease string, data model.MessageAttr) (int64, error)
  • func (m *Message) GetByContent(ctx context.Context, content string) (model.Message, error)
  • func (m *Message) GetByID(ctx context.Context, id int64) (model.Message, error)
  • func (m *Message) GetCompletedAndFailed(ctx context.Context) ([]model.Message, error)
  • func (m *Message) GetStale(ctx context.Context) ([]model.Message, error)
  • func (m *Message) Heartbeat(ctx context.Context, id int64, data model.MessageAttr, lease string) (int64, error)
  • func (l *Message) InitTable(ctx context.Context) error
  • func (m *Message) List(ctx context.Context) ([]model.Message, error)
  • func (m *Message) ResetToPending(ctx context.Context, id int64) (int64, error)
  • func (m *Message) UpdateByID(ctx context.Context, id int64, message model.Message) error
  • func (m *Message) UpdatePriorityByID(ctx context.Context, id int64, priority int) error

Functions

func WithDB

func WithDB(ctx context.Context, db DB) context.Context

WithDB returns a new context with the given database connection.

Types

type DB

type DB interface {
	ExecContext(ctx context.Context, query string, args ...any) (sql.Result, error)
	QueryContext(ctx context.Context, query string, args ...any) (*sql.Rows, error)
	QueryRowContext(ctx context.Context, query string, args ...any) *sql.Row
}

func GetDB

func GetDB(ctx context.Context) DB

GetDB retrieves the database connection from the context.

type Message

type Message struct{}

func NewMessage

func NewMessage() *Message

func (*Message) Cancel

func (m *Message) Cancel(ctx context.Context, id int64, lease string) (int64, error)

func (*Message) CleanUp

func (m *Message) CleanUp(ctx context.Context) error

func (*Message) Complete

func (m *Message) Complete(ctx context.Context, id int64, lease string) (int64, error)

func (*Message) Consume

func (m *Message) Consume(ctx context.Context, id int64, lease string) (int64, error)

func (*Message) Create

func (m *Message) Create(ctx context.Context, message model.Message) (int64, error)

func (*Message) DeleteByID

func (m *Message) DeleteByID(ctx context.Context, id int64) error

func (*Message) Failed

func (m *Message) Failed(ctx context.Context, id int64, lease string, data model.MessageAttr) (int64, error)

func (*Message) GetByContent

func (m *Message) GetByContent(ctx context.Context, content string) (model.Message, error)

func (*Message) GetByID

func (m *Message) GetByID(ctx context.Context, id int64) (model.Message, error)

func (*Message) GetCompletedAndFailed

func (m *Message) GetCompletedAndFailed(ctx context.Context) ([]model.Message, error)

func (*Message) GetStale

func (m *Message) GetStale(ctx context.Context) ([]model.Message, error)

func (*Message) Heartbeat

func (m *Message) Heartbeat(ctx context.Context, id int64, data model.MessageAttr, lease string) (int64, error)

func (*Message) InitTable

func (l *Message) InitTable(ctx context.Context) error

func (*Message) List

func (m *Message) List(ctx context.Context) ([]model.Message, error)

func (*Message) ResetToPending

func (m *Message) ResetToPending(ctx context.Context, id int64) (int64, error)

func (*Message) UpdateByID

func (m *Message) UpdateByID(ctx context.Context, id int64, message model.Message) error

func (*Message) UpdatePriorityByID

func (m *Message) UpdatePriorityByID(ctx context.Context, id int64, priority int) error