connection

Documentation

Index

• func RefreshConnections(ctx context.Context, pluginManager pluginManager, ...) (res *steampipeconfig.RefreshConnectionResult)
• type ConnectionConfigMap
  • func NewConnectionConfigMap(connectionMap map[string]*modconfig.SteampipeConnection) ConnectionConfigMap
  • func (m ConnectionConfigMap) Diff(otherMap ConnectionConfigMap) (...)
• type ConnectionWatcher
  • func NewConnectionWatcher(pluginManager pluginManager) (*ConnectionWatcher, error)
  • func (w *ConnectionWatcher) Close()
• type LimiterMap
  • func NewLimiterMap(limiters []*plugin.RateLimiter) LimiterMap
  • func (l LimiterMap) Equals(other LimiterMap) bool
  • func (l LimiterMap) ToPluginLimiterMap() PluginLimiterMap
• type PluginLimiterMap
  • func (l PluginLimiterMap) Equals(other PluginLimiterMap) bool
• type PluginMap
  • func (p PluginMap) ToPluginLimiterMap() PluginLimiterMap

Functions

func RefreshConnections

func RefreshConnections(ctx context.Context, pluginManager pluginManager, forceUpdateConnectionNames ...string) (res *steampipeconfig.RefreshConnectionResult)

Types

type ConnectionConfigMap

type ConnectionConfigMap map[string]*sdkproto.ConnectionConfig

func NewConnectionConfigMap

func NewConnectionConfigMap(connectionMap map[string]*modconfig.SteampipeConnection) ConnectionConfigMap

NewConnectionConfigMap creates a map of sdkproto.ConnectionConfig keyed by connection name NOTE: connections in error are EXCLUDED

func (ConnectionConfigMap) Diff

func (m ConnectionConfigMap) Diff(otherMap ConnectionConfigMap) (addedConnections, deletedConnections, changedConnections map[string][]*sdkproto.ConnectionConfig)

type ConnectionWatcher

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

func NewConnectionWatcher

func NewConnectionWatcher(pluginManager pluginManager) (*ConnectionWatcher, error)

func (*ConnectionWatcher) Close

func (w *ConnectionWatcher) Close()

type LimiterMap

type LimiterMap map[string]*plugin.RateLimiter

LimiterMap is a map of limiter name to limiter definition

func NewLimiterMap

func NewLimiterMap(limiters []*plugin.RateLimiter) LimiterMap

func (LimiterMap) Equals

func (l LimiterMap) Equals(other LimiterMap) bool

func (LimiterMap) ToPluginLimiterMap

func (l LimiterMap) ToPluginLimiterMap() PluginLimiterMap

ToPluginLimiterMap converts limiter map keyed by limiter name to a map of limiter maps keyed by plugin image ref

type PluginLimiterMap

type PluginLimiterMap map[string]LimiterMap

PluginLimiterMap map of plugin image ref to Limiter map for the plugin

func (PluginLimiterMap) Equals

func (l PluginLimiterMap) Equals(other PluginLimiterMap) bool

type PluginMap

type PluginMap map[string]*plugin.Plugin

func (PluginMap) ToPluginLimiterMap

func (p PluginMap) ToPluginLimiterMap() PluginLimiterMap