edge

Documentation

Index

• Constants
• type Config
• type Counter
• type Plugin
  • func (p *Plugin) Reconfigure(ctx context.Context, config interface{})
  • func (p *Plugin) Start(ctx context.Context) error
  • func (p *Plugin) Stop(ctx context.Context)
  • func (p *Plugin) SyncNow()
• type PluginFactory
  • func NewPluginFactory(ctx context.Context, cfg *topaz.Config, logger *zerolog.Logger) PluginFactory
  • func (f PluginFactory) New(m *plugins.Manager, config interface{}) plugins.Plugin
  • func (PluginFactory) Validate(m *plugins.Manager, config []byte) (interface{}, error)
• type Result
• type Sync
  • func NewSyncMgr(c *Config, topazConfig *topaz.Config, logger *zerolog.Logger) *Sync
  • func (s *Sync) Run()

Constants

const PluginName = "aserto_edge"

Types

type Config

type Config struct {
	Enabled      bool   `json:"enabled"`
	Addr         string `json:"addr"`
	APIKey       string `json:"apikey"`
	TenantID     string `json:"tenant_id,omitempty"`
	Timeout      int    `json:"timeout"`
	PageSize     int    `json:"page_size"`
	SyncInterval int    `json:"sync_interval"`
	Insecure     bool   `json:"insecure"`
	SessionID    string `json:"session_id,omitempty"`
}

type Counter

type Counter struct {
	Received      int32
	Upserts       int32
	Deletes       int32
	Errors        int32
	ObjectTypes   int32
	RelationTypes int32
	Permissions   int32
	Objects       int32
	Relations     int32
}

type Plugin

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

func (*Plugin) Reconfigure

func (p *Plugin) Reconfigure(ctx context.Context, config interface{})

func (*Plugin) Start

func (p *Plugin) Start(ctx context.Context) error

func (*Plugin) Stop

func (p *Plugin) Stop(ctx context.Context)

func (*Plugin) SyncNow

func (p *Plugin) SyncNow()

type PluginFactory

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

func NewPluginFactory

func NewPluginFactory(ctx context.Context, cfg *topaz.Config, logger *zerolog.Logger) PluginFactory

func (PluginFactory) New

func (f PluginFactory) New(m *plugins.Manager, config interface{}) plugins.Plugin

func (PluginFactory) Validate

func (PluginFactory) Validate(m *plugins.Manager, config []byte) (interface{}, error)

type Result

type Result struct {
	Counts *Counter
	Err    error
}

type Sync

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

func NewSyncMgr

func NewSyncMgr(c *Config, topazConfig *topaz.Config, logger *zerolog.Logger) *Sync

func (*Sync) Run

func (s *Sync) Run()