producer

Documentation

Index

• Constants
• type SinkActivityEvent
  • func (s *SinkActivityEvent) Encode() map[string]interface{}
• type SinkActivityProducer
  • func NewSinkActivityProducer(l *zap.Logger, redisStreamClient *redis.Client, sinkTTL SinkerKeyService) SinkActivityProducer
• type SinkIdleEvent
  • func (s *SinkIdleEvent) Encode() map[string]interface{}
• type SinkIdleProducer
  • func NewSinkIdleProducer(l *zap.Logger, redisStreamClient *redis.Client) SinkIdleProducer
• type SinkerKey
  • func (s *SinkerKey) Encode() map[string]interface{}
• type SinkerKeyService
  • func NewSinkerKeyService(l *zap.Logger, cacheRepository *redis.Client) SinkerKeyService

Constants

const DefaultExpiration = 5 * time.Minute

Types

type SinkActivityEvent

type SinkActivityEvent struct {
	OwnerID   string
	SinkID    string
	State     string
	Size      string
	Timestamp time.Time
}

func (*SinkActivityEvent) Encode

func (s *SinkActivityEvent) Encode() map[string]interface{}

type SinkActivityProducer

type SinkActivityProducer interface {
	// PublishSinkActivity to be used to publish the sink activity to the sinker, mainly used by Otel Bridge Service
	PublishSinkActivity(ctx context.Context, event SinkActivityEvent) error
}

func NewSinkActivityProducer

func NewSinkActivityProducer(l *zap.Logger, redisStreamClient *redis.Client, sinkTTL SinkerKeyService) SinkActivityProducer

type SinkIdleEvent

type SinkIdleEvent struct {
	OwnerID   string
	SinkID    string
	State     string
	Size      string
	Timestamp time.Time
}

func (*SinkIdleEvent) Encode

func (s *SinkIdleEvent) Encode() map[string]interface{}

type SinkIdleProducer

type SinkIdleProducer interface {
	// PublishSinkIdle to be used to publish the sink activity to the sinker, mainly used by Otel Bridge Service
	PublishSinkIdle(ctx context.Context, event SinkIdleEvent) error
}

func NewSinkIdleProducer

func NewSinkIdleProducer(l *zap.Logger, redisStreamClient *redis.Client) SinkIdleProducer

type SinkerKey

type SinkerKey struct {
	OwnerID      string
	SinkID       string
	Size         string
	LastActivity time.Time
}

func (*SinkerKey) Encode

func (s *SinkerKey) Encode() map[string]interface{}

type SinkerKeyService

type SinkerKeyService interface {
	// AddNewSinkerKey Add New Sinker Key with default Expiration of 5 minutes
	AddNewSinkerKey(ctx context.Context, key SinkerKey) error
	// RenewSinkerKey Increment Expiration of Sinker Key
	RenewSinkerKey(ctx context.Context, key SinkerKey) error
	// RenewSinkerKeyInternal Increment Expiration of Sinker Key
	RenewSinkerKeyInternal(ctx context.Context, sink SinkerKey, expiration time.Duration) error
}

func NewSinkerKeyService

func NewSinkerKeyService(l *zap.Logger, cacheRepository *redis.Client) SinkerKeyService