isbsvc

package
v1.2.2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 15, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func JetStreamName added in v0.5.2

func JetStreamName(bufferName string) string

func JetStreamSideInputsStoreKVName added in v0.10.0

func JetStreamSideInputsStoreKVName(sideInputStoreName string) string

Types

type BufferInfo

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

BufferInfo wraps the buffer state information

type CreateOption added in v0.8.1

type CreateOption func(*createOptions) error

func WithConfig added in v0.8.1

func WithConfig(conf string) CreateOption

WithConfig sets buffer and bucket config option

type ISBService

type ISBService interface {
	// CreateBuffersAndBuckets creates buffers and buckets
	CreateBuffersAndBuckets(ctx context.Context, buffers, buckets []string, sideInputsStore string, opts ...CreateOption) error
	// DeleteBuffersAndBuckets deletes buffers and buckets
	DeleteBuffersAndBuckets(ctx context.Context, buffers, buckets []string, sideInputsStore string) error
	// ValidateBuffersAndBuckets validates buffers and buckets
	ValidateBuffersAndBuckets(ctx context.Context, buffers, buckets []string, sideInputsStore string) error
	// GetBufferInfo returns buffer info for the given buffer
	GetBufferInfo(ctx context.Context, buffer string) (*BufferInfo, error)
	// CreateWatermarkStores creates watermark stores
	CreateWatermarkStores(ctx context.Context, bucketName string, partitions int, isReduce bool) ([]store.WatermarkStore, 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 added in v0.5.4

func WithJetStreamClient(jsClient *jsclient.Client) JSServiceOption

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL