cloudblob

Documentation

Index

• Variables
• type BucketState
• type Provider
  • func NewProvider(app app.Context, rsp rule.SetProcessor) (*Provider, error)
  • func (p *Provider) Start(_ context.Context) error
  • func (p *Provider) Stop(_ context.Context) error
• type RuleSetFetcher

Variables

var Module = fx.Options(
	fx.Invoke(
		fx.Annotate(
			NewProvider,
			fx.OnStart(func(ctx context.Context, p *Provider) error { return p.Start(ctx) }),
			fx.OnStop(func(ctx context.Context, p *Provider) error { return p.Stop(ctx) }),
		),
	),
)

Module is used on app bootstrap. nolint: gochecknoglobals

Types

type BucketState

type BucketState map[string][]byte

type Provider

type Provider struct {
	// contains filtered or unexported fields
}

func NewProvider

func NewProvider(app app.Context, rsp rule.SetProcessor) (*Provider, error)

func (*Provider) Start

func (p *Provider) Start(_ context.Context) error

func (*Provider) Stop

func (p *Provider) Stop(_ context.Context) error

type RuleSetFetcher

type RuleSetFetcher interface {
	FetchRuleSets(ctx context.Context, app app.Context) ([]*config.RuleSet, error)
	ID() string
}