isbsvc

Documentation

Index

• type BufferCreateOption
  • func WithBufferConfig(conf string) BufferCreateOption
• type BufferInfo
• type ISBService
  • func NewISBJetStreamSvc(pipelineName string, opts ...JSServiceOption) (ISBService, error)
  • func NewISBRedisSvc(client *clients.RedisClient) ISBService
• type JSServiceOption
  • func WithNatsConnection(conn *nats.Conn) JSServiceOption

Types

type BufferCreateOption

type BufferCreateOption func(*bufferCreateOptions) error

func WithBufferConfig

func WithBufferConfig(conf string) BufferCreateOption

WithBufferConfig sets buffer config option

type BufferInfo

type BufferInfo struct {
	Name            string
	PendingCount    int64
	AckPendingCount int64
	TotalMessages   int64
}

BufferInfo wraps the buffer state information

type ISBService

type ISBService interface {
	CreateBuffers(ctx context.Context, buffers []string, opts ...BufferCreateOption) error
	DeleteBuffers(ctx context.Context, buffers []string) error
	ValidateBuffers(ctx context.Context, buffers []string) error
	GetBufferInfo(ctx context.Context, buffer string) (*BufferInfo, error)
}

ISBService is an interface used to do the operations on ISBS

func NewISBJetStreamSvc

func NewISBJetStreamSvc(pipelineName string, opts ...JSServiceOption) (ISBService, error)

func NewISBRedisSvc

func NewISBRedisSvc(client *clients.RedisClient) ISBService

NewISBRedisSvc is used to return a new object of type isbsRedisSvc

type JSServiceOption

type JSServiceOption func(*jetStreamSvc) error

func WithNatsConnection

func WithNatsConnection(conn *nats.Conn) JSServiceOption