Documentation ¶
Index ¶
- func RegisterNSMDServer(s *grpc.Server, srv NSMDServer)
- type ClientConnectionReply
- func (*ClientConnectionReply) Descriptor() ([]byte, []int)
- func (m *ClientConnectionReply) GetClientBaseDir() string
- func (m *ClientConnectionReply) GetHostBasedir() string
- func (m *ClientConnectionReply) GetNsmClientSocket() string
- func (m *ClientConnectionReply) GetNsmServerSocket() string
- func (m *ClientConnectionReply) GetWorkspace() string
- func (*ClientConnectionReply) ProtoMessage()
- func (m *ClientConnectionReply) Reset()
- func (m *ClientConnectionReply) String() string
- func (m *ClientConnectionReply) XXX_DiscardUnknown()
- func (m *ClientConnectionReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClientConnectionReply) XXX_Merge(src proto.Message)
- func (m *ClientConnectionReply) XXX_Size() int
- func (m *ClientConnectionReply) XXX_Unmarshal(b []byte) error
- type ClientConnectionRequest
- func (*ClientConnectionRequest) Descriptor() ([]byte, []int)
- func (m *ClientConnectionRequest) GetWorkspace() string
- func (*ClientConnectionRequest) ProtoMessage()
- func (m *ClientConnectionRequest) Reset()
- func (m *ClientConnectionRequest) String() string
- func (m *ClientConnectionRequest) XXX_DiscardUnknown()
- func (m *ClientConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ClientConnectionRequest) XXX_Merge(src proto.Message)
- func (m *ClientConnectionRequest) XXX_Size() int
- func (m *ClientConnectionRequest) XXX_Unmarshal(b []byte) error
- type DeleteConnectionReply
- func (*DeleteConnectionReply) Descriptor() ([]byte, []int)
- func (*DeleteConnectionReply) ProtoMessage()
- func (m *DeleteConnectionReply) Reset()
- func (m *DeleteConnectionReply) String() string
- func (m *DeleteConnectionReply) XXX_DiscardUnknown()
- func (m *DeleteConnectionReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteConnectionReply) XXX_Merge(src proto.Message)
- func (m *DeleteConnectionReply) XXX_Size() int
- func (m *DeleteConnectionReply) XXX_Unmarshal(b []byte) error
- type DeleteConnectionRequest
- func (*DeleteConnectionRequest) Descriptor() ([]byte, []int)
- func (m *DeleteConnectionRequest) GetWorkspace() string
- func (*DeleteConnectionRequest) ProtoMessage()
- func (m *DeleteConnectionRequest) Reset()
- func (m *DeleteConnectionRequest) String() string
- func (m *DeleteConnectionRequest) XXX_DiscardUnknown()
- func (m *DeleteConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *DeleteConnectionRequest) XXX_Merge(src proto.Message)
- func (m *DeleteConnectionRequest) XXX_Size() int
- func (m *DeleteConnectionRequest) XXX_Unmarshal(b []byte) error
- type EnumConnectionReply
- func (*EnumConnectionReply) Descriptor() ([]byte, []int)
- func (m *EnumConnectionReply) GetWorkspace() []string
- func (*EnumConnectionReply) ProtoMessage()
- func (m *EnumConnectionReply) Reset()
- func (m *EnumConnectionReply) String() string
- func (m *EnumConnectionReply) XXX_DiscardUnknown()
- func (m *EnumConnectionReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EnumConnectionReply) XXX_Merge(src proto.Message)
- func (m *EnumConnectionReply) XXX_Size() int
- func (m *EnumConnectionReply) XXX_Unmarshal(b []byte) error
- type EnumConnectionRequest
- func (*EnumConnectionRequest) Descriptor() ([]byte, []int)
- func (*EnumConnectionRequest) ProtoMessage()
- func (m *EnumConnectionRequest) Reset()
- func (m *EnumConnectionRequest) String() string
- func (m *EnumConnectionRequest) XXX_DiscardUnknown()
- func (m *EnumConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EnumConnectionRequest) XXX_Merge(src proto.Message)
- func (m *EnumConnectionRequest) XXX_Size() int
- func (m *EnumConnectionRequest) XXX_Unmarshal(b []byte) error
- type NSMDClient
- type NSMDServer
- type UnimplementedNSMDServer
- func (*UnimplementedNSMDServer) DeleteClientConnection(ctx context.Context, req *DeleteConnectionRequest) (*DeleteConnectionReply, error)
- func (*UnimplementedNSMDServer) EnumConnection(ctx context.Context, req *EnumConnectionRequest) (*EnumConnectionReply, error)
- func (*UnimplementedNSMDServer) RequestClientConnection(ctx context.Context, req *ClientConnectionRequest) (*ClientConnectionReply, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterNSMDServer ¶
func RegisterNSMDServer(s *grpc.Server, srv NSMDServer)
Types ¶
type ClientConnectionReply ¶
type ClientConnectionReply struct { Workspace string `protobuf:"bytes,1,opt,name=workspace,proto3" json:"workspace,omitempty"` HostBasedir string `protobuf:"bytes,2,opt,name=hostBasedir,proto3" json:"hostBasedir,omitempty"` ClientBaseDir string `protobuf:"bytes,3,opt,name=clientBaseDir,proto3" json:"clientBaseDir,omitempty"` NsmServerSocket string `protobuf:"bytes,4,opt,name=nsmServerSocket,proto3" json:"nsmServerSocket,omitempty"` NsmClientSocket string `protobuf:"bytes,5,opt,name=nsmClientSocket,proto3" json:"nsmClientSocket,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ClientConnectionReply is sent back by NSM as a reply to ClientConnectionRequest accepted true will indicate that the connection is accepted, otherwise false indicates that connection was refused and admission_error will provide details why connection was refused.
func (*ClientConnectionReply) Descriptor ¶
func (*ClientConnectionReply) Descriptor() ([]byte, []int)
func (*ClientConnectionReply) GetClientBaseDir ¶
func (m *ClientConnectionReply) GetClientBaseDir() string
func (*ClientConnectionReply) GetHostBasedir ¶
func (m *ClientConnectionReply) GetHostBasedir() string
func (*ClientConnectionReply) GetNsmClientSocket ¶
func (m *ClientConnectionReply) GetNsmClientSocket() string
func (*ClientConnectionReply) GetNsmServerSocket ¶
func (m *ClientConnectionReply) GetNsmServerSocket() string
func (*ClientConnectionReply) GetWorkspace ¶
func (m *ClientConnectionReply) GetWorkspace() string
func (*ClientConnectionReply) ProtoMessage ¶
func (*ClientConnectionReply) ProtoMessage()
func (*ClientConnectionReply) Reset ¶
func (m *ClientConnectionReply) Reset()
func (*ClientConnectionReply) String ¶
func (m *ClientConnectionReply) String() string
func (*ClientConnectionReply) XXX_DiscardUnknown ¶
func (m *ClientConnectionReply) XXX_DiscardUnknown()
func (*ClientConnectionReply) XXX_Marshal ¶
func (m *ClientConnectionReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClientConnectionReply) XXX_Merge ¶
func (m *ClientConnectionReply) XXX_Merge(src proto.Message)
func (*ClientConnectionReply) XXX_Size ¶
func (m *ClientConnectionReply) XXX_Size() int
func (*ClientConnectionReply) XXX_Unmarshal ¶
func (m *ClientConnectionReply) XXX_Unmarshal(b []byte) error
type ClientConnectionRequest ¶
type ClientConnectionRequest struct { Workspace string `protobuf:"bytes,1,opt,name=workspace,proto3" json:"workspace,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
ConnectionRequest is sent by a NSM client to build a connection with NSM.
func (*ClientConnectionRequest) Descriptor ¶
func (*ClientConnectionRequest) Descriptor() ([]byte, []int)
func (*ClientConnectionRequest) GetWorkspace ¶
func (m *ClientConnectionRequest) GetWorkspace() string
func (*ClientConnectionRequest) ProtoMessage ¶
func (*ClientConnectionRequest) ProtoMessage()
func (*ClientConnectionRequest) Reset ¶
func (m *ClientConnectionRequest) Reset()
func (*ClientConnectionRequest) String ¶
func (m *ClientConnectionRequest) String() string
func (*ClientConnectionRequest) XXX_DiscardUnknown ¶
func (m *ClientConnectionRequest) XXX_DiscardUnknown()
func (*ClientConnectionRequest) XXX_Marshal ¶
func (m *ClientConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ClientConnectionRequest) XXX_Merge ¶
func (m *ClientConnectionRequest) XXX_Merge(src proto.Message)
func (*ClientConnectionRequest) XXX_Size ¶
func (m *ClientConnectionRequest) XXX_Size() int
func (*ClientConnectionRequest) XXX_Unmarshal ¶
func (m *ClientConnectionRequest) XXX_Unmarshal(b []byte) error
type DeleteConnectionReply ¶
type DeleteConnectionReply struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*DeleteConnectionReply) Descriptor ¶
func (*DeleteConnectionReply) Descriptor() ([]byte, []int)
func (*DeleteConnectionReply) ProtoMessage ¶
func (*DeleteConnectionReply) ProtoMessage()
func (*DeleteConnectionReply) Reset ¶
func (m *DeleteConnectionReply) Reset()
func (*DeleteConnectionReply) String ¶
func (m *DeleteConnectionReply) String() string
func (*DeleteConnectionReply) XXX_DiscardUnknown ¶
func (m *DeleteConnectionReply) XXX_DiscardUnknown()
func (*DeleteConnectionReply) XXX_Marshal ¶
func (m *DeleteConnectionReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteConnectionReply) XXX_Merge ¶
func (m *DeleteConnectionReply) XXX_Merge(src proto.Message)
func (*DeleteConnectionReply) XXX_Size ¶
func (m *DeleteConnectionReply) XXX_Size() int
func (*DeleteConnectionReply) XXX_Unmarshal ¶
func (m *DeleteConnectionReply) XXX_Unmarshal(b []byte) error
type DeleteConnectionRequest ¶
type DeleteConnectionRequest struct { Workspace string `protobuf:"bytes,1,opt,name=workspace,proto3" json:"workspace,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
DeleteConnectionRequest is sent by a nsm-k8s to delete connection with a client.
func (*DeleteConnectionRequest) Descriptor ¶
func (*DeleteConnectionRequest) Descriptor() ([]byte, []int)
func (*DeleteConnectionRequest) GetWorkspace ¶
func (m *DeleteConnectionRequest) GetWorkspace() string
func (*DeleteConnectionRequest) ProtoMessage ¶
func (*DeleteConnectionRequest) ProtoMessage()
func (*DeleteConnectionRequest) Reset ¶
func (m *DeleteConnectionRequest) Reset()
func (*DeleteConnectionRequest) String ¶
func (m *DeleteConnectionRequest) String() string
func (*DeleteConnectionRequest) XXX_DiscardUnknown ¶
func (m *DeleteConnectionRequest) XXX_DiscardUnknown()
func (*DeleteConnectionRequest) XXX_Marshal ¶
func (m *DeleteConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*DeleteConnectionRequest) XXX_Merge ¶
func (m *DeleteConnectionRequest) XXX_Merge(src proto.Message)
func (*DeleteConnectionRequest) XXX_Size ¶
func (m *DeleteConnectionRequest) XXX_Size() int
func (*DeleteConnectionRequest) XXX_Unmarshal ¶
func (m *DeleteConnectionRequest) XXX_Unmarshal(b []byte) error
type EnumConnectionReply ¶
type EnumConnectionReply struct { Workspace []string `protobuf:"bytes,1,rep,name=workspace,proto3" json:"workspace,omitempty"` XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*EnumConnectionReply) Descriptor ¶
func (*EnumConnectionReply) Descriptor() ([]byte, []int)
func (*EnumConnectionReply) GetWorkspace ¶
func (m *EnumConnectionReply) GetWorkspace() []string
func (*EnumConnectionReply) ProtoMessage ¶
func (*EnumConnectionReply) ProtoMessage()
func (*EnumConnectionReply) Reset ¶
func (m *EnumConnectionReply) Reset()
func (*EnumConnectionReply) String ¶
func (m *EnumConnectionReply) String() string
func (*EnumConnectionReply) XXX_DiscardUnknown ¶
func (m *EnumConnectionReply) XXX_DiscardUnknown()
func (*EnumConnectionReply) XXX_Marshal ¶
func (m *EnumConnectionReply) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EnumConnectionReply) XXX_Merge ¶
func (m *EnumConnectionReply) XXX_Merge(src proto.Message)
func (*EnumConnectionReply) XXX_Size ¶
func (m *EnumConnectionReply) XXX_Size() int
func (*EnumConnectionReply) XXX_Unmarshal ¶
func (m *EnumConnectionReply) XXX_Unmarshal(b []byte) error
type EnumConnectionRequest ¶
type EnumConnectionRequest struct { XXX_NoUnkeyedLiteral struct{} `json:"-"` XXX_unrecognized []byte `json:"-"` XXX_sizecache int32 `json:"-"` }
func (*EnumConnectionRequest) Descriptor ¶
func (*EnumConnectionRequest) Descriptor() ([]byte, []int)
func (*EnumConnectionRequest) ProtoMessage ¶
func (*EnumConnectionRequest) ProtoMessage()
func (*EnumConnectionRequest) Reset ¶
func (m *EnumConnectionRequest) Reset()
func (*EnumConnectionRequest) String ¶
func (m *EnumConnectionRequest) String() string
func (*EnumConnectionRequest) XXX_DiscardUnknown ¶
func (m *EnumConnectionRequest) XXX_DiscardUnknown()
func (*EnumConnectionRequest) XXX_Marshal ¶
func (m *EnumConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EnumConnectionRequest) XXX_Merge ¶
func (m *EnumConnectionRequest) XXX_Merge(src proto.Message)
func (*EnumConnectionRequest) XXX_Size ¶
func (m *EnumConnectionRequest) XXX_Size() int
func (*EnumConnectionRequest) XXX_Unmarshal ¶
func (m *EnumConnectionRequest) XXX_Unmarshal(b []byte) error
type NSMDClient ¶
type NSMDClient interface { RequestClientConnection(ctx context.Context, in *ClientConnectionRequest, opts ...grpc.CallOption) (*ClientConnectionReply, error) EnumConnection(ctx context.Context, in *EnumConnectionRequest, opts ...grpc.CallOption) (*EnumConnectionReply, error) DeleteClientConnection(ctx context.Context, in *DeleteConnectionRequest, opts ...grpc.CallOption) (*DeleteConnectionReply, error) }
NSMDClient is the client API for NSMD service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewNSMDClient ¶
func NewNSMDClient(cc grpc.ClientConnInterface) NSMDClient
type NSMDServer ¶
type NSMDServer interface { RequestClientConnection(context.Context, *ClientConnectionRequest) (*ClientConnectionReply, error) EnumConnection(context.Context, *EnumConnectionRequest) (*EnumConnectionReply, error) DeleteClientConnection(context.Context, *DeleteConnectionRequest) (*DeleteConnectionReply, error) }
NSMDServer is the server API for NSMD service.
type UnimplementedNSMDServer ¶
type UnimplementedNSMDServer struct { }
UnimplementedNSMDServer can be embedded to have forward compatible implementations.
func (*UnimplementedNSMDServer) DeleteClientConnection ¶
func (*UnimplementedNSMDServer) DeleteClientConnection(ctx context.Context, req *DeleteConnectionRequest) (*DeleteConnectionReply, error)
func (*UnimplementedNSMDServer) EnumConnection ¶
func (*UnimplementedNSMDServer) EnumConnection(ctx context.Context, req *EnumConnectionRequest) (*EnumConnectionReply, error)
func (*UnimplementedNSMDServer) RequestClientConnection ¶
func (*UnimplementedNSMDServer) RequestClientConnection(ctx context.Context, req *ClientConnectionRequest) (*ClientConnectionReply, error)