message

package
v0.0.0-...-49c8f32 Latest Latest
Warning

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

 Go to latest Published: Dec 4, 2021 License: MIT Imports: 33 Imported by: 0

Documentation

Overview

Code generated by protoc-gen-auth. DO NOT EDIT! source: chat.proto

Package message is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Code generated by protoc-gen-auth. DO NOT EDIT! source: include.proto

Code generated by protoc-gen-auth. DO NOT EDIT! source: inner_chat.proto

Package message is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Code generated by protoc-gen-auth. DO NOT EDIT! source: inner_router.proto

Code generated by protoc-gen-auth. DO NOT EDIT! source: inner_session.proto

Package message is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Code generated by protoc-gen-auth. DO NOT EDIT! source: room.proto

Package message is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const Default_RoomServerOption_Port uint32 = 443
View Source 
const Default_RoomServerOption_Secure bool = true

Variables

View Source 
var Category_name = map[int32]string{
	0: "CATEGORY_UNSPECIFIED",
	1: "CATEGORY_PRIVATE",
	2: "CATEGORY_GROUP",
	3: "CATEGORY_CHANNEL",
	4: "CATEGORY_ROOM",
}
View Source 
var Category_value = map[string]int32{
	"CATEGORY_UNSPECIFIED": 0,
	"CATEGORY_PRIVATE":     1,
	"CATEGORY_GROUP":       2,
	"CATEGORY_CHANNEL":     3,
	"CATEGORY_ROOM":        4,
}
View Source 
var PayloadType_name = map[int32]string{
	0: "PAYLOAD_TYPE_UNSPECIFIED",
	1: "PAYLOAD_TYPE_SYNC",
	2: "PAYLOAD_TYPE_MESSAGES",
	3: "PAYLOAD_TYPE_RECEIPTS",
}
View Source 
var PayloadType_value = map[string]int32{
	"PAYLOAD_TYPE_UNSPECIFIED": 0,
	"PAYLOAD_TYPE_SYNC":        1,
	"PAYLOAD_TYPE_MESSAGES":    2,
	"PAYLOAD_TYPE_RECEIPTS":    3,
}
View Source 
var SessionType_name = map[int32]string{
	0: "SESSION_TYPE_UNSPECIFIED",
	1: "SESSION_TYPE_CHAT",
	2: "SESSION_TYPE_ROOM",
}
View Source 
var SessionType_value = map[string]int32{
	"SESSION_TYPE_UNSPECIFIED": 0,
	"SESSION_TYPE_CHAT":        1,
	"SESSION_TYPE_ROOM":        2,
}
View Source 
var Type_name = map[int32]string{
	0:  "TYPE_UNSPECIFIED",
	1:  "TYPE_TEXT",
	2:  "TYPE_AUDIO",
	3:  "TYPE_STICKER",
	4:  "TYPE_PHOTO",
	5:  "TYPE_VIDEO",
	6:  "TYPE_GIF",
	7:  "TYPE_FILE",
	8:  "TYPE_LOCATION",
	9:  "TYPE_CONTACT",
	10: "TYPE_RECALL",
	11: "TYPE_READ",
}
View Source 
var Type_value = map[string]int32{
	"TYPE_UNSPECIFIED": 0,
	"TYPE_TEXT":        1,
	"TYPE_AUDIO":       2,
	"TYPE_STICKER":     3,
	"TYPE_PHOTO":       4,
	"TYPE_VIDEO":       5,
	"TYPE_GIF":         6,
	"TYPE_FILE":        7,
	"TYPE_LOCATION":    8,
	"TYPE_CONTACT":     9,
	"TYPE_RECALL":      10,
	"TYPE_READ":        11,
}

Functions

func RegisterChatHandler 

func RegisterChatHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterChatHandler registers the http handlers for service Chat to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterChatHandlerClient 

func RegisterChatHandlerClient(ctx context.Context, mux *runtime.ServeMux, client ChatClient) error

RegisterChatHandlerClient registers the http handlers for service Chat to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "ChatClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "ChatClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "ChatClient" to call the correct interceptors.

func RegisterChatHandlerFromEndpoint 

func RegisterChatHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterChatHandlerFromEndpoint is same as RegisterChatHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterChatHandlerServer 

func RegisterChatHandlerServer(ctx context.Context, mux *runtime.ServeMux, server ChatServer) error

RegisterChatHandlerServer registers the http handlers for service Chat to "mux". UnaryRPC :call ChatServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterChatScopeServer 

func RegisterChatScopeServer(component string, auth service.Authenticator, impl service.Implementor, srv ChatServer) error

Register scoped server.

func RegisterChatServer 

func RegisterChatServer(s *grpc.Server, srv ChatServer)

func RegisterChatWsHandlerServer 

func RegisterChatWsHandlerServer(mux *runtime.ServeMux, srv ChatServer, streamInterceptor grpc.StreamServerInterceptor) error

func RegisterInnerChatHandler 

func RegisterInnerChatHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterInnerChatHandler registers the http handlers for service InnerChat to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterInnerChatHandlerClient 

func RegisterInnerChatHandlerClient(ctx context.Context, mux *runtime.ServeMux, client InnerChatClient) error

RegisterInnerChatHandlerClient registers the http handlers for service InnerChat to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "InnerChatClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "InnerChatClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "InnerChatClient" to call the correct interceptors.

func RegisterInnerChatHandlerFromEndpoint 

func RegisterInnerChatHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterInnerChatHandlerFromEndpoint is same as RegisterInnerChatHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterInnerChatHandlerServer 

func RegisterInnerChatHandlerServer(ctx context.Context, mux *runtime.ServeMux, server InnerChatServer) error

RegisterInnerChatHandlerServer registers the http handlers for service InnerChat to "mux". UnaryRPC :call InnerChatServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterInnerChatScopeServer 

func RegisterInnerChatScopeServer(component string, auth service.Authenticator, impl service.Implementor, srv InnerChatServer) error

Register scoped server.

func RegisterInnerChatServer 

func RegisterInnerChatServer(s *grpc.Server, srv InnerChatServer)

func RegisterInnerRouterScopeServer 

func RegisterInnerRouterScopeServer(component string, auth service.Authenticator, impl service.Implementor, srv InnerRouterServer) error

Register scoped server.

func RegisterInnerRouterServer 

func RegisterInnerRouterServer(s *grpc.Server, srv InnerRouterServer)

func RegisterInnerSessionHandler 

func RegisterInnerSessionHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterInnerSessionHandler registers the http handlers for service InnerSession to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterInnerSessionHandlerClient 

func RegisterInnerSessionHandlerClient(ctx context.Context, mux *runtime.ServeMux, client InnerSessionClient) error

RegisterInnerSessionHandlerClient registers the http handlers for service InnerSession to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "InnerSessionClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "InnerSessionClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "InnerSessionClient" to call the correct interceptors.

func RegisterInnerSessionHandlerFromEndpoint 

func RegisterInnerSessionHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterInnerSessionHandlerFromEndpoint is same as RegisterInnerSessionHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterInnerSessionHandlerServer 

func RegisterInnerSessionHandlerServer(ctx context.Context, mux *runtime.ServeMux, server InnerSessionServer) error

RegisterInnerSessionHandlerServer registers the http handlers for service InnerSession to "mux". UnaryRPC :call InnerSessionServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterInnerSessionScopeServer 

func RegisterInnerSessionScopeServer(component string, auth service.Authenticator, impl service.Implementor, srv InnerSessionServer) error

Register scoped server.

func RegisterInnerSessionServer 

func RegisterInnerSessionServer(s *grpc.Server, srv InnerSessionServer)

func RegisterRoomHandler 

func RegisterRoomHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterRoomHandler registers the http handlers for service Room to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterRoomHandlerClient 

func RegisterRoomHandlerClient(ctx context.Context, mux *runtime.ServeMux, client RoomClient) error

RegisterRoomHandlerClient registers the http handlers for service Room to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "RoomClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "RoomClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "RoomClient" to call the correct interceptors.

func RegisterRoomHandlerFromEndpoint 

func RegisterRoomHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterRoomHandlerFromEndpoint is same as RegisterRoomHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterRoomHandlerServer 

func RegisterRoomHandlerServer(ctx context.Context, mux *runtime.ServeMux, server RoomServer) error

RegisterRoomHandlerServer registers the http handlers for service Room to "mux". UnaryRPC :call RoomServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterRoomScopeServer 

func RegisterRoomScopeServer(component string, auth service.Authenticator, impl service.Implementor, srv RoomServer) error

Register scoped server.

func RegisterRoomServer 

func RegisterRoomServer(s *grpc.Server, srv RoomServer)

func RegisterRoomWsHandlerServer 

func RegisterRoomWsHandlerServer(mux *runtime.ServeMux, srv RoomServer, streamInterceptor grpc.StreamServerInterceptor) error

Types

type Category 

type Category int32

Message category enums. 

const (
	Category_CATEGORY_UNSPECIFIED Category = 0
	Category_CATEGORY_PRIVATE     Category = 1
	Category_CATEGORY_GROUP       Category = 2
	Category_CATEGORY_CHANNEL     Category = 3
	Category_CATEGORY_ROOM        Category = 4
)

func (Category) Enum 

func (x Category) Enum() *Category

func (Category) EnumDescriptor 

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

func (Category) String 

func (x Category) String() string

func (*Category) UnmarshalJSON 

func (x *Category) UnmarshalJSON(data []byte) error

type ChatClient 

type ChatClient interface {
	// Chat streaming interaction.
	Interact(ctx context.Context, opts ...grpc.CallOption) (Chat_InteractClient, error)
	// Send chat message.
	Send(ctx context.Context, in *Post, opts ...grpc.CallOption) (*Postmark, error)
}

ChatClient is the client API for Chat service.

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

func NewChatClient 

func NewChatClient(cc *grpc.ClientConn) ChatClient

type ChatServer 

type ChatServer interface {
	// Chat streaming interaction.
	Interact(Chat_InteractServer) error
	// Send chat message.
	Send(context.Context, *Post) (*Postmark, error)
}

ChatServer is the server API for Chat service.

type Chat_InteractClient 

type Chat_InteractClient interface {
	Send(*Stream) error
	Recv() (*Stream, error)
	grpc.ClientStream
}

type Chat_InteractServer 

type Chat_InteractServer interface {
	Send(*Stream) error
	Recv() (*Stream, error)
	grpc.ServerStream
}

type ClientId 

type ClientId struct {
	Category             *Category `protobuf:"varint,1,req,name=category,enum=appootb.message.Category" json:"category,omitempty"`
	LastId               *uint64   `protobuf:"varint,2,opt,name=last_id,json=lastId" json:"last_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

Client local ID.

func (*ClientId) Descriptor 

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

func (*ClientId) GetCategory 

func (m *ClientId) GetCategory() Category

func (*ClientId) GetLastId 

func (m *ClientId) GetLastId() uint64

func (*ClientId) ProtoMessage 

func (*ClientId) ProtoMessage()

func (*ClientId) Reset 

func (m *ClientId) Reset()

func (*ClientId) String 

func (m *ClientId) String() string

func (*ClientId) Validate 

func (m *ClientId) Validate() error

Validate checks the field values on ClientId with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ClientId) XXX_DiscardUnknown 

func (m *ClientId) XXX_DiscardUnknown()

func (*ClientId) XXX_Marshal 

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

func (*ClientId) XXX_Merge 

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

func (*ClientId) XXX_Size 

func (m *ClientId) XXX_Size() int

func (*ClientId) XXX_Unmarshal 

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

type ClientIdValidationError 

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

ClientIdValidationError is the validation error returned by ClientId.Validate if the designated constraints aren't met.

func (ClientIdValidationError) Cause 

func (e ClientIdValidationError) Cause() error

Cause function returns cause value.

func (ClientIdValidationError) Error 

func (e ClientIdValidationError) Error() string

Error satisfies the builtin error interface

func (ClientIdValidationError) ErrorName 

func (e ClientIdValidationError) ErrorName() string

ErrorName returns error name.

func (ClientIdValidationError) Field 

func (e ClientIdValidationError) Field() string

Field function returns field value.

func (ClientIdValidationError) Key 

func (e ClientIdValidationError) Key() bool

Key function returns key value.

func (ClientIdValidationError) Reason 

func (e ClientIdValidationError) Reason() string

Reason function returns reason value.

type ClientIds 

type ClientIds struct {
	Ids                  []*ClientId `protobuf:"bytes,1,rep,name=ids" json:"ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

Client local IDs.

func (*ClientIds) Descriptor 

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

func (*ClientIds) GetIds 

func (m *ClientIds) GetIds() []*ClientId

func (*ClientIds) ProtoMessage 

func (*ClientIds) ProtoMessage()

func (*ClientIds) Reset 

func (m *ClientIds) Reset()

func (*ClientIds) String 

func (m *ClientIds) String() string

func (*ClientIds) Validate 

func (m *ClientIds) Validate() error

Validate checks the field values on ClientIds with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*ClientIds) XXX_DiscardUnknown 

func (m *ClientIds) XXX_DiscardUnknown()

func (*ClientIds) XXX_Marshal 

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

func (*ClientIds) XXX_Merge 

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

func (*ClientIds) XXX_Size 

func (m *ClientIds) XXX_Size() int

func (*ClientIds) XXX_Unmarshal 

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

type ClientIdsValidationError 

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

ClientIdsValidationError is the validation error returned by ClientIds.Validate if the designated constraints aren't met.

func (ClientIdsValidationError) Cause 

func (e ClientIdsValidationError) Cause() error

Cause function returns cause value.

func (ClientIdsValidationError) Error 

func (e ClientIdsValidationError) Error() string

Error satisfies the builtin error interface

func (ClientIdsValidationError) ErrorName 

func (e ClientIdsValidationError) ErrorName() string

ErrorName returns error name.

func (ClientIdsValidationError) Field 

func (e ClientIdsValidationError) Field() string

Field function returns field value.

func (ClientIdsValidationError) Key 

func (e ClientIdsValidationError) Key() bool

Key function returns key value.

func (ClientIdsValidationError) Reason 

func (e ClientIdsValidationError) Reason() string

Reason function returns reason value.

type Connections 

type Connections struct {
	Product              *string  `protobuf:"bytes,1,req,name=product" json:"product,omitempty"`
	UniqueIds            []string `protobuf:"bytes,2,rep,name=unique_ids,json=uniqueIds" json:"unique_ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Connections.

func (*Connections) Descriptor 

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

func (*Connections) GetProduct 

func (m *Connections) GetProduct() string

func (*Connections) GetUniqueIds 

func (m *Connections) GetUniqueIds() []string

func (*Connections) ProtoMessage 

func (*Connections) ProtoMessage()

func (*Connections) Reset 

func (m *Connections) Reset()

func (*Connections) String 

func (m *Connections) String() string

func (*Connections) Validate 

func (m *Connections) Validate() error

Validate checks the field values on Connections with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Connections) XXX_DiscardUnknown 

func (m *Connections) XXX_DiscardUnknown()

func (*Connections) XXX_Marshal 

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

func (*Connections) XXX_Merge 

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

func (*Connections) XXX_Size 

func (m *Connections) XXX_Size() int

func (*Connections) XXX_Unmarshal 

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

type ConnectionsValidationError 

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

ConnectionsValidationError is the validation error returned by Connections.Validate if the designated constraints aren't met.

func (ConnectionsValidationError) Cause 

func (e ConnectionsValidationError) Cause() error

Cause function returns cause value.

func (ConnectionsValidationError) Error 

func (e ConnectionsValidationError) Error() string

Error satisfies the builtin error interface

func (ConnectionsValidationError) ErrorName 

func (e ConnectionsValidationError) ErrorName() string

ErrorName returns error name.

func (ConnectionsValidationError) Field 

func (e ConnectionsValidationError) Field() string

Field function returns field value.

func (ConnectionsValidationError) Key 

func (e ConnectionsValidationError) Key() bool

Key function returns key value.

func (ConnectionsValidationError) Reason 

func (e ConnectionsValidationError) Reason() string

Reason function returns reason value.

type InnerChatClient 

type InnerChatClient interface {
	// Deliver message.
	Deliver(ctx context.Context, in *Package, opts ...grpc.CallOption) (*empty.Empty, error)
	// Kick the connection.
	Kick(ctx context.Context, in *Connections, opts ...grpc.CallOption) (*empty.Empty, error)
}

InnerChatClient is the client API for InnerChat service.

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

func NewInnerChatClient 

func NewInnerChatClient(cc *grpc.ClientConn) InnerChatClient

type InnerChatServer 

type InnerChatServer interface {
	// Deliver message.
	Deliver(context.Context, *Package) (*empty.Empty, error)
	// Kick the connection.
	Kick(context.Context, *Connections) (*empty.Empty, error)
}

InnerChatServer is the server API for InnerChat service.

type InnerRouterClient 

type InnerRouterClient interface {
}

InnerRouterClient is the client API for InnerRouter service.

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

func NewInnerRouterClient 

func NewInnerRouterClient(cc *grpc.ClientConn) InnerRouterClient

type InnerRouterServer 

type InnerRouterServer interface {
}

InnerRouterServer is the server API for InnerRouter service.

type InnerSessionClient 

type InnerSessionClient interface {
	// Add user session.
	Open(ctx context.Context, in *Session, opts ...grpc.CallOption) (*Sessions, error)
	// Close user session.
	Close(ctx context.Context, in *SessionId, opts ...grpc.CallOption) (*empty.Empty, error)
	// Get user sessions.
	Gets(ctx context.Context, in *SessionIds, opts ...grpc.CallOption) (*Sessions, error)
}

InnerSessionClient is the client API for InnerSession service.

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

func NewInnerSessionClient 

func NewInnerSessionClient(cc *grpc.ClientConn) InnerSessionClient

type InnerSessionServer 

type InnerSessionServer interface {
	// Add user session.
	Open(context.Context, *Session) (*Sessions, error)
	// Close user session.
	Close(context.Context, *SessionId) (*empty.Empty, error)
	// Get user sessions.
	Gets(context.Context, *SessionIds) (*Sessions, error)
}

InnerSessionServer is the server API for InnerSession service.

type Location 

type Location struct {
	Latitude             *float32 `protobuf:"fixed32,1,req,name=latitude" json:"latitude,omitempty"`
	Longitude            *float32 `protobuf:"fixed32,2,req,name=longitude" json:"longitude,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Location coordinate.

func (*Location) Descriptor 

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

func (*Location) GetLatitude 

func (m *Location) GetLatitude() float32

func (*Location) GetLongitude 

func (m *Location) GetLongitude() float32

func (*Location) ProtoMessage 

func (*Location) ProtoMessage()

func (*Location) Reset 

func (m *Location) Reset()

func (*Location) String 

func (m *Location) String() string

func (*Location) Validate 

func (m *Location) Validate() error

Validate checks the field values on Location with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Location) XXX_DiscardUnknown 

func (m *Location) XXX_DiscardUnknown()

func (*Location) XXX_Marshal 

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

func (*Location) XXX_Merge 

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

func (*Location) XXX_Size 

func (m *Location) XXX_Size() int

func (*Location) XXX_Unmarshal 

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

type LocationValidationError 

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

LocationValidationError is the validation error returned by Location.Validate if the designated constraints aren't met.

func (LocationValidationError) Cause 

func (e LocationValidationError) Cause() error

Cause function returns cause value.

func (LocationValidationError) Error 

func (e LocationValidationError) Error() string

Error satisfies the builtin error interface

func (LocationValidationError) ErrorName 

func (e LocationValidationError) ErrorName() string

ErrorName returns error name.

func (LocationValidationError) Field 

func (e LocationValidationError) Field() string

Field function returns field value.

func (LocationValidationError) Key 

func (e LocationValidationError) Key() bool

Key function returns key value.

func (LocationValidationError) Reason 

func (e LocationValidationError) Reason() string

Reason function returns reason value.

type Media 

type Media struct {
	Url                  *string  `protobuf:"bytes,1,req,name=url" json:"url,omitempty"`
	Thumbnail            *string  `protobuf:"bytes,2,opt,name=thumbnail" json:"thumbnail,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Media message.

func (*Media) Descriptor 

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

func (*Media) GetThumbnail 

func (m *Media) GetThumbnail() string

func (*Media) GetUrl 

func (m *Media) GetUrl() string

func (*Media) ProtoMessage 

func (*Media) ProtoMessage()

func (*Media) Reset 

func (m *Media) Reset()

func (*Media) String 

func (m *Media) String() string

func (*Media) Validate 

func (m *Media) Validate() error

Validate checks the field values on Media with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Media) XXX_DiscardUnknown 

func (m *Media) XXX_DiscardUnknown()

func (*Media) XXX_Marshal 

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

func (*Media) XXX_Merge 

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

func (*Media) XXX_Size 

func (m *Media) XXX_Size() int

func (*Media) XXX_Unmarshal 

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

type MediaValidationError 

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

MediaValidationError is the validation error returned by Media.Validate if the designated constraints aren't met.

func (MediaValidationError) Cause 

func (e MediaValidationError) Cause() error

Cause function returns cause value.

func (MediaValidationError) Error 

func (e MediaValidationError) Error() string

Error satisfies the builtin error interface

func (MediaValidationError) ErrorName 

func (e MediaValidationError) ErrorName() string

ErrorName returns error name.

func (MediaValidationError) Field 

func (e MediaValidationError) Field() string

Field function returns field value.

func (MediaValidationError) Key 

func (e MediaValidationError) Key() bool

Key function returns key value.

func (MediaValidationError) Reason 

func (e MediaValidationError) Reason() string

Reason function returns reason value.

type Package 

type Package struct {
	// Target
	//
	// Types that are valid to be assigned to Target:
	//	*Package_Tag
	//	*Package_Conn
	Target               isPackage_Target `protobuf_oneof:"target"`
	Sn                   *string          `protobuf:"bytes,8,req,name=sn" json:"sn,omitempty"`
	Posts                []*Post          `protobuf:"bytes,9,rep,name=posts" json:"posts,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Router package.

func (*Package) Descriptor 

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

func (*Package) GetConn 

func (m *Package) GetConn() *Connections

func (*Package) GetPosts 

func (m *Package) GetPosts() []*Post

func (*Package) GetSn 

func (m *Package) GetSn() string

func (*Package) GetTag 

func (m *Package) GetTag() *Tag

func (*Package) GetTarget 

func (m *Package) GetTarget() isPackage_Target

func (*Package) ProtoMessage 

func (*Package) ProtoMessage()

func (*Package) Reset 

func (m *Package) Reset()

func (*Package) String 

func (m *Package) String() string

func (*Package) Validate 

func (m *Package) Validate() error

Validate checks the field values on Package with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Package) XXX_DiscardUnknown 

func (m *Package) XXX_DiscardUnknown()

func (*Package) XXX_Marshal 

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

func (*Package) XXX_Merge 

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

func (*Package) XXX_OneofWrappers 

func (*Package) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Package) XXX_Size 

func (m *Package) XXX_Size() int

func (*Package) XXX_Unmarshal 

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

type PackageValidationError 

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

PackageValidationError is the validation error returned by Package.Validate if the designated constraints aren't met.

func (PackageValidationError) Cause 

func (e PackageValidationError) Cause() error

Cause function returns cause value.

func (PackageValidationError) Error 

func (e PackageValidationError) Error() string

Error satisfies the builtin error interface

func (PackageValidationError) ErrorName 

func (e PackageValidationError) ErrorName() string

ErrorName returns error name.

func (PackageValidationError) Field 

func (e PackageValidationError) Field() string

Field function returns field value.

func (PackageValidationError) Key 

func (e PackageValidationError) Key() bool

Key function returns key value.

func (PackageValidationError) Reason 

func (e PackageValidationError) Reason() string

Reason function returns reason value.

type Package_Conn 

type Package_Conn struct {
	Conn *Connections `protobuf:"bytes,2,opt,name=conn,oneof"`
}

type Package_Tag 

type Package_Tag struct {
	Tag *Tag `protobuf:"bytes,1,opt,name=tag,oneof"`
}

type PayloadType 

type PayloadType int32

Message stream payload type. 

const (
	PayloadType_PAYLOAD_TYPE_UNSPECIFIED PayloadType = 0
	PayloadType_PAYLOAD_TYPE_SYNC        PayloadType = 1
	PayloadType_PAYLOAD_TYPE_MESSAGES    PayloadType = 2
	PayloadType_PAYLOAD_TYPE_RECEIPTS    PayloadType = 3
)

func (PayloadType) Enum 

func (x PayloadType) Enum() *PayloadType

func (PayloadType) EnumDescriptor 

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

func (PayloadType) String 

func (x PayloadType) String() string

func (*PayloadType) UnmarshalJSON 

func (x *PayloadType) UnmarshalJSON(data []byte) error

type Post 

type Post struct {
	Postmark *Postmark `protobuf:"bytes,1,req,name=postmark" json:"postmark,omitempty"`
	Type     *Type     `protobuf:"varint,2,req,name=type,enum=appootb.message.Type" json:"type,omitempty"`
	// Message content
	//
	// Types that are valid to be assigned to Envelope:
	//	*Post_Text
	//	*Post_Resource
	//	*Post_Coordinate
	Envelope             isPost_Envelope `protobuf_oneof:"envelope"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

Message post.

func (*Post) Descriptor 

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

func (*Post) GetCoordinate 

func (m *Post) GetCoordinate() *Location

func (*Post) GetEnvelope 

func (m *Post) GetEnvelope() isPost_Envelope

func (*Post) GetPostmark 

func (m *Post) GetPostmark() *Postmark

func (*Post) GetResource 

func (m *Post) GetResource() *Media

func (*Post) GetText 

func (m *Post) GetText() *Text

func (*Post) GetType 

func (m *Post) GetType() Type

func (*Post) ProtoMessage 

func (*Post) ProtoMessage()

func (*Post) Reset 

func (m *Post) Reset()

func (*Post) String 

func (m *Post) String() string

func (*Post) Validate 

func (m *Post) Validate() error

Validate checks the field values on Post with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Post) XXX_DiscardUnknown 

func (m *Post) XXX_DiscardUnknown()

func (*Post) XXX_Marshal 

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

func (*Post) XXX_Merge 

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

func (*Post) XXX_OneofWrappers 

func (*Post) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Post) XXX_Size 

func (m *Post) XXX_Size() int

func (*Post) XXX_Unmarshal 

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

type PostValidationError 

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

PostValidationError is the validation error returned by Post.Validate if the designated constraints aren't met.

func (PostValidationError) Cause 

func (e PostValidationError) Cause() error

Cause function returns cause value.

func (PostValidationError) Error 

func (e PostValidationError) Error() string

Error satisfies the builtin error interface

func (PostValidationError) ErrorName 

func (e PostValidationError) ErrorName() string

ErrorName returns error name.

func (PostValidationError) Field 

func (e PostValidationError) Field() string

Field function returns field value.

func (PostValidationError) Key 

func (e PostValidationError) Key() bool

Key function returns key value.

func (PostValidationError) Reason 

func (e PostValidationError) Reason() string

Reason function returns reason value.

type Post_Coordinate 

type Post_Coordinate struct {
	Coordinate *Location `protobuf:"bytes,12,opt,name=coordinate,oneof"`
}

type Post_Resource 

type Post_Resource struct {
	Resource *Media `protobuf:"bytes,11,opt,name=resource,oneof"`
}

type Post_Text 

type Post_Text struct {
	Text *Text `protobuf:"bytes,10,opt,name=text,oneof"`
}

type Postbox 

type Postbox struct {
	Posts                []*Post  `protobuf:"bytes,1,rep,name=posts" json:"posts,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Message postbox.

func (*Postbox) Descriptor 

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

func (*Postbox) GetPosts 

func (m *Postbox) GetPosts() []*Post

func (*Postbox) ProtoMessage 

func (*Postbox) ProtoMessage()

func (*Postbox) Reset 

func (m *Postbox) Reset()

func (*Postbox) String 

func (m *Postbox) String() string

func (*Postbox) Validate 

func (m *Postbox) Validate() error

Validate checks the field values on Postbox with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Postbox) XXX_DiscardUnknown 

func (m *Postbox) XXX_DiscardUnknown()

func (*Postbox) XXX_Marshal 

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

func (*Postbox) XXX_Merge 

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

func (*Postbox) XXX_Size 

func (m *Postbox) XXX_Size() int

func (*Postbox) XXX_Unmarshal 

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

type PostboxValidationError 

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

PostboxValidationError is the validation error returned by Postbox.Validate if the designated constraints aren't met.

func (PostboxValidationError) Cause 

func (e PostboxValidationError) Cause() error

Cause function returns cause value.

func (PostboxValidationError) Error 

func (e PostboxValidationError) Error() string

Error satisfies the builtin error interface

func (PostboxValidationError) ErrorName 

func (e PostboxValidationError) ErrorName() string

ErrorName returns error name.

func (PostboxValidationError) Field 

func (e PostboxValidationError) Field() string

Field function returns field value.

func (PostboxValidationError) Key 

func (e PostboxValidationError) Key() bool

Key function returns key value.

func (PostboxValidationError) Reason 

func (e PostboxValidationError) Reason() string

Reason function returns reason value.

type Postmark 

type Postmark struct {
	Category             *Category            `protobuf:"varint,1,req,name=category,enum=appootb.message.Category" json:"category,omitempty"`
	Sender               *uint64              `protobuf:"varint,2,req,name=sender" json:"sender,omitempty"`
	Receiver             *uint64              `protobuf:"varint,3,req,name=receiver" json:"receiver,omitempty"`
	UniqueId             *uint64              `protobuf:"varint,4,opt,name=unique_id,json=uniqueId" json:"unique_id,omitempty"`
	Expire               *duration.Duration   `protobuf:"bytes,8,opt,name=expire" json:"expire,omitempty"`
	Timestamp            *timestamp.Timestamp `protobuf:"bytes,9,opt,name=timestamp" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Message postmark.

func (*Postmark) Descriptor 

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

func (*Postmark) GetCategory 

func (m *Postmark) GetCategory() Category

func (*Postmark) GetExpire 

func (m *Postmark) GetExpire() *duration.Duration

func (*Postmark) GetReceiver 

func (m *Postmark) GetReceiver() uint64

func (*Postmark) GetSender 

func (m *Postmark) GetSender() uint64

func (*Postmark) GetTimestamp 

func (m *Postmark) GetTimestamp() *timestamp.Timestamp

func (*Postmark) GetUniqueId 

func (m *Postmark) GetUniqueId() uint64

func (*Postmark) ProtoMessage 

func (*Postmark) ProtoMessage()

func (*Postmark) Reset 

func (m *Postmark) Reset()

func (*Postmark) String 

func (m *Postmark) String() string

func (*Postmark) Validate 

func (m *Postmark) Validate() error

Validate checks the field values on Postmark with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Postmark) XXX_DiscardUnknown 

func (m *Postmark) XXX_DiscardUnknown()

func (*Postmark) XXX_Marshal 

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

func (*Postmark) XXX_Merge 

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

func (*Postmark) XXX_Size 

func (m *Postmark) XXX_Size() int

func (*Postmark) XXX_Unmarshal 

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

type PostmarkValidationError 

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

PostmarkValidationError is the validation error returned by Postmark.Validate if the designated constraints aren't met.

func (PostmarkValidationError) Cause 

func (e PostmarkValidationError) Cause() error

Cause function returns cause value.

func (PostmarkValidationError) Error 

func (e PostmarkValidationError) Error() string

Error satisfies the builtin error interface

func (PostmarkValidationError) ErrorName 

func (e PostmarkValidationError) ErrorName() string

ErrorName returns error name.

func (PostmarkValidationError) Field 

func (e PostmarkValidationError) Field() string

Field function returns field value.

func (PostmarkValidationError) Key 

func (e PostmarkValidationError) Key() bool

Key function returns key value.

func (PostmarkValidationError) Reason 

func (e PostmarkValidationError) Reason() string

Reason function returns reason value.

type Receipts 

type Receipts struct {
	LocalIds             []*ClientId `protobuf:"bytes,1,rep,name=local_ids,json=localIds" json:"local_ids,omitempty"`
	Postmarks            []*Postmark `protobuf:"bytes,2,rep,name=postmarks" json:"postmarks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

Message receipts.

func (*Receipts) Descriptor 

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

func (*Receipts) GetLocalIds 

func (m *Receipts) GetLocalIds() []*ClientId

func (*Receipts) GetPostmarks 

func (m *Receipts) GetPostmarks() []*Postmark

func (*Receipts) ProtoMessage 

func (*Receipts) ProtoMessage()

func (*Receipts) Reset 

func (m *Receipts) Reset()

func (*Receipts) String 

func (m *Receipts) String() string

func (*Receipts) Validate 

func (m *Receipts) Validate() error

Validate checks the field values on Receipts with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Receipts) XXX_DiscardUnknown 

func (m *Receipts) XXX_DiscardUnknown()

func (*Receipts) XXX_Marshal 

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

func (*Receipts) XXX_Merge 

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

func (*Receipts) XXX_Size 

func (m *Receipts) XXX_Size() int

func (*Receipts) XXX_Unmarshal 

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

type ReceiptsValidationError 

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

ReceiptsValidationError is the validation error returned by Receipts.Validate if the designated constraints aren't met.

func (ReceiptsValidationError) Cause 

func (e ReceiptsValidationError) Cause() error

Cause function returns cause value.

func (ReceiptsValidationError) Error 

func (e ReceiptsValidationError) Error() string

Error satisfies the builtin error interface

func (ReceiptsValidationError) ErrorName 

func (e ReceiptsValidationError) ErrorName() string

ErrorName returns error name.

func (ReceiptsValidationError) Field 

func (e ReceiptsValidationError) Field() string

Field function returns field value.

func (ReceiptsValidationError) Key 

func (e ReceiptsValidationError) Key() bool

Key function returns key value.

func (ReceiptsValidationError) Reason 

func (e ReceiptsValidationError) Reason() string

Reason function returns reason value.

type RoomClient 

type RoomClient interface {
	// Get room connection server.
	Dispatch(ctx context.Context, in *common.UniqueId, opts ...grpc.CallOption) (*RoomServerOption, error)
	// Room streaming interaction.
	Interact(ctx context.Context, opts ...grpc.CallOption) (Room_InteractClient, error)
	// Send room message.
	Send(ctx context.Context, in *Post, opts ...grpc.CallOption) (*Postmark, error)
}

RoomClient is the client API for Room service.

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

func NewRoomClient 

func NewRoomClient(cc *grpc.ClientConn) RoomClient

type RoomServer 

type RoomServer interface {
	// Get room connection server.
	Dispatch(context.Context, *common.UniqueId) (*RoomServerOption, error)
	// Room streaming interaction.
	Interact(Room_InteractServer) error
	// Send room message.
	Send(context.Context, *Post) (*Postmark, error)
}

RoomServer is the server API for Room service.

type RoomServerOption 

type RoomServerOption struct {
	Host                 *string  `protobuf:"bytes,1,req,name=host" json:"host,omitempty"`
	Port                 *uint32  `protobuf:"varint,2,opt,name=port,def=443" json:"port,omitempty"`
	Secure               *bool    `protobuf:"varint,3,opt,name=secure,def=1" json:"secure,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Room server connect option.

func (*RoomServerOption) Descriptor 

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

func (*RoomServerOption) GetHost 

func (m *RoomServerOption) GetHost() string

func (*RoomServerOption) GetPort 

func (m *RoomServerOption) GetPort() uint32

func (*RoomServerOption) GetSecure 

func (m *RoomServerOption) GetSecure() bool

func (*RoomServerOption) ProtoMessage 

func (*RoomServerOption) ProtoMessage()

func (*RoomServerOption) Reset 

func (m *RoomServerOption) Reset()

func (*RoomServerOption) String 

func (m *RoomServerOption) String() string

func (*RoomServerOption) Validate 

func (m *RoomServerOption) Validate() error

Validate checks the field values on RoomServerOption with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*RoomServerOption) XXX_DiscardUnknown 

func (m *RoomServerOption) XXX_DiscardUnknown()

func (*RoomServerOption) XXX_Marshal 

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

func (*RoomServerOption) XXX_Merge 

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

func (*RoomServerOption) XXX_Size 

func (m *RoomServerOption) XXX_Size() int

func (*RoomServerOption) XXX_Unmarshal 

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

type RoomServerOptionValidationError 

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

RoomServerOptionValidationError is the validation error returned by RoomServerOption.Validate if the designated constraints aren't met.

func (RoomServerOptionValidationError) Cause 

func (e RoomServerOptionValidationError) Cause() error

Cause function returns cause value.

func (RoomServerOptionValidationError) Error 

func (e RoomServerOptionValidationError) Error() string

Error satisfies the builtin error interface

func (RoomServerOptionValidationError) ErrorName 

func (e RoomServerOptionValidationError) ErrorName() string

ErrorName returns error name.

func (RoomServerOptionValidationError) Field 

func (e RoomServerOptionValidationError) Field() string

Field function returns field value.

func (RoomServerOptionValidationError) Key 

func (e RoomServerOptionValidationError) Key() bool

Key function returns key value.

func (RoomServerOptionValidationError) Reason 

func (e RoomServerOptionValidationError) Reason() string

Reason function returns reason value.

type Room_InteractClient 

type Room_InteractClient interface {
	Send(*Stream) error
	Recv() (*Stream, error)
	grpc.ClientStream
}

type Room_InteractServer 

type Room_InteractServer interface {
	Send(*Stream) error
	Recv() (*Stream, error)
	grpc.ServerStream
}

type Session 

type Session struct {
	Type                 *SessionType         `protobuf:"varint,1,req,name=type,enum=appootb.message.SessionType" json:"type,omitempty"`
	Entry                *string              `protobuf:"bytes,2,req,name=entry" json:"entry,omitempty"`
	Metadata             *common.Metadata     `protobuf:"bytes,3,req,name=metadata" json:"metadata,omitempty"`
	CreatedAt            *timestamp.Timestamp `protobuf:"bytes,4,req,name=created_at,json=createdAt" json:"created_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Account session.

func (*Session) Descriptor 

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

func (*Session) GetCreatedAt 

func (m *Session) GetCreatedAt() *timestamp.Timestamp

func (*Session) GetEntry 

func (m *Session) GetEntry() string

func (*Session) GetMetadata 

func (m *Session) GetMetadata() *common.Metadata

func (*Session) GetType 

func (m *Session) GetType() SessionType

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) Reset 

func (m *Session) Reset()

func (*Session) String 

func (m *Session) String() string

func (*Session) Validate 

func (m *Session) Validate() error

Validate checks the field values on Session with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Session) XXX_DiscardUnknown 

func (m *Session) XXX_DiscardUnknown()

func (*Session) XXX_Marshal 

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

func (*Session) XXX_Merge 

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

func (*Session) XXX_Size 

func (m *Session) XXX_Size() int

func (*Session) XXX_Unmarshal 

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

type SessionId 

type SessionId struct {
	Type                 *SessionType `protobuf:"varint,1,req,name=type,enum=appootb.message.SessionType" json:"type,omitempty"`
	Account              *uint64      `protobuf:"varint,2,req,name=account" json:"account,omitempty"`
	DeviceId             *string      `protobuf:"bytes,3,opt,name=device_id,json=deviceId" json:"device_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Account session ID.

func (*SessionId) Descriptor 

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

func (*SessionId) GetAccount 

func (m *SessionId) GetAccount() uint64

func (*SessionId) GetDeviceId 

func (m *SessionId) GetDeviceId() string

func (*SessionId) GetType 

func (m *SessionId) GetType() SessionType

func (*SessionId) ProtoMessage 

func (*SessionId) ProtoMessage()

func (*SessionId) Reset 

func (m *SessionId) Reset()

func (*SessionId) String 

func (m *SessionId) String() string

func (*SessionId) Validate 

func (m *SessionId) Validate() error

Validate checks the field values on SessionId with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*SessionId) XXX_DiscardUnknown 

func (m *SessionId) XXX_DiscardUnknown()

func (*SessionId) XXX_Marshal 

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

func (*SessionId) XXX_Merge 

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

func (*SessionId) XXX_Size 

func (m *SessionId) XXX_Size() int

func (*SessionId) XXX_Unmarshal 

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

type SessionIdValidationError 

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

SessionIdValidationError is the validation error returned by SessionId.Validate if the designated constraints aren't met.

func (SessionIdValidationError) Cause 

func (e SessionIdValidationError) Cause() error

Cause function returns cause value.

func (SessionIdValidationError) Error 

func (e SessionIdValidationError) Error() string

Error satisfies the builtin error interface

func (SessionIdValidationError) ErrorName 

func (e SessionIdValidationError) ErrorName() string

ErrorName returns error name.

func (SessionIdValidationError) Field 

func (e SessionIdValidationError) Field() string

Field function returns field value.

func (SessionIdValidationError) Key 

func (e SessionIdValidationError) Key() bool

Key function returns key value.

func (SessionIdValidationError) Reason 

func (e SessionIdValidationError) Reason() string

Reason function returns reason value.

type SessionIds 

type SessionIds struct {
	Ids                  []*SessionId `protobuf:"bytes,1,rep,name=ids" json:"ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

Account session IDs.

func (*SessionIds) Descriptor 

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

func (*SessionIds) GetIds 

func (m *SessionIds) GetIds() []*SessionId

func (*SessionIds) ProtoMessage 

func (*SessionIds) ProtoMessage()

func (*SessionIds) Reset 

func (m *SessionIds) Reset()

func (*SessionIds) String 

func (m *SessionIds) String() string

func (*SessionIds) Validate 

func (m *SessionIds) Validate() error

Validate checks the field values on SessionIds with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*SessionIds) XXX_DiscardUnknown 

func (m *SessionIds) XXX_DiscardUnknown()

func (*SessionIds) XXX_Marshal 

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

func (*SessionIds) XXX_Merge 

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

func (*SessionIds) XXX_Size 

func (m *SessionIds) XXX_Size() int

func (*SessionIds) XXX_Unmarshal 

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

type SessionIdsValidationError 

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

SessionIdsValidationError is the validation error returned by SessionIds.Validate if the designated constraints aren't met.

func (SessionIdsValidationError) Cause 

func (e SessionIdsValidationError) Cause() error

Cause function returns cause value.

func (SessionIdsValidationError) Error 

func (e SessionIdsValidationError) Error() string

Error satisfies the builtin error interface

func (SessionIdsValidationError) ErrorName 

func (e SessionIdsValidationError) ErrorName() string

ErrorName returns error name.

func (SessionIdsValidationError) Field 

func (e SessionIdsValidationError) Field() string

Field function returns field value.

func (SessionIdsValidationError) Key 

func (e SessionIdsValidationError) Key() bool

Key function returns key value.

func (SessionIdsValidationError) Reason 

func (e SessionIdsValidationError) Reason() string

Reason function returns reason value.

type SessionType 

type SessionType int32

Account session type. 

const (
	SessionType_SESSION_TYPE_UNSPECIFIED SessionType = 0
	SessionType_SESSION_TYPE_CHAT        SessionType = 1
	SessionType_SESSION_TYPE_ROOM        SessionType = 2
)

func (SessionType) Enum 

func (x SessionType) Enum() *SessionType

func (SessionType) EnumDescriptor 

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

func (SessionType) String 

func (x SessionType) String() string

func (*SessionType) UnmarshalJSON 

func (x *SessionType) UnmarshalJSON(data []byte) error

type SessionValidationError 

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

SessionValidationError is the validation error returned by Session.Validate if the designated constraints aren't met.

func (SessionValidationError) Cause 

func (e SessionValidationError) Cause() error

Cause function returns cause value.

func (SessionValidationError) Error 

func (e SessionValidationError) Error() string

Error satisfies the builtin error interface

func (SessionValidationError) ErrorName 

func (e SessionValidationError) ErrorName() string

ErrorName returns error name.

func (SessionValidationError) Field 

func (e SessionValidationError) Field() string

Field function returns field value.

func (SessionValidationError) Key 

func (e SessionValidationError) Key() bool

Key function returns key value.

func (SessionValidationError) Reason 

func (e SessionValidationError) Reason() string

Reason function returns reason value.

type Sessions 

type Sessions struct {
	Sessions             []*Session `protobuf:"bytes,1,rep,name=sessions" json:"sessions,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

Account sessions.

func (*Sessions) Descriptor 

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

func (*Sessions) GetSessions 

func (m *Sessions) GetSessions() []*Session

func (*Sessions) ProtoMessage 

func (*Sessions) ProtoMessage()

func (*Sessions) Reset 

func (m *Sessions) Reset()

func (*Sessions) String 

func (m *Sessions) String() string

func (*Sessions) Validate 

func (m *Sessions) Validate() error

Validate checks the field values on Sessions with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Sessions) XXX_DiscardUnknown 

func (m *Sessions) XXX_DiscardUnknown()

func (*Sessions) XXX_Marshal 

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

func (*Sessions) XXX_Merge 

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

func (*Sessions) XXX_Size 

func (m *Sessions) XXX_Size() int

func (*Sessions) XXX_Unmarshal 

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

type SessionsValidationError 

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

SessionsValidationError is the validation error returned by Sessions.Validate if the designated constraints aren't met.

func (SessionsValidationError) Cause 

func (e SessionsValidationError) Cause() error

Cause function returns cause value.

func (SessionsValidationError) Error 

func (e SessionsValidationError) Error() string

Error satisfies the builtin error interface

func (SessionsValidationError) ErrorName 

func (e SessionsValidationError) ErrorName() string

ErrorName returns error name.

func (SessionsValidationError) Field 

func (e SessionsValidationError) Field() string

Field function returns field value.

func (SessionsValidationError) Key 

func (e SessionsValidationError) Key() bool

Key function returns key value.

func (SessionsValidationError) Reason 

func (e SessionsValidationError) Reason() string

Reason function returns reason value.

type Stream 

type Stream struct {
	Sn     *string      `protobuf:"bytes,1,req,name=sn" json:"sn,omitempty"`
	Target *uint64      `protobuf:"varint,2,opt,name=target" json:"target,omitempty"`
	Type   *PayloadType `protobuf:"varint,3,req,name=type,enum=appootb.message.PayloadType" json:"type,omitempty"`
	// Payload data
	//
	// Types that are valid to be assigned to Payload:
	//	*Stream_Local
	//	*Stream_Postbox
	//	*Stream_Receipts
	Payload              isStream_Payload `protobuf_oneof:"payload"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

Message streaming.

func (*Stream) Descriptor 

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

func (*Stream) GetLocal 

func (m *Stream) GetLocal() *ClientIds

func (*Stream) GetPayload 

func (m *Stream) GetPayload() isStream_Payload

func (*Stream) GetPostbox 

func (m *Stream) GetPostbox() *Postbox

func (*Stream) GetReceipts 

func (m *Stream) GetReceipts() *Receipts

func (*Stream) GetSn 

func (m *Stream) GetSn() string

func (*Stream) GetTarget 

func (m *Stream) GetTarget() uint64

func (*Stream) GetType 

func (m *Stream) GetType() PayloadType

func (*Stream) ProtoMessage 

func (*Stream) ProtoMessage()

func (*Stream) Reset 

func (m *Stream) Reset()

func (*Stream) String 

func (m *Stream) String() string

func (*Stream) Validate 

func (m *Stream) Validate() error

Validate checks the field values on Stream with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Stream) XXX_DiscardUnknown 

func (m *Stream) XXX_DiscardUnknown()

func (*Stream) XXX_Marshal 

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

func (*Stream) XXX_Merge 

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

func (*Stream) XXX_OneofWrappers 

func (*Stream) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Stream) XXX_Size 

func (m *Stream) XXX_Size() int

func (*Stream) XXX_Unmarshal 

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

type StreamValidationError 

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

StreamValidationError is the validation error returned by Stream.Validate if the designated constraints aren't met.

func (StreamValidationError) Cause 

func (e StreamValidationError) Cause() error

Cause function returns cause value.

func (StreamValidationError) Error 

func (e StreamValidationError) Error() string

Error satisfies the builtin error interface

func (StreamValidationError) ErrorName 

func (e StreamValidationError) ErrorName() string

ErrorName returns error name.

func (StreamValidationError) Field 

func (e StreamValidationError) Field() string

Field function returns field value.

func (StreamValidationError) Key 

func (e StreamValidationError) Key() bool

Key function returns key value.

func (StreamValidationError) Reason 

func (e StreamValidationError) Reason() string

Reason function returns reason value.

type Stream_Local 

type Stream_Local struct {
	Local *ClientIds `protobuf:"bytes,10,opt,name=local,oneof"`
}

type Stream_Postbox 

type Stream_Postbox struct {
	Postbox *Postbox `protobuf:"bytes,11,opt,name=postbox,oneof"`
}

type Stream_Receipts 

type Stream_Receipts struct {
	Receipts *Receipts `protobuf:"bytes,12,opt,name=receipts,oneof"`
}

type Tag 

type Tag struct {
	Product              *string  `protobuf:"bytes,1,req,name=product" json:"product,omitempty"`
	Name                 *string  `protobuf:"bytes,2,req,name=name" json:"name,omitempty"`
	Prefixed             *bool    `protobuf:"varint,3,opt,name=prefixed" json:"prefixed,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Connection tags.

func (*Tag) Descriptor 

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

func (*Tag) GetName 

func (m *Tag) GetName() string

func (*Tag) GetPrefixed 

func (m *Tag) GetPrefixed() bool

func (*Tag) GetProduct 

func (m *Tag) GetProduct() string

func (*Tag) ProtoMessage 

func (*Tag) ProtoMessage()

func (*Tag) Reset 

func (m *Tag) Reset()

func (*Tag) String 

func (m *Tag) String() string

func (*Tag) Validate 

func (m *Tag) Validate() error

Validate checks the field values on Tag with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Tag) XXX_DiscardUnknown 

func (m *Tag) XXX_DiscardUnknown()

func (*Tag) XXX_Marshal 

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

func (*Tag) XXX_Merge 

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

func (*Tag) XXX_Size 

func (m *Tag) XXX_Size() int

func (*Tag) XXX_Unmarshal 

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

type TagValidationError 

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

TagValidationError is the validation error returned by Tag.Validate if the designated constraints aren't met.

func (TagValidationError) Cause 

func (e TagValidationError) Cause() error

Cause function returns cause value.

func (TagValidationError) Error 

func (e TagValidationError) Error() string

Error satisfies the builtin error interface

func (TagValidationError) ErrorName 

func (e TagValidationError) ErrorName() string

ErrorName returns error name.

func (TagValidationError) Field 

func (e TagValidationError) Field() string

Field function returns field value.

func (TagValidationError) Key 

func (e TagValidationError) Key() bool

Key function returns key value.

func (TagValidationError) Reason 

func (e TagValidationError) Reason() string

Reason function returns reason value.

type Text 

type Text struct {
	Content              *string  `protobuf:"bytes,1,req,name=content" json:"content,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Text message.

func (*Text) Descriptor 

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

func (*Text) GetContent 

func (m *Text) GetContent() string

func (*Text) ProtoMessage 

func (*Text) ProtoMessage()

func (*Text) Reset 

func (m *Text) Reset()

func (*Text) String 

func (m *Text) String() string

func (*Text) Validate 

func (m *Text) Validate() error

Validate checks the field values on Text with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

func (*Text) XXX_DiscardUnknown 

func (m *Text) XXX_DiscardUnknown()

func (*Text) XXX_Marshal 

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

func (*Text) XXX_Merge 

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

func (*Text) XXX_Size 

func (m *Text) XXX_Size() int

func (*Text) XXX_Unmarshal 

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

type TextValidationError 

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

TextValidationError is the validation error returned by Text.Validate if the designated constraints aren't met.

func (TextValidationError) Cause 

func (e TextValidationError) Cause() error

Cause function returns cause value.

func (TextValidationError) Error 

func (e TextValidationError) Error() string

Error satisfies the builtin error interface

func (TextValidationError) ErrorName 

func (e TextValidationError) ErrorName() string

ErrorName returns error name.

func (TextValidationError) Field 

func (e TextValidationError) Field() string

Field function returns field value.

func (TextValidationError) Key 

func (e TextValidationError) Key() bool

Key function returns key value.

func (TextValidationError) Reason 

func (e TextValidationError) Reason() string

Reason function returns reason value.

type Type 

type Type int32

Message type enums. 

const (
	Type_TYPE_UNSPECIFIED Type = 0
	Type_TYPE_TEXT        Type = 1
	Type_TYPE_AUDIO       Type = 2
	Type_TYPE_STICKER     Type = 3
	Type_TYPE_PHOTO       Type = 4
	Type_TYPE_VIDEO       Type = 5
	Type_TYPE_GIF         Type = 6
	Type_TYPE_FILE        Type = 7
	Type_TYPE_LOCATION    Type = 8
	Type_TYPE_CONTACT     Type = 9
	Type_TYPE_RECALL      Type = 10
	Type_TYPE_READ        Type = 11
)

func (Type) Enum 

func (x Type) Enum() *Type

func (Type) EnumDescriptor 

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

func (Type) String 

func (x Type) String() string

func (*Type) UnmarshalJSON 

func (x *Type) UnmarshalJSON(data []byte) error

type UnimplementedChatServer 

type UnimplementedChatServer struct {
}

UnimplementedChatServer can be embedded to have forward compatible implementations.

func (*UnimplementedChatServer) Interact 

func (*UnimplementedChatServer) Interact(srv Chat_InteractServer) error

func (*UnimplementedChatServer) Send 

func (*UnimplementedChatServer) Send(ctx context.Context, req *Post) (*Postmark, error)

type UnimplementedInnerChatServer 

type UnimplementedInnerChatServer struct {
}

UnimplementedInnerChatServer can be embedded to have forward compatible implementations.

func (*UnimplementedInnerChatServer) Deliver 

func (*UnimplementedInnerChatServer) Deliver(ctx context.Context, req *Package) (*empty.Empty, error)

func (*UnimplementedInnerChatServer) Kick 

func (*UnimplementedInnerChatServer) Kick(ctx context.Context, req *Connections) (*empty.Empty, error)

type UnimplementedInnerRouterServer 

type UnimplementedInnerRouterServer struct {
}

UnimplementedInnerRouterServer can be embedded to have forward compatible implementations.

type UnimplementedInnerSessionServer 

type UnimplementedInnerSessionServer struct {
}

UnimplementedInnerSessionServer can be embedded to have forward compatible implementations.

func (*UnimplementedInnerSessionServer) Close 

func (*UnimplementedInnerSessionServer) Close(ctx context.Context, req *SessionId) (*empty.Empty, error)

func (*UnimplementedInnerSessionServer) Gets 

func (*UnimplementedInnerSessionServer) Gets(ctx context.Context, req *SessionIds) (*Sessions, error)

func (*UnimplementedInnerSessionServer) Open 

func (*UnimplementedInnerSessionServer) Open(ctx context.Context, req *Session) (*Sessions, error)

type UnimplementedRoomServer 

type UnimplementedRoomServer struct {
}

UnimplementedRoomServer can be embedded to have forward compatible implementations.

func (*UnimplementedRoomServer) Dispatch 

func (*UnimplementedRoomServer) Dispatch(ctx context.Context, req *common.UniqueId) (*RoomServerOption, error)

func (*UnimplementedRoomServer) Interact 

func (*UnimplementedRoomServer) Interact(srv Room_InteractServer) error

func (*UnimplementedRoomServer) Send 

func (*UnimplementedRoomServer) Send(ctx context.Context, req *Post) (*Postmark, error)

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.