v1

package
v0.0.0-...-83adff0 Latest Latest
Warning

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

 Go to latest Published: Jul 6, 2020 License: GPL-3.0 Imports: 11 Imported by: 0

Documentation

Overview

Package v1 is a generated protocol buffer package.

It is generated from these files: 

app/interface/main/broadcast/api/grpc/v1/api.proto

It has these top-level messages: 

Empty
PushMsgReq
PushMsgReply
BroadcastReq
BroadcastReply
BroadcastRoomReq
BroadcastRoomReply
RoomsReq
RoomsReply

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthApi = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowApi   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterZergServer 

func RegisterZergServer(s *grpc.Server, srv ZergServer)

Types

type BroadcastReply 

type BroadcastReply struct {
}

func (*BroadcastReply) Descriptor 

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

func (*BroadcastReply) Marshal 

func (m *BroadcastReply) Marshal() (dAtA []byte, err error)

func (*BroadcastReply) MarshalTo 

func (m *BroadcastReply) MarshalTo(dAtA []byte) (int, error)

func (*BroadcastReply) ProtoMessage 

func (*BroadcastReply) ProtoMessage()

func (*BroadcastReply) Reset 

func (m *BroadcastReply) Reset()

func (*BroadcastReply) Size 

func (m *BroadcastReply) Size() (n int)

func (*BroadcastReply) String 

func (m *BroadcastReply) String() string

func (*BroadcastReply) Unmarshal 

func (m *BroadcastReply) Unmarshal(dAtA []byte) error

type BroadcastReq 

type BroadcastReq struct {
	ProtoOp  int32                               `protobuf:"varint,1,opt,name=protoOp,proto3" json:"protoOp,omitempty"`
	Proto    *push_service_broadcast_model.Proto `protobuf:"bytes,2,opt,name=proto" json:"proto,omitempty"`
	Speed    int32                               `protobuf:"varint,3,opt,name=speed,proto3" json:"speed,omitempty"`
	Platform string                              `protobuf:"bytes,4,opt,name=platform,proto3" json:"platform,omitempty"`
}

func (*BroadcastReq) Descriptor 

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

func (*BroadcastReq) GetPlatform 

func (m *BroadcastReq) GetPlatform() string

func (*BroadcastReq) GetProto 

func (m *BroadcastReq) GetProto() *push_service_broadcast_model.Proto

func (*BroadcastReq) GetProtoOp 

func (m *BroadcastReq) GetProtoOp() int32

func (*BroadcastReq) GetSpeed 

func (m *BroadcastReq) GetSpeed() int32

func (*BroadcastReq) Marshal 

func (m *BroadcastReq) Marshal() (dAtA []byte, err error)

func (*BroadcastReq) MarshalTo 

func (m *BroadcastReq) MarshalTo(dAtA []byte) (int, error)

func (*BroadcastReq) ProtoMessage 

func (*BroadcastReq) ProtoMessage()

func (*BroadcastReq) Reset 

func (m *BroadcastReq) Reset()

func (*BroadcastReq) Size 

func (m *BroadcastReq) Size() (n int)

func (*BroadcastReq) String 

func (m *BroadcastReq) String() string

func (*BroadcastReq) Unmarshal 

func (m *BroadcastReq) Unmarshal(dAtA []byte) error

type BroadcastRoomReply 

type BroadcastRoomReply struct {
}

func (*BroadcastRoomReply) Descriptor 

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

func (*BroadcastRoomReply) Marshal 

func (m *BroadcastRoomReply) Marshal() (dAtA []byte, err error)

func (*BroadcastRoomReply) MarshalTo 

func (m *BroadcastRoomReply) MarshalTo(dAtA []byte) (int, error)

func (*BroadcastRoomReply) ProtoMessage 

func (*BroadcastRoomReply) ProtoMessage()

func (*BroadcastRoomReply) Reset 

func (m *BroadcastRoomReply) Reset()

func (*BroadcastRoomReply) Size 

func (m *BroadcastRoomReply) Size() (n int)

func (*BroadcastRoomReply) String 

func (m *BroadcastRoomReply) String() string

func (*BroadcastRoomReply) Unmarshal 

func (m *BroadcastRoomReply) Unmarshal(dAtA []byte) error

type BroadcastRoomReq 

type BroadcastRoomReq struct {
	RoomID string                              `protobuf:"bytes,1,opt,name=roomID,proto3" json:"roomID,omitempty"`
	Proto  *push_service_broadcast_model.Proto `protobuf:"bytes,2,opt,name=proto" json:"proto,omitempty"`
}

func (*BroadcastRoomReq) Descriptor 

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

func (*BroadcastRoomReq) GetProto 

func (m *BroadcastRoomReq) GetProto() *push_service_broadcast_model.Proto

func (*BroadcastRoomReq) GetRoomID 

func (m *BroadcastRoomReq) GetRoomID() string

func (*BroadcastRoomReq) Marshal 

func (m *BroadcastRoomReq) Marshal() (dAtA []byte, err error)

func (*BroadcastRoomReq) MarshalTo 

func (m *BroadcastRoomReq) MarshalTo(dAtA []byte) (int, error)

func (*BroadcastRoomReq) ProtoMessage 

func (*BroadcastRoomReq) ProtoMessage()

func (*BroadcastRoomReq) Reset 

func (m *BroadcastRoomReq) Reset()

func (*BroadcastRoomReq) Size 

func (m *BroadcastRoomReq) Size() (n int)

func (*BroadcastRoomReq) String 

func (m *BroadcastRoomReq) String() string

func (*BroadcastRoomReq) Unmarshal 

func (m *BroadcastRoomReq) Unmarshal(dAtA []byte) error

type Empty 

type Empty struct {
}

func (*Empty) Descriptor 

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

func (*Empty) Marshal 

func (m *Empty) Marshal() (dAtA []byte, err error)

func (*Empty) MarshalTo 

func (m *Empty) MarshalTo(dAtA []byte) (int, error)

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) Reset 

func (m *Empty) Reset()

func (*Empty) Size 

func (m *Empty) Size() (n int)

func (*Empty) String 

func (m *Empty) String() string

func (*Empty) Unmarshal 

func (m *Empty) Unmarshal(dAtA []byte) error

type PushMsgReply 

type PushMsgReply struct {
}

func (*PushMsgReply) Descriptor 

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

func (*PushMsgReply) Marshal 

func (m *PushMsgReply) Marshal() (dAtA []byte, err error)

func (*PushMsgReply) MarshalTo 

func (m *PushMsgReply) MarshalTo(dAtA []byte) (int, error)

func (*PushMsgReply) ProtoMessage 

func (*PushMsgReply) ProtoMessage()

func (*PushMsgReply) Reset 

func (m *PushMsgReply) Reset()

func (*PushMsgReply) Size 

func (m *PushMsgReply) Size() (n int)

func (*PushMsgReply) String 

func (m *PushMsgReply) String() string

func (*PushMsgReply) Unmarshal 

func (m *PushMsgReply) Unmarshal(dAtA []byte) error

type PushMsgReq 

type PushMsgReq struct {
	Keys    []string                            `protobuf:"bytes,1,rep,name=keys" json:"keys,omitempty"`
	ProtoOp int32                               `protobuf:"varint,3,opt,name=protoOp,proto3" json:"protoOp,omitempty"`
	Proto   *push_service_broadcast_model.Proto `protobuf:"bytes,2,opt,name=proto" json:"proto,omitempty"`
}

func (*PushMsgReq) Descriptor 

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

func (*PushMsgReq) GetKeys 

func (m *PushMsgReq) GetKeys() []string

func (*PushMsgReq) GetProto 

func (m *PushMsgReq) GetProto() *push_service_broadcast_model.Proto

func (*PushMsgReq) GetProtoOp 

func (m *PushMsgReq) GetProtoOp() int32

func (*PushMsgReq) Marshal 

func (m *PushMsgReq) Marshal() (dAtA []byte, err error)

func (*PushMsgReq) MarshalTo 

func (m *PushMsgReq) MarshalTo(dAtA []byte) (int, error)

func (*PushMsgReq) ProtoMessage 

func (*PushMsgReq) ProtoMessage()

func (*PushMsgReq) Reset 

func (m *PushMsgReq) Reset()

func (*PushMsgReq) Size 

func (m *PushMsgReq) Size() (n int)

func (*PushMsgReq) String 

func (m *PushMsgReq) String() string

func (*PushMsgReq) Unmarshal 

func (m *PushMsgReq) Unmarshal(dAtA []byte) error

type RoomsReply 

type RoomsReply struct {
	Rooms map[string]bool `` /* 145-byte string literal not displayed */
}

func (*RoomsReply) Descriptor 

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

func (*RoomsReply) GetRooms 

func (m *RoomsReply) GetRooms() map[string]bool

func (*RoomsReply) Marshal 

func (m *RoomsReply) Marshal() (dAtA []byte, err error)

func (*RoomsReply) MarshalTo 

func (m *RoomsReply) MarshalTo(dAtA []byte) (int, error)

func (*RoomsReply) ProtoMessage 

func (*RoomsReply) ProtoMessage()

func (*RoomsReply) Reset 

func (m *RoomsReply) Reset()

func (*RoomsReply) Size 

func (m *RoomsReply) Size() (n int)

func (*RoomsReply) String 

func (r *RoomsReply) String() string

func (*RoomsReply) Unmarshal 

func (m *RoomsReply) Unmarshal(dAtA []byte) error

type RoomsReq 

type RoomsReq struct {
}

func (*RoomsReq) Descriptor 

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

func (*RoomsReq) Marshal 

func (m *RoomsReq) Marshal() (dAtA []byte, err error)

func (*RoomsReq) MarshalTo 

func (m *RoomsReq) MarshalTo(dAtA []byte) (int, error)

func (*RoomsReq) ProtoMessage 

func (*RoomsReq) ProtoMessage()

func (*RoomsReq) Reset 

func (m *RoomsReq) Reset()

func (*RoomsReq) Size 

func (m *RoomsReq) Size() (n int)

func (*RoomsReq) String 

func (m *RoomsReq) String() string

func (*RoomsReq) Unmarshal 

func (m *RoomsReq) Unmarshal(dAtA []byte) error

type ZergClient 

type ZergClient interface {
	// Ping Service
	Ping(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	// Close Service
	Close(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*Empty, error)
	// PushMsg push by key or mid
	PushMsg(ctx context.Context, in *PushMsgReq, opts ...grpc.CallOption) (*PushMsgReply, error)
	// Broadcast send to every enrity
	Broadcast(ctx context.Context, in *BroadcastReq, opts ...grpc.CallOption) (*BroadcastReply, error)
	// BroadcastRoom broadcast to one room
	BroadcastRoom(ctx context.Context, in *BroadcastRoomReq, opts ...grpc.CallOption) (*BroadcastRoomReply, error)
	// Rooms get all rooms
	Rooms(ctx context.Context, in *RoomsReq, opts ...grpc.CallOption) (*RoomsReply, error)
}

func NewClient 

func NewClient(target string, cfg *warden.ClientConfig, opts ...grpc.DialOption) (ZergClient, error)

NewClient new a client.

func NewZergClient 

func NewZergClient(cc *grpc.ClientConn) ZergClient

type ZergServer 

type ZergServer interface {
	// Ping Service
	Ping(context.Context, *Empty) (*Empty, error)
	// Close Service
	Close(context.Context, *Empty) (*Empty, error)
	// PushMsg push by key or mid
	PushMsg(context.Context, *PushMsgReq) (*PushMsgReply, error)
	// Broadcast send to every enrity
	Broadcast(context.Context, *BroadcastReq) (*BroadcastReply, error)
	// BroadcastRoom broadcast to one room
	BroadcastRoom(context.Context, *BroadcastRoomReq) (*BroadcastRoomReply, error)
	// Rooms get all rooms
	Rooms(context.Context, *RoomsReq) (*RoomsReply, 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.