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) PushCommonMsg

func (UnimplementedAnswerServer) PushNoticeMsg

func (UnimplementedAnswerServer) UniCastSignal

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL