mongodb

Documentation

Index

• type PolicyEvent
• type Storage
  • func New(db *mongo.Client, dbname, collection string, logger *zap.Logger) (*Storage, error)
  • func (s *Storage) ActiveImportConfigs(ctx context.Context) ([]*storage.PolicyAutoImport, error)
  • func (s *Storage) AddPolicySubscribers(subscribers ...storage.PolicySubscriber)
  • func (s *Storage) AutoImportConfig(ctx context.Context, policyURL string) (*storage.PolicyAutoImport, error)
  • func (s *Storage) AutoImportConfigs(ctx context.Context) ([]*storage.PolicyAutoImport, error)
  • func (s *Storage) Close(ctx context.Context)
  • func (s *Storage) CreateSubscriber(ctx context.Context, subscriber *storage.Subscriber) (*storage.Subscriber, error)
  • func (s *Storage) DeleteAutoImportConfig(ctx context.Context, policyURL string) error
  • func (s *Storage) DeleteData(ctx context.Context, key string) error
  • func (s *Storage) GetData(ctx context.Context, key string) (any, error)
  • func (s *Storage) GetPolicies(ctx context.Context, locked *bool, policyName *string) ([]*storage.Policy, error)
  • func (s *Storage) GetRefreshPolicies(ctx context.Context) ([]*storage.Policy, error)
  • func (s *Storage) ListenPolicyDataChanges(ctx context.Context) error
  • func (s *Storage) Policy(ctx context.Context, repository, group, name, version string) (*storage.Policy, error)
  • func (s *Storage) PolicySubscribers(ctx context.Context, ...) ([]*storage.Subscriber, error)
  • func (s *Storage) SaveAutoImportConfig(ctx context.Context, importConfig *storage.PolicyAutoImport) error
  • func (s *Storage) SavePolicy(ctx context.Context, policy *storage.Policy) error
  • func (s *Storage) SetData(ctx context.Context, key string, data map[string]interface{}) error
  • func (s *Storage) SetPolicyLock(ctx context.Context, repository, group, name, version string, lock bool) error
  • func (s *Storage) Subscriber(ctx context.Context, ...) (*storage.Subscriber, error)
  • func (s *Storage) Transaction(ctx context.Context, ...) (interface{}, error)
  • func (s *Storage) UpdateNextRefreshTime(ctx context.Context, p *storage.Policy, nextDataRefreshTime time.Time) error

Types

type PolicyEvent

type PolicyEvent struct {
	OperationType string         `bson:"operationType"`
	Policy        storage.Policy `bson:"fullDocument"`
}

type Storage

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

func New

func New(db *mongo.Client, dbname, collection string, logger *zap.Logger) (*Storage, error)

func (*Storage) ActiveImportConfigs

func (s *Storage) ActiveImportConfigs(ctx context.Context) ([]*storage.PolicyAutoImport, error)

func (*Storage) AddPolicySubscribers

func (s *Storage) AddPolicySubscribers(subscribers ...storage.PolicySubscriber)

func (*Storage) AutoImportConfig

func (s *Storage) AutoImportConfig(ctx context.Context, policyURL string) (*storage.PolicyAutoImport, error)

func (*Storage) AutoImportConfigs

func (s *Storage) AutoImportConfigs(ctx context.Context) ([]*storage.PolicyAutoImport, error)

func (*Storage) Close

func (s *Storage) Close(ctx context.Context)

func (*Storage) CreateSubscriber

func (s *Storage) CreateSubscriber(ctx context.Context, subscriber *storage.Subscriber) (*storage.Subscriber, error)

func (*Storage) DeleteAutoImportConfig

func (s *Storage) DeleteAutoImportConfig(ctx context.Context, policyURL string) error

func (*Storage) DeleteData

func (s *Storage) DeleteData(ctx context.Context, key string) error

func (*Storage) GetData

func (s *Storage) GetData(ctx context.Context, key string) (any, error)

func (*Storage) GetPolicies

func (s *Storage) GetPolicies(ctx context.Context, locked *bool, policyName *string) ([]*storage.Policy, error)

func (*Storage) GetRefreshPolicies

func (s *Storage) GetRefreshPolicies(ctx context.Context) ([]*storage.Policy, error)

func (*Storage) ListenPolicyDataChanges

func (s *Storage) ListenPolicyDataChanges(ctx context.Context) error

func (*Storage) Policy

func (s *Storage) Policy(ctx context.Context, repository, group, name, version string) (*storage.Policy, error)

func (*Storage) PolicySubscribers

func (s *Storage) PolicySubscribers(ctx context.Context, policyRepository, policyName, policyGroup, policyVersion string) ([]*storage.Subscriber, error)

func (*Storage) SaveAutoImportConfig

func (s *Storage) SaveAutoImportConfig(ctx context.Context, importConfig *storage.PolicyAutoImport) error

func (*Storage) SavePolicy

func (s *Storage) SavePolicy(ctx context.Context, policy *storage.Policy) error

func (*Storage) SetData

func (s *Storage) SetData(ctx context.Context, key string, data map[string]interface{}) error

func (*Storage) SetPolicyLock

func (s *Storage) SetPolicyLock(ctx context.Context, repository, group, name, version string, lock bool) error

func (*Storage) Subscriber

func (s *Storage) Subscriber(ctx context.Context, policyRepository, policyGroup, policyName, policyVersion, webhookURL, name string) (*storage.Subscriber, error)

func (*Storage) Transaction

func (s *Storage) Transaction(ctx context.Context, callback func(mCtx mongo.SessionContext) (interface{}, error)) (interface{}, error)

func (*Storage) UpdateNextRefreshTime

func (s *Storage) UpdateNextRefreshTime(ctx context.Context, p *storage.Policy, nextDataRefreshTime time.Time) error

UpdateNextRefreshTime updates policy's data and nextDataRefreshTimeField fields