isbsvc

Documentation

Index

• func JetStreamName(pipelineName, bufferName string) string
• func JetStreamOTBucket(pipelineName, bufferName string) string
• func JetStreamProcessorBucket(pipelineName, bufferName string) string
• type BufferCreateOption
  • func WithBufferConfig(conf string) BufferCreateOption
• type BufferInfo
• type ISBService
  • func NewISBJetStreamSvc(pipelineName string, opts ...JSServiceOption) (ISBService, error)
  • func NewISBRedisSvc(client *redisclient.RedisClient) ISBService
• type JSServiceOption
  • func WithJetStreamClient(jsClient jsclient.JetStreamClient) JSServiceOption

Functions

func JetStreamName

func JetStreamName(pipelineName, bufferName string) string

func JetStreamOTBucket

func JetStreamOTBucket(pipelineName, bufferName string) string

func JetStreamProcessorBucket

func JetStreamProcessorBucket(pipelineName, bufferName string) string

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 []dfv1.Buffer, opts ...BufferCreateOption) error
	DeleteBuffers(ctx context.Context, buffers []dfv1.Buffer) error
	ValidateBuffers(ctx context.Context, buffers []dfv1.Buffer) error
	GetBufferInfo(ctx context.Context, buffer dfv1.Buffer) (*BufferInfo, error)
	CreateWatermarkFetcher(ctx context.Context, bufferName string) (fetch.Fetcher, error)
}

ISBService is an interface used to do the operations on ISBSvc

func NewISBJetStreamSvc

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

func NewISBRedisSvc

func NewISBRedisSvc(client *redisclient.RedisClient) ISBService

NewISBRedisSvc is used to return a new object of type isbsRedisSvc

type JSServiceOption

type JSServiceOption func(*jetStreamSvc) error

func WithJetStreamClient

func WithJetStreamClient(jsClient jsclient.JetStreamClient) JSServiceOption