messager

package
v4.3.6 Latest Latest
Warning

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

 Go to latest Published: Sep 19, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_grpc_proto_messager_proto protoreflect.FileDescriptor
View Source 
var Message_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "message.Message",
	HandlerType: (*MessageServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Register",
			Handler:    _Message_Register_Handler,
		},
		{
			MethodName: "SignOut",
			Handler:    _Message_SignOut_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "BidirectionalStreamingMessage",
			Handler:       _Message_BidirectionalStreamingMessage_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "grpc/proto/messager.proto",
}

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

Functions

func RegisterMessageServer 

func RegisterMessageServer(s grpc.ServiceRegistrar, srv MessageServer)

Types

type MessageClient 

type MessageClient interface {
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error)
	SignOut(ctx context.Context, in *SignOutRequest, opts ...grpc.CallOption) (*SignOutResponse, error)
	BidirectionalStreamingMessage(ctx context.Context, opts ...grpc.CallOption) (Message_BidirectionalStreamingMessageClient, error)
}

MessageClient is the client API for Message 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 NewMessageClient 

func NewMessageClient(cc grpc.ClientConnInterface) MessageClient

type MessageServer 

type MessageServer interface {
	Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
	SignOut(context.Context, *SignOutRequest) (*SignOutResponse, error)
	BidirectionalStreamingMessage(Message_BidirectionalStreamingMessageServer) error
	// contains filtered or unexported methods
}

MessageServer is the server API for Message service. All implementations must embed UnimplementedMessageServer for forward compatibility

type Message_BidirectionalStreamingMessageClient 

type Message_BidirectionalStreamingMessageClient interface {
	Send(*StreamRequest) error
	Recv() (*StreamResponse, error)
	grpc.ClientStream
}

type Message_BidirectionalStreamingMessageServer 

type Message_BidirectionalStreamingMessageServer interface {
	Send(*StreamResponse) error
	Recv() (*StreamRequest, error)
	grpc.ServerStream
}

type RegisterRequest 

type RegisterRequest struct {
	NodeID string `protobuf:"bytes,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	Os     string `protobuf:"bytes,2,opt,name=os,proto3" json:"os,omitempty"`
	Arch   string `protobuf:"bytes,3,opt,name=arch,proto3" json:"arch,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterRequest) Descriptor deprecated 

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

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) GetArch 

func (x *RegisterRequest) GetArch() string

func (*RegisterRequest) GetNodeID 

func (x *RegisterRequest) GetNodeID() string

func (*RegisterRequest) GetOs 

func (x *RegisterRequest) GetOs() string

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect 

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

func (*RegisterRequest) Reset 

func (x *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (x *RegisterRequest) String() string

type RegisterResponse 

type RegisterResponse struct {
	Code    string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterResponse) Descriptor deprecated 

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

Deprecated: Use RegisterResponse.ProtoReflect.Descriptor instead.

func (*RegisterResponse) GetCode 

func (x *RegisterResponse) GetCode() string

func (*RegisterResponse) GetMessage 

func (x *RegisterResponse) GetMessage() string

func (*RegisterResponse) ProtoMessage 

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) ProtoReflect 

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

func (*RegisterResponse) Reset 

func (x *RegisterResponse) Reset()

func (*RegisterResponse) String 

func (x *RegisterResponse) String() string

type SignOutRequest 

type SignOutRequest struct {
	NodeID string `protobuf:"bytes,1,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	// contains filtered or unexported fields
}

func (*SignOutRequest) Descriptor deprecated 

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

Deprecated: Use SignOutRequest.ProtoReflect.Descriptor instead.

func (*SignOutRequest) GetNodeID 

func (x *SignOutRequest) GetNodeID() string

func (*SignOutRequest) ProtoMessage 

func (*SignOutRequest) ProtoMessage()

func (*SignOutRequest) ProtoReflect 

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

func (*SignOutRequest) Reset 

func (x *SignOutRequest) Reset()

func (*SignOutRequest) String 

func (x *SignOutRequest) String() string

type SignOutResponse 

type SignOutResponse struct {
	Code    string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*SignOutResponse) Descriptor deprecated 

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

Deprecated: Use SignOutResponse.ProtoReflect.Descriptor instead.

func (*SignOutResponse) GetCode 

func (x *SignOutResponse) GetCode() string

func (*SignOutResponse) GetMessage 

func (x *SignOutResponse) GetMessage() string

func (*SignOutResponse) ProtoMessage 

func (*SignOutResponse) ProtoMessage()

func (*SignOutResponse) ProtoReflect 

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

func (*SignOutResponse) Reset 

func (x *SignOutResponse) Reset()

func (*SignOutResponse) String 

func (x *SignOutResponse) String() string

type StreamRequest 

type StreamRequest struct {
	Type   string            `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	NodeID string            `protobuf:"bytes,2,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	Data   map[string][]byte `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StreamRequest) Descriptor deprecated 

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

Deprecated: Use StreamRequest.ProtoReflect.Descriptor instead.

func (*StreamRequest) GetData 

func (x *StreamRequest) GetData() map[string][]byte

func (*StreamRequest) GetNodeID 

func (x *StreamRequest) GetNodeID() string

func (*StreamRequest) GetType 

func (x *StreamRequest) GetType() string

func (*StreamRequest) ProtoMessage 

func (*StreamRequest) ProtoMessage()

func (*StreamRequest) ProtoReflect 

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

func (*StreamRequest) Reset 

func (x *StreamRequest) Reset()

func (*StreamRequest) String 

func (x *StreamRequest) String() string

type StreamResponse 

type StreamResponse struct {
	Type    string            `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	NodeID  string            `protobuf:"bytes,2,opt,name=nodeID,proto3" json:"nodeID,omitempty"`
	Profile []byte            `protobuf:"bytes,3,opt,name=profile,proto3" json:"profile,omitempty"`
	Tasks   []byte            `protobuf:"bytes,4,opt,name=tasks,proto3" json:"tasks,omitempty"`
	Data    map[string][]byte `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*StreamResponse) Descriptor deprecated 

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

Deprecated: Use StreamResponse.ProtoReflect.Descriptor instead.

func (*StreamResponse) GetData 

func (x *StreamResponse) GetData() map[string][]byte

func (*StreamResponse) GetNodeID 

func (x *StreamResponse) GetNodeID() string

func (*StreamResponse) GetProfile 

func (x *StreamResponse) GetProfile() []byte

func (*StreamResponse) GetTasks 

func (x *StreamResponse) GetTasks() []byte

func (*StreamResponse) GetType 

func (x *StreamResponse) GetType() string

func (*StreamResponse) ProtoMessage 

func (*StreamResponse) ProtoMessage()

func (*StreamResponse) ProtoReflect 

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

func (*StreamResponse) Reset 

func (x *StreamResponse) Reset()

func (*StreamResponse) String 

func (x *StreamResponse) String() string

type UnimplementedMessageServer 

type UnimplementedMessageServer struct{}

UnimplementedMessageServer must be embedded to have forward compatible implementations.

func (UnimplementedMessageServer) BidirectionalStreamingMessage 

func (UnimplementedMessageServer) BidirectionalStreamingMessage(Message_BidirectionalStreamingMessageServer) error

func (UnimplementedMessageServer) Register 

func (UnimplementedMessageServer) Register(context.Context, *RegisterRequest) (*RegisterResponse, error)

func (UnimplementedMessageServer) SignOut 

func (UnimplementedMessageServer) SignOut(context.Context, *SignOutRequest) (*SignOutResponse, error)

type UnsafeMessageServer 

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

UnsafeMessageServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MessageServer 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.