v0

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: 8 Imported by: 0

Documentation

Overview

Package v0 is a generated liverpc stub package. This code was generated with go-common/app/tool/liverpc/protoc-gen-liverpc v0.1.

It is generated from these files: 

v0/Message.proto

Index

Constants

This section is empty.

Variables

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

Functions

This section is empty.

Types

type Message 

type Message interface {
	// * 监控队列： topic：RoomStatusNotify-T
	//
	LiveNotify(context.Context, *MessageLiveNotifyReq) (*MessageLiveNotifyResp, error)

	// * 监控队列： topic：OneLiveRoomAreaChange-T
	//
	AreaNotify(context.Context, *MessageAreaNotifyReq) (*MessageAreaNotifyResp, error)
}

func NewMessageRpcClient 

func NewMessageRpcClient(client *liverpc.Client) Message

NewMessageRpcClient creates a Rpc client that implements the Message interface. It communicates using Rpc and can be configured with a custom HTTPClient.

type MessageAreaNotifyReq 

type MessageAreaNotifyReq struct {
}

func (*MessageAreaNotifyReq) Descriptor 

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

func (*MessageAreaNotifyReq) Marshal 

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

func (*MessageAreaNotifyReq) MarshalTo 

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

func (*MessageAreaNotifyReq) ProtoMessage 

func (*MessageAreaNotifyReq) ProtoMessage()

func (*MessageAreaNotifyReq) Reset 

func (m *MessageAreaNotifyReq) Reset()

func (*MessageAreaNotifyReq) Size 

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

func (*MessageAreaNotifyReq) String 

func (m *MessageAreaNotifyReq) String() string

func (*MessageAreaNotifyReq) Unmarshal 

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

func (*MessageAreaNotifyReq) XXX_DiscardUnknown 

func (m *MessageAreaNotifyReq) XXX_DiscardUnknown()

func (*MessageAreaNotifyReq) XXX_Marshal 

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

func (*MessageAreaNotifyReq) XXX_Merge 

func (dst *MessageAreaNotifyReq) XXX_Merge(src proto.Message)

func (*MessageAreaNotifyReq) XXX_Size 

func (m *MessageAreaNotifyReq) XXX_Size() int

func (*MessageAreaNotifyReq) XXX_Unmarshal 

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

type MessageAreaNotifyResp 

type MessageAreaNotifyResp struct {
	// code
	Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code"`
	// msg
	Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg"`
	//
	Data *MessageAreaNotifyResp_Data `protobuf:"bytes,3,opt,name=data" json:"data"`
}

func (*MessageAreaNotifyResp) Descriptor 

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

func (*MessageAreaNotifyResp) GetCode 

func (m *MessageAreaNotifyResp) GetCode() int64

func (*MessageAreaNotifyResp) GetData 

func (m *MessageAreaNotifyResp) GetData() *MessageAreaNotifyResp_Data

func (*MessageAreaNotifyResp) GetMsg 

func (m *MessageAreaNotifyResp) GetMsg() string

func (*MessageAreaNotifyResp) Marshal 

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

func (*MessageAreaNotifyResp) MarshalTo 

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

func (*MessageAreaNotifyResp) ProtoMessage 

func (*MessageAreaNotifyResp) ProtoMessage()

func (*MessageAreaNotifyResp) Reset 

func (m *MessageAreaNotifyResp) Reset()

func (*MessageAreaNotifyResp) Size 

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

func (*MessageAreaNotifyResp) String 

func (m *MessageAreaNotifyResp) String() string

func (*MessageAreaNotifyResp) Unmarshal 

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

func (*MessageAreaNotifyResp) XXX_DiscardUnknown 

func (m *MessageAreaNotifyResp) XXX_DiscardUnknown()

func (*MessageAreaNotifyResp) XXX_Marshal 

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

func (*MessageAreaNotifyResp) XXX_Merge 

func (dst *MessageAreaNotifyResp) XXX_Merge(src proto.Message)

func (*MessageAreaNotifyResp) XXX_Size 

func (m *MessageAreaNotifyResp) XXX_Size() int

func (*MessageAreaNotifyResp) XXX_Unmarshal 

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

type MessageAreaNotifyResp_Data 

type MessageAreaNotifyResp_Data struct {
}

func (*MessageAreaNotifyResp_Data) Descriptor 

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

func (*MessageAreaNotifyResp_Data) Marshal 

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

func (*MessageAreaNotifyResp_Data) MarshalTo 

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

func (*MessageAreaNotifyResp_Data) ProtoMessage 

func (*MessageAreaNotifyResp_Data) ProtoMessage()

func (*MessageAreaNotifyResp_Data) Reset 

func (m *MessageAreaNotifyResp_Data) Reset()

func (*MessageAreaNotifyResp_Data) Size 

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

func (*MessageAreaNotifyResp_Data) String 

func (m *MessageAreaNotifyResp_Data) String() string

func (*MessageAreaNotifyResp_Data) Unmarshal 

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

func (*MessageAreaNotifyResp_Data) XXX_DiscardUnknown 

func (m *MessageAreaNotifyResp_Data) XXX_DiscardUnknown()

func (*MessageAreaNotifyResp_Data) XXX_Marshal 

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

func (*MessageAreaNotifyResp_Data) XXX_Merge 

func (dst *MessageAreaNotifyResp_Data) XXX_Merge(src proto.Message)

func (*MessageAreaNotifyResp_Data) XXX_Size 

func (m *MessageAreaNotifyResp_Data) XXX_Size() int

func (*MessageAreaNotifyResp_Data) XXX_Unmarshal 

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

type MessageLiveNotifyReq 

type MessageLiveNotifyReq struct {
}

func (*MessageLiveNotifyReq) Descriptor 

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

func (*MessageLiveNotifyReq) Marshal 

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

func (*MessageLiveNotifyReq) MarshalTo 

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

func (*MessageLiveNotifyReq) ProtoMessage 

func (*MessageLiveNotifyReq) ProtoMessage()

func (*MessageLiveNotifyReq) Reset 

func (m *MessageLiveNotifyReq) Reset()

func (*MessageLiveNotifyReq) Size 

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

func (*MessageLiveNotifyReq) String 

func (m *MessageLiveNotifyReq) String() string

func (*MessageLiveNotifyReq) Unmarshal 

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

func (*MessageLiveNotifyReq) XXX_DiscardUnknown 

func (m *MessageLiveNotifyReq) XXX_DiscardUnknown()

func (*MessageLiveNotifyReq) XXX_Marshal 

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

func (*MessageLiveNotifyReq) XXX_Merge 

func (dst *MessageLiveNotifyReq) XXX_Merge(src proto.Message)

func (*MessageLiveNotifyReq) XXX_Size 

func (m *MessageLiveNotifyReq) XXX_Size() int

func (*MessageLiveNotifyReq) XXX_Unmarshal 

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

type MessageLiveNotifyResp 

type MessageLiveNotifyResp struct {
	// code
	Code int64 `protobuf:"varint,1,opt,name=code,proto3" json:"code"`
	// msg
	Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg"`
	//
	Data *MessageLiveNotifyResp_Data `protobuf:"bytes,3,opt,name=data" json:"data"`
}

func (*MessageLiveNotifyResp) Descriptor 

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

func (*MessageLiveNotifyResp) GetCode 

func (m *MessageLiveNotifyResp) GetCode() int64

func (*MessageLiveNotifyResp) GetData 

func (m *MessageLiveNotifyResp) GetData() *MessageLiveNotifyResp_Data

func (*MessageLiveNotifyResp) GetMsg 

func (m *MessageLiveNotifyResp) GetMsg() string

func (*MessageLiveNotifyResp) Marshal 

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

func (*MessageLiveNotifyResp) MarshalTo 

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

func (*MessageLiveNotifyResp) ProtoMessage 

func (*MessageLiveNotifyResp) ProtoMessage()

func (*MessageLiveNotifyResp) Reset 

func (m *MessageLiveNotifyResp) Reset()

func (*MessageLiveNotifyResp) Size 

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

func (*MessageLiveNotifyResp) String 

func (m *MessageLiveNotifyResp) String() string

func (*MessageLiveNotifyResp) Unmarshal 

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

func (*MessageLiveNotifyResp) XXX_DiscardUnknown 

func (m *MessageLiveNotifyResp) XXX_DiscardUnknown()

func (*MessageLiveNotifyResp) XXX_Marshal 

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

func (*MessageLiveNotifyResp) XXX_Merge 

func (dst *MessageLiveNotifyResp) XXX_Merge(src proto.Message)

func (*MessageLiveNotifyResp) XXX_Size 

func (m *MessageLiveNotifyResp) XXX_Size() int

func (*MessageLiveNotifyResp) XXX_Unmarshal 

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

type MessageLiveNotifyResp_Data 

type MessageLiveNotifyResp_Data struct {
}

func (*MessageLiveNotifyResp_Data) Descriptor 

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

func (*MessageLiveNotifyResp_Data) Marshal 

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

func (*MessageLiveNotifyResp_Data) MarshalTo 

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

func (*MessageLiveNotifyResp_Data) ProtoMessage 

func (*MessageLiveNotifyResp_Data) ProtoMessage()

func (*MessageLiveNotifyResp_Data) Reset 

func (m *MessageLiveNotifyResp_Data) Reset()

func (*MessageLiveNotifyResp_Data) Size 

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

func (*MessageLiveNotifyResp_Data) String 

func (m *MessageLiveNotifyResp_Data) String() string

func (*MessageLiveNotifyResp_Data) Unmarshal 

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

func (*MessageLiveNotifyResp_Data) XXX_DiscardUnknown 

func (m *MessageLiveNotifyResp_Data) XXX_DiscardUnknown()

func (*MessageLiveNotifyResp_Data) XXX_Marshal 

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

func (*MessageLiveNotifyResp_Data) XXX_Merge 

func (dst *MessageLiveNotifyResp_Data) XXX_Merge(src proto.Message)

func (*MessageLiveNotifyResp_Data) XXX_Size 

func (m *MessageLiveNotifyResp_Data) XXX_Size() int

func (*MessageLiveNotifyResp_Data) XXX_Unmarshal 

func (m *MessageLiveNotifyResp_Data) XXX_Unmarshal(b []byte) 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.