answer

package
v0.1.3 Latest Latest
Warning

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

 Go to latest Published: Aug 18, 2022 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Answer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "dtalk.answer.Answer",
	HandlerType: (*AnswerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "PushCommonMsg",
			Handler:    _Answer_PushCommonMsg_Handler,
		},
		{
			MethodName: "PushNoticeMsg",
			Handler:    _Answer_PushNoticeMsg_Handler,
		},
		{
			MethodName: "UniCastSignal",
			Handler:    _Answer_UniCastSignal_Handler,
		},
		{
			MethodName: "GroupCastSignal",
			Handler:    _Answer_GroupCastSignal_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "answer.proto",
}

Answer_ServiceDesc is the grpc.ServiceDesc for Answer 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_answer_proto protoreflect.FileDescriptor

Functions

func RegisterAnswerServer 

func RegisterAnswerServer(s grpc.ServiceRegistrar, srv AnswerServer)

Types

type AnswerClient 

type AnswerClient interface {
	PushCommonMsg(ctx context.Context, in *PushCommonMsgReq, opts ...grpc.CallOption) (*PushCommonMsgReply, error)
	PushNoticeMsg(ctx context.Context, in *PushNoticeMsgReq, opts ...grpc.CallOption) (*PushNoticeMsgReply, error)
	UniCastSignal(ctx context.Context, in *UniCastSignalReq, opts ...grpc.CallOption) (*UniCastSignalReply, error)
	GroupCastSignal(ctx context.Context, in *GroupCastSignalReq, opts ...grpc.CallOption) (*GroupCastSignalReply, error)
}

AnswerClient is the client API for Answer 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 NewAnswerClient 

func NewAnswerClient(cc grpc.ClientConnInterface) AnswerClient

type AnswerServer 

type AnswerServer interface {
	PushCommonMsg(context.Context, *PushCommonMsgReq) (*PushCommonMsgReply, error)
	PushNoticeMsg(context.Context, *PushNoticeMsgReq) (*PushNoticeMsgReply, error)
	UniCastSignal(context.Context, *UniCastSignalReq) (*UniCastSignalReply, error)
	GroupCastSignal(context.Context, *GroupCastSignalReq) (*GroupCastSignalReply, error)
	// contains filtered or unexported methods
}

AnswerServer is the server API for Answer service. All implementations must embed UnimplementedAnswerServer for forward compatibility

type Client 

type Client struct {
	// contains filtered or unexported fields
}

func New 

func New(etcdAddr, schema, srvName string, dial time.Duration) *Client

func (*Client) GroupCastSignal 

func (c *Client) GroupCastSignal(ctx context.Context, Action xproto.SignalType, Target string, Body []byte) error

func (*Client) PushCommonMsg 

func (c *Client) PushCommonMsg(ctx context.Context, key, From string, body []byte) (int64, uint64, error)

func (*Client) PushNoticeMsg 

func (c *Client) PushNoticeMsg(ctx context.Context, Seq string, ChannelType int32, From, Target string, Data []byte) (int64, error)

func (*Client) UniCastSignal 

func (c *Client) UniCastSignal(ctx context.Context, Action xproto.SignalType, Target string, Body []byte) error

type GroupCastSignalReply 

type GroupCastSignalReply struct {
	Mid int64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupCastSignalReply) Descriptor deprecated 

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

Deprecated: Use GroupCastSignalReply.ProtoReflect.Descriptor instead.

func (*GroupCastSignalReply) GetMid 

func (x *GroupCastSignalReply) GetMid() int64

func (*GroupCastSignalReply) ProtoMessage 

func (*GroupCastSignalReply) ProtoMessage()

func (*GroupCastSignalReply) ProtoReflect 

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

func (*GroupCastSignalReply) Reset 

func (x *GroupCastSignalReply) Reset()

func (*GroupCastSignalReply) String 

func (x *GroupCastSignalReply) String() string

type GroupCastSignalReq 

type GroupCastSignalReq struct {
	Type   proto.SignalType `protobuf:"varint,1,opt,name=type,proto3,enum=imparse.signal.SignalType" json:"type,omitempty"`
	Target string           `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	Body   []byte           `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*GroupCastSignalReq) Descriptor deprecated 

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

Deprecated: Use GroupCastSignalReq.ProtoReflect.Descriptor instead.

func (*GroupCastSignalReq) GetBody 

func (x *GroupCastSignalReq) GetBody() []byte

func (*GroupCastSignalReq) GetTarget 

func (x *GroupCastSignalReq) GetTarget() string

func (*GroupCastSignalReq) GetType 

func (x *GroupCastSignalReq) GetType() proto.SignalType

func (*GroupCastSignalReq) ProtoMessage 

func (*GroupCastSignalReq) ProtoMessage()

func (*GroupCastSignalReq) ProtoReflect 

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

func (*GroupCastSignalReq) Reset 

func (x *GroupCastSignalReq) Reset()

func (*GroupCastSignalReq) String 

func (x *GroupCastSignalReq) String() string

type PushCommonMsgReply 

type PushCommonMsgReply struct {
	Mid  int64  `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"`
	Time uint64 `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*PushCommonMsgReply) Descriptor deprecated 

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

Deprecated: Use PushCommonMsgReply.ProtoReflect.Descriptor instead.

func (*PushCommonMsgReply) GetMid 

func (x *PushCommonMsgReply) GetMid() int64

func (*PushCommonMsgReply) GetTime 

func (x *PushCommonMsgReply) GetTime() uint64

func (*PushCommonMsgReply) ProtoMessage 

func (*PushCommonMsgReply) ProtoMessage()

func (*PushCommonMsgReply) ProtoReflect 

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

func (*PushCommonMsgReply) Reset 

func (x *PushCommonMsgReply) Reset()

func (*PushCommonMsgReply) String 

func (x *PushCommonMsgReply) String() string

type PushCommonMsgReq 

type PushCommonMsgReq struct {
	Key  string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	From string `protobuf:"bytes,2,opt,name=from,proto3" json:"from,omitempty"`
	Body []byte `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*PushCommonMsgReq) Descriptor deprecated 

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

Deprecated: Use PushCommonMsgReq.ProtoReflect.Descriptor instead.

func (*PushCommonMsgReq) GetBody 

func (x *PushCommonMsgReq) GetBody() []byte

func (*PushCommonMsgReq) GetFrom 

func (x *PushCommonMsgReq) GetFrom() string

func (*PushCommonMsgReq) GetKey 

func (x *PushCommonMsgReq) GetKey() string

func (*PushCommonMsgReq) ProtoMessage 

func (*PushCommonMsgReq) ProtoMessage()

func (*PushCommonMsgReq) ProtoReflect 

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

func (*PushCommonMsgReq) Reset 

func (x *PushCommonMsgReq) Reset()

func (*PushCommonMsgReq) String 

func (x *PushCommonMsgReq) String() string

type PushNoticeMsgReply 

type PushNoticeMsgReply struct {
	Mid int64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"`
	// contains filtered or unexported fields
}

func (*PushNoticeMsgReply) Descriptor deprecated 

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

Deprecated: Use PushNoticeMsgReply.ProtoReflect.Descriptor instead.

func (*PushNoticeMsgReply) GetMid 

func (x *PushNoticeMsgReply) GetMid() int64

func (*PushNoticeMsgReply) ProtoMessage 

func (*PushNoticeMsgReply) ProtoMessage()

func (*PushNoticeMsgReply) ProtoReflect 

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

func (*PushNoticeMsgReply) Reset 

func (x *PushNoticeMsgReply) Reset()

func (*PushNoticeMsgReply) String 

func (x *PushNoticeMsgReply) String() string

type PushNoticeMsgReq 

type PushNoticeMsgReq struct {
	Seq         string `protobuf:"bytes,1,opt,name=seq,proto3" json:"seq,omitempty"`
	ChannelType int32  `protobuf:"varint,2,opt,name=channelType,proto3" json:"channelType,omitempty"`
	From        string `protobuf:"bytes,3,opt,name=from,proto3" json:"from,omitempty"`
	Target      string `protobuf:"bytes,4,opt,name=target,proto3" json:"target,omitempty"`
	Data        []byte `protobuf:"bytes,5,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PushNoticeMsgReq) Descriptor deprecated 

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

Deprecated: Use PushNoticeMsgReq.ProtoReflect.Descriptor instead.

func (*PushNoticeMsgReq) GetChannelType 

func (x *PushNoticeMsgReq) GetChannelType() int32

func (*PushNoticeMsgReq) GetData 

func (x *PushNoticeMsgReq) GetData() []byte

func (*PushNoticeMsgReq) GetFrom 

func (x *PushNoticeMsgReq) GetFrom() string

func (*PushNoticeMsgReq) GetSeq 

func (x *PushNoticeMsgReq) GetSeq() string

func (*PushNoticeMsgReq) GetTarget 

func (x *PushNoticeMsgReq) GetTarget() string

func (*PushNoticeMsgReq) ProtoMessage 

func (*PushNoticeMsgReq) ProtoMessage()

func (*PushNoticeMsgReq) ProtoReflect 

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

func (*PushNoticeMsgReq) Reset 

func (x *PushNoticeMsgReq) Reset()

func (*PushNoticeMsgReq) String 

func (x *PushNoticeMsgReq) String() string

type UniCastSignalReply 

type UniCastSignalReply struct {
	Mid int64 `protobuf:"varint,1,opt,name=mid,proto3" json:"mid,omitempty"`
	// contains filtered or unexported fields
}

func (*UniCastSignalReply) Descriptor deprecated 

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

Deprecated: Use UniCastSignalReply.ProtoReflect.Descriptor instead.

func (*UniCastSignalReply) GetMid 

func (x *UniCastSignalReply) GetMid() int64

func (*UniCastSignalReply) ProtoMessage 

func (*UniCastSignalReply) ProtoMessage()

func (*UniCastSignalReply) ProtoReflect 

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

func (*UniCastSignalReply) Reset 

func (x *UniCastSignalReply) Reset()

func (*UniCastSignalReply) String 

func (x *UniCastSignalReply) String() string

type UniCastSignalReq 

type UniCastSignalReq struct {
	Type   proto.SignalType `protobuf:"varint,1,opt,name=type,proto3,enum=imparse.signal.SignalType" json:"type,omitempty"`
	Target string           `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	Body   []byte           `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*UniCastSignalReq) Descriptor deprecated 

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

Deprecated: Use UniCastSignalReq.ProtoReflect.Descriptor instead.

func (*UniCastSignalReq) GetBody 

func (x *UniCastSignalReq) GetBody() []byte

func (*UniCastSignalReq) GetTarget 

func (x *UniCastSignalReq) GetTarget() string

func (*UniCastSignalReq) GetType 

func (x *UniCastSignalReq) GetType() proto.SignalType

func (*UniCastSignalReq) ProtoMessage 

func (*UniCastSignalReq) ProtoMessage()

func (*UniCastSignalReq) ProtoReflect 

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

func (*UniCastSignalReq) Reset 

func (x *UniCastSignalReq) Reset()

func (*UniCastSignalReq) String 

func (x *UniCastSignalReq) String() string

type UnimplementedAnswerServer 

type UnimplementedAnswerServer struct {
}

UnimplementedAnswerServer must be embedded to have forward compatible implementations.

func (UnimplementedAnswerServer) GroupCastSignal 

func (UnimplementedAnswerServer) GroupCastSignal(context.Context, *GroupCastSignalReq) (*GroupCastSignalReply, error)

func (UnimplementedAnswerServer) PushCommonMsg 

func (UnimplementedAnswerServer) PushCommonMsg(context.Context, *PushCommonMsgReq) (*PushCommonMsgReply, error)

func (UnimplementedAnswerServer) PushNoticeMsg 

func (UnimplementedAnswerServer) PushNoticeMsg(context.Context, *PushNoticeMsgReq) (*PushNoticeMsgReply, error)

func (UnimplementedAnswerServer) UniCastSignal 

func (UnimplementedAnswerServer) UniCastSignal(context.Context, *UniCastSignalReq) (*UniCastSignalReply, error)

type UnsafeAnswerServer 

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

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