Documentation
¶
Index ¶
- Variables
- func RegisterOpenNMSIpcServer(s *grpc.Server, srv OpenNMSIpcServer)
- type Empty
- type OpenNMSIpcClient
- type OpenNMSIpcServer
- type OpenNMSIpc_RpcStreamingClient
- type OpenNMSIpc_RpcStreamingServer
- type OpenNMSIpc_SinkStreamingClient
- type OpenNMSIpc_SinkStreamingServer
- type RpcRequestProto
- func (*RpcRequestProto) Descriptor() ([]byte, []int)deprecated
- func (x *RpcRequestProto) GetExpirationTime() uint64
- func (x *RpcRequestProto) GetLocation() string
- func (x *RpcRequestProto) GetModuleId() string
- func (x *RpcRequestProto) GetRpcContent() []byte
- func (x *RpcRequestProto) GetRpcId() string
- func (x *RpcRequestProto) GetSystemId() string
- func (x *RpcRequestProto) GetTracingInfo() map[string]string
- func (*RpcRequestProto) ProtoMessage()
- func (x *RpcRequestProto) ProtoReflect() protoreflect.Message
- func (x *RpcRequestProto) Reset()
- func (x *RpcRequestProto) String() string
- type RpcResponseProto
- func (*RpcResponseProto) Descriptor() ([]byte, []int)deprecated
- func (x *RpcResponseProto) GetLocation() string
- func (x *RpcResponseProto) GetModuleId() string
- func (x *RpcResponseProto) GetRpcContent() []byte
- func (x *RpcResponseProto) GetRpcId() string
- func (x *RpcResponseProto) GetSystemId() string
- func (x *RpcResponseProto) GetTracingInfo() map[string]string
- func (*RpcResponseProto) ProtoMessage()
- func (x *RpcResponseProto) ProtoReflect() protoreflect.Message
- func (x *RpcResponseProto) Reset()
- func (x *RpcResponseProto) String() string
- type SinkMessage
- func (*SinkMessage) Descriptor() ([]byte, []int)deprecated
- func (x *SinkMessage) GetContent() []byte
- func (x *SinkMessage) GetLocation() string
- func (x *SinkMessage) GetMessageId() string
- func (x *SinkMessage) GetModuleId() string
- func (x *SinkMessage) GetSystemId() string
- func (x *SinkMessage) GetTracingInfo() map[string]string
- func (*SinkMessage) ProtoMessage()
- func (x *SinkMessage) ProtoReflect() protoreflect.Message
- func (x *SinkMessage) Reset()
- func (x *SinkMessage) String() string
- type UnimplementedOpenNMSIpcServer
Constants ¶
This section is empty.
Variables ¶
View Source
var File_ipc_proto protoreflect.FileDescriptor
Functions ¶
func RegisterOpenNMSIpcServer ¶
func RegisterOpenNMSIpcServer(s *grpc.Server, srv OpenNMSIpcServer)
Types ¶
type Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
func (*Empty) Descriptor
deprecated
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
type OpenNMSIpcClient ¶
type OpenNMSIpcClient interface { // Streams RPC messages between OpenNMS and Minion. RpcStreaming(ctx context.Context, opts ...grpc.CallOption) (OpenNMSIpc_RpcStreamingClient, error) // Streams Sink messages from Minion to OpenNMS SinkStreaming(ctx context.Context, opts ...grpc.CallOption) (OpenNMSIpc_SinkStreamingClient, error) }
OpenNMSIpcClient is the client API for OpenNMSIpc service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewOpenNMSIpcClient ¶
func NewOpenNMSIpcClient(cc grpc.ClientConnInterface) OpenNMSIpcClient
type OpenNMSIpcServer ¶
type OpenNMSIpcServer interface { // Streams RPC messages between OpenNMS and Minion. RpcStreaming(OpenNMSIpc_RpcStreamingServer) error // Streams Sink messages from Minion to OpenNMS SinkStreaming(OpenNMSIpc_SinkStreamingServer) error }
OpenNMSIpcServer is the server API for OpenNMSIpc service.
type OpenNMSIpc_RpcStreamingClient ¶
type OpenNMSIpc_RpcStreamingClient interface { Send(*RpcResponseProto) error Recv() (*RpcRequestProto, error) grpc.ClientStream }
type OpenNMSIpc_RpcStreamingServer ¶
type OpenNMSIpc_RpcStreamingServer interface { Send(*RpcRequestProto) error Recv() (*RpcResponseProto, error) grpc.ServerStream }
type OpenNMSIpc_SinkStreamingClient ¶
type OpenNMSIpc_SinkStreamingClient interface { Send(*SinkMessage) error CloseAndRecv() (*Empty, error) grpc.ClientStream }
type OpenNMSIpc_SinkStreamingServer ¶
type OpenNMSIpc_SinkStreamingServer interface { SendAndClose(*Empty) error Recv() (*SinkMessage, error) grpc.ServerStream }
type RpcRequestProto ¶
type RpcRequestProto struct { RpcId string `protobuf:"bytes,1,opt,name=rpc_id,json=rpcId,proto3" json:"rpc_id,omitempty"` RpcContent []byte `protobuf:"bytes,2,opt,name=rpc_content,json=rpcContent,proto3" json:"rpc_content,omitempty"` SystemId string `protobuf:"bytes,3,opt,name=system_id,json=systemId,proto3" json:"system_id,omitempty"` Location string `protobuf:"bytes,4,opt,name=location,proto3" json:"location,omitempty"` ModuleId string `protobuf:"bytes,5,opt,name=module_id,json=moduleId,proto3" json:"module_id,omitempty"` // absolute time elapsed since the epoch in msec. ExpirationTime uint64 `protobuf:"varint,6,opt,name=expiration_time,json=expirationTime,proto3" json:"expiration_time,omitempty"` TracingInfo map[string]string `` /* 182-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RpcRequestProto) Descriptor
deprecated
func (*RpcRequestProto) Descriptor() ([]byte, []int)
Deprecated: Use RpcRequestProto.ProtoReflect.Descriptor instead.
func (*RpcRequestProto) GetExpirationTime ¶
func (x *RpcRequestProto) GetExpirationTime() uint64
func (*RpcRequestProto) GetLocation ¶
func (x *RpcRequestProto) GetLocation() string
func (*RpcRequestProto) GetModuleId ¶
func (x *RpcRequestProto) GetModuleId() string
func (*RpcRequestProto) GetRpcContent ¶
func (x *RpcRequestProto) GetRpcContent() []byte
func (*RpcRequestProto) GetRpcId ¶
func (x *RpcRequestProto) GetRpcId() string
func (*RpcRequestProto) GetSystemId ¶
func (x *RpcRequestProto) GetSystemId() string
func (*RpcRequestProto) GetTracingInfo ¶
func (x *RpcRequestProto) GetTracingInfo() map[string]string
func (*RpcRequestProto) ProtoMessage ¶
func (*RpcRequestProto) ProtoMessage()
func (*RpcRequestProto) ProtoReflect ¶
func (x *RpcRequestProto) ProtoReflect() protoreflect.Message
func (*RpcRequestProto) Reset ¶
func (x *RpcRequestProto) Reset()
func (*RpcRequestProto) String ¶
func (x *RpcRequestProto) String() string
type RpcResponseProto ¶
type RpcResponseProto struct { RpcId string `protobuf:"bytes,1,opt,name=rpc_id,json=rpcId,proto3" json:"rpc_id,omitempty"` RpcContent []byte `protobuf:"bytes,2,opt,name=rpc_content,json=rpcContent,proto3" json:"rpc_content,omitempty"` SystemId string `protobuf:"bytes,3,opt,name=system_id,json=systemId,proto3" json:"system_id,omitempty"` Location string `protobuf:"bytes,4,opt,name=location,proto3" json:"location,omitempty"` ModuleId string `protobuf:"bytes,5,opt,name=module_id,json=moduleId,proto3" json:"module_id,omitempty"` TracingInfo map[string]string `` /* 182-byte string literal not displayed */ // contains filtered or unexported fields }
func (*RpcResponseProto) Descriptor
deprecated
func (*RpcResponseProto) Descriptor() ([]byte, []int)
Deprecated: Use RpcResponseProto.ProtoReflect.Descriptor instead.
func (*RpcResponseProto) GetLocation ¶
func (x *RpcResponseProto) GetLocation() string
func (*RpcResponseProto) GetModuleId ¶
func (x *RpcResponseProto) GetModuleId() string
func (*RpcResponseProto) GetRpcContent ¶
func (x *RpcResponseProto) GetRpcContent() []byte
func (*RpcResponseProto) GetRpcId ¶
func (x *RpcResponseProto) GetRpcId() string
func (*RpcResponseProto) GetSystemId ¶
func (x *RpcResponseProto) GetSystemId() string
func (*RpcResponseProto) GetTracingInfo ¶
func (x *RpcResponseProto) GetTracingInfo() map[string]string
func (*RpcResponseProto) ProtoMessage ¶
func (*RpcResponseProto) ProtoMessage()
func (*RpcResponseProto) ProtoReflect ¶
func (x *RpcResponseProto) ProtoReflect() protoreflect.Message
func (*RpcResponseProto) Reset ¶
func (x *RpcResponseProto) Reset()
func (*RpcResponseProto) String ¶
func (x *RpcResponseProto) String() string
type SinkMessage ¶
type SinkMessage struct { MessageId string `protobuf:"bytes,1,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"` Content []byte `protobuf:"bytes,2,opt,name=content,proto3" json:"content,omitempty"` SystemId string `protobuf:"bytes,3,opt,name=system_id,json=systemId,proto3" json:"system_id,omitempty"` Location string `protobuf:"bytes,4,opt,name=location,proto3" json:"location,omitempty"` ModuleId string `protobuf:"bytes,5,opt,name=module_id,json=moduleId,proto3" json:"module_id,omitempty"` TracingInfo map[string]string `` /* 182-byte string literal not displayed */ // contains filtered or unexported fields }
func (*SinkMessage) Descriptor
deprecated
func (*SinkMessage) Descriptor() ([]byte, []int)
Deprecated: Use SinkMessage.ProtoReflect.Descriptor instead.
func (*SinkMessage) GetContent ¶
func (x *SinkMessage) GetContent() []byte
func (*SinkMessage) GetLocation ¶
func (x *SinkMessage) GetLocation() string
func (*SinkMessage) GetMessageId ¶
func (x *SinkMessage) GetMessageId() string
func (*SinkMessage) GetModuleId ¶
func (x *SinkMessage) GetModuleId() string
func (*SinkMessage) GetSystemId ¶
func (x *SinkMessage) GetSystemId() string
func (*SinkMessage) GetTracingInfo ¶
func (x *SinkMessage) GetTracingInfo() map[string]string
func (*SinkMessage) ProtoMessage ¶
func (*SinkMessage) ProtoMessage()
func (*SinkMessage) ProtoReflect ¶
func (x *SinkMessage) ProtoReflect() protoreflect.Message
func (*SinkMessage) Reset ¶
func (x *SinkMessage) Reset()
func (*SinkMessage) String ¶
func (x *SinkMessage) String() string
type UnimplementedOpenNMSIpcServer ¶
type UnimplementedOpenNMSIpcServer struct { }
UnimplementedOpenNMSIpcServer can be embedded to have forward compatible implementations.
func (*UnimplementedOpenNMSIpcServer) RpcStreaming ¶
func (*UnimplementedOpenNMSIpcServer) RpcStreaming(OpenNMSIpc_RpcStreamingServer) error
func (*UnimplementedOpenNMSIpcServer) SinkStreaming ¶
func (*UnimplementedOpenNMSIpcServer) SinkStreaming(OpenNMSIpc_SinkStreamingServer) error
Click to show internal directories.
Click to hide internal directories.