biz

package
v0.5.1-0...-e9fb175 Latest Latest
Warning

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

 Go to latest Published: May 25, 2021 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Biz_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "biz.Biz",
	HandlerType: (*BizServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Signal",
			Handler:       _Biz_Signal_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "protos/biz.proto",
}

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

View Source 
var File_protos_biz_proto protoreflect.FileDescriptor

Functions

func RegisterBizServer 

func RegisterBizServer(s grpc.ServiceRegistrar, srv BizServer)

Types

type BizClient 

type BizClient interface {
	Signal(ctx context.Context, opts ...grpc.CallOption) (Biz_SignalClient, error)
}

BizClient is the client API for Biz 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 NewBizClient 

func NewBizClient(cc grpc.ClientConnInterface) BizClient

type BizServer 

type BizServer interface {
	Signal(Biz_SignalServer) error
	// contains filtered or unexported methods
}

BizServer is the server API for Biz service. All implementations must embed UnimplementedBizServer for forward compatibility

type Biz_SignalClient 

type Biz_SignalClient interface {
	Send(*SignalRequest) error
	Recv() (*SignalReply, error)
	grpc.ClientStream
}

type Biz_SignalServer 

type Biz_SignalServer interface {
	Send(*SignalReply) error
	Recv() (*SignalRequest, error)
	grpc.ServerStream
}

type Join 

type Join struct {
	Peer  *ion.Peer `protobuf:"bytes,1,opt,name=peer,proto3" json:"peer,omitempty"`
	Token string    `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

func (*Join) Descriptor deprecated 

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

Deprecated: Use Join.ProtoReflect.Descriptor instead.

func (*Join) GetPeer 

func (x *Join) GetPeer() *ion.Peer

func (*Join) GetToken 

func (x *Join) GetToken() string

func (*Join) ProtoMessage 

func (*Join) ProtoMessage()

func (*Join) ProtoReflect 

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

func (*Join) Reset 

func (x *Join) Reset()

func (*Join) String 

func (x *Join) String() string

type JoinReply 

type JoinReply struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Reason  string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*JoinReply) Descriptor deprecated 

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

Deprecated: Use JoinReply.ProtoReflect.Descriptor instead.

func (*JoinReply) GetReason 

func (x *JoinReply) GetReason() string

func (*JoinReply) GetSuccess 

func (x *JoinReply) GetSuccess() bool

func (*JoinReply) ProtoMessage 

func (*JoinReply) ProtoMessage()

func (*JoinReply) ProtoReflect 

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

func (*JoinReply) Reset 

func (x *JoinReply) Reset()

func (*JoinReply) String 

func (x *JoinReply) String() string

type Leave 

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

func (*Leave) Descriptor deprecated 

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

Deprecated: Use Leave.ProtoReflect.Descriptor instead.

func (*Leave) GetUid 

func (x *Leave) GetUid() string

func (*Leave) ProtoMessage 

func (*Leave) ProtoMessage()

func (*Leave) ProtoReflect 

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

func (*Leave) Reset 

func (x *Leave) Reset()

func (*Leave) String 

func (x *Leave) String() string

type LeaveReply 

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

func (*LeaveReply) Descriptor deprecated 

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

Deprecated: Use LeaveReply.ProtoReflect.Descriptor instead.

func (*LeaveReply) GetReason 

func (x *LeaveReply) GetReason() string

func (*LeaveReply) ProtoMessage 

func (*LeaveReply) ProtoMessage()

func (*LeaveReply) ProtoReflect 

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

func (*LeaveReply) Reset 

func (x *LeaveReply) Reset()

func (*LeaveReply) String 

func (x *LeaveReply) String() string

type SignalReply 

type SignalReply struct {

	// Types that are assignable to Payload:
	//	*SignalReply_JoinReply
	//	*SignalReply_LeaveReply
	//	*SignalReply_PeerEvent
	//	*SignalReply_StreamEvent
	//	*SignalReply_Msg
	Payload isSignalReply_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*SignalReply) Descriptor deprecated 

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

Deprecated: Use SignalReply.ProtoReflect.Descriptor instead.

func (*SignalReply) GetJoinReply 

func (x *SignalReply) GetJoinReply() *JoinReply

func (*SignalReply) GetLeaveReply 

func (x *SignalReply) GetLeaveReply() *LeaveReply

func (*SignalReply) GetMsg 

func (x *SignalReply) GetMsg() *ion.Message

func (*SignalReply) GetPayload 

func (m *SignalReply) GetPayload() isSignalReply_Payload

func (*SignalReply) GetPeerEvent 

func (x *SignalReply) GetPeerEvent() *ion.PeerEvent

func (*SignalReply) GetStreamEvent 

func (x *SignalReply) GetStreamEvent() *ion.StreamEvent

func (*SignalReply) ProtoMessage 

func (*SignalReply) ProtoMessage()

func (*SignalReply) ProtoReflect 

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

func (*SignalReply) Reset 

func (x *SignalReply) Reset()

func (*SignalReply) String 

func (x *SignalReply) String() string

type SignalReply_JoinReply 

type SignalReply_JoinReply struct {
	JoinReply *JoinReply `protobuf:"bytes,1,opt,name=joinReply,proto3,oneof"`
}

type SignalReply_LeaveReply 

type SignalReply_LeaveReply struct {
	LeaveReply *LeaveReply `protobuf:"bytes,2,opt,name=leaveReply,proto3,oneof"`
}

type SignalReply_Msg 

type SignalReply_Msg struct {
	Msg *ion.Message `protobuf:"bytes,5,opt,name=msg,proto3,oneof"`
}

type SignalReply_PeerEvent 

type SignalReply_PeerEvent struct {
	PeerEvent *ion.PeerEvent `protobuf:"bytes,3,opt,name=peerEvent,proto3,oneof"`
}

type SignalReply_StreamEvent 

type SignalReply_StreamEvent struct {
	StreamEvent *ion.StreamEvent `protobuf:"bytes,4,opt,name=streamEvent,proto3,oneof"`
}

type SignalRequest 

type SignalRequest struct {

	// Types that are assignable to Payload:
	//	*SignalRequest_Join
	//	*SignalRequest_Leave
	//	*SignalRequest_Msg
	Payload isSignalRequest_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*SignalRequest) Descriptor deprecated 

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

Deprecated: Use SignalRequest.ProtoReflect.Descriptor instead.

func (*SignalRequest) GetJoin 

func (x *SignalRequest) GetJoin() *Join

func (*SignalRequest) GetLeave 

func (x *SignalRequest) GetLeave() *Leave

func (*SignalRequest) GetMsg 

func (x *SignalRequest) GetMsg() *ion.Message

func (*SignalRequest) GetPayload 

func (m *SignalRequest) GetPayload() isSignalRequest_Payload

func (*SignalRequest) ProtoMessage 

func (*SignalRequest) ProtoMessage()

func (*SignalRequest) ProtoReflect 

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

func (*SignalRequest) Reset 

func (x *SignalRequest) Reset()

func (*SignalRequest) String 

func (x *SignalRequest) String() string

type SignalRequest_Join 

type SignalRequest_Join struct {
	Join *Join `protobuf:"bytes,1,opt,name=join,proto3,oneof"`
}

type SignalRequest_Leave 

type SignalRequest_Leave struct {
	Leave *Leave `protobuf:"bytes,2,opt,name=leave,proto3,oneof"`
}

type SignalRequest_Msg 

type SignalRequest_Msg struct {
	Msg *ion.Message `protobuf:"bytes,4,opt,name=msg,proto3,oneof"`
}

type UnimplementedBizServer 

type UnimplementedBizServer struct {
}

UnimplementedBizServer must be embedded to have forward compatible implementations.

func (UnimplementedBizServer) Signal 

func (UnimplementedBizServer) Signal(Biz_SignalServer) error

type UnsafeBizServer 

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

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