streamclient

Documentation

Index

• func DisconnectAllProxies(reason error) chan struct{}
• func InitProxyMemoryCleanup()
• func IsAgentOnline(streamAgentID streamtypes.ID) bool
• type AgentStream
  • func GetAgentStream(streamAgentID streamtypes.ID) *AgentStream
  • func NewAgent(a pgrest.Agent, s pb.Transport_ConnectServer) *AgentStream
  • func (s *AgentStream) AgentID() string
  • func (s *AgentStream) AgentName() string
  • func (s *AgentStream) Close(pctx plugintypes.Context, errMsg error) error
  • func (s *AgentStream) ConnectionName() string
  • func (s *AgentStream) Context() context.Context
  • func (s *AgentStream) GetMeta(key string) string
  • func (s *AgentStream) GetOrgID() string
  • func (s *AgentStream) GetOrgName() string
  • func (s *AgentStream) Save() (err error)
  • func (s *AgentStream) StreamAgentID() streamtypes.ID
  • func (s *AgentStream) String() string
• type ProxyStream
  • func GetProxyStream(sid string) *ProxyStream
  • func NewProxy(pluginCtx *plugintypes.Context, s pb.Transport_ConnectServer) *ProxyStream
  • func (s *ProxyStream) Close(errMsg error) error
  • func (s *ProxyStream) Context() context.Context
  • func (s *ProxyStream) ContextCauseError() error
  • func (s *ProxyStream) GetMeta(key string) string
  • func (s *ProxyStream) GetRedactInfoTypes() []string
  • func (s *ProxyStream) IsAgentOnline() bool
  • func (s *ProxyStream) PluginContext() plugintypes.Context
  • func (s *ProxyStream) PluginExecOnDisconnect(ctx plugintypes.Context, errMsg error) error
  • func (s *ProxyStream) PluginExecOnReceive(pctx plugintypes.Context, pkt *pb.Packet) (*plugintypes.ConnectResponse, error)
  • func (s *ProxyStream) Save() (err error)
  • func (s *ProxyStream) SendToAgent(pkt *pb.Packet) error
  • func (s *ProxyStream) SetPluginContext(fn func(pctx *plugintypes.Context))
  • func (s *ProxyStream) StreamAgentID() streamtypes.ID
  • func (s *ProxyStream) String() string

Functions

func DisconnectAllProxies

func DisconnectAllProxies(reason error) chan struct{}

func InitProxyMemoryCleanup

func InitProxyMemoryCleanup()

InitProxyMemoryCleanup ensures the cleanup of proxy streams in memory

func IsAgentOnline

func IsAgentOnline(streamAgentID streamtypes.ID) bool

Types

type AgentStream

type AgentStream struct {
	pb.Transport_ConnectServer
	// contains filtered or unexported fields
}

func GetAgentStream

func GetAgentStream(streamAgentID streamtypes.ID) *AgentStream

func NewAgent

func NewAgent(a pgrest.Agent, s pb.Transport_ConnectServer) *AgentStream

func (*AgentStream) AgentID

func (s *AgentStream) AgentID() string

func (*AgentStream) AgentName

func (s *AgentStream) AgentName() string

func (*AgentStream) Close

func (s *AgentStream) Close(pctx plugintypes.Context, errMsg error) error

func (*AgentStream) ConnectionName

func (s *AgentStream) ConnectionName() string

func (*AgentStream) Context

func (s *AgentStream) Context() context.Context

Override context from transport stream

func (*AgentStream) GetMeta

func (s *AgentStream) GetMeta(key string) string

func (*AgentStream) GetOrgID

func (s *AgentStream) GetOrgID() string

func (*AgentStream) GetOrgName

func (s *AgentStream) GetOrgName() string

func (*AgentStream) Save

func (s *AgentStream) Save() (err error)

func (*AgentStream) StreamAgentID

func (s *AgentStream) StreamAgentID() streamtypes.ID

func (*AgentStream) String

func (s *AgentStream) String() string

type ProxyStream

type ProxyStream struct {
	pb.Transport_ConnectServer
	// contains filtered or unexported fields
}

func GetProxyStream

func GetProxyStream(sid string) *ProxyStream

func NewProxy

func NewProxy(pluginCtx *plugintypes.Context, s pb.Transport_ConnectServer) *ProxyStream

func (*ProxyStream) Close

func (s *ProxyStream) Close(errMsg error) error

func (*ProxyStream) Context

func (s *ProxyStream) Context() context.Context

Override context from transport stream

func (*ProxyStream) ContextCauseError

func (s *ProxyStream) ContextCauseError() error

func (*ProxyStream) GetMeta

func (s *ProxyStream) GetMeta(key string) string

func (*ProxyStream) GetRedactInfoTypes

func (s *ProxyStream) GetRedactInfoTypes() []string

GetRedactInfoTypes return the in memory info types for the data masking (dlp) plugin

func (*ProxyStream) IsAgentOnline

func (s *ProxyStream) IsAgentOnline() bool

func (*ProxyStream) PluginContext

func (s *ProxyStream) PluginContext() plugintypes.Context

func (*ProxyStream) PluginExecOnDisconnect

func (s *ProxyStream) PluginExecOnDisconnect(ctx plugintypes.Context, errMsg error) error

func (*ProxyStream) PluginExecOnReceive

func (s *ProxyStream) PluginExecOnReceive(pctx plugintypes.Context, pkt *pb.Packet) (*plugintypes.ConnectResponse, error)

func (*ProxyStream) Save

func (s *ProxyStream) Save() (err error)

func (*ProxyStream) SendToAgent

func (s *ProxyStream) SendToAgent(pkt *pb.Packet) error

func (*ProxyStream) SetPluginContext

func (s *ProxyStream) SetPluginContext(fn func(pctx *plugintypes.Context))

SetPluginContext allows overriding the plugin context configuration

func (*ProxyStream) StreamAgentID

func (s *ProxyStream) StreamAgentID() streamtypes.ID

If the agent is a multi connection type, it returns a deterministic uuid based on the agent id and the id of the connection, otherwise it returns the agent_id of the connection

func (*ProxyStream) String

func (s *ProxyStream) String() string