store

package

Go to main page

Versions in this module

v0

v0.0.12

Dec 15, 2023

Changes in this version

type Options

+ InstallID string

v0.0.11

Dec 12, 2023

v0.0.10

Dec 6, 2023

Changes in this version

+ const InstallIDKey

+ const RedisCreationDateKey

+ const RedisTelemetryAudienceFormat

+ const RedisTelemetryAudiencePrefix

+ const RedisTelemetryRegistrationFormat

+ const RedisTelemetryRegistrationPrefix

+ func RedisTelemetryAudience(aud *protos.Audience) string

+ func RedisTelemetryRegistrationKey(serviceName, os, sdk, arch string) string

type IStore

+ GetCreationDate func(ctx context.Context) (int64, error)

+ GetInstallID func(ctx context.Context) (string, error)

+ IsPipelineAttachedAny func(ctx context.Context, pipelineID string) bool

+ RecordRegistration func(ctx context.Context, req *protos.RegisterRequest) error

+ SeenRegistration func(ctx context.Context, req *protos.RegisterRequest) bool

+ SetCreationDate func(ctx context.Context, ts int64) error

type Options

+ Telemetry statsd.Statter

type Store

+ InstallID string

+ func (s *Store) GetCreationDate(ctx context.Context) (int64, error)

+ func (s *Store) GetInstallID(ctx context.Context) (string, error)

+ func (s *Store) IsPipelineAttachedAny(ctx context.Context, pipelineID string) bool

+ func (s *Store) RecordRegistration(ctx context.Context, req *protos.RegisterRequest) error

+ func (s *Store) SeenRegistration(ctx context.Context, req *protos.RegisterRequest) bool

+ func (s *Store) SetCreationDate(ctx context.Context, ts int64) error

v0.0.9

Dec 1, 2023

Changes in this version

+ const RedisPausedTailKeyFormat

+ func RedisActiveTailKey(tailID string) string

+ func RedisPausedTailKey(tailID string) string

type IStore

+ GetTailRequestById func(ctx context.Context, tailID string) (*protos.TailRequest, error)

+ PauseTailRequest func(ctx context.Context, req *protos.PauseTailRequest) (*protos.TailRequest, error)

+ ResumeTailRequest func(ctx context.Context, req *protos.ResumeTailRequest) (*protos.TailRequest, error)

type Store

+ func (s *Store) GetPausedTailRequestById(ctx context.Context, tailID string) (*protos.TailRequest, error)

+ func (s *Store) GetTailRequestById(ctx context.Context, tailID string) (*protos.TailRequest, error)

+ func (s *Store) PauseTailRequest(ctx context.Context, req *protos.PauseTailRequest) (*protos.TailRequest, error)

+ func (s *Store) ResumeTailRequest(ctx context.Context, req *protos.ResumeTailRequest) (*protos.TailRequest, error)

v0.0.8

Nov 20, 2023

v0.0.7

Nov 20, 2023

v0.0.6

Nov 16, 2023

v0.0.5

Nov 9, 2023

v0.0.4

Nov 8, 2023

v0.0.3

Nov 8, 2023

v0.0.2

Nov 8, 2023

v0.0.1

Oct 30, 2023

Changes in this version

+ const RedisActiveTailKeyFormat

+ const RedisActiveTailPrefix

+ const RedisActiveTailTTL

+ const RedisAudienceKeyFormat

+ const RedisAudiencePrefix

+ const RedisConfigKeyFormat

+ const RedisConfigPrefix

+ const RedisKeyWatchPrefix

+ const RedisLiveFormat

+ const RedisLivePrefix

+ const RedisNotificationAssocFormat

+ const RedisNotificationAssocPrefix

+ const RedisNotificationConfigKeyFormat

+ const RedisNotificationConfigPrefix

+ const RedisPausedKeyFormat

+ const RedisPausedPrefix

+ const RedisPipelineKeyFormat

+ const RedisPipelinePrefix

+ const RedisRegisterFormat

+ const RedisSchemaFormat

+ const RedisSchemaPrefix

+ const StreamdalIDKey

+ var ErrConfigNotFound = errors.New("config not found")

+ var ErrPipelineNotFound = errors.New("pipeline not found")

+ func RedisAudienceKey(audience string) string

+ func RedisConfigKey(audience *protos.Audience, pipelineID string) string

+ func RedisLiveKey(session, node, audience string) string

+ func RedisNotificationAssocKey(pipelineID, configID string) string

+ func RedisNotificationConfigKey(configID string) string

+ func RedisPausedKey(audience, pipelineID string) string

+ func RedisPipelineKey(pipelineID string) string

+ func RedisRegisterKey(session, node string) string

+ func RedisSchemaKey(audience string) string

+ type IStore interface

+ AddActiveTailRequest func(ctx context.Context, req *protos.TailRequest) (string, error)

+ AddAudience func(ctx context.Context, req *protos.NewAudienceRequest) error

+ AddRegistration func(ctx context.Context, req *protos.RegisterRequest) error

+ AddSchema func(ctx context.Context, req *protos.SendSchemaRequest) error

+ AttachNotificationConfig func(ctx context.Context, req *protos.AttachNotificationRequest) error

+ AttachPipeline func(ctx context.Context, req *protos.AttachPipelineRequest) error

+ CreateNotificationConfig func(ctx context.Context, req *protos.CreateNotificationRequest) error

+ CreatePipeline func(ctx context.Context, pipeline *protos.Pipeline) error

+ DeleteAudience func(ctx context.Context, req *protos.DeleteAudienceRequest) error

+ DeleteNotificationConfig func(ctx context.Context, req *protos.DeleteNotificationRequest) error

+ DeletePipeline func(ctx context.Context, pipelineID string) error

+ DeleteRegistration func(ctx context.Context, req *protos.DeregisterRequest) error

+ DetachNotificationConfig func(ctx context.Context, req *protos.DetachNotificationRequest) error

+ DetachPipeline func(ctx context.Context, req *protos.DetachPipelineRequest) error

+ GetActivePipelineUsage func(ctx context.Context, pipelineID string) ([]*PipelineUsage, error)

+ GetActiveTailCommandsByService func(ctx context.Context, serviceName string) ([]*protos.Command, error)

+ GetAttachCommandsByService func(ctx context.Context, serviceName string) ([]*protos.Command, error)

+ GetAudiences func(ctx context.Context) ([]*protos.Audience, error)

+ GetAudiencesByService func(ctx context.Context, serviceName string) ([]*protos.Audience, error)

+ GetAudiencesBySessionID func(ctx context.Context, sessionID string) ([]*protos.Audience, error)

+ GetConfig func(ctx context.Context) (map[*protos.Audience][]string, error)

+ GetConfigByAudience func(ctx context.Context, audience *protos.Audience) ([]string, error)

+ GetLive func(ctx context.Context) ([]*types.LiveEntry, error)

+ GetNotificationConfig func(ctx context.Context, req *protos.GetNotificationRequest) (*protos.NotificationConfig, error)

+ GetNotificationConfigs func(ctx context.Context) (map[string]*protos.NotificationConfig, error)

+ GetNotificationConfigsByPipeline func(ctx context.Context, pipelineID string) ([]*protos.NotificationConfig, error)

+ GetPaused func(ctx context.Context) (map[string]*types.PausedEntry, error)

+ GetPipeline func(ctx context.Context, pipelineID string) (*protos.Pipeline, error)

+ GetPipelineUsage func(ctx context.Context) ([]*PipelineUsage, error)

+ GetPipelines func(ctx context.Context) (map[string]*protos.Pipeline, error)

+ GetSchema func(ctx context.Context, aud *protos.Audience) (*protos.Schema, error)

+ GetStreamdalID func(ctx context.Context) (string, error)

+ IsPaused func(ctx context.Context, audience *protos.Audience, pipelineID string) (bool, error)

+ IsPipelineAttached func(ctx context.Context, audience *protos.Audience, pipelineID string) (bool, error)

+ PausePipeline func(ctx context.Context, req *protos.PausePipelineRequest) error

+ ResumePipeline func(ctx context.Context, req *protos.ResumePipelineRequest) error

+ UpdateNotificationConfig func(ctx context.Context, req *protos.UpdateNotificationRequest) error

+ UpdatePipeline func(ctx context.Context, pipeline *protos.Pipeline) error

+ WatchKeys func(quitCtx context.Context, key string) chan struct{}

+ type Options struct

+ Encryption encryption.IEncryption

+ NodeName string

+ RedisBackend *redis.Client

+ SessionTTL time.Duration

+ ShutdownCtx context.Context

+ type PipelineUsage struct

+ Active bool

+ Audience *protos.Audience

+ NodeName string

+ PipelineId string

+ SessionId string

+ type Store struct

+ func New(opts *Options) (*Store, error)

+ func (s *Store) AddActiveTailRequest(ctx context.Context, req *protos.TailRequest) (string, error)

+ func (s *Store) AddAudience(ctx context.Context, req *protos.NewAudienceRequest) error

+ func (s *Store) AddRegistration(ctx context.Context, req *protos.RegisterRequest) error

+ func (s *Store) AddSchema(ctx context.Context, req *protos.SendSchemaRequest) error

+ func (s *Store) AttachNotificationConfig(ctx context.Context, req *protos.AttachNotificationRequest) error

+ func (s *Store) AttachPipeline(ctx context.Context, req *protos.AttachPipelineRequest) error

+ func (s *Store) CreateNotificationConfig(ctx context.Context, req *protos.CreateNotificationRequest) error

+ func (s *Store) CreatePipeline(ctx context.Context, pipeline *protos.Pipeline) error

+ func (s *Store) DeleteAudience(ctx context.Context, req *protos.DeleteAudienceRequest) error

+ func (s *Store) DeleteNotificationConfig(ctx context.Context, req *protos.DeleteNotificationRequest) error

+ func (s *Store) DeletePipeline(ctx context.Context, pipelineId string) error

+ func (s *Store) DeleteRegistration(ctx context.Context, req *protos.DeregisterRequest) error

+ func (s *Store) DetachNotificationConfig(ctx context.Context, req *protos.DetachNotificationRequest) error

+ func (s *Store) DetachPipeline(ctx context.Context, req *protos.DetachPipelineRequest) error

+ func (s *Store) GetActivePipelineUsage(ctx context.Context, pipelineID string) ([]*PipelineUsage, error)

+ func (s *Store) GetActiveTailCommandsByService(ctx context.Context, serviceName string) ([]*protos.Command, error)

+ func (s *Store) GetAttachCommandsByService(ctx context.Context, serviceName string) ([]*protos.Command, error)

+ func (s *Store) GetAudiences(ctx context.Context) ([]*protos.Audience, error)

+ func (s *Store) GetAudiencesByService(ctx context.Context, serviceName string) ([]*protos.Audience, error)

+ func (s *Store) GetAudiencesBySessionID(ctx context.Context, sessionID string) ([]*protos.Audience, error)

+ func (s *Store) GetConfig(ctx context.Context) (map[*protos.Audience][]string, error)

+ func (s *Store) GetConfigByAudience(ctx context.Context, audience *protos.Audience) ([]string, error)

+ func (s *Store) GetLive(ctx context.Context) ([]*types.LiveEntry, error)

+ func (s *Store) GetNotificationConfig(ctx context.Context, req *protos.GetNotificationRequest) (*protos.NotificationConfig, error)

+ func (s *Store) GetNotificationConfigs(ctx context.Context) (map[string]*protos.NotificationConfig, error)

+ func (s *Store) GetNotificationConfigsByPipeline(ctx context.Context, pipelineID string) ([]*protos.NotificationConfig, error)

+ func (s *Store) GetPaused(ctx context.Context) (map[string]*types.PausedEntry, error)

+ func (s *Store) GetPipeline(ctx context.Context, pipelineId string) (*protos.Pipeline, error)

+ func (s *Store) GetPipelineUsage(ctx context.Context) ([]*PipelineUsage, error)

+ func (s *Store) GetPipelines(ctx context.Context) (map[string]*protos.Pipeline, error)

+ func (s *Store) GetSchema(ctx context.Context, aud *protos.Audience) (*protos.Schema, error)

+ func (s *Store) GetStreamdalID(ctx context.Context) (string, error)

+ func (s *Store) IsPaused(ctx context.Context, audience *protos.Audience, pipelineID string) (bool, error)

+ func (s *Store) IsPipelineAttached(ctx context.Context, audience *protos.Audience, pipelineID string) (bool, error)

+ func (s *Store) PausePipeline(ctx context.Context, req *protos.PausePipelineRequest) error

+ func (s *Store) ResumePipeline(ctx context.Context, req *protos.ResumePipelineRequest) error

+ func (s *Store) UpdateNotificationConfig(ctx context.Context, req *protos.UpdateNotificationRequest) error

+ func (s *Store) UpdatePipeline(ctx context.Context, pipeline *protos.Pipeline) error

+ func (s *Store) WatchKeys(quitCtx context.Context, key string) chan struct{}

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