Documentation
¶
Index ¶
- Variables
- func RegisterMessageStoreServiceServer(s grpc.ServiceRegistrar, srv MessageStoreServiceServer)
- type FeedId
- type FeedItem
- func (*FeedItem) Descriptor() ([]byte, []int)deprecated
- func (x *FeedItem) GetId() string
- func (x *FeedItem) GetInitiatorFirstName() string
- func (x *FeedItem) GetInitiatorLastName() string
- func (x *FeedItem) GetInitiatorType() string
- func (x *FeedItem) GetInitiatorUsername() *ParticipantId
- func (x *FeedItem) GetLastContentPreview() string
- func (x *FeedItem) GetLastSenderFirstName() string
- func (x *FeedItem) GetLastSenderLastName() string
- func (x *FeedItem) GetLastTimestamp() *timestamppb.Timestamp
- func (*FeedItem) ProtoMessage()
- func (x *FeedItem) ProtoReflect() protoreflect.Message
- func (x *FeedItem) Reset()
- func (x *FeedItem) String() string
- type FeedItemPagedResponse
- func (*FeedItemPagedResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FeedItemPagedResponse) GetFeedItems() []*FeedItem
- func (x *FeedItemPagedResponse) GetTotalElements() int32
- func (*FeedItemPagedResponse) ProtoMessage()
- func (x *FeedItemPagedResponse) ProtoReflect() protoreflect.Message
- func (x *FeedItemPagedResponse) Reset()
- func (x *FeedItemPagedResponse) String() string
- type FeedItemState
- func (FeedItemState) Descriptor() protoreflect.EnumDescriptor
- func (x FeedItemState) Enum() *FeedItemState
- func (FeedItemState) EnumDescriptor() ([]byte, []int)deprecated
- func (x FeedItemState) Number() protoreflect.EnumNumber
- func (x FeedItemState) String() string
- func (FeedItemState) Type() protoreflect.EnumType
- type GetFeedsPagedRequest
- func (*GetFeedsPagedRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetFeedsPagedRequest) GetOnlyContacts() bool
- func (x *GetFeedsPagedRequest) GetPage() int32
- func (x *GetFeedsPagedRequest) GetPageSize() int32
- func (x *GetFeedsPagedRequest) GetStateIn() []FeedItemState
- func (*GetFeedsPagedRequest) ProtoMessage()
- func (x *GetFeedsPagedRequest) ProtoReflect() protoreflect.Message
- func (x *GetFeedsPagedRequest) Reset()
- func (x *GetFeedsPagedRequest) String() string
- type InputMessage
- func (*InputMessage) Descriptor() ([]byte, []int)deprecated
- func (x *InputMessage) GetContent() string
- func (x *InputMessage) GetConversationId() string
- func (x *InputMessage) GetDirection() MessageDirection
- func (x *InputMessage) GetInitiatorIdentifier() *ParticipantId
- func (x *InputMessage) GetParticipantsIdentifiers() []*ParticipantId
- func (x *InputMessage) GetSubtype() MessageSubtype
- func (x *InputMessage) GetThreadId() string
- func (x *InputMessage) GetType() MessageType
- func (*InputMessage) ProtoMessage()
- func (x *InputMessage) ProtoReflect() protoreflect.Message
- func (x *InputMessage) Reset()
- func (x *InputMessage) String() string
- type Message
- func (*Message) Descriptor() ([]byte, []int)deprecated
- func (x *Message) GetContent() string
- func (x *Message) GetDirection() MessageDirection
- func (x *Message) GetInitiatorUsername() *ParticipantId
- func (x *Message) GetMessageId() *MessageId
- func (x *Message) GetSenderId() string
- func (x *Message) GetSenderType() SenderType
- func (x *Message) GetSenderUsername() *ParticipantId
- func (x *Message) GetSubtype() MessageSubtype
- func (x *Message) GetTime() *timestamppb.Timestamp
- func (x *Message) GetType() MessageType
- func (*Message) ProtoMessage()
- func (x *Message) ProtoReflect() protoreflect.Message
- func (x *Message) Reset()
- func (x *Message) String() string
- type MessageDirection
- func (MessageDirection) Descriptor() protoreflect.EnumDescriptor
- func (x MessageDirection) Enum() *MessageDirection
- func (MessageDirection) EnumDescriptor() ([]byte, []int)deprecated
- func (x MessageDirection) Number() protoreflect.EnumNumber
- func (x MessageDirection) String() string
- func (MessageDirection) Type() protoreflect.EnumType
- type MessageId
- func (*MessageId) Descriptor() ([]byte, []int)deprecated
- func (x *MessageId) GetConversationEventId() string
- func (x *MessageId) GetConversationId() string
- func (*MessageId) ProtoMessage()
- func (x *MessageId) ProtoReflect() protoreflect.Message
- func (x *MessageId) Reset()
- func (x *MessageId) String() string
- type MessageListResponse
- func (*MessageListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MessageListResponse) GetMessages() []*Message
- func (*MessageListResponse) ProtoMessage()
- func (x *MessageListResponse) ProtoReflect() protoreflect.Message
- func (x *MessageListResponse) Reset()
- func (x *MessageListResponse) String() string
- type MessageStoreServiceClient
- type MessageStoreServiceServer
- type MessageSubtype
- func (MessageSubtype) Descriptor() protoreflect.EnumDescriptor
- func (x MessageSubtype) Enum() *MessageSubtype
- func (MessageSubtype) EnumDescriptor() ([]byte, []int)deprecated
- func (x MessageSubtype) Number() protoreflect.EnumNumber
- func (x MessageSubtype) String() string
- func (MessageSubtype) Type() protoreflect.EnumType
- type MessageType
- func (MessageType) Descriptor() protoreflect.EnumDescriptor
- func (x MessageType) Enum() *MessageType
- func (MessageType) EnumDescriptor() ([]byte, []int)deprecated
- func (x MessageType) Number() protoreflect.EnumNumber
- func (x MessageType) String() string
- func (MessageType) Type() protoreflect.EnumType
- type PageInfo
- type PagedMessages
- func (*PagedMessages) Descriptor() ([]byte, []int)deprecated
- func (x *PagedMessages) GetFeed() *FeedId
- func (x *PagedMessages) GetPage() *PageInfo
- func (*PagedMessages) ProtoMessage()
- func (x *PagedMessages) ProtoReflect() protoreflect.Message
- func (x *PagedMessages) Reset()
- func (x *PagedMessages) String() string
- type Participant
- type ParticipantId
- func (*ParticipantId) Descriptor() ([]byte, []int)deprecated
- func (x *ParticipantId) GetIdentifier() string
- func (x *ParticipantId) GetType() ParticipantIdType
- func (*ParticipantId) ProtoMessage()
- func (x *ParticipantId) ProtoReflect() protoreflect.Message
- func (x *ParticipantId) Reset()
- func (x *ParticipantId) String() string
- type ParticipantIdType
- func (ParticipantIdType) Descriptor() protoreflect.EnumDescriptor
- func (x ParticipantIdType) Enum() *ParticipantIdType
- func (ParticipantIdType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ParticipantIdType) Number() protoreflect.EnumNumber
- func (x ParticipantIdType) String() string
- func (ParticipantIdType) Type() protoreflect.EnumType
- type ParticipantObjectListResponse
- func (*ParticipantObjectListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ParticipantObjectListResponse) GetParticipants() []*Participant
- func (*ParticipantObjectListResponse) ProtoMessage()
- func (x *ParticipantObjectListResponse) ProtoReflect() protoreflect.Message
- func (x *ParticipantObjectListResponse) Reset()
- func (x *ParticipantObjectListResponse) String() string
- type ParticipantsListResponse
- func (*ParticipantsListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ParticipantsListResponse) GetParticipants() []string
- func (*ParticipantsListResponse) ProtoMessage()
- func (x *ParticipantsListResponse) ProtoReflect() protoreflect.Message
- func (x *ParticipantsListResponse) Reset()
- func (x *ParticipantsListResponse) String() string
- type SenderType
- type UnimplementedMessageStoreServiceServer
- func (UnimplementedMessageStoreServiceServer) GetFeed(context.Context, *FeedId) (*FeedItem, error)
- func (UnimplementedMessageStoreServiceServer) GetFeeds(context.Context, *GetFeedsPagedRequest) (*FeedItemPagedResponse, error)
- func (UnimplementedMessageStoreServiceServer) GetMessage(context.Context, *MessageId) (*Message, error)
- func (UnimplementedMessageStoreServiceServer) GetMessagesForFeed(context.Context, *PagedMessages) (*MessageListResponse, error)
- func (UnimplementedMessageStoreServiceServer) GetParticipantIds(context.Context, *FeedId) (*ParticipantObjectListResponse, error)
- func (UnimplementedMessageStoreServiceServer) GetParticipants(context.Context, *FeedId) (*ParticipantsListResponse, error)
- func (UnimplementedMessageStoreServiceServer) SaveMessage(context.Context, *InputMessage) (*MessageId, error)
- type UnsafeMessageStoreServiceServer
Constants ¶
This section is empty.
Variables ¶
var ( SenderType_name = map[int32]string{ 0: "CONTACT", 1: "USER", } SenderType_value = map[string]int32{ "CONTACT": 0, "USER": 1, } )
Enum value maps for SenderType.
var ( MessageSubtype_name = map[int32]string{ 0: "MESSAGE", 1: "FILE", } MessageSubtype_value = map[string]int32{ "MESSAGE": 0, "FILE": 1, } )
Enum value maps for MessageSubtype.
var ( MessageDirection_name = map[int32]string{ 0: "INBOUND", 1: "OUTBOUND", } MessageDirection_value = map[string]int32{ "INBOUND": 0, "OUTBOUND": 1, } )
Enum value maps for MessageDirection.
var ( MessageType_name = map[int32]string{ 0: "WEB_CHAT", 1: "EMAIL", 2: "VOICE", } MessageType_value = map[string]int32{ "WEB_CHAT": 0, "EMAIL": 1, "VOICE": 2, } )
Enum value maps for MessageType.
var ( ParticipantIdType_name = map[int32]string{ 0: "MAILTO", 1: "TEL", } ParticipantIdType_value = map[string]int32{ "MAILTO": 0, "TEL": 1, } )
Enum value maps for ParticipantIdType.
var ( FeedItemState_name = map[int32]string{ 0: "NEW", 1: "IN_PROGRESS", 2: "CLOSED", } FeedItemState_value = map[string]int32{ "NEW": 0, "IN_PROGRESS": 1, "CLOSED": 2, } )
Enum value maps for FeedItemState.
var File_MessageStore_proto protoreflect.FileDescriptor
var File_Message_proto protoreflect.FileDescriptor
var MessageStoreService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "proto.MessageStoreService", HandlerType: (*MessageStoreServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "getFeeds", Handler: _MessageStoreService_GetFeeds_Handler, }, { MethodName: "getFeed", Handler: _MessageStoreService_GetFeed_Handler, }, { MethodName: "getMessagesForFeed", Handler: _MessageStoreService_GetMessagesForFeed_Handler, }, { MethodName: "getMessage", Handler: _MessageStoreService_GetMessage_Handler, }, { MethodName: "saveMessage", Handler: _MessageStoreService_SaveMessage_Handler, }, { MethodName: "getParticipants", Handler: _MessageStoreService_GetParticipants_Handler, }, { MethodName: "getParticipantIds", Handler: _MessageStoreService_GetParticipantIds_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "MessageStore.proto", }
MessageStoreService_ServiceDesc is the grpc.ServiceDesc for MessageStoreService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterMessageStoreServiceServer ¶
func RegisterMessageStoreServiceServer(s grpc.ServiceRegistrar, srv MessageStoreServiceServer)
Types ¶
type FeedId ¶
type FeedId struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id"` // contains filtered or unexported fields }
func (*FeedId) Descriptor
deprecated
func (*FeedId) ProtoMessage ¶
func (*FeedId) ProtoMessage()
func (*FeedId) ProtoReflect ¶
func (x *FeedId) ProtoReflect() protoreflect.Message
type FeedItem ¶
type FeedItem struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id"` // used to produce a record in the feed InitiatorFirstName string `protobuf:"bytes,2,opt,name=initiatorFirstName,proto3" json:"initiatorFirstName"` InitiatorLastName string `protobuf:"bytes,3,opt,name=initiatorLastName,proto3" json:"initiatorLastName"` InitiatorUsername *ParticipantId `protobuf:"bytes,4,opt,name=initiatorUsername,proto3" json:"initiatorUsername"` InitiatorType string `protobuf:"bytes,5,opt,name=initiatorType,proto3" json:"initiatorType"` // used to produce the preview in the feed LastSenderFirstName string `protobuf:"bytes,6,opt,name=lastSenderFirstName,proto3" json:"lastSenderFirstName"` LastSenderLastName string `protobuf:"bytes,7,opt,name=lastSenderLastName,proto3" json:"lastSenderLastName"` LastContentPreview string `protobuf:"bytes,8,opt,name=lastContentPreview,proto3" json:"lastContentPreview"` LastTimestamp *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=lastTimestamp,proto3" json:"lastTimestamp"` // contains filtered or unexported fields }
func (*FeedItem) Descriptor
deprecated
func (*FeedItem) GetInitiatorFirstName ¶
func (*FeedItem) GetInitiatorLastName ¶
func (*FeedItem) GetInitiatorType ¶
func (*FeedItem) GetInitiatorUsername ¶
func (x *FeedItem) GetInitiatorUsername() *ParticipantId
func (*FeedItem) GetLastContentPreview ¶
func (*FeedItem) GetLastSenderFirstName ¶
func (*FeedItem) GetLastSenderLastName ¶
func (*FeedItem) GetLastTimestamp ¶
func (x *FeedItem) GetLastTimestamp() *timestamppb.Timestamp
func (*FeedItem) ProtoMessage ¶
func (*FeedItem) ProtoMessage()
func (*FeedItem) ProtoReflect ¶
func (x *FeedItem) ProtoReflect() protoreflect.Message
type FeedItemPagedResponse ¶
type FeedItemPagedResponse struct { FeedItems []*FeedItem `protobuf:"bytes,1,rep,name=feedItems,proto3" json:"feedItems"` TotalElements int32 `protobuf:"varint,2,opt,name=totalElements,proto3" json:"totalElements"` // contains filtered or unexported fields }
func (*FeedItemPagedResponse) Descriptor
deprecated
func (*FeedItemPagedResponse) Descriptor() ([]byte, []int)
Deprecated: Use FeedItemPagedResponse.ProtoReflect.Descriptor instead.
func (*FeedItemPagedResponse) GetFeedItems ¶
func (x *FeedItemPagedResponse) GetFeedItems() []*FeedItem
func (*FeedItemPagedResponse) GetTotalElements ¶
func (x *FeedItemPagedResponse) GetTotalElements() int32
func (*FeedItemPagedResponse) ProtoMessage ¶
func (*FeedItemPagedResponse) ProtoMessage()
func (*FeedItemPagedResponse) ProtoReflect ¶
func (x *FeedItemPagedResponse) ProtoReflect() protoreflect.Message
func (*FeedItemPagedResponse) Reset ¶
func (x *FeedItemPagedResponse) Reset()
func (*FeedItemPagedResponse) String ¶
func (x *FeedItemPagedResponse) String() string
type FeedItemState ¶
type FeedItemState int32
const ( FeedItemState_NEW FeedItemState = 0 FeedItemState_IN_PROGRESS FeedItemState = 1 FeedItemState_CLOSED FeedItemState = 2 )
func (FeedItemState) Descriptor ¶
func (FeedItemState) Descriptor() protoreflect.EnumDescriptor
func (FeedItemState) Enum ¶
func (x FeedItemState) Enum() *FeedItemState
func (FeedItemState) EnumDescriptor
deprecated
func (FeedItemState) EnumDescriptor() ([]byte, []int)
Deprecated: Use FeedItemState.Descriptor instead.
func (FeedItemState) Number ¶
func (x FeedItemState) Number() protoreflect.EnumNumber
func (FeedItemState) String ¶
func (x FeedItemState) String() string
func (FeedItemState) Type ¶
func (FeedItemState) Type() protoreflect.EnumType
type GetFeedsPagedRequest ¶
type GetFeedsPagedRequest struct { StateIn []FeedItemState `protobuf:"varint,1,rep,packed,name=stateIn,proto3,enum=proto.FeedItemState" json:"stateIn"` Page int32 `protobuf:"varint,2,opt,name=page,proto3" json:"page"` PageSize int32 `protobuf:"varint,3,opt,name=pageSize,proto3" json:"pageSize"` OnlyContacts bool `protobuf:"varint,4,opt,name=onlyContacts,proto3" json:"onlyContacts"` // contains filtered or unexported fields }
func (*GetFeedsPagedRequest) Descriptor
deprecated
func (*GetFeedsPagedRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetFeedsPagedRequest.ProtoReflect.Descriptor instead.
func (*GetFeedsPagedRequest) GetOnlyContacts ¶
func (x *GetFeedsPagedRequest) GetOnlyContacts() bool
func (*GetFeedsPagedRequest) GetPage ¶
func (x *GetFeedsPagedRequest) GetPage() int32
func (*GetFeedsPagedRequest) GetPageSize ¶
func (x *GetFeedsPagedRequest) GetPageSize() int32
func (*GetFeedsPagedRequest) GetStateIn ¶
func (x *GetFeedsPagedRequest) GetStateIn() []FeedItemState
func (*GetFeedsPagedRequest) ProtoMessage ¶
func (*GetFeedsPagedRequest) ProtoMessage()
func (*GetFeedsPagedRequest) ProtoReflect ¶
func (x *GetFeedsPagedRequest) ProtoReflect() protoreflect.Message
func (*GetFeedsPagedRequest) Reset ¶
func (x *GetFeedsPagedRequest) Reset()
func (*GetFeedsPagedRequest) String ¶
func (x *GetFeedsPagedRequest) String() string
type InputMessage ¶
type InputMessage struct { ConversationId *string `protobuf:"bytes,1,opt,name=conversationId,proto3,oneof" json:"conversationId"` InitiatorIdentifier *ParticipantId `protobuf:"bytes,2,opt,name=initiatorIdentifier,proto3,oneof" json:"initiatorIdentifier"` Type MessageType `protobuf:"varint,3,opt,name=type,proto3,enum=proto.MessageType" json:"type"` Subtype MessageSubtype `protobuf:"varint,4,opt,name=subtype,proto3,enum=proto.MessageSubtype" json:"subtype"` Content *string `protobuf:"bytes,5,opt,name=content,proto3,oneof" json:"content"` Direction MessageDirection `protobuf:"varint,6,opt,name=direction,proto3,enum=proto.MessageDirection" json:"direction"` ParticipantsIdentifiers []*ParticipantId `protobuf:"bytes,7,rep,name=participantsIdentifiers,proto3" json:"participantsIdentifiers"` ThreadId *string `protobuf:"bytes,8,opt,name=threadId,proto3,oneof" json:"threadId"` // contains filtered or unexported fields }
func (*InputMessage) Descriptor
deprecated
func (*InputMessage) Descriptor() ([]byte, []int)
Deprecated: Use InputMessage.ProtoReflect.Descriptor instead.
func (*InputMessage) GetContent ¶
func (x *InputMessage) GetContent() string
func (*InputMessage) GetConversationId ¶
func (x *InputMessage) GetConversationId() string
func (*InputMessage) GetDirection ¶
func (x *InputMessage) GetDirection() MessageDirection
func (*InputMessage) GetInitiatorIdentifier ¶
func (x *InputMessage) GetInitiatorIdentifier() *ParticipantId
func (*InputMessage) GetParticipantsIdentifiers ¶
func (x *InputMessage) GetParticipantsIdentifiers() []*ParticipantId
func (*InputMessage) GetSubtype ¶
func (x *InputMessage) GetSubtype() MessageSubtype
func (*InputMessage) GetThreadId ¶
func (x *InputMessage) GetThreadId() string
func (*InputMessage) GetType ¶
func (x *InputMessage) GetType() MessageType
func (*InputMessage) ProtoMessage ¶
func (*InputMessage) ProtoMessage()
func (*InputMessage) ProtoReflect ¶
func (x *InputMessage) ProtoReflect() protoreflect.Message
func (*InputMessage) Reset ¶
func (x *InputMessage) Reset()
func (*InputMessage) String ¶
func (x *InputMessage) String() string
type Message ¶
type Message struct { MessageId *MessageId `protobuf:"bytes,1,opt,name=messageId,proto3" json:"messageId"` InitiatorUsername *ParticipantId `protobuf:"bytes,2,opt,name=initiatorUsername,proto3" json:"initiatorUsername"` Type MessageType `protobuf:"varint,3,opt,name=type,proto3,enum=proto.MessageType" json:"type"` Subtype MessageSubtype `protobuf:"varint,4,opt,name=subtype,proto3,enum=proto.MessageSubtype" json:"subtype"` Content string `protobuf:"bytes,5,opt,name=content,proto3" json:"content"` Direction MessageDirection `protobuf:"varint,6,opt,name=direction,proto3,enum=proto.MessageDirection" json:"direction"` Time *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=time,proto3" json:"time"` SenderType SenderType `protobuf:"varint,8,opt,name=senderType,proto3,enum=proto.SenderType" json:"senderType"` SenderId string `protobuf:"bytes,9,opt,name=senderId,proto3" json:"senderId"` SenderUsername *ParticipantId `protobuf:"bytes,10,opt,name=senderUsername,proto3" json:"senderUsername"` // contains filtered or unexported fields }
func (*Message) Descriptor
deprecated
func (*Message) GetContent ¶
func (*Message) GetDirection ¶
func (x *Message) GetDirection() MessageDirection
func (*Message) GetInitiatorUsername ¶
func (x *Message) GetInitiatorUsername() *ParticipantId
func (*Message) GetMessageId ¶
func (*Message) GetSenderId ¶
func (*Message) GetSenderType ¶
func (x *Message) GetSenderType() SenderType
func (*Message) GetSenderUsername ¶
func (x *Message) GetSenderUsername() *ParticipantId
func (*Message) GetSubtype ¶
func (x *Message) GetSubtype() MessageSubtype
func (*Message) GetTime ¶
func (x *Message) GetTime() *timestamppb.Timestamp
func (*Message) GetType ¶
func (x *Message) GetType() MessageType
func (*Message) ProtoMessage ¶
func (*Message) ProtoMessage()
func (*Message) ProtoReflect ¶
func (x *Message) ProtoReflect() protoreflect.Message
type MessageDirection ¶
type MessageDirection int32
const ( MessageDirection_INBOUND MessageDirection = 0 MessageDirection_OUTBOUND MessageDirection = 1 )
func (MessageDirection) Descriptor ¶
func (MessageDirection) Descriptor() protoreflect.EnumDescriptor
func (MessageDirection) Enum ¶
func (x MessageDirection) Enum() *MessageDirection
func (MessageDirection) EnumDescriptor
deprecated
func (MessageDirection) EnumDescriptor() ([]byte, []int)
Deprecated: Use MessageDirection.Descriptor instead.
func (MessageDirection) Number ¶
func (x MessageDirection) Number() protoreflect.EnumNumber
func (MessageDirection) String ¶
func (x MessageDirection) String() string
func (MessageDirection) Type ¶
func (MessageDirection) Type() protoreflect.EnumType
type MessageId ¶
type MessageId struct { // postgres id ConversationEventId string `protobuf:"bytes,1,opt,name=conversationEventId,proto3" json:"conversationEventId"` // neo4j id ConversationId string `protobuf:"bytes,2,opt,name=conversationId,proto3" json:"conversationId"` // contains filtered or unexported fields }
func (*MessageId) Descriptor
deprecated
func (*MessageId) GetConversationEventId ¶
func (*MessageId) GetConversationId ¶
func (*MessageId) ProtoMessage ¶
func (*MessageId) ProtoMessage()
func (*MessageId) ProtoReflect ¶
func (x *MessageId) ProtoReflect() protoreflect.Message
type MessageListResponse ¶
type MessageListResponse struct { Messages []*Message `protobuf:"bytes,1,rep,name=messages,proto3" json:"messages"` // contains filtered or unexported fields }
func (*MessageListResponse) Descriptor
deprecated
func (*MessageListResponse) Descriptor() ([]byte, []int)
Deprecated: Use MessageListResponse.ProtoReflect.Descriptor instead.
func (*MessageListResponse) GetMessages ¶
func (x *MessageListResponse) GetMessages() []*Message
func (*MessageListResponse) ProtoMessage ¶
func (*MessageListResponse) ProtoMessage()
func (*MessageListResponse) ProtoReflect ¶
func (x *MessageListResponse) ProtoReflect() protoreflect.Message
func (*MessageListResponse) Reset ¶
func (x *MessageListResponse) Reset()
func (*MessageListResponse) String ¶
func (x *MessageListResponse) String() string
type MessageStoreServiceClient ¶
type MessageStoreServiceClient interface { GetFeeds(ctx context.Context, in *GetFeedsPagedRequest, opts ...grpc.CallOption) (*FeedItemPagedResponse, error) GetFeed(ctx context.Context, in *FeedId, opts ...grpc.CallOption) (*FeedItem, error) GetMessagesForFeed(ctx context.Context, in *PagedMessages, opts ...grpc.CallOption) (*MessageListResponse, error) GetMessage(ctx context.Context, in *MessageId, opts ...grpc.CallOption) (*Message, error) SaveMessage(ctx context.Context, in *InputMessage, opts ...grpc.CallOption) (*MessageId, error) GetParticipants(ctx context.Context, in *FeedId, opts ...grpc.CallOption) (*ParticipantsListResponse, error) GetParticipantIds(ctx context.Context, in *FeedId, opts ...grpc.CallOption) (*ParticipantObjectListResponse, error) }
MessageStoreServiceClient is the client API for MessageStoreService 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 NewMessageStoreServiceClient ¶
func NewMessageStoreServiceClient(cc grpc.ClientConnInterface) MessageStoreServiceClient
type MessageStoreServiceServer ¶
type MessageStoreServiceServer interface { GetFeeds(context.Context, *GetFeedsPagedRequest) (*FeedItemPagedResponse, error) GetFeed(context.Context, *FeedId) (*FeedItem, error) GetMessagesForFeed(context.Context, *PagedMessages) (*MessageListResponse, error) GetMessage(context.Context, *MessageId) (*Message, error) SaveMessage(context.Context, *InputMessage) (*MessageId, error) GetParticipants(context.Context, *FeedId) (*ParticipantsListResponse, error) GetParticipantIds(context.Context, *FeedId) (*ParticipantObjectListResponse, error) // contains filtered or unexported methods }
MessageStoreServiceServer is the server API for MessageStoreService service. All implementations must embed UnimplementedMessageStoreServiceServer for forward compatibility
type MessageSubtype ¶
type MessageSubtype int32
const ( MessageSubtype_MESSAGE MessageSubtype = 0 MessageSubtype_FILE MessageSubtype = 1 )
func (MessageSubtype) Descriptor ¶
func (MessageSubtype) Descriptor() protoreflect.EnumDescriptor
func (MessageSubtype) Enum ¶
func (x MessageSubtype) Enum() *MessageSubtype
func (MessageSubtype) EnumDescriptor
deprecated
func (MessageSubtype) EnumDescriptor() ([]byte, []int)
Deprecated: Use MessageSubtype.Descriptor instead.
func (MessageSubtype) Number ¶
func (x MessageSubtype) Number() protoreflect.EnumNumber
func (MessageSubtype) String ¶
func (x MessageSubtype) String() string
func (MessageSubtype) Type ¶
func (MessageSubtype) Type() protoreflect.EnumType
type MessageType ¶
type MessageType int32
const ( MessageType_WEB_CHAT MessageType = 0 MessageType_EMAIL MessageType = 1 MessageType_VOICE MessageType = 2 )
func (MessageType) Descriptor ¶
func (MessageType) Descriptor() protoreflect.EnumDescriptor
func (MessageType) Enum ¶
func (x MessageType) Enum() *MessageType
func (MessageType) EnumDescriptor
deprecated
func (MessageType) EnumDescriptor() ([]byte, []int)
Deprecated: Use MessageType.Descriptor instead.
func (MessageType) Number ¶
func (x MessageType) Number() protoreflect.EnumNumber
func (MessageType) String ¶
func (x MessageType) String() string
func (MessageType) Type ¶
func (MessageType) Type() protoreflect.EnumType
type PageInfo ¶
type PageInfo struct { Before *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=before,proto3,oneof" json:"before"` PageSize int32 `protobuf:"varint,2,opt,name=pageSize,proto3" json:"pageSize"` // contains filtered or unexported fields }
func (*PageInfo) Descriptor
deprecated
func (*PageInfo) GetBefore ¶
func (x *PageInfo) GetBefore() *timestamppb.Timestamp
func (*PageInfo) GetPageSize ¶
func (*PageInfo) ProtoMessage ¶
func (*PageInfo) ProtoMessage()
func (*PageInfo) ProtoReflect ¶
func (x *PageInfo) ProtoReflect() protoreflect.Message
type PagedMessages ¶
type PagedMessages struct { Feed *FeedId `protobuf:"bytes,1,opt,name=feed,proto3" json:"feed"` Page *PageInfo `protobuf:"bytes,2,opt,name=page,proto3,oneof" json:"page"` // contains filtered or unexported fields }
func (*PagedMessages) Descriptor
deprecated
func (*PagedMessages) Descriptor() ([]byte, []int)
Deprecated: Use PagedMessages.ProtoReflect.Descriptor instead.
func (*PagedMessages) GetFeed ¶
func (x *PagedMessages) GetFeed() *FeedId
func (*PagedMessages) GetPage ¶
func (x *PagedMessages) GetPage() *PageInfo
func (*PagedMessages) ProtoMessage ¶
func (*PagedMessages) ProtoMessage()
func (*PagedMessages) ProtoReflect ¶
func (x *PagedMessages) ProtoReflect() protoreflect.Message
func (*PagedMessages) Reset ¶
func (x *PagedMessages) Reset()
func (*PagedMessages) String ¶
func (x *PagedMessages) String() string
type Participant ¶
type Participant struct { Id string `protobuf:"bytes,1,opt,name=Id,proto3" json:"Id"` Type SenderType `protobuf:"varint,2,opt,name=Type,proto3,enum=proto.SenderType" json:"Type"` // contains filtered or unexported fields }
func (*Participant) Descriptor
deprecated
func (*Participant) Descriptor() ([]byte, []int)
Deprecated: Use Participant.ProtoReflect.Descriptor instead.
func (*Participant) GetId ¶
func (x *Participant) GetId() string
func (*Participant) GetType ¶
func (x *Participant) GetType() SenderType
func (*Participant) ProtoMessage ¶
func (*Participant) ProtoMessage()
func (*Participant) ProtoReflect ¶
func (x *Participant) ProtoReflect() protoreflect.Message
func (*Participant) Reset ¶
func (x *Participant) Reset()
func (*Participant) String ¶
func (x *Participant) String() string
type ParticipantId ¶
type ParticipantId struct { Type ParticipantIdType `protobuf:"varint,1,opt,name=type,proto3,enum=proto.ParticipantIdType" json:"type"` Identifier string `protobuf:"bytes,2,opt,name=identifier,proto3" json:"identifier"` // contains filtered or unexported fields }
func (*ParticipantId) Descriptor
deprecated
func (*ParticipantId) Descriptor() ([]byte, []int)
Deprecated: Use ParticipantId.ProtoReflect.Descriptor instead.
func (*ParticipantId) GetIdentifier ¶
func (x *ParticipantId) GetIdentifier() string
func (*ParticipantId) GetType ¶
func (x *ParticipantId) GetType() ParticipantIdType
func (*ParticipantId) ProtoMessage ¶
func (*ParticipantId) ProtoMessage()
func (*ParticipantId) ProtoReflect ¶
func (x *ParticipantId) ProtoReflect() protoreflect.Message
func (*ParticipantId) Reset ¶
func (x *ParticipantId) Reset()
func (*ParticipantId) String ¶
func (x *ParticipantId) String() string
type ParticipantIdType ¶
type ParticipantIdType int32
const ( ParticipantIdType_MAILTO ParticipantIdType = 0 ParticipantIdType_TEL ParticipantIdType = 1 )
func (ParticipantIdType) Descriptor ¶
func (ParticipantIdType) Descriptor() protoreflect.EnumDescriptor
func (ParticipantIdType) Enum ¶
func (x ParticipantIdType) Enum() *ParticipantIdType
func (ParticipantIdType) EnumDescriptor
deprecated
func (ParticipantIdType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ParticipantIdType.Descriptor instead.
func (ParticipantIdType) Number ¶
func (x ParticipantIdType) Number() protoreflect.EnumNumber
func (ParticipantIdType) String ¶
func (x ParticipantIdType) String() string
func (ParticipantIdType) Type ¶
func (ParticipantIdType) Type() protoreflect.EnumType
type ParticipantObjectListResponse ¶
type ParticipantObjectListResponse struct { Participants []*Participant `protobuf:"bytes,1,rep,name=participants,proto3" json:"participants"` // contains filtered or unexported fields }
func (*ParticipantObjectListResponse) Descriptor
deprecated
func (*ParticipantObjectListResponse) Descriptor() ([]byte, []int)
Deprecated: Use ParticipantObjectListResponse.ProtoReflect.Descriptor instead.
func (*ParticipantObjectListResponse) GetParticipants ¶
func (x *ParticipantObjectListResponse) GetParticipants() []*Participant
func (*ParticipantObjectListResponse) ProtoMessage ¶
func (*ParticipantObjectListResponse) ProtoMessage()
func (*ParticipantObjectListResponse) ProtoReflect ¶
func (x *ParticipantObjectListResponse) ProtoReflect() protoreflect.Message
func (*ParticipantObjectListResponse) Reset ¶
func (x *ParticipantObjectListResponse) Reset()
func (*ParticipantObjectListResponse) String ¶
func (x *ParticipantObjectListResponse) String() string
type ParticipantsListResponse ¶
type ParticipantsListResponse struct { Participants []string `protobuf:"bytes,1,rep,name=participants,proto3" json:"participants"` // contains filtered or unexported fields }
func (*ParticipantsListResponse) Descriptor
deprecated
func (*ParticipantsListResponse) Descriptor() ([]byte, []int)
Deprecated: Use ParticipantsListResponse.ProtoReflect.Descriptor instead.
func (*ParticipantsListResponse) GetParticipants ¶
func (x *ParticipantsListResponse) GetParticipants() []string
func (*ParticipantsListResponse) ProtoMessage ¶
func (*ParticipantsListResponse) ProtoMessage()
func (*ParticipantsListResponse) ProtoReflect ¶
func (x *ParticipantsListResponse) ProtoReflect() protoreflect.Message
func (*ParticipantsListResponse) Reset ¶
func (x *ParticipantsListResponse) Reset()
func (*ParticipantsListResponse) String ¶
func (x *ParticipantsListResponse) String() string
type SenderType ¶
type SenderType int32
const ( SenderType_CONTACT SenderType = 0 SenderType_USER SenderType = 1 )
func (SenderType) Descriptor ¶
func (SenderType) Descriptor() protoreflect.EnumDescriptor
func (SenderType) Enum ¶
func (x SenderType) Enum() *SenderType
func (SenderType) EnumDescriptor
deprecated
func (SenderType) EnumDescriptor() ([]byte, []int)
Deprecated: Use SenderType.Descriptor instead.
func (SenderType) Number ¶
func (x SenderType) Number() protoreflect.EnumNumber
func (SenderType) String ¶
func (x SenderType) String() string
func (SenderType) Type ¶
func (SenderType) Type() protoreflect.EnumType
type UnimplementedMessageStoreServiceServer ¶
type UnimplementedMessageStoreServiceServer struct { }
UnimplementedMessageStoreServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedMessageStoreServiceServer) GetFeeds ¶
func (UnimplementedMessageStoreServiceServer) GetFeeds(context.Context, *GetFeedsPagedRequest) (*FeedItemPagedResponse, error)
func (UnimplementedMessageStoreServiceServer) GetMessage ¶
func (UnimplementedMessageStoreServiceServer) GetMessagesForFeed ¶
func (UnimplementedMessageStoreServiceServer) GetMessagesForFeed(context.Context, *PagedMessages) (*MessageListResponse, error)
func (UnimplementedMessageStoreServiceServer) GetParticipantIds ¶
func (UnimplementedMessageStoreServiceServer) GetParticipantIds(context.Context, *FeedId) (*ParticipantObjectListResponse, error)
func (UnimplementedMessageStoreServiceServer) GetParticipants ¶
func (UnimplementedMessageStoreServiceServer) GetParticipants(context.Context, *FeedId) (*ParticipantsListResponse, error)
func (UnimplementedMessageStoreServiceServer) SaveMessage ¶
func (UnimplementedMessageStoreServiceServer) SaveMessage(context.Context, *InputMessage) (*MessageId, error)
type UnsafeMessageStoreServiceServer ¶
type UnsafeMessageStoreServiceServer interface {
// contains filtered or unexported methods
}
UnsafeMessageStoreServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MessageStoreServiceServer will result in compilation errors.