push

package
v0.0.0-...-4cc9216 Latest Latest
Warning

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

 Go to latest Published: Jun 14, 2024 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var KitexUnusedProtection = struct{}{}

KitexUnusedProtection is used to prevent 'imported and not used' error.

View Source 
var PushMessageRequest_Message_DEFAULT *base.LiveMessage
View Source 
var ReceiveMessageResponse_Message_DEFAULT *base.LiveMessage

Functions

This section is empty.

Types

type InitLiveRoomReciverRequest 

type InitLiveRoomReciverRequest struct {
	LiveId int64 `thrift:"live_id,1" frugal:"1,default,i64" json:"live_id"`
}
var PushServiceInitLiveRoomReciverArgs_Req_DEFAULT *InitLiveRoomReciverRequest

func NewInitLiveRoomReciverRequest 

func NewInitLiveRoomReciverRequest() *InitLiveRoomReciverRequest

func (*InitLiveRoomReciverRequest) BLength 

func (p *InitLiveRoomReciverRequest) BLength() int

func (*InitLiveRoomReciverRequest) DeepEqual 

func (p *InitLiveRoomReciverRequest) DeepEqual(ano *InitLiveRoomReciverRequest) bool

func (*InitLiveRoomReciverRequest) FastRead 

func (p *InitLiveRoomReciverRequest) FastRead(buf []byte) (int, error)

func (*InitLiveRoomReciverRequest) FastReadField1 

func (p *InitLiveRoomReciverRequest) FastReadField1(buf []byte) (int, error)

func (*InitLiveRoomReciverRequest) FastWrite 

func (p *InitLiveRoomReciverRequest) FastWrite(buf []byte) int

for compatibility

func (*InitLiveRoomReciverRequest) FastWriteNocopy 

func (p *InitLiveRoomReciverRequest) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*InitLiveRoomReciverRequest) Field1DeepEqual 

func (p *InitLiveRoomReciverRequest) Field1DeepEqual(src int64) bool

func (*InitLiveRoomReciverRequest) GetLiveId 

func (p *InitLiveRoomReciverRequest) GetLiveId() (v int64)

func (*InitLiveRoomReciverRequest) InitDefault 

func (p *InitLiveRoomReciverRequest) InitDefault()

func (*InitLiveRoomReciverRequest) Read 

func (p *InitLiveRoomReciverRequest) Read(iprot thrift.TProtocol) (err error)

func (*InitLiveRoomReciverRequest) ReadField1 

func (p *InitLiveRoomReciverRequest) ReadField1(iprot thrift.TProtocol) error

func (*InitLiveRoomReciverRequest) SetLiveId 

func (p *InitLiveRoomReciverRequest) SetLiveId(val int64)

func (*InitLiveRoomReciverRequest) String 

func (p *InitLiveRoomReciverRequest) String() string

func (*InitLiveRoomReciverRequest) Write 

func (p *InitLiveRoomReciverRequest) Write(oprot thrift.TProtocol) (err error)

type PushMessageRequest 

type PushMessageRequest struct {
	Message *base.LiveMessage `thrift:"message,1" frugal:"1,default,base.LiveMessage" json:"message"`
}
var PushServicePushMessageArgs_Req_DEFAULT *PushMessageRequest

func NewPushMessageRequest 

func NewPushMessageRequest() *PushMessageRequest

func (*PushMessageRequest) BLength 

func (p *PushMessageRequest) BLength() int

func (*PushMessageRequest) DeepEqual 

func (p *PushMessageRequest) DeepEqual(ano *PushMessageRequest) bool

func (*PushMessageRequest) FastRead 

func (p *PushMessageRequest) FastRead(buf []byte) (int, error)

func (*PushMessageRequest) FastReadField1 

func (p *PushMessageRequest) FastReadField1(buf []byte) (int, error)

func (*PushMessageRequest) FastWrite 

func (p *PushMessageRequest) FastWrite(buf []byte) int

for compatibility

func (*PushMessageRequest) FastWriteNocopy 

func (p *PushMessageRequest) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*PushMessageRequest) Field1DeepEqual 

func (p *PushMessageRequest) Field1DeepEqual(src *base.LiveMessage) bool

func (*PushMessageRequest) GetMessage 

func (p *PushMessageRequest) GetMessage() (v *base.LiveMessage)

func (*PushMessageRequest) InitDefault 

func (p *PushMessageRequest) InitDefault()

func (*PushMessageRequest) IsSetMessage 

func (p *PushMessageRequest) IsSetMessage() bool

func (*PushMessageRequest) Read 

func (p *PushMessageRequest) Read(iprot thrift.TProtocol) (err error)

func (*PushMessageRequest) ReadField1 

func (p *PushMessageRequest) ReadField1(iprot thrift.TProtocol) error

func (*PushMessageRequest) SetMessage 

func (p *PushMessageRequest) SetMessage(val *base.LiveMessage)

func (*PushMessageRequest) String 

func (p *PushMessageRequest) String() string

func (*PushMessageRequest) Write 

func (p *PushMessageRequest) Write(oprot thrift.TProtocol) (err error)

type PushService 

type PushService interface {
	PushMessage(ctx context.Context, req *PushMessageRequest) (err error)

	StopMessage(ctx context.Context, req *StopMessageRequest) (err error)

	InitLiveRoomReciver(ctx context.Context, req *InitLiveRoomReciverRequest) (err error)

	ReceiveMessage(stream PushService_ReceiveMessageServer) (err error)
}

type PushServiceClient 

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

func NewPushServiceClient 

func NewPushServiceClient(c thrift.TClient) *PushServiceClient

func NewPushServiceClientFactory 

func NewPushServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *PushServiceClient

func NewPushServiceClientProtocol 

func NewPushServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *PushServiceClient

func (*PushServiceClient) Client_ 

func (p *PushServiceClient) Client_() thrift.TClient

func (*PushServiceClient) InitLiveRoomReciver 

func (p *PushServiceClient) InitLiveRoomReciver(ctx context.Context, req *InitLiveRoomReciverRequest) (err error)

func (*PushServiceClient) PushMessage 

func (p *PushServiceClient) PushMessage(ctx context.Context, req *PushMessageRequest) (err error)

func (*PushServiceClient) ReceiveMessage 

func (p *PushServiceClient) ReceiveMessage(stream PushService_ReceiveMessageServer) (err error)

func (*PushServiceClient) StopMessage 

func (p *PushServiceClient) StopMessage(ctx context.Context, req *StopMessageRequest) (err error)

type PushServiceInitLiveRoomReciverArgs 

type PushServiceInitLiveRoomReciverArgs struct {
	Req *InitLiveRoomReciverRequest `thrift:"req,1" frugal:"1,default,InitLiveRoomReciverRequest" json:"req"`
}

func NewPushServiceInitLiveRoomReciverArgs 

func NewPushServiceInitLiveRoomReciverArgs() *PushServiceInitLiveRoomReciverArgs

func (*PushServiceInitLiveRoomReciverArgs) BLength 

func (p *PushServiceInitLiveRoomReciverArgs) BLength() int

func (*PushServiceInitLiveRoomReciverArgs) DeepEqual 

func (p *PushServiceInitLiveRoomReciverArgs) DeepEqual(ano *PushServiceInitLiveRoomReciverArgs) bool

func (*PushServiceInitLiveRoomReciverArgs) FastRead 

func (p *PushServiceInitLiveRoomReciverArgs) FastRead(buf []byte) (int, error)

func (*PushServiceInitLiveRoomReciverArgs) FastReadField1 

func (p *PushServiceInitLiveRoomReciverArgs) FastReadField1(buf []byte) (int, error)

func (*PushServiceInitLiveRoomReciverArgs) FastWrite 

func (p *PushServiceInitLiveRoomReciverArgs) FastWrite(buf []byte) int

for compatibility

func (*PushServiceInitLiveRoomReciverArgs) FastWriteNocopy 

func (p *PushServiceInitLiveRoomReciverArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*PushServiceInitLiveRoomReciverArgs) Field1DeepEqual 

func (p *PushServiceInitLiveRoomReciverArgs) Field1DeepEqual(src *InitLiveRoomReciverRequest) bool

func (*PushServiceInitLiveRoomReciverArgs) GetFirstArgument 

func (p *PushServiceInitLiveRoomReciverArgs) GetFirstArgument() interface{}

func (*PushServiceInitLiveRoomReciverArgs) GetReq 

func (p *PushServiceInitLiveRoomReciverArgs) GetReq() (v *InitLiveRoomReciverRequest)

func (*PushServiceInitLiveRoomReciverArgs) InitDefault 

func (p *PushServiceInitLiveRoomReciverArgs) InitDefault()

func (*PushServiceInitLiveRoomReciverArgs) IsSetReq 

func (p *PushServiceInitLiveRoomReciverArgs) IsSetReq() bool

func (*PushServiceInitLiveRoomReciverArgs) Read 

func (p *PushServiceInitLiveRoomReciverArgs) Read(iprot thrift.TProtocol) (err error)

func (*PushServiceInitLiveRoomReciverArgs) ReadField1 

func (p *PushServiceInitLiveRoomReciverArgs) ReadField1(iprot thrift.TProtocol) error

func (*PushServiceInitLiveRoomReciverArgs) SetReq 

func (p *PushServiceInitLiveRoomReciverArgs) SetReq(val *InitLiveRoomReciverRequest)

func (*PushServiceInitLiveRoomReciverArgs) String 

func (p *PushServiceInitLiveRoomReciverArgs) String() string

func (*PushServiceInitLiveRoomReciverArgs) Write 

func (p *PushServiceInitLiveRoomReciverArgs) Write(oprot thrift.TProtocol) (err error)

type PushServiceInitLiveRoomReciverResult 

type PushServiceInitLiveRoomReciverResult struct {
}

func NewPushServiceInitLiveRoomReciverResult 

func NewPushServiceInitLiveRoomReciverResult() *PushServiceInitLiveRoomReciverResult

func (*PushServiceInitLiveRoomReciverResult) BLength 

func (p *PushServiceInitLiveRoomReciverResult) BLength() int

func (*PushServiceInitLiveRoomReciverResult) DeepEqual 

func (p *PushServiceInitLiveRoomReciverResult) DeepEqual(ano *PushServiceInitLiveRoomReciverResult) bool

func (*PushServiceInitLiveRoomReciverResult) FastRead 

func (p *PushServiceInitLiveRoomReciverResult) FastRead(buf []byte) (int, error)

func (*PushServiceInitLiveRoomReciverResult) FastWrite 

func (p *PushServiceInitLiveRoomReciverResult) FastWrite(buf []byte) int

for compatibility

func (*PushServiceInitLiveRoomReciverResult) FastWriteNocopy 

func (p *PushServiceInitLiveRoomReciverResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*PushServiceInitLiveRoomReciverResult) GetResult 

func (p *PushServiceInitLiveRoomReciverResult) GetResult() interface{}

func (*PushServiceInitLiveRoomReciverResult) InitDefault 

func (p *PushServiceInitLiveRoomReciverResult) InitDefault()

func (*PushServiceInitLiveRoomReciverResult) Read 

func (p *PushServiceInitLiveRoomReciverResult) Read(iprot thrift.TProtocol) (err error)

func (*PushServiceInitLiveRoomReciverResult) String 

func (p *PushServiceInitLiveRoomReciverResult) String() string

func (*PushServiceInitLiveRoomReciverResult) Write 

func (p *PushServiceInitLiveRoomReciverResult) Write(oprot thrift.TProtocol) (err error)

type PushServiceProcessor 

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

func NewPushServiceProcessor 

func NewPushServiceProcessor(handler PushService) *PushServiceProcessor

func (*PushServiceProcessor) AddToProcessorMap 

func (p *PushServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*PushServiceProcessor) GetProcessorFunction 

func (p *PushServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*PushServiceProcessor) Process 

func (p *PushServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*PushServiceProcessor) ProcessorMap 

func (p *PushServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type PushServicePushMessageArgs 

type PushServicePushMessageArgs struct {
	Req *PushMessageRequest `thrift:"req,1" frugal:"1,default,PushMessageRequest" json:"req"`
}

func NewPushServicePushMessageArgs 

func NewPushServicePushMessageArgs() *PushServicePushMessageArgs

func (*PushServicePushMessageArgs) BLength 

func (p *PushServicePushMessageArgs) BLength() int

func (*PushServicePushMessageArgs) DeepEqual 

func (p *PushServicePushMessageArgs) DeepEqual(ano *PushServicePushMessageArgs) bool

func (*PushServicePushMessageArgs) FastRead 

func (p *PushServicePushMessageArgs) FastRead(buf []byte) (int, error)

func (*PushServicePushMessageArgs) FastReadField1 

func (p *PushServicePushMessageArgs) FastReadField1(buf []byte) (int, error)

func (*PushServicePushMessageArgs) FastWrite 

func (p *PushServicePushMessageArgs) FastWrite(buf []byte) int

for compatibility

func (*PushServicePushMessageArgs) FastWriteNocopy 

func (p *PushServicePushMessageArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*PushServicePushMessageArgs) Field1DeepEqual 

func (p *PushServicePushMessageArgs) Field1DeepEqual(src *PushMessageRequest) bool

func (*PushServicePushMessageArgs) GetFirstArgument 

func (p *PushServicePushMessageArgs) GetFirstArgument() interface{}

func (*PushServicePushMessageArgs) GetReq 

func (p *PushServicePushMessageArgs) GetReq() (v *PushMessageRequest)

func (*PushServicePushMessageArgs) InitDefault 

func (p *PushServicePushMessageArgs) InitDefault()

func (*PushServicePushMessageArgs) IsSetReq 

func (p *PushServicePushMessageArgs) IsSetReq() bool

func (*PushServicePushMessageArgs) Read 

func (p *PushServicePushMessageArgs) Read(iprot thrift.TProtocol) (err error)

func (*PushServicePushMessageArgs) ReadField1 

func (p *PushServicePushMessageArgs) ReadField1(iprot thrift.TProtocol) error

func (*PushServicePushMessageArgs) SetReq 

func (p *PushServicePushMessageArgs) SetReq(val *PushMessageRequest)

func (*PushServicePushMessageArgs) String 

func (p *PushServicePushMessageArgs) String() string

func (*PushServicePushMessageArgs) Write 

func (p *PushServicePushMessageArgs) Write(oprot thrift.TProtocol) (err error)

type PushServicePushMessageResult 

type PushServicePushMessageResult struct {
}

func NewPushServicePushMessageResult 

func NewPushServicePushMessageResult() *PushServicePushMessageResult

func (*PushServicePushMessageResult) BLength 

func (p *PushServicePushMessageResult) BLength() int

func (*PushServicePushMessageResult) DeepEqual 

func (p *PushServicePushMessageResult) DeepEqual(ano *PushServicePushMessageResult) bool

func (*PushServicePushMessageResult) FastRead 

func (p *PushServicePushMessageResult) FastRead(buf []byte) (int, error)

func (*PushServicePushMessageResult) FastWrite 

func (p *PushServicePushMessageResult) FastWrite(buf []byte) int

for compatibility

func (*PushServicePushMessageResult) FastWriteNocopy 

func (p *PushServicePushMessageResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*PushServicePushMessageResult) GetResult 

func (p *PushServicePushMessageResult) GetResult() interface{}

func (*PushServicePushMessageResult) InitDefault 

func (p *PushServicePushMessageResult) InitDefault()

func (*PushServicePushMessageResult) Read 

func (p *PushServicePushMessageResult) Read(iprot thrift.TProtocol) (err error)

func (*PushServicePushMessageResult) String 

func (p *PushServicePushMessageResult) String() string

func (*PushServicePushMessageResult) Write 

func (p *PushServicePushMessageResult) Write(oprot thrift.TProtocol) (err error)

type PushServiceReceiveMessageArgs 

type PushServiceReceiveMessageArgs struct {
	Req *ReceiveMessageRequest `thrift:"req,1" frugal:"1,default,ReceiveMessageRequest" json:"req"`
}

func NewPushServiceReceiveMessageArgs 

func NewPushServiceReceiveMessageArgs() *PushServiceReceiveMessageArgs

func (*PushServiceReceiveMessageArgs) BLength 

func (p *PushServiceReceiveMessageArgs) BLength() int

func (*PushServiceReceiveMessageArgs) DeepEqual 

func (p *PushServiceReceiveMessageArgs) DeepEqual(ano *PushServiceReceiveMessageArgs) bool

func (*PushServiceReceiveMessageArgs) FastRead 

func (p *PushServiceReceiveMessageArgs) FastRead(buf []byte) (int, error)

func (*PushServiceReceiveMessageArgs) FastReadField1 

func (p *PushServiceReceiveMessageArgs) FastReadField1(buf []byte) (int, error)

func (*PushServiceReceiveMessageArgs) FastWrite 

func (p *PushServiceReceiveMessageArgs) FastWrite(buf []byte) int

for compatibility

func (*PushServiceReceiveMessageArgs) FastWriteNocopy 

func (p *PushServiceReceiveMessageArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*PushServiceReceiveMessageArgs) Field1DeepEqual 

func (p *PushServiceReceiveMessageArgs) Field1DeepEqual(src *ReceiveMessageRequest) bool

func (*PushServiceReceiveMessageArgs) GetFirstArgument 

func (p *PushServiceReceiveMessageArgs) GetFirstArgument() interface{}

func (*PushServiceReceiveMessageArgs) GetReq 

func (p *PushServiceReceiveMessageArgs) GetReq() (v *ReceiveMessageRequest)

func (*PushServiceReceiveMessageArgs) InitDefault 

func (p *PushServiceReceiveMessageArgs) InitDefault()

func (*PushServiceReceiveMessageArgs) IsSetReq 

func (p *PushServiceReceiveMessageArgs) IsSetReq() bool

func (*PushServiceReceiveMessageArgs) Read 

func (p *PushServiceReceiveMessageArgs) Read(iprot thrift.TProtocol) (err error)

func (*PushServiceReceiveMessageArgs) ReadField1 

func (p *PushServiceReceiveMessageArgs) ReadField1(iprot thrift.TProtocol) error

func (*PushServiceReceiveMessageArgs) SetReq 

func (p *PushServiceReceiveMessageArgs) SetReq(val *ReceiveMessageRequest)

func (*PushServiceReceiveMessageArgs) String 

func (p *PushServiceReceiveMessageArgs) String() string

func (*PushServiceReceiveMessageArgs) Write 

func (p *PushServiceReceiveMessageArgs) Write(oprot thrift.TProtocol) (err error)

type PushServiceReceiveMessageResult 

type PushServiceReceiveMessageResult struct {
	Success *ReceiveMessageResponse `thrift:"success,0,optional" frugal:"0,optional,ReceiveMessageResponse" json:"success,omitempty"`
}

func NewPushServiceReceiveMessageResult 

func NewPushServiceReceiveMessageResult() *PushServiceReceiveMessageResult

func (*PushServiceReceiveMessageResult) BLength 

func (p *PushServiceReceiveMessageResult) BLength() int

func (*PushServiceReceiveMessageResult) DeepEqual 

func (p *PushServiceReceiveMessageResult) DeepEqual(ano *PushServiceReceiveMessageResult) bool

func (*PushServiceReceiveMessageResult) FastRead 

func (p *PushServiceReceiveMessageResult) FastRead(buf []byte) (int, error)

func (*PushServiceReceiveMessageResult) FastReadField0 

func (p *PushServiceReceiveMessageResult) FastReadField0(buf []byte) (int, error)

func (*PushServiceReceiveMessageResult) FastWrite 

func (p *PushServiceReceiveMessageResult) FastWrite(buf []byte) int

for compatibility

func (*PushServiceReceiveMessageResult) FastWriteNocopy 

func (p *PushServiceReceiveMessageResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*PushServiceReceiveMessageResult) Field0DeepEqual 

func (p *PushServiceReceiveMessageResult) Field0DeepEqual(src *ReceiveMessageResponse) bool

func (*PushServiceReceiveMessageResult) GetResult 

func (p *PushServiceReceiveMessageResult) GetResult() interface{}

func (*PushServiceReceiveMessageResult) GetSuccess 

func (p *PushServiceReceiveMessageResult) GetSuccess() (v *ReceiveMessageResponse)

func (*PushServiceReceiveMessageResult) InitDefault 

func (p *PushServiceReceiveMessageResult) InitDefault()

func (*PushServiceReceiveMessageResult) IsSetSuccess 

func (p *PushServiceReceiveMessageResult) IsSetSuccess() bool

func (*PushServiceReceiveMessageResult) Read 

func (p *PushServiceReceiveMessageResult) Read(iprot thrift.TProtocol) (err error)

func (*PushServiceReceiveMessageResult) ReadField0 

func (p *PushServiceReceiveMessageResult) ReadField0(iprot thrift.TProtocol) error

func (*PushServiceReceiveMessageResult) SetSuccess 

func (p *PushServiceReceiveMessageResult) SetSuccess(x interface{})

func (*PushServiceReceiveMessageResult) String 

func (p *PushServiceReceiveMessageResult) String() string

func (*PushServiceReceiveMessageResult) Write 

func (p *PushServiceReceiveMessageResult) Write(oprot thrift.TProtocol) (err error)

type PushServiceStopMessageArgs 

type PushServiceStopMessageArgs struct {
	Req *StopMessageRequest `thrift:"req,1" frugal:"1,default,StopMessageRequest" json:"req"`
}

func NewPushServiceStopMessageArgs 

func NewPushServiceStopMessageArgs() *PushServiceStopMessageArgs

func (*PushServiceStopMessageArgs) BLength 

func (p *PushServiceStopMessageArgs) BLength() int

func (*PushServiceStopMessageArgs) DeepEqual 

func (p *PushServiceStopMessageArgs) DeepEqual(ano *PushServiceStopMessageArgs) bool

func (*PushServiceStopMessageArgs) FastRead 

func (p *PushServiceStopMessageArgs) FastRead(buf []byte) (int, error)

func (*PushServiceStopMessageArgs) FastReadField1 

func (p *PushServiceStopMessageArgs) FastReadField1(buf []byte) (int, error)

func (*PushServiceStopMessageArgs) FastWrite 

func (p *PushServiceStopMessageArgs) FastWrite(buf []byte) int

for compatibility

func (*PushServiceStopMessageArgs) FastWriteNocopy 

func (p *PushServiceStopMessageArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*PushServiceStopMessageArgs) Field1DeepEqual 

func (p *PushServiceStopMessageArgs) Field1DeepEqual(src *StopMessageRequest) bool

func (*PushServiceStopMessageArgs) GetFirstArgument 

func (p *PushServiceStopMessageArgs) GetFirstArgument() interface{}

func (*PushServiceStopMessageArgs) GetReq 

func (p *PushServiceStopMessageArgs) GetReq() (v *StopMessageRequest)

func (*PushServiceStopMessageArgs) InitDefault 

func (p *PushServiceStopMessageArgs) InitDefault()

func (*PushServiceStopMessageArgs) IsSetReq 

func (p *PushServiceStopMessageArgs) IsSetReq() bool

func (*PushServiceStopMessageArgs) Read 

func (p *PushServiceStopMessageArgs) Read(iprot thrift.TProtocol) (err error)

func (*PushServiceStopMessageArgs) ReadField1 

func (p *PushServiceStopMessageArgs) ReadField1(iprot thrift.TProtocol) error

func (*PushServiceStopMessageArgs) SetReq 

func (p *PushServiceStopMessageArgs) SetReq(val *StopMessageRequest)

func (*PushServiceStopMessageArgs) String 

func (p *PushServiceStopMessageArgs) String() string

func (*PushServiceStopMessageArgs) Write 

func (p *PushServiceStopMessageArgs) Write(oprot thrift.TProtocol) (err error)

type PushServiceStopMessageResult 

type PushServiceStopMessageResult struct {
}

func NewPushServiceStopMessageResult 

func NewPushServiceStopMessageResult() *PushServiceStopMessageResult

func (*PushServiceStopMessageResult) BLength 

func (p *PushServiceStopMessageResult) BLength() int

func (*PushServiceStopMessageResult) DeepEqual 

func (p *PushServiceStopMessageResult) DeepEqual(ano *PushServiceStopMessageResult) bool

func (*PushServiceStopMessageResult) FastRead 

func (p *PushServiceStopMessageResult) FastRead(buf []byte) (int, error)

func (*PushServiceStopMessageResult) FastWrite 

func (p *PushServiceStopMessageResult) FastWrite(buf []byte) int

for compatibility

func (*PushServiceStopMessageResult) FastWriteNocopy 

func (p *PushServiceStopMessageResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*PushServiceStopMessageResult) GetResult 

func (p *PushServiceStopMessageResult) GetResult() interface{}

func (*PushServiceStopMessageResult) InitDefault 

func (p *PushServiceStopMessageResult) InitDefault()

func (*PushServiceStopMessageResult) Read 

func (p *PushServiceStopMessageResult) Read(iprot thrift.TProtocol) (err error)

func (*PushServiceStopMessageResult) String 

func (p *PushServiceStopMessageResult) String() string

func (*PushServiceStopMessageResult) Write 

func (p *PushServiceStopMessageResult) Write(oprot thrift.TProtocol) (err error)

type PushService_ReceiveMessageServer 

type PushService_ReceiveMessageServer interface {
	streaming.Stream

	Recv() (*ReceiveMessageRequest, error)

	Send(*ReceiveMessageResponse) error
}

type ReceiveMessageRequest 

type ReceiveMessageRequest struct {
	UserId int64 `thrift:"user_id,1" frugal:"1,default,i64" json:"user_id"`
	LiveId int64 `thrift:"live_id,2" frugal:"2,default,i64" json:"live_id"`
}
var PushServiceReceiveMessageArgs_Req_DEFAULT *ReceiveMessageRequest

func NewReceiveMessageRequest 

func NewReceiveMessageRequest() *ReceiveMessageRequest

func (*ReceiveMessageRequest) BLength 

func (p *ReceiveMessageRequest) BLength() int

func (*ReceiveMessageRequest) DeepEqual 

func (p *ReceiveMessageRequest) DeepEqual(ano *ReceiveMessageRequest) bool

func (*ReceiveMessageRequest) FastRead 

func (p *ReceiveMessageRequest) FastRead(buf []byte) (int, error)

func (*ReceiveMessageRequest) FastReadField1 

func (p *ReceiveMessageRequest) FastReadField1(buf []byte) (int, error)

func (*ReceiveMessageRequest) FastReadField2 

func (p *ReceiveMessageRequest) FastReadField2(buf []byte) (int, error)

func (*ReceiveMessageRequest) FastWrite 

func (p *ReceiveMessageRequest) FastWrite(buf []byte) int

for compatibility

func (*ReceiveMessageRequest) FastWriteNocopy 

func (p *ReceiveMessageRequest) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*ReceiveMessageRequest) Field1DeepEqual 

func (p *ReceiveMessageRequest) Field1DeepEqual(src int64) bool

func (*ReceiveMessageRequest) Field2DeepEqual 

func (p *ReceiveMessageRequest) Field2DeepEqual(src int64) bool

func (*ReceiveMessageRequest) GetLiveId 

func (p *ReceiveMessageRequest) GetLiveId() (v int64)

func (*ReceiveMessageRequest) GetUserId 

func (p *ReceiveMessageRequest) GetUserId() (v int64)

func (*ReceiveMessageRequest) InitDefault 

func (p *ReceiveMessageRequest) InitDefault()

func (*ReceiveMessageRequest) Read 

func (p *ReceiveMessageRequest) Read(iprot thrift.TProtocol) (err error)

func (*ReceiveMessageRequest) ReadField1 

func (p *ReceiveMessageRequest) ReadField1(iprot thrift.TProtocol) error

func (*ReceiveMessageRequest) ReadField2 

func (p *ReceiveMessageRequest) ReadField2(iprot thrift.TProtocol) error

func (*ReceiveMessageRequest) SetLiveId 

func (p *ReceiveMessageRequest) SetLiveId(val int64)

func (*ReceiveMessageRequest) SetUserId 

func (p *ReceiveMessageRequest) SetUserId(val int64)

func (*ReceiveMessageRequest) String 

func (p *ReceiveMessageRequest) String() string

func (*ReceiveMessageRequest) Write 

func (p *ReceiveMessageRequest) Write(oprot thrift.TProtocol) (err error)

type ReceiveMessageResponse 

type ReceiveMessageResponse struct {
	Message *base.LiveMessage `thrift:"message,1" frugal:"1,default,base.LiveMessage" json:"message"`
}
var PushServiceReceiveMessageResult_Success_DEFAULT *ReceiveMessageResponse

func NewReceiveMessageResponse 

func NewReceiveMessageResponse() *ReceiveMessageResponse

func (*ReceiveMessageResponse) BLength 

func (p *ReceiveMessageResponse) BLength() int

func (*ReceiveMessageResponse) DeepEqual 

func (p *ReceiveMessageResponse) DeepEqual(ano *ReceiveMessageResponse) bool

func (*ReceiveMessageResponse) FastRead 

func (p *ReceiveMessageResponse) FastRead(buf []byte) (int, error)

func (*ReceiveMessageResponse) FastReadField1 

func (p *ReceiveMessageResponse) FastReadField1(buf []byte) (int, error)

func (*ReceiveMessageResponse) FastWrite 

func (p *ReceiveMessageResponse) FastWrite(buf []byte) int

for compatibility

func (*ReceiveMessageResponse) FastWriteNocopy 

func (p *ReceiveMessageResponse) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*ReceiveMessageResponse) Field1DeepEqual 

func (p *ReceiveMessageResponse) Field1DeepEqual(src *base.LiveMessage) bool

func (*ReceiveMessageResponse) GetMessage 

func (p *ReceiveMessageResponse) GetMessage() (v *base.LiveMessage)

func (*ReceiveMessageResponse) InitDefault 

func (p *ReceiveMessageResponse) InitDefault()

func (*ReceiveMessageResponse) IsSetMessage 

func (p *ReceiveMessageResponse) IsSetMessage() bool

func (*ReceiveMessageResponse) Read 

func (p *ReceiveMessageResponse) Read(iprot thrift.TProtocol) (err error)

func (*ReceiveMessageResponse) ReadField1 

func (p *ReceiveMessageResponse) ReadField1(iprot thrift.TProtocol) error

func (*ReceiveMessageResponse) SetMessage 

func (p *ReceiveMessageResponse) SetMessage(val *base.LiveMessage)

func (*ReceiveMessageResponse) String 

func (p *ReceiveMessageResponse) String() string

func (*ReceiveMessageResponse) Write 

func (p *ReceiveMessageResponse) Write(oprot thrift.TProtocol) (err error)

type StopMessageRequest 

type StopMessageRequest struct {
	LiveId int64 `thrift:"live_id,1" frugal:"1,default,i64" json:"live_id"`
}
var PushServiceStopMessageArgs_Req_DEFAULT *StopMessageRequest

func NewStopMessageRequest 

func NewStopMessageRequest() *StopMessageRequest

func (*StopMessageRequest) BLength 

func (p *StopMessageRequest) BLength() int

func (*StopMessageRequest) DeepEqual 

func (p *StopMessageRequest) DeepEqual(ano *StopMessageRequest) bool

func (*StopMessageRequest) FastRead 

func (p *StopMessageRequest) FastRead(buf []byte) (int, error)

func (*StopMessageRequest) FastReadField1 

func (p *StopMessageRequest) FastReadField1(buf []byte) (int, error)

func (*StopMessageRequest) FastWrite 

func (p *StopMessageRequest) FastWrite(buf []byte) int

for compatibility

func (*StopMessageRequest) FastWriteNocopy 

func (p *StopMessageRequest) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*StopMessageRequest) Field1DeepEqual 

func (p *StopMessageRequest) Field1DeepEqual(src int64) bool

func (*StopMessageRequest) GetLiveId 

func (p *StopMessageRequest) GetLiveId() (v int64)

func (*StopMessageRequest) InitDefault 

func (p *StopMessageRequest) InitDefault()

func (*StopMessageRequest) Read 

func (p *StopMessageRequest) Read(iprot thrift.TProtocol) (err error)

func (*StopMessageRequest) ReadField1 

func (p *StopMessageRequest) ReadField1(iprot thrift.TProtocol) error

func (*StopMessageRequest) SetLiveId 

func (p *StopMessageRequest) SetLiveId(val int64)

func (*StopMessageRequest) String 

func (p *StopMessageRequest) String() string

func (*StopMessageRequest) Write 

func (p *StopMessageRequest) Write(oprot thrift.TProtocol) (err error)

Source Files

View all Source files

Directories

Path Synopsis
Code generated by Kitex v0.9.1.
 Code generated by Kitex v0.9.1.

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.