Versions in this module Expand all Collapse all v0 v0.1.0 Dec 13, 2022 Changes in this version + const OperationTimelineGetGroupHistoryMessage + const OperationTimelineGetSingleHistoryMessage + const OperationTimelineGetSyncMessage + const OperationTimelineSend + const OperationTimelineSendGroup + var ErrorReason_name = map[int32]string + var ErrorReason_value = map[string]int32 + var File_api_timeline_v1_error_reason_proto protoreflect.FileDescriptor + var File_api_timeline_v1_timeline_proto protoreflect.FileDescriptor + var Timeline_ServiceDesc = grpc.ServiceDesc + func RegisterTimelineHTTPServer(s *http.Server, srv TimelineHTTPServer) + func RegisterTimelineServer(s grpc.ServiceRegistrar, srv TimelineServer) + type ErrorReason int32 + const ErrorReason_GEETER_UNSPECIFIED + const ErrorReason_TIMELINE_INVALID_PARAM + const ErrorReason_USER_NOT_FOUND + func (ErrorReason) Descriptor() protoreflect.EnumDescriptor + func (ErrorReason) EnumDescriptor() ([]byte, []int) + func (ErrorReason) Type() protoreflect.EnumType + func (x ErrorReason) Enum() *ErrorReason + func (x ErrorReason) Number() protoreflect.EnumNumber + func (x ErrorReason) String() string + type GetGroupHistoryMessageReply struct + EntrySet []*TimelineEntry + func (*GetGroupHistoryMessageReply) Descriptor() ([]byte, []int) + func (*GetGroupHistoryMessageReply) ProtoMessage() + func (x *GetGroupHistoryMessageReply) GetEntrySet() []*TimelineEntry + func (x *GetGroupHistoryMessageReply) ProtoReflect() protoreflect.Message + func (x *GetGroupHistoryMessageReply) Reset() + func (x *GetGroupHistoryMessageReply) String() string + type GetGroupHistoryMessageRequest struct + Count int32 + Group string + LastRead int64 + func (*GetGroupHistoryMessageRequest) Descriptor() ([]byte, []int) + func (*GetGroupHistoryMessageRequest) ProtoMessage() + func (x *GetGroupHistoryMessageRequest) GetCount() int32 + func (x *GetGroupHistoryMessageRequest) GetGroup() string + func (x *GetGroupHistoryMessageRequest) GetLastRead() int64 + func (x *GetGroupHistoryMessageRequest) ProtoReflect() protoreflect.Message + func (x *GetGroupHistoryMessageRequest) Reset() + func (x *GetGroupHistoryMessageRequest) String() string + type GetSingleHistoryMessageReply struct + EntrySet []*TimelineEntry + func (*GetSingleHistoryMessageReply) Descriptor() ([]byte, []int) + func (*GetSingleHistoryMessageReply) ProtoMessage() + func (x *GetSingleHistoryMessageReply) GetEntrySet() []*TimelineEntry + func (x *GetSingleHistoryMessageReply) ProtoReflect() protoreflect.Message + func (x *GetSingleHistoryMessageReply) Reset() + func (x *GetSingleHistoryMessageReply) String() string + type GetSingleHistoryMessageRequest struct + Count int32 + From string + LastRead int64 + To string + func (*GetSingleHistoryMessageRequest) Descriptor() ([]byte, []int) + func (*GetSingleHistoryMessageRequest) ProtoMessage() + func (x *GetSingleHistoryMessageRequest) GetCount() int32 + func (x *GetSingleHistoryMessageRequest) GetFrom() string + func (x *GetSingleHistoryMessageRequest) GetLastRead() int64 + func (x *GetSingleHistoryMessageRequest) GetTo() string + func (x *GetSingleHistoryMessageRequest) ProtoReflect() protoreflect.Message + func (x *GetSingleHistoryMessageRequest) Reset() + func (x *GetSingleHistoryMessageRequest) String() string + type SendGroupReply struct + FailedMembers []string + func (*SendGroupReply) Descriptor() ([]byte, []int) + func (*SendGroupReply) ProtoMessage() + func (x *SendGroupReply) GetFailedMembers() []string + func (x *SendGroupReply) ProtoReflect() protoreflect.Message + func (x *SendGroupReply) Reset() + func (x *SendGroupReply) String() string + type SendGroupRequest struct + GroupMembers []string + GroupName string + Message string + func (*SendGroupRequest) Descriptor() ([]byte, []int) + func (*SendGroupRequest) ProtoMessage() + func (x *SendGroupRequest) GetGroupMembers() []string + func (x *SendGroupRequest) GetGroupName() string + func (x *SendGroupRequest) GetMessage() string + func (x *SendGroupRequest) ProtoReflect() protoreflect.Message + func (x *SendGroupRequest) Reset() + func (x *SendGroupRequest) String() string + type SendMessageReply struct + Sequence int64 + func (*SendMessageReply) Descriptor() ([]byte, []int) + func (*SendMessageReply) ProtoMessage() + func (x *SendMessageReply) GetSequence() int64 + func (x *SendMessageReply) ProtoReflect() protoreflect.Message + func (x *SendMessageReply) Reset() + func (x *SendMessageReply) String() string + type SendMessageRequest struct + From string + Message string + To string + func (*SendMessageRequest) Descriptor() ([]byte, []int) + func (*SendMessageRequest) ProtoMessage() + func (x *SendMessageRequest) GetFrom() string + func (x *SendMessageRequest) GetMessage() string + func (x *SendMessageRequest) GetTo() string + func (x *SendMessageRequest) ProtoReflect() protoreflect.Message + func (x *SendMessageRequest) Reset() + func (x *SendMessageRequest) String() string + type SyncMessageReply struct + EntrySet []*TimelineEntry + EntrySetLastSeq int64 + LatestSeq int64 + func (*SyncMessageReply) Descriptor() ([]byte, []int) + func (*SyncMessageReply) ProtoMessage() + func (x *SyncMessageReply) GetEntrySet() []*TimelineEntry + func (x *SyncMessageReply) GetEntrySetLastSeq() int64 + func (x *SyncMessageReply) GetLatestSeq() int64 + func (x *SyncMessageReply) ProtoReflect() protoreflect.Message + func (x *SyncMessageReply) Reset() + func (x *SyncMessageReply) String() string + type SyncMessageRequest struct + Count int32 + LastRead int64 + Member string + func (*SyncMessageRequest) Descriptor() ([]byte, []int) + func (*SyncMessageRequest) ProtoMessage() + func (x *SyncMessageRequest) GetCount() int32 + func (x *SyncMessageRequest) GetLastRead() int64 + func (x *SyncMessageRequest) GetMember() string + func (x *SyncMessageRequest) ProtoReflect() protoreflect.Message + func (x *SyncMessageRequest) Reset() + func (x *SyncMessageRequest) String() string + type TimelineClient interface + GetGroupHistoryMessage func(ctx context.Context, in *GetGroupHistoryMessageRequest, ...) (*GetGroupHistoryMessageReply, error) + GetSingleHistoryMessage func(ctx context.Context, in *GetSingleHistoryMessageRequest, ...) (*GetSingleHistoryMessageReply, error) + GetSyncMessage func(ctx context.Context, in *SyncMessageRequest, opts ...grpc.CallOption) (*SyncMessageReply, error) + Send func(ctx context.Context, in *SendMessageRequest, opts ...grpc.CallOption) (*SendMessageReply, error) + SendGroup func(ctx context.Context, in *SendGroupRequest, opts ...grpc.CallOption) (*SendGroupReply, error) + func NewTimelineClient(cc grpc.ClientConnInterface) TimelineClient + type TimelineEntry struct + Message string + Sequence int64 + func (*TimelineEntry) Descriptor() ([]byte, []int) + func (*TimelineEntry) ProtoMessage() + func (x *TimelineEntry) GetMessage() string + func (x *TimelineEntry) GetSequence() int64 + func (x *TimelineEntry) ProtoReflect() protoreflect.Message + func (x *TimelineEntry) Reset() + func (x *TimelineEntry) String() string + type TimelineHTTPClient interface + GetGroupHistoryMessage func(ctx context.Context, req *GetGroupHistoryMessageRequest, ...) (rsp *GetGroupHistoryMessageReply, err error) + GetSingleHistoryMessage func(ctx context.Context, req *GetSingleHistoryMessageRequest, ...) (rsp *GetSingleHistoryMessageReply, err error) + GetSyncMessage func(ctx context.Context, req *SyncMessageRequest, opts ...http.CallOption) (rsp *SyncMessageReply, err error) + Send func(ctx context.Context, req *SendMessageRequest, opts ...http.CallOption) (rsp *SendMessageReply, err error) + SendGroup func(ctx context.Context, req *SendGroupRequest, opts ...http.CallOption) (rsp *SendGroupReply, err error) + func NewTimelineHTTPClient(client *http.Client) TimelineHTTPClient + type TimelineHTTPClientImpl struct + func (c *TimelineHTTPClientImpl) GetGroupHistoryMessage(ctx context.Context, in *GetGroupHistoryMessageRequest, ...) (*GetGroupHistoryMessageReply, error) + func (c *TimelineHTTPClientImpl) GetSingleHistoryMessage(ctx context.Context, in *GetSingleHistoryMessageRequest, ...) (*GetSingleHistoryMessageReply, error) + func (c *TimelineHTTPClientImpl) GetSyncMessage(ctx context.Context, in *SyncMessageRequest, opts ...http.CallOption) (*SyncMessageReply, error) + func (c *TimelineHTTPClientImpl) Send(ctx context.Context, in *SendMessageRequest, opts ...http.CallOption) (*SendMessageReply, error) + func (c *TimelineHTTPClientImpl) SendGroup(ctx context.Context, in *SendGroupRequest, opts ...http.CallOption) (*SendGroupReply, error) + type TimelineHTTPServer interface + GetGroupHistoryMessage func(context.Context, *GetGroupHistoryMessageRequest) (*GetGroupHistoryMessageReply, error) + GetSingleHistoryMessage func(context.Context, *GetSingleHistoryMessageRequest) (*GetSingleHistoryMessageReply, error) + GetSyncMessage func(context.Context, *SyncMessageRequest) (*SyncMessageReply, error) + Send func(context.Context, *SendMessageRequest) (*SendMessageReply, error) + SendGroup func(context.Context, *SendGroupRequest) (*SendGroupReply, error) + type TimelineServer interface + GetGroupHistoryMessage func(context.Context, *GetGroupHistoryMessageRequest) (*GetGroupHistoryMessageReply, error) + GetSingleHistoryMessage func(context.Context, *GetSingleHistoryMessageRequest) (*GetSingleHistoryMessageReply, error) + GetSyncMessage func(context.Context, *SyncMessageRequest) (*SyncMessageReply, error) + Send func(context.Context, *SendMessageRequest) (*SendMessageReply, error) + SendGroup func(context.Context, *SendGroupRequest) (*SendGroupReply, error) + type UnimplementedTimelineServer struct + func (UnimplementedTimelineServer) GetGroupHistoryMessage(context.Context, *GetGroupHistoryMessageRequest) (*GetGroupHistoryMessageReply, error) + func (UnimplementedTimelineServer) GetSingleHistoryMessage(context.Context, *GetSingleHistoryMessageRequest) (*GetSingleHistoryMessageReply, error) + func (UnimplementedTimelineServer) GetSyncMessage(context.Context, *SyncMessageRequest) (*SyncMessageReply, error) + func (UnimplementedTimelineServer) Send(context.Context, *SendMessageRequest) (*SendMessageReply, error) + func (UnimplementedTimelineServer) SendGroup(context.Context, *SendGroupRequest) (*SendGroupReply, error) + type UnsafeTimelineServer interface