retry

Documentation

Index

• type Closable
• type Countable
• type Packet
  • func NewPacket(view cx.View, batch *cx.Batch) *Packet
• type Queueable
  • func NewImMemoryQueueEngine() Queueable
• type Retryable
  • func NewRetry(ctx context.Context, engine Queueable, writer Writeable, logger cx.Logger, ...) Retryable
• type Writeable
  • func NewDefaultWriter(conn cx.Clickhouse) Writeable

Types

type Closable

type Closable interface {
	Close() error
	CloseMessage() string
}

type Countable

type Countable interface {
	Inc() uint64
	Dec() uint64
	Val() uint64
}

type Packet

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

func NewPacket

func NewPacket(view cx.View, batch *cx.Batch) *Packet

type Queueable

type Queueable interface {
	Queue(packet *Packet)
	Retries() <-chan *Packet
}

func NewImMemoryQueueEngine

func NewImMemoryQueueEngine() Queueable

type Retryable

type Retryable interface {
	Retry(packet *Packet)
	Metrics() (uint64, uint64, uint64)
}

func NewRetry

func NewRetry(ctx context.Context, engine Queueable, writer Writeable, logger cx.Logger, isDebug bool) Retryable

type Writeable

type Writeable interface {
	Write(ctx context.Context, view cx.View, batch *cx.Batch) (uint64, error)
}

func NewDefaultWriter

func NewDefaultWriter(conn cx.Clickhouse) Writeable