chattyproto

package module
v0.0.0-...-745af2a Latest Latest
Warning

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

 Go to latest Published: Dec 31, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

README

chatty-proto

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var RequestMetaSortsDirection_name = map[int32]string{
	0: "Descending",
	1: "Ascending",
}
View Source 
var RequestMetaSortsDirection_value = map[string]int32{
	"Descending": 0,
	"Ascending":  1,
}

Functions

func RegisterUserServiceServer 

func RegisterUserServiceServer(s *grpc.Server, srv UserServiceServer)

Types

type Any 

type Any struct {
	TypeUrl              string   `protobuf:"bytes,1,opt,name=type_url,json=typeUrl,proto3" json:"type_url"`
	Value                []byte   `protobuf:"bytes,2,opt,name=value,proto3" json:"value"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Any) Descriptor 

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

func (*Any) GetTypeUrl 

func (m *Any) GetTypeUrl() string

func (*Any) GetValue 

func (m *Any) GetValue() []byte

func (*Any) ProtoMessage 

func (*Any) ProtoMessage()

func (*Any) Reset 

func (m *Any) Reset()

func (*Any) String 

func (m *Any) String() string

func (*Any) XXX_DiscardUnknown 

func (m *Any) XXX_DiscardUnknown()

func (*Any) XXX_Marshal 

func (m *Any) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Any) XXX_Merge 

func (m *Any) XXX_Merge(src proto.Message)

func (*Any) XXX_Size 

func (m *Any) XXX_Size() int

func (*Any) XXX_Unmarshal 

func (m *Any) XXX_Unmarshal(b []byte) error

type CreateConnectionRequest 

type CreateConnectionRequest struct {
	// create connection with one of thus connection infos
	Connection           *CreateConnectionRequest_ConnectionInfo `protobuf:"bytes,1,opt,name=Connection,proto3" json:"Connection"`
	XXX_NoUnkeyedLiteral struct{}                                `json:"-"`
	XXX_unrecognized     []byte                                  `json:"-"`
	XXX_sizecache        int32                                   `json:"-"`
}

========== Add data which have to be transferred between services create connection request and response

func (*CreateConnectionRequest) Descriptor 

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

func (*CreateConnectionRequest) GetConnection 

func (m *CreateConnectionRequest) GetConnection() *CreateConnectionRequest_ConnectionInfo

func (*CreateConnectionRequest) ProtoMessage 

func (*CreateConnectionRequest) ProtoMessage()

func (*CreateConnectionRequest) Reset 

func (m *CreateConnectionRequest) Reset()

func (*CreateConnectionRequest) String 

func (m *CreateConnectionRequest) String() string

func (*CreateConnectionRequest) XXX_DiscardUnknown 

func (m *CreateConnectionRequest) XXX_DiscardUnknown()

func (*CreateConnectionRequest) XXX_Marshal 

func (m *CreateConnectionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateConnectionRequest) XXX_Merge 

func (m *CreateConnectionRequest) XXX_Merge(src proto.Message)

func (*CreateConnectionRequest) XXX_Size 

func (m *CreateConnectionRequest) XXX_Size() int

func (*CreateConnectionRequest) XXX_Unmarshal 

func (m *CreateConnectionRequest) XXX_Unmarshal(b []byte) error

type CreateConnectionRequest_ConnectionInfo 

type CreateConnectionRequest_ConnectionInfo struct {
	UID                  string   `protobuf:"bytes,1,opt,name=UID,proto3" json:"UID"`
	PhoneNumber          string   `protobuf:"bytes,2,opt,name=PhoneNumber,proto3" json:"PhoneNumber"`
	Email                string   `protobuf:"bytes,3,opt,name=Email,proto3" json:"Email"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateConnectionRequest_ConnectionInfo) Descriptor 

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

func (*CreateConnectionRequest_ConnectionInfo) GetEmail 

func (m *CreateConnectionRequest_ConnectionInfo) GetEmail() string

func (*CreateConnectionRequest_ConnectionInfo) GetPhoneNumber 

func (m *CreateConnectionRequest_ConnectionInfo) GetPhoneNumber() string

func (*CreateConnectionRequest_ConnectionInfo) GetUID 

func (m *CreateConnectionRequest_ConnectionInfo) GetUID() string

func (*CreateConnectionRequest_ConnectionInfo) ProtoMessage 

func (*CreateConnectionRequest_ConnectionInfo) ProtoMessage()

func (*CreateConnectionRequest_ConnectionInfo) Reset 

func (m *CreateConnectionRequest_ConnectionInfo) Reset()

func (*CreateConnectionRequest_ConnectionInfo) String 

func (m *CreateConnectionRequest_ConnectionInfo) String() string

func (*CreateConnectionRequest_ConnectionInfo) XXX_DiscardUnknown 

func (m *CreateConnectionRequest_ConnectionInfo) XXX_DiscardUnknown()

func (*CreateConnectionRequest_ConnectionInfo) XXX_Marshal 

func (m *CreateConnectionRequest_ConnectionInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateConnectionRequest_ConnectionInfo) XXX_Merge 

func (m *CreateConnectionRequest_ConnectionInfo) XXX_Merge(src proto.Message)

func (*CreateConnectionRequest_ConnectionInfo) XXX_Size 

func (m *CreateConnectionRequest_ConnectionInfo) XXX_Size() int

func (*CreateConnectionRequest_ConnectionInfo) XXX_Unmarshal 

func (m *CreateConnectionRequest_ConnectionInfo) XXX_Unmarshal(b []byte) error

type Empty 

type Empty struct {
	Empty                string   `protobuf:"bytes,1,opt,name=empty,proto3" json:"empty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Empty) Descriptor 

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

func (*Empty) GetEmpty 

func (m *Empty) GetEmpty() string

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) XXX_DiscardUnknown 

func (m *Empty) XXX_DiscardUnknown()

func (*Empty) XXX_Marshal 

func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Empty) XXX_Merge 

func (m *Empty) XXX_Merge(src proto.Message)

func (*Empty) XXX_Size 

func (m *Empty) XXX_Size() int

func (*Empty) XXX_Unmarshal 

func (m *Empty) XXX_Unmarshal(b []byte) error

type FetchMessagesRequest 

type FetchMessagesRequest struct {
	ChannelId            string   `protobuf:"bytes,1,opt,name=ChannelId,proto3" json:"ChannelId"`
	Page                 uint64   `protobuf:"varint,2,opt,name=Page,proto3" json:"Page"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

fetch messages request and response

func (*FetchMessagesRequest) Descriptor 

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

func (*FetchMessagesRequest) GetChannelId 

func (m *FetchMessagesRequest) GetChannelId() string

func (*FetchMessagesRequest) GetPage 

func (m *FetchMessagesRequest) GetPage() uint64

func (*FetchMessagesRequest) ProtoMessage 

func (*FetchMessagesRequest) ProtoMessage()

func (*FetchMessagesRequest) Reset 

func (m *FetchMessagesRequest) Reset()

func (*FetchMessagesRequest) String 

func (m *FetchMessagesRequest) String() string

func (*FetchMessagesRequest) XXX_DiscardUnknown 

func (m *FetchMessagesRequest) XXX_DiscardUnknown()

func (*FetchMessagesRequest) XXX_Marshal 

func (m *FetchMessagesRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FetchMessagesRequest) XXX_Merge 

func (m *FetchMessagesRequest) XXX_Merge(src proto.Message)

func (*FetchMessagesRequest) XXX_Size 

func (m *FetchMessagesRequest) XXX_Size() int

func (*FetchMessagesRequest) XXX_Unmarshal 

func (m *FetchMessagesRequest) XXX_Unmarshal(b []byte) error

type FetchMessagesResponse 

type FetchMessagesResponse struct {
	Messages             []*FetchMessagesResponse_Message `protobuf:"bytes,1,rep,name=Messages,proto3" json:"Messages"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*FetchMessagesResponse) Descriptor 

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

func (*FetchMessagesResponse) GetMessages 

func (m *FetchMessagesResponse) GetMessages() []*FetchMessagesResponse_Message

func (*FetchMessagesResponse) ProtoMessage 

func (*FetchMessagesResponse) ProtoMessage()

func (*FetchMessagesResponse) Reset 

func (m *FetchMessagesResponse) Reset()

func (*FetchMessagesResponse) String 

func (m *FetchMessagesResponse) String() string

func (*FetchMessagesResponse) XXX_DiscardUnknown 

func (m *FetchMessagesResponse) XXX_DiscardUnknown()

func (*FetchMessagesResponse) XXX_Marshal 

func (m *FetchMessagesResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FetchMessagesResponse) XXX_Merge 

func (m *FetchMessagesResponse) XXX_Merge(src proto.Message)

func (*FetchMessagesResponse) XXX_Size 

func (m *FetchMessagesResponse) XXX_Size() int

func (*FetchMessagesResponse) XXX_Unmarshal 

func (m *FetchMessagesResponse) XXX_Unmarshal(b []byte) error

type FetchMessagesResponse_Message 

type FetchMessagesResponse_Message struct {
	ChannelId            string   `protobuf:"bytes,1,opt,name=ChannelId,proto3" json:"ChannelId"`
	CreatedAt            string   `protobuf:"bytes,2,opt,name=CreatedAt,proto3" json:"CreatedAt"`
	UpdatedAt            string   `protobuf:"bytes,3,opt,name=UpdatedAt,proto3" json:"UpdatedAt"`
	ChannelIndex         string   `protobuf:"bytes,4,opt,name=ChannelIndex,proto3" json:"ChannelIndex"`
	MessageReference     string   `protobuf:"bytes,5,opt,name=MessageReference,proto3" json:"MessageReference"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FetchMessagesResponse_Message) Descriptor 

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

func (*FetchMessagesResponse_Message) GetChannelId 

func (m *FetchMessagesResponse_Message) GetChannelId() string

func (*FetchMessagesResponse_Message) GetChannelIndex 

func (m *FetchMessagesResponse_Message) GetChannelIndex() string

func (*FetchMessagesResponse_Message) GetCreatedAt 

func (m *FetchMessagesResponse_Message) GetCreatedAt() string

func (*FetchMessagesResponse_Message) GetMessageReference 

func (m *FetchMessagesResponse_Message) GetMessageReference() string

func (*FetchMessagesResponse_Message) GetUpdatedAt 

func (m *FetchMessagesResponse_Message) GetUpdatedAt() string

func (*FetchMessagesResponse_Message) ProtoMessage 

func (*FetchMessagesResponse_Message) ProtoMessage()

func (*FetchMessagesResponse_Message) Reset 

func (m *FetchMessagesResponse_Message) Reset()

func (*FetchMessagesResponse_Message) String 

func (m *FetchMessagesResponse_Message) String() string

func (*FetchMessagesResponse_Message) XXX_DiscardUnknown 

func (m *FetchMessagesResponse_Message) XXX_DiscardUnknown()

func (*FetchMessagesResponse_Message) XXX_Marshal 

func (m *FetchMessagesResponse_Message) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FetchMessagesResponse_Message) XXX_Merge 

func (m *FetchMessagesResponse_Message) XXX_Merge(src proto.Message)

func (*FetchMessagesResponse_Message) XXX_Size 

func (m *FetchMessagesResponse_Message) XXX_Size() int

func (*FetchMessagesResponse_Message) XXX_Unmarshal 

func (m *FetchMessagesResponse_Message) XXX_Unmarshal(b []byte) error

type ReportChannelsResponse 

type ReportChannelsResponse struct {
	Channels             []*ReportChannelsResponse_ChannelItem `protobuf:"bytes,1,rep,name=Channels,proto3" json:"Channels"`
	PerPageMessage       uint64                                `protobuf:"varint,2,opt,name=PerPageMessage,proto3" json:"PerPageMessage"`
	XXX_NoUnkeyedLiteral struct{}                              `json:"-"`
	XXX_unrecognized     []byte                                `json:"-"`
	XXX_sizecache        int32                                 `json:"-"`
}

report channels messages request and response

func (*ReportChannelsResponse) Descriptor 

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

func (*ReportChannelsResponse) GetChannels 

func (m *ReportChannelsResponse) GetChannels() []*ReportChannelsResponse_ChannelItem

func (*ReportChannelsResponse) GetPerPageMessage 

func (m *ReportChannelsResponse) GetPerPageMessage() uint64

func (*ReportChannelsResponse) ProtoMessage 

func (*ReportChannelsResponse) ProtoMessage()

func (*ReportChannelsResponse) Reset 

func (m *ReportChannelsResponse) Reset()

func (*ReportChannelsResponse) String 

func (m *ReportChannelsResponse) String() string

func (*ReportChannelsResponse) XXX_DiscardUnknown 

func (m *ReportChannelsResponse) XXX_DiscardUnknown()

func (*ReportChannelsResponse) XXX_Marshal 

func (m *ReportChannelsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReportChannelsResponse) XXX_Merge 

func (m *ReportChannelsResponse) XXX_Merge(src proto.Message)

func (*ReportChannelsResponse) XXX_Size 

func (m *ReportChannelsResponse) XXX_Size() int

func (*ReportChannelsResponse) XXX_Unmarshal 

func (m *ReportChannelsResponse) XXX_Unmarshal(b []byte) error

type ReportChannelsResponse_ChannelItem 

type ReportChannelsResponse_ChannelItem struct {
	ChannelId            string   `protobuf:"bytes,1,opt,name=ChannelId,proto3" json:"ChannelId"`
	ChannelType          string   `protobuf:"bytes,2,opt,name=ChannelType,proto3" json:"ChannelType"`
	ChannelName          string   `protobuf:"bytes,3,opt,name=ChannelName,proto3" json:"ChannelName"`
	YourOffset           uint64   `protobuf:"varint,4,opt,name=YourOffset,proto3" json:"YourOffset"`
	ChannelOffset        uint64   `protobuf:"varint,5,opt,name=ChannelOffset,proto3" json:"ChannelOffset"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ReportChannelsResponse_ChannelItem) Descriptor 

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

func (*ReportChannelsResponse_ChannelItem) GetChannelId 

func (m *ReportChannelsResponse_ChannelItem) GetChannelId() string

func (*ReportChannelsResponse_ChannelItem) GetChannelName 

func (m *ReportChannelsResponse_ChannelItem) GetChannelName() string

func (*ReportChannelsResponse_ChannelItem) GetChannelOffset 

func (m *ReportChannelsResponse_ChannelItem) GetChannelOffset() uint64

func (*ReportChannelsResponse_ChannelItem) GetChannelType 

func (m *ReportChannelsResponse_ChannelItem) GetChannelType() string

func (*ReportChannelsResponse_ChannelItem) GetYourOffset 

func (m *ReportChannelsResponse_ChannelItem) GetYourOffset() uint64

func (*ReportChannelsResponse_ChannelItem) ProtoMessage 

func (*ReportChannelsResponse_ChannelItem) ProtoMessage()

func (*ReportChannelsResponse_ChannelItem) Reset 

func (m *ReportChannelsResponse_ChannelItem) Reset()

func (*ReportChannelsResponse_ChannelItem) String 

func (m *ReportChannelsResponse_ChannelItem) String() string

func (*ReportChannelsResponse_ChannelItem) XXX_DiscardUnknown 

func (m *ReportChannelsResponse_ChannelItem) XXX_DiscardUnknown()

func (*ReportChannelsResponse_ChannelItem) XXX_Marshal 

func (m *ReportChannelsResponse_ChannelItem) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReportChannelsResponse_ChannelItem) XXX_Merge 

func (m *ReportChannelsResponse_ChannelItem) XXX_Merge(src proto.Message)

func (*ReportChannelsResponse_ChannelItem) XXX_Size 

func (m *ReportChannelsResponse_ChannelItem) XXX_Size() int

func (*ReportChannelsResponse_ChannelItem) XXX_Unmarshal 

func (m *ReportChannelsResponse_ChannelItem) XXX_Unmarshal(b []byte) error

type ReqMeta 

type ReqMeta struct {
	UTP                  string             `protobuf:"bytes,1,opt,name=UTP,proto3" json:"UTP"`
	UID                  string             `protobuf:"bytes,2,opt,name=UID,proto3" json:"UID"`
	FID                  string             `protobuf:"bytes,3,opt,name=FID,proto3" json:"FID"`
	Page                 uint32             `protobuf:"varint,4,opt,name=page,proto3" json:"page"`
	PerPage              uint32             `protobuf:"varint,5,opt,name=perPage,proto3" json:"perPage"`
	IpAddress            string             `protobuf:"bytes,6,opt,name=ipAddress,proto3" json:"ipAddress"`
	StartAt              string             `protobuf:"bytes,7,opt,name=startAt,proto3" json:"startAt"`
	EndAt                string             `protobuf:"bytes,8,opt,name=endAt,proto3" json:"endAt"`
	Sorts                *RequestMetaSorts  `protobuf:"bytes,9,opt,name=sorts,proto3" json:"sorts"`
	Filters              *RequestMetaFilter `protobuf:"bytes,10,opt,name=filters,proto3" json:"filters"`
	Action               *RequestMetaAction `protobuf:"bytes,11,opt,name=action,proto3" json:"action"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

==================== Meta

func (*ReqMeta) Descriptor 

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

func (*ReqMeta) GetAction 

func (m *ReqMeta) GetAction() *RequestMetaAction

func (*ReqMeta) GetEndAt 

func (m *ReqMeta) GetEndAt() string

func (*ReqMeta) GetFID 

func (m *ReqMeta) GetFID() string

func (*ReqMeta) GetFilters 

func (m *ReqMeta) GetFilters() *RequestMetaFilter

func (*ReqMeta) GetIpAddress 

func (m *ReqMeta) GetIpAddress() string

func (*ReqMeta) GetPage 

func (m *ReqMeta) GetPage() uint32

func (*ReqMeta) GetPerPage 

func (m *ReqMeta) GetPerPage() uint32

func (*ReqMeta) GetSorts 

func (m *ReqMeta) GetSorts() *RequestMetaSorts

func (*ReqMeta) GetStartAt 

func (m *ReqMeta) GetStartAt() string

func (*ReqMeta) GetUID 

func (m *ReqMeta) GetUID() string

func (*ReqMeta) GetUTP 

func (m *ReqMeta) GetUTP() string

func (*ReqMeta) ProtoMessage 

func (*ReqMeta) ProtoMessage()

func (*ReqMeta) Reset 

func (m *ReqMeta) Reset()

func (*ReqMeta) String 

func (m *ReqMeta) String() string

func (*ReqMeta) XXX_DiscardUnknown 

func (m *ReqMeta) XXX_DiscardUnknown()

func (*ReqMeta) XXX_Marshal 

func (m *ReqMeta) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ReqMeta) XXX_Merge 

func (m *ReqMeta) XXX_Merge(src proto.Message)

func (*ReqMeta) XXX_Size 

func (m *ReqMeta) XXX_Size() int

func (*ReqMeta) XXX_Unmarshal 

func (m *ReqMeta) XXX_Unmarshal(b []byte) error

type RequestMessage 

type RequestMessage struct {
	Name                 string   `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name"`
	Type                 string   `protobuf:"bytes,2,opt,name=Type,proto3" json:"Type"`
	Time                 string   `protobuf:"bytes,3,opt,name=time,proto3" json:"time"`
	Header               *ReqMeta `protobuf:"bytes,4,opt,name=Header,proto3" json:"Header"`
	Body                 *Any     `protobuf:"bytes,5,opt,name=Body,proto3" json:"Body"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

============ The request message

func (*RequestMessage) Descriptor 

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

func (*RequestMessage) GetBody 

func (m *RequestMessage) GetBody() *Any

func (*RequestMessage) GetHeader 

func (m *RequestMessage) GetHeader() *ReqMeta

func (*RequestMessage) GetName 

func (m *RequestMessage) GetName() string

func (*RequestMessage) GetTime 

func (m *RequestMessage) GetTime() string

func (*RequestMessage) GetType 

func (m *RequestMessage) GetType() string

func (*RequestMessage) ProtoMessage 

func (*RequestMessage) ProtoMessage()

func (*RequestMessage) Reset 

func (m *RequestMessage) Reset()

func (*RequestMessage) String 

func (m *RequestMessage) String() string

func (*RequestMessage) XXX_DiscardUnknown 

func (m *RequestMessage) XXX_DiscardUnknown()

func (*RequestMessage) XXX_Marshal 

func (m *RequestMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestMessage) XXX_Merge 

func (m *RequestMessage) XXX_Merge(src proto.Message)

func (*RequestMessage) XXX_Size 

func (m *RequestMessage) XXX_Size() int

func (*RequestMessage) XXX_Unmarshal 

func (m *RequestMessage) XXX_Unmarshal(b []byte) error

type RequestMetaAction 

type RequestMetaAction struct {
	ActionType           string   `protobuf:"bytes,1,opt,name=actionType,proto3" json:"actionType"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RequestMetaAction) Descriptor 

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

func (*RequestMetaAction) GetActionType 

func (m *RequestMetaAction) GetActionType() string

func (*RequestMetaAction) ProtoMessage 

func (*RequestMetaAction) ProtoMessage()

func (*RequestMetaAction) Reset 

func (m *RequestMetaAction) Reset()

func (*RequestMetaAction) String 

func (m *RequestMetaAction) String() string

func (*RequestMetaAction) XXX_DiscardUnknown 

func (m *RequestMetaAction) XXX_DiscardUnknown()

func (*RequestMetaAction) XXX_Marshal 

func (m *RequestMetaAction) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestMetaAction) XXX_Merge 

func (m *RequestMetaAction) XXX_Merge(src proto.Message)

func (*RequestMetaAction) XXX_Size 

func (m *RequestMetaAction) XXX_Size() int

func (*RequestMetaAction) XXX_Unmarshal 

func (m *RequestMetaAction) XXX_Unmarshal(b []byte) error

type RequestMetaFilter 

type RequestMetaFilter struct {
	Type                 string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type"`
	Opt                  string   `protobuf:"bytes,2,opt,name=opt,proto3" json:"opt"`
	Value                string   `protobuf:"bytes,3,opt,name=value,proto3" json:"value"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RequestMetaFilter) Descriptor 

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

func (*RequestMetaFilter) GetOpt 

func (m *RequestMetaFilter) GetOpt() string

func (*RequestMetaFilter) GetType 

func (m *RequestMetaFilter) GetType() string

func (*RequestMetaFilter) GetValue 

func (m *RequestMetaFilter) GetValue() string

func (*RequestMetaFilter) ProtoMessage 

func (*RequestMetaFilter) ProtoMessage()

func (*RequestMetaFilter) Reset 

func (m *RequestMetaFilter) Reset()

func (*RequestMetaFilter) String 

func (m *RequestMetaFilter) String() string

func (*RequestMetaFilter) XXX_DiscardUnknown 

func (m *RequestMetaFilter) XXX_DiscardUnknown()

func (*RequestMetaFilter) XXX_Marshal 

func (m *RequestMetaFilter) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestMetaFilter) XXX_Merge 

func (m *RequestMetaFilter) XXX_Merge(src proto.Message)

func (*RequestMetaFilter) XXX_Size 

func (m *RequestMetaFilter) XXX_Size() int

func (*RequestMetaFilter) XXX_Unmarshal 

func (m *RequestMetaFilter) XXX_Unmarshal(b []byte) error

type RequestMetaSorts 

type RequestMetaSorts struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name"`
	Dir                  uint32   `protobuf:"varint,2,opt,name=dir,proto3" json:"dir"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RequestMetaSorts) Descriptor 

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

func (*RequestMetaSorts) GetDir 

func (m *RequestMetaSorts) GetDir() uint32

func (*RequestMetaSorts) GetName 

func (m *RequestMetaSorts) GetName() string

func (*RequestMetaSorts) ProtoMessage 

func (*RequestMetaSorts) ProtoMessage()

func (*RequestMetaSorts) Reset 

func (m *RequestMetaSorts) Reset()

func (*RequestMetaSorts) String 

func (m *RequestMetaSorts) String() string

func (*RequestMetaSorts) XXX_DiscardUnknown 

func (m *RequestMetaSorts) XXX_DiscardUnknown()

func (*RequestMetaSorts) XXX_Marshal 

func (m *RequestMetaSorts) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RequestMetaSorts) XXX_Merge 

func (m *RequestMetaSorts) XXX_Merge(src proto.Message)

func (*RequestMetaSorts) XXX_Size 

func (m *RequestMetaSorts) XXX_Size() int

func (*RequestMetaSorts) XXX_Unmarshal 

func (m *RequestMetaSorts) XXX_Unmarshal(b []byte) error

type RequestMetaSortsDirection 

type RequestMetaSortsDirection int32
const (
	RequestMetaSorts_Descending RequestMetaSortsDirection = 0
	RequestMetaSorts_Ascending  RequestMetaSortsDirection = 1
)

func (RequestMetaSortsDirection) EnumDescriptor 

func (RequestMetaSortsDirection) EnumDescriptor() ([]byte, []int)

func (RequestMetaSortsDirection) String 

func (x RequestMetaSortsDirection) String() string

type ResponseMessage 

type ResponseMessage struct {
	Entity               string            `protobuf:"bytes,1,opt,name=entity,proto3" json:"entity"`
	Meta                 *ResponseMetadata `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta"`
	Data                 *Any              `protobuf:"bytes,3,opt,name=Data,proto3" json:"Data"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

============ The response message

func (*ResponseMessage) Descriptor 

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

func (*ResponseMessage) GetData 

func (m *ResponseMessage) GetData() *Any

func (*ResponseMessage) GetEntity 

func (m *ResponseMessage) GetEntity() string

func (*ResponseMessage) GetMeta 

func (m *ResponseMessage) GetMeta() *ResponseMetadata

func (*ResponseMessage) ProtoMessage 

func (*ResponseMessage) ProtoMessage()

func (*ResponseMessage) Reset 

func (m *ResponseMessage) Reset()

func (*ResponseMessage) String 

func (m *ResponseMessage) String() string

func (*ResponseMessage) XXX_DiscardUnknown 

func (m *ResponseMessage) XXX_DiscardUnknown()

func (*ResponseMessage) XXX_Marshal 

func (m *ResponseMessage) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResponseMessage) XXX_Merge 

func (m *ResponseMessage) XXX_Merge(src proto.Message)

func (*ResponseMessage) XXX_Size 

func (m *ResponseMessage) XXX_Size() int

func (*ResponseMessage) XXX_Unmarshal 

func (m *ResponseMessage) XXX_Unmarshal(b []byte) error

type ResponseMetadata 

type ResponseMetadata struct {
	Total                uint32   `protobuf:"varint,1,opt,name=total,proto3" json:"total"`
	Page                 uint32   `protobuf:"varint,2,opt,name=page,proto3" json:"page"`
	PerPage              uint32   `protobuf:"varint,3,opt,name=perPage,proto3" json:"perPage"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResponseMetadata) Descriptor 

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

func (*ResponseMetadata) GetPage 

func (m *ResponseMetadata) GetPage() uint32

func (*ResponseMetadata) GetPerPage 

func (m *ResponseMetadata) GetPerPage() uint32

func (*ResponseMetadata) GetTotal 

func (m *ResponseMetadata) GetTotal() uint32

func (*ResponseMetadata) ProtoMessage 

func (*ResponseMetadata) ProtoMessage()

func (*ResponseMetadata) Reset 

func (m *ResponseMetadata) Reset()

func (*ResponseMetadata) String 

func (m *ResponseMetadata) String() string

func (*ResponseMetadata) XXX_DiscardUnknown 

func (m *ResponseMetadata) XXX_DiscardUnknown()

func (*ResponseMetadata) XXX_Marshal 

func (m *ResponseMetadata) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResponseMetadata) XXX_Merge 

func (m *ResponseMetadata) XXX_Merge(src proto.Message)

func (*ResponseMetadata) XXX_Size 

func (m *ResponseMetadata) XXX_Size() int

func (*ResponseMetadata) XXX_Unmarshal 

func (m *ResponseMetadata) XXX_Unmarshal(b []byte) error

type SendMessageRequest 

type SendMessageRequest struct {
	ChannelId            string   `protobuf:"bytes,1,opt,name=ChannelId,proto3" json:"ChannelId"`
	CreatedAt            string   `protobuf:"bytes,2,opt,name=CreatedAt,proto3" json:"CreatedAt"`
	MessageReference     string   `protobuf:"bytes,3,opt,name=MessageReference,proto3" json:"MessageReference"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

send message request and response

func (*SendMessageRequest) Descriptor 

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

func (*SendMessageRequest) GetChannelId 

func (m *SendMessageRequest) GetChannelId() string

func (*SendMessageRequest) GetCreatedAt 

func (m *SendMessageRequest) GetCreatedAt() string

func (*SendMessageRequest) GetMessageReference 

func (m *SendMessageRequest) GetMessageReference() string

func (*SendMessageRequest) ProtoMessage 

func (*SendMessageRequest) ProtoMessage()

func (*SendMessageRequest) Reset 

func (m *SendMessageRequest) Reset()

func (*SendMessageRequest) String 

func (m *SendMessageRequest) String() string

func (*SendMessageRequest) XXX_DiscardUnknown 

func (m *SendMessageRequest) XXX_DiscardUnknown()

func (*SendMessageRequest) XXX_Marshal 

func (m *SendMessageRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SendMessageRequest) XXX_Merge 

func (m *SendMessageRequest) XXX_Merge(src proto.Message)

func (*SendMessageRequest) XXX_Size 

func (m *SendMessageRequest) XXX_Size() int

func (*SendMessageRequest) XXX_Unmarshal 

func (m *SendMessageRequest) XXX_Unmarshal(b []byte) error

type UnimplementedUserServiceServer 

type UnimplementedUserServiceServer struct {
}

UnimplementedUserServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedUserServiceServer) AddMemberToConversation 

func (*UnimplementedUserServiceServer) AddMemberToConversation(ctx context.Context, req *RequestMessage) (*ResponseMessage, error)

func (*UnimplementedUserServiceServer) CreateConnection 

func (*UnimplementedUserServiceServer) CreateConnection(ctx context.Context, req *RequestMessage) (*ResponseMessage, error)

func (*UnimplementedUserServiceServer) FetchMessages 

func (*UnimplementedUserServiceServer) FetchMessages(ctx context.Context, req *RequestMessage) (*ResponseMessage, error)

func (*UnimplementedUserServiceServer) JoinConversation 

func (*UnimplementedUserServiceServer) JoinConversation(ctx context.Context, req *RequestMessage) (*ResponseMessage, error)

func (*UnimplementedUserServiceServer) ReportChannelsMessages 

func (*UnimplementedUserServiceServer) ReportChannelsMessages(ctx context.Context, req *RequestMessage) (*ResponseMessage, error)

func (*UnimplementedUserServiceServer) SendMessage 

func (*UnimplementedUserServiceServer) SendMessage(ctx context.Context, req *RequestMessage) (*ResponseMessage, error)

type UserServiceClient 

type UserServiceClient interface {
	CreateConnection(ctx context.Context, in *RequestMessage, opts ...grpc.CallOption) (*ResponseMessage, error)
	SendMessage(ctx context.Context, in *RequestMessage, opts ...grpc.CallOption) (*ResponseMessage, error)
	ReportChannelsMessages(ctx context.Context, in *RequestMessage, opts ...grpc.CallOption) (*ResponseMessage, error)
	FetchMessages(ctx context.Context, in *RequestMessage, opts ...grpc.CallOption) (*ResponseMessage, error)
	JoinConversation(ctx context.Context, in *RequestMessage, opts ...grpc.CallOption) (*ResponseMessage, error)
	AddMemberToConversation(ctx context.Context, in *RequestMessage, opts ...grpc.CallOption) (*ResponseMessage, error)
}

UserServiceClient is the client API for UserService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewUserServiceClient 

func NewUserServiceClient(cc grpc.ClientConnInterface) UserServiceClient

type UserServiceServer 

type UserServiceServer interface {
	CreateConnection(context.Context, *RequestMessage) (*ResponseMessage, error)
	SendMessage(context.Context, *RequestMessage) (*ResponseMessage, error)
	ReportChannelsMessages(context.Context, *RequestMessage) (*ResponseMessage, error)
	FetchMessages(context.Context, *RequestMessage) (*ResponseMessage, error)
	JoinConversation(context.Context, *RequestMessage) (*ResponseMessage, error)
	AddMemberToConversation(context.Context, *RequestMessage) (*ResponseMessage, error)
}

UserServiceServer is the server API for UserService service.

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.