Versions in this module Expand all Collapse all v0 v0.2.0 Nov 18, 2019 Changes in this version + const NamespaceKey + const PodNameKey + const Workspace + var ConnectionEventType_name = map[int32]string + var ConnectionEventType_value = map[string]int32 + var State_name = map[int32]string + var State_value = map[string]int32 + func AddMechanism(mtype string, validator func(*Mechanism) error) + func FilterMapOnManagerScopeSelector(c map[string]*Connection, selector *MonitorScopeSelector) map[string]*Connection + func RegisterMonitorConnectionServer(s *grpc.Server, srv MonitorConnectionServer) + type Connection struct + Context *connectioncontext.ConnectionContext + Id string + Labels map[string]string + Mechanism *Mechanism + NetworkService string + NetworkServiceEndpointName string + NetworkServiceManagers []string + State State + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Connection) Descriptor() ([]byte, []int) + func (*Connection) ProtoMessage() + func (c *Connection) Clone() *Connection + func (c *Connection) Equals(connection *Connection) bool + func (c *Connection) GetDestinationNetworkServiceManagerName() string + func (c *Connection) GetSourceNetworkServiceManagerName() string + func (c *Connection) IsComplete() error + func (c *Connection) IsRemote() bool + func (c *Connection) IsValid() error + func (c *Connection) MatchesMonitorScopeSelector(selector *MonitorScopeSelector) bool + func (c *Connection) UpdateContext(context *connectioncontext.ConnectionContext) error + func (m *Connection) GetContext() *connectioncontext.ConnectionContext + func (m *Connection) GetId() string + func (m *Connection) GetLabels() map[string]string + func (m *Connection) GetMechanism() *Mechanism + func (m *Connection) GetNetworkService() string + func (m *Connection) GetNetworkServiceEndpointName() string + func (m *Connection) GetNetworkServiceManagers() []string + func (m *Connection) GetState() State + func (m *Connection) Reset() + func (m *Connection) String() string + func (m *Connection) XXX_DiscardUnknown() + func (m *Connection) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Connection) XXX_Merge(src proto.Message) + func (m *Connection) XXX_Size() int + func (m *Connection) XXX_Unmarshal(b []byte) error + type ConnectionEvent struct + Connections map[string]*Connection + Type ConnectionEventType + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ConnectionEvent) Descriptor() ([]byte, []int) + func (*ConnectionEvent) ProtoMessage() + func (m *ConnectionEvent) GetConnections() map[string]*Connection + func (m *ConnectionEvent) GetType() ConnectionEventType + func (m *ConnectionEvent) Reset() + func (m *ConnectionEvent) String() string + func (m *ConnectionEvent) XXX_DiscardUnknown() + func (m *ConnectionEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ConnectionEvent) XXX_Merge(src proto.Message) + func (m *ConnectionEvent) XXX_Size() int + func (m *ConnectionEvent) XXX_Unmarshal(b []byte) error + type ConnectionEventType int32 + const ConnectionEventType_DELETE + const ConnectionEventType_INITIAL_STATE_TRANSFER + const ConnectionEventType_UPDATE + func (ConnectionEventType) EnumDescriptor() ([]byte, []int) + func (x ConnectionEventType) String() string + type Mechanism struct + Cls string + Parameters map[string]string + Type string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Mechanism) Descriptor() ([]byte, []int) + func (*Mechanism) ProtoMessage() + func (m *Mechanism) Clone() *Mechanism + func (m *Mechanism) Equals(mechanism *Mechanism) bool + func (m *Mechanism) GetCls() string + func (m *Mechanism) GetParameters() map[string]string + func (m *Mechanism) GetType() string + func (m *Mechanism) IsValid() error + func (m *Mechanism) Reset() + func (m *Mechanism) String() string + func (m *Mechanism) XXX_DiscardUnknown() + func (m *Mechanism) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Mechanism) XXX_Merge(src proto.Message) + func (m *Mechanism) XXX_Size() int + func (m *Mechanism) XXX_Unmarshal(b []byte) error + type MonitorConnectionClient interface + MonitorConnections func(ctx context.Context, in *MonitorScopeSelector, opts ...grpc.CallOption) (MonitorConnection_MonitorConnectionsClient, error) + func NewMonitorConnectionClient(cc *grpc.ClientConn) MonitorConnectionClient + type MonitorConnectionServer interface + MonitorConnections func(*MonitorScopeSelector, MonitorConnection_MonitorConnectionsServer) error + type MonitorConnection_MonitorConnectionsClient interface + Recv func() (*ConnectionEvent, error) + type MonitorConnection_MonitorConnectionsServer interface + Send func(*ConnectionEvent) error + type MonitorScopeSelector struct + NetworkServiceManagers []string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*MonitorScopeSelector) Descriptor() ([]byte, []int) + func (*MonitorScopeSelector) ProtoMessage() + func (m *MonitorScopeSelector) GetNetworkServiceManagers() []string + func (m *MonitorScopeSelector) Reset() + func (m *MonitorScopeSelector) String() string + func (m *MonitorScopeSelector) XXX_DiscardUnknown() + func (m *MonitorScopeSelector) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *MonitorScopeSelector) XXX_Merge(src proto.Message) + func (m *MonitorScopeSelector) XXX_Size() int + func (m *MonitorScopeSelector) XXX_Unmarshal(b []byte) error + type State int32 + const State_DOWN + const State_UP + func (State) EnumDescriptor() ([]byte, []int) + func (x State) String() string + type UnimplementedMonitorConnectionServer struct + func (*UnimplementedMonitorConnectionServer) MonitorConnections(req *MonitorScopeSelector, srv MonitorConnection_MonitorConnectionsServer) error