ipc

package
v0.1.11 Latest Latest
Warning

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

 Go to latest Published: Mar 14, 2024 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
View Source 
var OpenNMSIpc_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "OpenNMSIpc",
	HandlerType: (*OpenNMSIpcServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "RpcStreaming",
			Handler:       _OpenNMSIpc_RpcStreaming_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "SinkStreaming",
			Handler:       _OpenNMSIpc_SinkStreaming_Handler,
			ClientStreams: true,
		},
	},
	Metadata: "ipc.proto",
}

OpenNMSIpc_ServiceDesc is the grpc.ServiceDesc for OpenNMSIpc service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterOpenNMSIpcServer 

func RegisterOpenNMSIpcServer(s grpc.ServiceRegistrar, 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://pkg.go.dev/google.golang.org/grpc/?tab=doc#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
	// contains filtered or unexported methods
}

OpenNMSIpcServer is the server API for OpenNMSIpc service. All implementations must embed UnimplementedOpenNMSIpcServer for forward compatibility

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 must 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

type UnsafeOpenNMSIpcServer added in v0.1.8 

type UnsafeOpenNMSIpcServer interface {
	// contains filtered or unexported methods
}

UnsafeOpenNMSIpcServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to OpenNMSIpcServer will result in compilation errors.

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.