model

Documentation

Overview

Package model provides dev projects and flag override data models for the api handler to use. It exists so that it can also notify observers to support streaming updates

Index

• Variables
• func ContextWithStore(ctx context.Context, store Store) context.Context
• func NewError(message string) error
• func ObserversMiddleware(observers *Observers) func(handler http.Handler) http.Handler
• func SetObserversOnContext(ctx context.Context, observers *Observers) context.Context
• func StoreMiddleware(store Store) mux.MiddlewareFunc
• type Error
  • func (e Error) Error() string
  • func (e Error) Unwrap() error
• type FlagState
• type FlagsState
  • func FromAllFlags(sdkFlags flagstate.AllFlags) FlagsState
• type Observer
• type Observers
  • func GetObserversFromContext(ctx context.Context) *Observers
  • func NewObservers() *Observers
  • func (o *Observers) DeregisterObserver(observerId uuid.UUID) bool
  • func (o *Observers) Notify(event interface{})
  • func (o *Observers) RegisterObserver(observer Observer) uuid.UUID
• type Override
  • func UpsertOverride(ctx context.Context, projectKey, flagKey string, value ldvalue.Value) (Override, error)
  • func (o Override) Apply(state FlagState) FlagState
• type Overrides
  • func (o Overrides) GetFlag(key string) (Override, bool)
• type Project
  • func CreateProject(ctx context.Context, projectKey, sourceEnvironmentKey string, ...) (Project, error)
  • func SyncProject(ctx context.Context, projectKey string) (Project, error)
  • func UpdateProject(ctx context.Context, projectKey string, context *ldcontext.Context, ...) (Project, error)
  • func (p Project) FetchFlagState(ctx context.Context) (FlagsState, error)
  • func (p Project) GetFlagStateWithOverridesForProject(ctx context.Context) (FlagsState, error)
• type Store
  • func StoreFromContext(ctx context.Context) Store
• type SyncEvent
• type UpsertOverrideEvent

Variables

var ErrAlreadyExists = errors.New("already exists")

var ErrNotFound = errors.New("not found")

Functions

func ContextWithStore

func ContextWithStore(ctx context.Context, store Store) context.Context

func NewError

func NewError(message string) error

func ObserversMiddleware

func ObserversMiddleware(observers *Observers) func(handler http.Handler) http.Handler

func SetObserversOnContext

func SetObserversOnContext(ctx context.Context, observers *Observers) context.Context

func StoreMiddleware

func StoreMiddleware(store Store) mux.MiddlewareFunc

Types

type Error

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

func (Error) Error

func (e Error) Error() string

func (Error) Unwrap

func (e Error) Unwrap() error

type FlagState

type FlagState struct {
	Value   ldvalue.Value `json:"value"`
	Version int           `json:"version"`
}

type FlagsState

type FlagsState map[string]FlagState

func FromAllFlags

func FromAllFlags(sdkFlags flagstate.AllFlags) FlagsState

type Observer

type Observer interface {
	Handle(interface{})
}

type Observers

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

func GetObserversFromContext

func GetObserversFromContext(ctx context.Context) *Observers

func NewObservers

func NewObservers() *Observers

func (*Observers) DeregisterObserver

func (o *Observers) DeregisterObserver(observerId uuid.UUID) bool

func (*Observers) Notify

func (o *Observers) Notify(event interface{})

func (*Observers) RegisterObserver

func (o *Observers) RegisterObserver(observer Observer) uuid.UUID

type Override

type Override struct {
	ProjectKey string
	FlagKey    string
	Value      ldvalue.Value
	Active     bool
	Version    int
}

func UpsertOverride

func UpsertOverride(ctx context.Context, projectKey, flagKey string, value ldvalue.Value) (Override, error)

func (Override) Apply

func (o Override) Apply(state FlagState) FlagState

type Overrides

type Overrides []Override

func (Overrides) GetFlag

func (o Overrides) GetFlag(key string) (Override, bool)

type Project

type Project struct {
	Key                  string
	SourceEnvironmentKey string
	Context              ldcontext.Context
	LastSyncTime         time.Time
	AllFlagsState        FlagsState
}

func CreateProject

func CreateProject(ctx context.Context, projectKey, sourceEnvironmentKey string, ldCtx *ldcontext.Context) (Project, error)

CreateProject creates a project and adds it to the database.

func SyncProject

func SyncProject(ctx context.Context, projectKey string) (Project, error)

func UpdateProject

func UpdateProject(ctx context.Context, projectKey string, context *ldcontext.Context, sourceEnvironmentKey *string) (Project, error)

func (Project) FetchFlagState

func (p Project) FetchFlagState(ctx context.Context) (FlagsState, error)

func (Project) GetFlagStateWithOverridesForProject

func (p Project) GetFlagStateWithOverridesForProject(ctx context.Context) (FlagsState, error)

type Store

type Store interface {
	DeactivateOverride(ctx context.Context, projectKey, flagKey string) error
	GetDevProjectKeys(ctx context.Context) ([]string, error)
	// GetDevProject fetches the project based on the projectKey. If it doesn't exist, ErrNotFound is returned
	GetDevProject(ctx context.Context, projectKey string) (*Project, error)
	UpdateProject(ctx context.Context, project Project) (bool, error)
	DeleteDevProject(ctx context.Context, projectKey string) (bool, error)
	// InsertProject inserts the project. If it already exists, ErrAlreadyExists is returned
	InsertProject(ctx context.Context, project Project) error
	UpsertOverride(ctx context.Context, override Override) (Override, error)
	GetOverridesForProject(ctx context.Context, projectKey string) (Overrides, error)
}

func StoreFromContext

func StoreFromContext(ctx context.Context) Store

type SyncEvent

type SyncEvent struct {
	ProjectKey    string
	AllFlagsState FlagsState
}

Event for full project sync

type UpsertOverrideEvent

type UpsertOverrideEvent struct {
	FlagKey    string
	ProjectKey string
	FlagState  FlagState
}

Event for individual flag overrides