isbsvc

Documentation

Index

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

Functions

func JetStreamName

func JetStreamName(bufferName string) string

func JetStreamOTBucket

func JetStreamOTBucket(bucketName string) string

func JetStreamProcessorBucket

func JetStreamProcessorBucket(bucketName string) string

Types

type BufferInfo

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

BufferInfo wraps the buffer state information

type CreateOption

type CreateOption func(*createOptions) error

func WithConfig

func WithConfig(conf string) CreateOption

WithConfig sets buffer and bucket config option

type ISBService

type ISBService interface {
	CreateBuffersAndBuckets(ctx context.Context, buffers, buckets []string, opts ...CreateOption) error
	DeleteBuffersAndBuckets(ctx context.Context, buffers, buckets []string) error
	ValidateBuffersAndBuckets(ctx context.Context, buffers, buckets []string) error
	GetBufferInfo(ctx context.Context, buffer string) (*BufferInfo, error)
	CreateWatermarkFetcher(ctx context.Context, bucketName string, partitions int, isReduce bool) ([]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.NATSClient) JSServiceOption