gorm

Documentation

Index

• type Client
  • func NewClient(db *gorm.DB) *Client
  • func (c *Client) Create(ctx context.Context, messages []gooutstore.Message) error
  • func (c *Client) FromContext(ctx context.Context) *gorm.DB
  • func (c *Client) IncRetry(ctx context.Context, m gooutstore.Message) error
  • func (c *Client) ReadBatch(ctx context.Context, messageType string, batchSize int) ([]gooutstore.Message, error)
  • func (c *Client) SetBroken(ctx context.Context, m gooutstore.Message) error
  • func (c *Client) SetDone(ctx context.Context, m gooutstore.Message) error
  • func (c *Client) ToContext(ctx context.Context, tx *gorm.DB) context.Context
  • func (c *Client) WithTransaction(ctx context.Context, fn func(context.Context) error) (err error)

Types

type Client

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

func NewClient

func NewClient(db *gorm.DB) *Client

func (*Client) Create

func (c *Client) Create(ctx context.Context, messages []gooutstore.Message) error

func (*Client) FromContext

func (c *Client) FromContext(ctx context.Context) *gorm.DB

func (*Client) IncRetry

func (c *Client) IncRetry(ctx context.Context, m gooutstore.Message) error

func (*Client) ReadBatch

func (c *Client) ReadBatch(ctx context.Context, messageType string, batchSize int) ([]gooutstore.Message, error)

func (*Client) SetBroken

func (c *Client) SetBroken(ctx context.Context, m gooutstore.Message) error

func (*Client) SetDone

func (c *Client) SetDone(ctx context.Context, m gooutstore.Message) error

func (*Client) ToContext

func (c *Client) ToContext(ctx context.Context, tx *gorm.DB) context.Context

func (*Client) WithTransaction

func (c *Client) WithTransaction(ctx context.Context, fn func(context.Context) error) (err error)