outbox

Documentation

Index

• type Opts
  • func WithBatchSize(batchSize int) Opts
  • func WithProducer(producer sarama.SyncProducer) Opts
  • func WithWorkerCount(workerCount int) Opts
• type Outbox
  • func NewPub(db *pg.DB, opt ...Opts) *Outbox
  • func (p *Outbox) Close()
  • func (p *Outbox) Save(topic string, key string, data []byte) error
  • func (p *Outbox) Start(ctx context.Context)
  • func (p *Outbox) Stop()
• type Outboxes

Types

type Opts

type Opts func(*Outbox) error

func WithBatchSize

func WithBatchSize(batchSize int) Opts

func WithProducer

func WithProducer(producer sarama.SyncProducer) Opts

func WithWorkerCount

func WithWorkerCount(workerCount int) Opts

type Outbox

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

func NewPub

func NewPub(db *pg.DB, opt ...Opts) *Outbox

func (*Outbox) Close

func (p *Outbox) Close()

func (*Outbox) Save

func (p *Outbox) Save(topic string, key string, data []byte) error

func (*Outbox) Start

func (p *Outbox) Start(ctx context.Context)

func (*Outbox) Stop

func (p *Outbox) Stop()

type Outboxes

type Outboxes struct {
	ID          string                 `pg:"id,type:uuid,default:uuid_generate_v4(),pk"`
	Payload     map[string]interface{} `pg:"type:jsonb,notnull"`
	Key         string                 `pg:"type:varchar(255)"`
	IsDeliver   bool                   `pg:"type:bool,notnull,default:false"`
	Topic       string                 `pg:"type:varchar(255),notnull"`
	CreatedAt   time.Time              `pg:"type:timestamptz,default:now()"`
	ProcessedAt time.Time              `pg:"type:timestamptz,default:null"`
	CreatedBy   string                 `pg:"type:varchar(255)"`
	UpdatedAt   time.Time              `pg:"type:timestamptz,default:now()"`
	UpdatedBy   string                 `pg:"type:varchar(255)"`
}