store

Documentation

Index

• Variables
• func Decoder() *decoder
• func NewApplicationFromResource(res *resource.Application, cfg *EncoderConfig) resourceState
• func NewComposeModuleFromResource(res *resource.ComposeModule, cfg *EncoderConfig) resourceState
• func NewComposeRecordFromResource(res *resource.ComposeRecord, cfg *EncoderConfig) resourceState
• func NewRoleFromResource(res *resource.Role, cfg *EncoderConfig) resourceState
• func NewSettingFromResource(res *resource.Setting, cfg *EncoderConfig) resourceState
• func NewStoreEncoder(s store.Storer, dal dalService, cfg *EncoderConfig) envoy.PrepareEncoder
• func NewTemplateFromResource(res *resource.Template, cfg *EncoderConfig) resourceState
• func NewUserFromResource(res *resource.User, cfg *EncoderConfig) resourceState
• type DecodeFilter
  • func NewDecodeFilter() *DecodeFilter
  • func (df *DecodeFilter) APIGWRoutes(f *types.ApigwRouteFilter) *DecodeFilter
  • func (df *DecodeFilter) Applications(f *types.ApplicationFilter) *DecodeFilter
  • func (df *DecodeFilter) AutomationWorkflows(f *types.WorkflowFilter) *DecodeFilter
  • func (df *DecodeFilter) ComposeChart(f *types.ChartFilter) *DecodeFilter
  • func (df *DecodeFilter) ComposeModule(f *types.ModuleFilter) *DecodeFilter
  • func (df *DecodeFilter) ComposeNamespace(f *types.NamespaceFilter) *DecodeFilter
  • func (df *DecodeFilter) ComposePage(f *types.PageFilter) *DecodeFilter
  • func (df *DecodeFilter) ComposeRecord(f *types.RecordFilter) *DecodeFilter
  • func (df *DecodeFilter) FromRef(rr ...*resource.Ref) *DecodeFilter
  • func (df *DecodeFilter) FromResource(rr ...string) *DecodeFilter
  • func (df *DecodeFilter) Rbac(f *rbac.RuleFilter) *DecodeFilter
  • func (df *DecodeFilter) RbacStrict(f *rbac.RuleFilter) *DecodeFilter
  • func (df *DecodeFilter) Reports(f *types.ReportFilter) *DecodeFilter
  • func (df *DecodeFilter) ResourceTranslation(f *types.ResourceTranslationFilter) *DecodeFilter
  • func (df *DecodeFilter) Roles(f *types.RoleFilter) *DecodeFilter
  • func (df *DecodeFilter) Settings(f *types.SettingsFilter) *DecodeFilter
  • func (df *DecodeFilter) Templates(f *types.TemplateFilter) *DecodeFilter
  • func (df *DecodeFilter) Users(f *types.UserFilter) *DecodeFilter
• type EncoderConfig

Variables

var (
	ErrUnknownResource        = fmt.Errorf("unknown resource")
	ErrResourceStateUndefined = fmt.Errorf("undefined resource state")
)

var (

	// wrapper around NextID that will aid service testing
	NextID = func() uint64 {
		return id.Next()
	}
)

Functions

func Decoder

func Decoder() *decoder

func NewApplicationFromResource

func NewApplicationFromResource(res *resource.Application, cfg *EncoderConfig) resourceState

func NewComposeModuleFromResource

func NewComposeModuleFromResource(res *resource.ComposeModule, cfg *EncoderConfig) resourceState

func NewComposeRecordFromResource

func NewComposeRecordFromResource(res *resource.ComposeRecord, cfg *EncoderConfig) resourceState

func NewRoleFromResource

func NewRoleFromResource(res *resource.Role, cfg *EncoderConfig) resourceState

func NewSettingFromResource

func NewSettingFromResource(res *resource.Setting, cfg *EncoderConfig) resourceState

func NewStoreEncoder

func NewStoreEncoder(s store.Storer, dal dalService, cfg *EncoderConfig) envoy.PrepareEncoder

NewStoreEncoder initializes a fresh store encoder

If no config is provided, it uses Skip as the default merge alg.

func NewTemplateFromResource

func NewTemplateFromResource(res *resource.Template, cfg *EncoderConfig) resourceState

func NewUserFromResource

func NewUserFromResource(res *resource.User, cfg *EncoderConfig) resourceState

Types

type DecodeFilter

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

func NewDecodeFilter

func NewDecodeFilter() *DecodeFilter

func (*DecodeFilter) APIGWRoutes

func (df *DecodeFilter) APIGWRoutes(f *types.ApigwRouteFilter) *DecodeFilter

func (*DecodeFilter) Applications

func (df *DecodeFilter) Applications(f *types.ApplicationFilter) *DecodeFilter

Applications adds a new ApplicationFilter

func (*DecodeFilter) AutomationWorkflows

func (df *DecodeFilter) AutomationWorkflows(f *types.WorkflowFilter) *DecodeFilter

AutomationWorkflows adds a new WorkflowFilter

func (*DecodeFilter) ComposeChart

func (df *DecodeFilter) ComposeChart(f *types.ChartFilter) *DecodeFilter

ComposeChart adds a new compose ChartFilter

func (*DecodeFilter) ComposeModule

func (df *DecodeFilter) ComposeModule(f *types.ModuleFilter) *DecodeFilter

ComposeModule adds a new compose ModuleFilter

func (*DecodeFilter) ComposeNamespace

func (df *DecodeFilter) ComposeNamespace(f *types.NamespaceFilter) *DecodeFilter

ComposeNamespace adds a new compose NamespaceFilter

func (*DecodeFilter) ComposePage

func (df *DecodeFilter) ComposePage(f *types.PageFilter) *DecodeFilter

ComposePage adds a new compose PageFilter

func (*DecodeFilter) ComposeRecord

func (df *DecodeFilter) ComposeRecord(f *types.RecordFilter) *DecodeFilter

ComposeRecord adds a new compose RecordFilter

func (*DecodeFilter) FromRef

func (df *DecodeFilter) FromRef(rr ...*resource.Ref) *DecodeFilter

func (*DecodeFilter) FromResource

func (df *DecodeFilter) FromResource(rr ...string) *DecodeFilter

func (*DecodeFilter) Rbac

func (df *DecodeFilter) Rbac(f *rbac.RuleFilter) *DecodeFilter

Rbac adds a new RuleFilter

func (*DecodeFilter) RbacStrict

func (df *DecodeFilter) RbacStrict(f *rbac.RuleFilter) *DecodeFilter

func (*DecodeFilter) Reports

func (df *DecodeFilter) Reports(f *types.ReportFilter) *DecodeFilter

func (*DecodeFilter) ResourceTranslation

func (df *DecodeFilter) ResourceTranslation(f *types.ResourceTranslationFilter) *DecodeFilter

ResourceTranslation adds a new ResourceTranslationFilter

func (*DecodeFilter) Roles

func (df *DecodeFilter) Roles(f *types.RoleFilter) *DecodeFilter

Roles adds a new RoleFilter

func (*DecodeFilter) Settings

func (df *DecodeFilter) Settings(f *types.SettingsFilter) *DecodeFilter

Settings adds a new SettingsFilter

func (*DecodeFilter) Templates

func (df *DecodeFilter) Templates(f *types.TemplateFilter) *DecodeFilter

Templates adds a new TemplateFilter

func (*DecodeFilter) Users

func (df *DecodeFilter) Users(f *types.UserFilter) *DecodeFilter

Users adds a new UserFilter

type EncoderConfig

type EncoderConfig struct {
	// OnExisting defines what to do if the resource exists
	OnExisting resource.MergeAlg
	// Skip if defines a pkg/expr expression when to skip the resource
	SkipIf string
	// Defer is called after the resource is encoded, regardles of the result
	Defer func()
	// DeferOk is called after the resource is encoded, only when successful
	DeferOk func()
	// DeferNok is called after the resource is encoded, only when failed
	// If you return an error, the encoding will terminate.
	// If you return nil (ignore the error), the encoding will continue.
	DeferNok func(error) error
}

EncoderConfig allows us to configure the resource encoding process