ipc

package
v0.1.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Apr 20, 2021 License: AGPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

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) Descriptor() ([]byte, []int)

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

func (x *Empty) ProtoReflect() protoreflect.Message

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.