pb

package
v0.0.0-...-c5acddb Latest Latest
Warning

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

 Go to latest Published: Dec 8, 2019 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Message_MessageKind_name = map[int32]string{
	0:  "None",
	1:  "Join",
	2:  "Broadcast",
	3:  "Custom",
	11: "OnAuthenticationFailedMessage",
	12: "OnJoinFailedMessage",
	13: "OnJoinMessage",
	14: "OnOtherUserJoinMessage",
	15: "OnOtherUserLeaveMessage",
	16: "OnBroadcastMessage",
}
View Source 
var Message_MessageKind_value = map[string]int32{
	"None":                          0,
	"Join":                          1,
	"Broadcast":                     2,
	"Custom":                        3,
	"OnAuthenticationFailedMessage": 11,
	"OnJoinFailedMessage":           12,
	"OnJoinMessage":                 13,
	"OnOtherUserJoinMessage":        14,
	"OnOtherUserLeaveMessage":       15,
	"OnBroadcastMessage":            16,
}

Functions

func RegisterHibariServer 

func RegisterHibariServer(s *grpc.Server, srv HibariServer)

Types

type BroadcastMessageBody 

type BroadcastMessageBody struct {
	Body                 *any.Any `protobuf:"bytes,1,opt,name=Body,proto3" json:"Body,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BroadcastMessageBody) Descriptor 

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

func (*BroadcastMessageBody) GetBody 

func (m *BroadcastMessageBody) GetBody() *any.Any

func (*BroadcastMessageBody) ProtoMessage 

func (*BroadcastMessageBody) ProtoMessage()

func (*BroadcastMessageBody) Reset 

func (m *BroadcastMessageBody) Reset()

func (*BroadcastMessageBody) String 

func (m *BroadcastMessageBody) String() string

func (*BroadcastMessageBody) XXX_DiscardUnknown 

func (m *BroadcastMessageBody) XXX_DiscardUnknown()

func (*BroadcastMessageBody) XXX_Marshal 

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

func (*BroadcastMessageBody) XXX_Merge 

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

func (*BroadcastMessageBody) XXX_Size 

func (m *BroadcastMessageBody) XXX_Size() int

func (*BroadcastMessageBody) XXX_Unmarshal 

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

type CustomMessageBody 

type CustomMessageBody struct {
	Kind                 int32    `protobuf:"varint,1,opt,name=Kind,proto3" json:"Kind,omitempty"`
	Body                 *any.Any `protobuf:"bytes,2,opt,name=Body,proto3" json:"Body,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CustomMessageBody) Descriptor 

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

func (*CustomMessageBody) GetBody 

func (m *CustomMessageBody) GetBody() *any.Any

func (*CustomMessageBody) GetKind 

func (m *CustomMessageBody) GetKind() int32

func (*CustomMessageBody) ProtoMessage 

func (*CustomMessageBody) ProtoMessage()

func (*CustomMessageBody) Reset 

func (m *CustomMessageBody) Reset()

func (*CustomMessageBody) String 

func (m *CustomMessageBody) String() string

func (*CustomMessageBody) XXX_DiscardUnknown 

func (m *CustomMessageBody) XXX_DiscardUnknown()

func (*CustomMessageBody) XXX_Marshal 

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

func (*CustomMessageBody) XXX_Merge 

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

func (*CustomMessageBody) XXX_Size 

func (m *CustomMessageBody) XXX_Size() int

func (*CustomMessageBody) XXX_Unmarshal 

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

type HibariClient 

type HibariClient interface {
	Conn(ctx context.Context, opts ...grpc.CallOption) (Hibari_ConnClient, error)
}

HibariClient is the client API for Hibari service.

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

func NewHibariClient 

func NewHibariClient(cc *grpc.ClientConn) HibariClient

type HibariServer 

type HibariServer interface {
	Conn(Hibari_ConnServer) error
}

HibariServer is the server API for Hibari service.

type Hibari_ConnClient 

type Hibari_ConnClient interface {
	Send(*Message) error
	Recv() (*Message, error)
	grpc.ClientStream
}

type Hibari_ConnServer 

type Hibari_ConnServer interface {
	Send(*Message) error
	Recv() (*Message, error)
	grpc.ServerStream
}

type JoinMessageBody 

type JoinMessageBody struct {
	UserID               string   `protobuf:"bytes,1,opt,name=UserID,proto3" json:"UserID,omitempty"`
	Secret               string   `protobuf:"bytes,2,opt,name=Secret,proto3" json:"Secret,omitempty"`
	RoomID               string   `protobuf:"bytes,3,opt,name=RoomID,proto3" json:"RoomID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*JoinMessageBody) Descriptor 

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

func (*JoinMessageBody) GetRoomID 

func (m *JoinMessageBody) GetRoomID() string

func (*JoinMessageBody) GetSecret 

func (m *JoinMessageBody) GetSecret() string

func (*JoinMessageBody) GetUserID 

func (m *JoinMessageBody) GetUserID() string

func (*JoinMessageBody) ProtoMessage 

func (*JoinMessageBody) ProtoMessage()

func (*JoinMessageBody) Reset 

func (m *JoinMessageBody) Reset()

func (*JoinMessageBody) String 

func (m *JoinMessageBody) String() string

func (*JoinMessageBody) XXX_DiscardUnknown 

func (m *JoinMessageBody) XXX_DiscardUnknown()

func (*JoinMessageBody) XXX_Marshal 

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

func (*JoinMessageBody) XXX_Merge 

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

func (*JoinMessageBody) XXX_Size 

func (m *JoinMessageBody) XXX_Size() int

func (*JoinMessageBody) XXX_Unmarshal 

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

type Message 

type Message struct {
	Kind                 Message_MessageKind `protobuf:"varint,1,opt,name=Kind,proto3,enum=Message_MessageKind" json:"Kind,omitempty"`
	Body                 *any.Any            `protobuf:"bytes,2,opt,name=Body,proto3" json:"Body,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*Message) Descriptor 

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

func (*Message) GetBody 

func (m *Message) GetBody() *any.Any

func (*Message) GetKind 

func (m *Message) GetKind() Message_MessageKind

func (*Message) ProtoMessage 

func (*Message) ProtoMessage()

func (*Message) Reset 

func (m *Message) Reset()

func (*Message) String 

func (m *Message) String() string

func (*Message) XXX_DiscardUnknown 

func (m *Message) XXX_DiscardUnknown()

func (*Message) XXX_Marshal 

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

func (*Message) XXX_Merge 

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

func (*Message) XXX_Size 

func (m *Message) XXX_Size() int

func (*Message) XXX_Unmarshal 

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

type Message_MessageKind 

type Message_MessageKind int32
const (
	Message_None                          Message_MessageKind = 0
	Message_Join                          Message_MessageKind = 1
	Message_Broadcast                     Message_MessageKind = 2
	Message_Custom                        Message_MessageKind = 3
	Message_OnAuthenticationFailedMessage Message_MessageKind = 11
	Message_OnJoinFailedMessage           Message_MessageKind = 12
	Message_OnJoinMessage                 Message_MessageKind = 13
	Message_OnOtherUserJoinMessage        Message_MessageKind = 14
	Message_OnOtherUserLeaveMessage       Message_MessageKind = 15
	Message_OnBroadcastMessage            Message_MessageKind = 16
)

func (Message_MessageKind) EnumDescriptor 

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

func (Message_MessageKind) String 

func (x Message_MessageKind) String() string

type OnBroadcastMessageBody 

type OnBroadcastMessageBody struct {
	From                 *ShortUser `protobuf:"bytes,1,opt,name=From,proto3" json:"From,omitempty"`
	Body                 *any.Any   `protobuf:"bytes,2,opt,name=Body,proto3" json:"Body,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*OnBroadcastMessageBody) Descriptor 

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

func (*OnBroadcastMessageBody) GetBody 

func (m *OnBroadcastMessageBody) GetBody() *any.Any

func (*OnBroadcastMessageBody) GetFrom 

func (m *OnBroadcastMessageBody) GetFrom() *ShortUser

func (*OnBroadcastMessageBody) ProtoMessage 

func (*OnBroadcastMessageBody) ProtoMessage()

func (*OnBroadcastMessageBody) Reset 

func (m *OnBroadcastMessageBody) Reset()

func (*OnBroadcastMessageBody) String 

func (m *OnBroadcastMessageBody) String() string

func (*OnBroadcastMessageBody) XXX_DiscardUnknown 

func (m *OnBroadcastMessageBody) XXX_DiscardUnknown()

func (*OnBroadcastMessageBody) XXX_Marshal 

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

func (*OnBroadcastMessageBody) XXX_Merge 

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

func (*OnBroadcastMessageBody) XXX_Size 

func (m *OnBroadcastMessageBody) XXX_Size() int

func (*OnBroadcastMessageBody) XXX_Unmarshal 

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

type OnJoinMessageBody 

type OnJoinMessageBody struct {
	UserMap              map[string]*ShortUser `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*OnJoinMessageBody) Descriptor 

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

func (*OnJoinMessageBody) GetUserMap 

func (m *OnJoinMessageBody) GetUserMap() map[string]*ShortUser

func (*OnJoinMessageBody) ProtoMessage 

func (*OnJoinMessageBody) ProtoMessage()

func (*OnJoinMessageBody) Reset 

func (m *OnJoinMessageBody) Reset()

func (*OnJoinMessageBody) String 

func (m *OnJoinMessageBody) String() string

func (*OnJoinMessageBody) XXX_DiscardUnknown 

func (m *OnJoinMessageBody) XXX_DiscardUnknown()

func (*OnJoinMessageBody) XXX_Marshal 

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

func (*OnJoinMessageBody) XXX_Merge 

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

func (*OnJoinMessageBody) XXX_Size 

func (m *OnJoinMessageBody) XXX_Size() int

func (*OnJoinMessageBody) XXX_Unmarshal 

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

type OnOtherUserJoinMessageBody 

type OnOtherUserJoinMessageBody struct {
	User                 *ShortUser `protobuf:"bytes,1,opt,name=User,proto3" json:"User,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*OnOtherUserJoinMessageBody) Descriptor 

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

func (*OnOtherUserJoinMessageBody) GetUser 

func (m *OnOtherUserJoinMessageBody) GetUser() *ShortUser

func (*OnOtherUserJoinMessageBody) ProtoMessage 

func (*OnOtherUserJoinMessageBody) ProtoMessage()

func (*OnOtherUserJoinMessageBody) Reset 

func (m *OnOtherUserJoinMessageBody) Reset()

func (*OnOtherUserJoinMessageBody) String 

func (m *OnOtherUserJoinMessageBody) String() string

func (*OnOtherUserJoinMessageBody) XXX_DiscardUnknown 

func (m *OnOtherUserJoinMessageBody) XXX_DiscardUnknown()

func (*OnOtherUserJoinMessageBody) XXX_Marshal 

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

func (*OnOtherUserJoinMessageBody) XXX_Merge 

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

func (*OnOtherUserJoinMessageBody) XXX_Size 

func (m *OnOtherUserJoinMessageBody) XXX_Size() int

func (*OnOtherUserJoinMessageBody) XXX_Unmarshal 

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

type OnOtherUserLeaveMessageBody 

type OnOtherUserLeaveMessageBody struct {
	User                 *ShortUser `protobuf:"bytes,1,opt,name=User,proto3" json:"User,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*OnOtherUserLeaveMessageBody) Descriptor 

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

func (*OnOtherUserLeaveMessageBody) GetUser 

func (m *OnOtherUserLeaveMessageBody) GetUser() *ShortUser

func (*OnOtherUserLeaveMessageBody) ProtoMessage 

func (*OnOtherUserLeaveMessageBody) ProtoMessage()

func (*OnOtherUserLeaveMessageBody) Reset 

func (m *OnOtherUserLeaveMessageBody) Reset()

func (*OnOtherUserLeaveMessageBody) String 

func (m *OnOtherUserLeaveMessageBody) String() string

func (*OnOtherUserLeaveMessageBody) XXX_DiscardUnknown 

func (m *OnOtherUserLeaveMessageBody) XXX_DiscardUnknown()

func (*OnOtherUserLeaveMessageBody) XXX_Marshal 

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

func (*OnOtherUserLeaveMessageBody) XXX_Merge 

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

func (*OnOtherUserLeaveMessageBody) XXX_Size 

func (m *OnOtherUserLeaveMessageBody) XXX_Size() int

func (*OnOtherUserLeaveMessageBody) XXX_Unmarshal 

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

type ShortUser 

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

func (*ShortUser) Descriptor 

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

func (*ShortUser) GetIndex 

func (m *ShortUser) GetIndex() int32

func (*ShortUser) GetName 

func (m *ShortUser) GetName() string

func (*ShortUser) ProtoMessage 

func (*ShortUser) ProtoMessage()

func (*ShortUser) Reset 

func (m *ShortUser) Reset()

func (*ShortUser) String 

func (m *ShortUser) String() string

func (*ShortUser) XXX_DiscardUnknown 

func (m *ShortUser) XXX_DiscardUnknown()

func (*ShortUser) XXX_Marshal 

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

func (*ShortUser) XXX_Merge 

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

func (*ShortUser) XXX_Size 

func (m *ShortUser) XXX_Size() int

func (*ShortUser) XXX_Unmarshal 

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

type UnimplementedHibariServer 

type UnimplementedHibariServer struct {
}

UnimplementedHibariServer can be embedded to have forward compatible implementations.

func (*UnimplementedHibariServer) Conn 

func (*UnimplementedHibariServer) Conn(srv Hibari_ConnServer) 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.