islb

package
v1.9.0 Latest Latest
Warning

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

 Go to latest Published: Apr 10, 2021 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_protos_islb_proto protoreflect.FileDescriptor
View Source 
var ISLB_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "islb.ISLB",
	HandlerType: (*ISLBServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "FindNode",
			Handler:    _ISLB_FindNode_Handler,
		},
		{
			MethodName: "PostISLBEvent",
			Handler:    _ISLB_PostISLBEvent_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchISLBEvent",
			Handler:       _ISLB_WatchISLBEvent_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "protos/islb.proto",
}

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

Functions

func RegisterISLBServer 

func RegisterISLBServer(s grpc.ServiceRegistrar, srv ISLBServer)

Types

type FindNodeReply 

type FindNodeReply struct {
	Nodes []*ion.Node `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

func (*FindNodeReply) Descriptor deprecated 

func (*FindNodeReply) Descriptor() ([]byte, []int)

Deprecated: Use FindNodeReply.ProtoReflect.Descriptor instead.

func (*FindNodeReply) GetNodes 

func (x *FindNodeReply) GetNodes() []*ion.Node

func (*FindNodeReply) ProtoMessage 

func (*FindNodeReply) ProtoMessage()

func (*FindNodeReply) ProtoReflect 

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

func (*FindNodeReply) Reset 

func (x *FindNodeReply) Reset()

func (*FindNodeReply) String 

func (x *FindNodeReply) String() string

type FindNodeRequest 

type FindNodeRequest struct {
	Sid     string `protobuf:"bytes,1,opt,name=sid,proto3" json:"sid,omitempty"`
	Nid     string `protobuf:"bytes,2,opt,name=nid,proto3" json:"nid,omitempty"`
	Service string `protobuf:"bytes,3,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

func (*FindNodeRequest) Descriptor deprecated 

func (*FindNodeRequest) Descriptor() ([]byte, []int)

Deprecated: Use FindNodeRequest.ProtoReflect.Descriptor instead.

func (*FindNodeRequest) GetNid 

func (x *FindNodeRequest) GetNid() string

func (*FindNodeRequest) GetService 

func (x *FindNodeRequest) GetService() string

func (*FindNodeRequest) GetSid 

func (x *FindNodeRequest) GetSid() string

func (*FindNodeRequest) ProtoMessage 

func (*FindNodeRequest) ProtoMessage()

func (*FindNodeRequest) ProtoReflect 

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

func (*FindNodeRequest) Reset 

func (x *FindNodeRequest) Reset()

func (*FindNodeRequest) String 

func (x *FindNodeRequest) String() string

type ISLBClient 

type ISLBClient interface {
	FindNode(ctx context.Context, in *FindNodeRequest, opts ...grpc.CallOption) (*FindNodeReply, error)
	PostISLBEvent(ctx context.Context, in *ISLBEvent, opts ...grpc.CallOption) (*ion.Empty, error)
	WatchISLBEvent(ctx context.Context, opts ...grpc.CallOption) (ISLB_WatchISLBEventClient, error)
}

ISLBClient is the client API for ISLB 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 NewISLBClient 

func NewISLBClient(cc grpc.ClientConnInterface) ISLBClient

type ISLBEvent 

type ISLBEvent struct {

	// Types that are assignable to Payload:
	//	*ISLBEvent_Session
	//	*ISLBEvent_Stream
	Payload isISLBEvent_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*ISLBEvent) Descriptor deprecated 

func (*ISLBEvent) Descriptor() ([]byte, []int)

Deprecated: Use ISLBEvent.ProtoReflect.Descriptor instead.

func (*ISLBEvent) GetPayload 

func (m *ISLBEvent) GetPayload() isISLBEvent_Payload

func (*ISLBEvent) GetSession 

func (x *ISLBEvent) GetSession() *ion.SessionEvent

func (*ISLBEvent) GetStream 

func (x *ISLBEvent) GetStream() *ion.StreamEvent

func (*ISLBEvent) ProtoMessage 

func (*ISLBEvent) ProtoMessage()

func (*ISLBEvent) ProtoReflect 

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

func (*ISLBEvent) Reset 

func (x *ISLBEvent) Reset()

func (*ISLBEvent) String 

func (x *ISLBEvent) String() string

type ISLBEvent_Session 

type ISLBEvent_Session struct {
	Session *ion.SessionEvent `protobuf:"bytes,1,opt,name=session,proto3,oneof"`
}

type ISLBEvent_Stream 

type ISLBEvent_Stream struct {
	Stream *ion.StreamEvent `protobuf:"bytes,2,opt,name=stream,proto3,oneof"`
}

type ISLBServer 

type ISLBServer interface {
	FindNode(context.Context, *FindNodeRequest) (*FindNodeReply, error)
	PostISLBEvent(context.Context, *ISLBEvent) (*ion.Empty, error)
	WatchISLBEvent(ISLB_WatchISLBEventServer) error
	// contains filtered or unexported methods
}

ISLBServer is the server API for ISLB service. All implementations must embed UnimplementedISLBServer for forward compatibility

type ISLB_WatchISLBEventClient 

type ISLB_WatchISLBEventClient interface {
	Send(*WatchRequest) error
	Recv() (*ISLBEvent, error)
	grpc.ClientStream
}

type ISLB_WatchISLBEventServer 

type ISLB_WatchISLBEventServer interface {
	Send(*ISLBEvent) error
	Recv() (*WatchRequest, error)
	grpc.ServerStream
}

type UnimplementedISLBServer 

type UnimplementedISLBServer struct {
}

UnimplementedISLBServer must be embedded to have forward compatible implementations.

func (UnimplementedISLBServer) FindNode 

func (UnimplementedISLBServer) FindNode(context.Context, *FindNodeRequest) (*FindNodeReply, error)

func (UnimplementedISLBServer) PostISLBEvent 

func (UnimplementedISLBServer) PostISLBEvent(context.Context, *ISLBEvent) (*ion.Empty, error)

func (UnimplementedISLBServer) WatchISLBEvent 

func (UnimplementedISLBServer) WatchISLBEvent(ISLB_WatchISLBEventServer) error

type UnsafeISLBServer 

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

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

type WatchRequest 

type WatchRequest struct {
	Nid string `protobuf:"bytes,1,opt,name=nid,proto3" json:"nid,omitempty"`
	Sid string `protobuf:"bytes,2,opt,name=sid,proto3" json:"sid,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchRequest) Descriptor deprecated 

func (*WatchRequest) Descriptor() ([]byte, []int)

Deprecated: Use WatchRequest.ProtoReflect.Descriptor instead.

func (*WatchRequest) GetNid 

func (x *WatchRequest) GetNid() string

func (*WatchRequest) GetSid 

func (x *WatchRequest) GetSid() string

func (*WatchRequest) ProtoMessage 

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) ProtoReflect 

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

func (*WatchRequest) Reset 

func (x *WatchRequest) Reset()

func (*WatchRequest) String 

func (x *WatchRequest) String() string

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.