record

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: 7 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.

Functions

This section is empty.

Types

type GetRecordListRequest 

type GetRecordListRequest struct {
	LiveId int64 `thrift:"liveId,1" frugal:"1,default,i64" json:"liveId"`
}

func NewGetRecordListRequest 

func NewGetRecordListRequest() *GetRecordListRequest

func (*GetRecordListRequest) BLength 

func (p *GetRecordListRequest) BLength() int

func (*GetRecordListRequest) DeepEqual 

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

func (*GetRecordListRequest) FastRead 

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

func (*GetRecordListRequest) FastReadField1 

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

func (*GetRecordListRequest) FastWrite 

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

for compatibility

func (*GetRecordListRequest) FastWriteNocopy 

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

func (*GetRecordListRequest) Field1DeepEqual 

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

func (*GetRecordListRequest) GetLiveId 

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

func (*GetRecordListRequest) InitDefault 

func (p *GetRecordListRequest) InitDefault()

func (*GetRecordListRequest) Read 

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

func (*GetRecordListRequest) ReadField1 

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

func (*GetRecordListRequest) SetLiveId 

func (p *GetRecordListRequest) SetLiveId(val int64)

func (*GetRecordListRequest) String 

func (p *GetRecordListRequest) String() string

func (*GetRecordListRequest) Write 

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

type RecordService 

type RecordService interface {
	StartRecord(ctx context.Context, req *StartRecordRecordRequest) (err error)

	StopRecord(ctx context.Context, req *StopRecordRecordRequest) (err error)
}

type RecordServiceClient 

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

func NewRecordServiceClient 

func NewRecordServiceClient(c thrift.TClient) *RecordServiceClient

func NewRecordServiceClientFactory 

func NewRecordServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *RecordServiceClient

func NewRecordServiceClientProtocol 

func NewRecordServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *RecordServiceClient

func (*RecordServiceClient) Client_ 

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

func (*RecordServiceClient) StartRecord 

func (p *RecordServiceClient) StartRecord(ctx context.Context, req *StartRecordRecordRequest) (err error)

func (*RecordServiceClient) StopRecord 

func (p *RecordServiceClient) StopRecord(ctx context.Context, req *StopRecordRecordRequest) (err error)

type RecordServiceProcessor 

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

func NewRecordServiceProcessor 

func NewRecordServiceProcessor(handler RecordService) *RecordServiceProcessor

func (*RecordServiceProcessor) AddToProcessorMap 

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

func (*RecordServiceProcessor) GetProcessorFunction 

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

func (*RecordServiceProcessor) Process 

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

func (*RecordServiceProcessor) ProcessorMap 

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

type RecordServiceStartRecordArgs 

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

func NewRecordServiceStartRecordArgs 

func NewRecordServiceStartRecordArgs() *RecordServiceStartRecordArgs

func (*RecordServiceStartRecordArgs) BLength 

func (p *RecordServiceStartRecordArgs) BLength() int

func (*RecordServiceStartRecordArgs) DeepEqual 

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

func (*RecordServiceStartRecordArgs) FastRead 

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

func (*RecordServiceStartRecordArgs) FastReadField1 

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

func (*RecordServiceStartRecordArgs) FastWrite 

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

for compatibility

func (*RecordServiceStartRecordArgs) FastWriteNocopy 

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

func (*RecordServiceStartRecordArgs) Field1DeepEqual 

func (p *RecordServiceStartRecordArgs) Field1DeepEqual(src *StartRecordRecordRequest) bool

func (*RecordServiceStartRecordArgs) GetFirstArgument 

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

func (*RecordServiceStartRecordArgs) GetReq 

func (p *RecordServiceStartRecordArgs) GetReq() (v *StartRecordRecordRequest)

func (*RecordServiceStartRecordArgs) InitDefault 

func (p *RecordServiceStartRecordArgs) InitDefault()

func (*RecordServiceStartRecordArgs) IsSetReq 

func (p *RecordServiceStartRecordArgs) IsSetReq() bool

func (*RecordServiceStartRecordArgs) Read 

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

func (*RecordServiceStartRecordArgs) ReadField1 

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

func (*RecordServiceStartRecordArgs) SetReq 

func (p *RecordServiceStartRecordArgs) SetReq(val *StartRecordRecordRequest)

func (*RecordServiceStartRecordArgs) String 

func (p *RecordServiceStartRecordArgs) String() string

func (*RecordServiceStartRecordArgs) Write 

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

type RecordServiceStartRecordResult 

type RecordServiceStartRecordResult struct {
}

func NewRecordServiceStartRecordResult 

func NewRecordServiceStartRecordResult() *RecordServiceStartRecordResult

func (*RecordServiceStartRecordResult) BLength 

func (p *RecordServiceStartRecordResult) BLength() int

func (*RecordServiceStartRecordResult) DeepEqual 

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

func (*RecordServiceStartRecordResult) FastRead 

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

func (*RecordServiceStartRecordResult) FastWrite 

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

for compatibility

func (*RecordServiceStartRecordResult) FastWriteNocopy 

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

func (*RecordServiceStartRecordResult) GetResult 

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

func (*RecordServiceStartRecordResult) InitDefault 

func (p *RecordServiceStartRecordResult) InitDefault()

func (*RecordServiceStartRecordResult) Read 

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

func (*RecordServiceStartRecordResult) String 

func (p *RecordServiceStartRecordResult) String() string

func (*RecordServiceStartRecordResult) Write 

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

type RecordServiceStopRecordArgs 

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

func NewRecordServiceStopRecordArgs 

func NewRecordServiceStopRecordArgs() *RecordServiceStopRecordArgs

func (*RecordServiceStopRecordArgs) BLength 

func (p *RecordServiceStopRecordArgs) BLength() int

func (*RecordServiceStopRecordArgs) DeepEqual 

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

func (*RecordServiceStopRecordArgs) FastRead 

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

func (*RecordServiceStopRecordArgs) FastReadField1 

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

func (*RecordServiceStopRecordArgs) FastWrite 

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

for compatibility

func (*RecordServiceStopRecordArgs) FastWriteNocopy 

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

func (*RecordServiceStopRecordArgs) Field1DeepEqual 

func (p *RecordServiceStopRecordArgs) Field1DeepEqual(src *StopRecordRecordRequest) bool

func (*RecordServiceStopRecordArgs) GetFirstArgument 

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

func (*RecordServiceStopRecordArgs) GetReq 

func (p *RecordServiceStopRecordArgs) GetReq() (v *StopRecordRecordRequest)

func (*RecordServiceStopRecordArgs) InitDefault 

func (p *RecordServiceStopRecordArgs) InitDefault()

func (*RecordServiceStopRecordArgs) IsSetReq 

func (p *RecordServiceStopRecordArgs) IsSetReq() bool

func (*RecordServiceStopRecordArgs) Read 

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

func (*RecordServiceStopRecordArgs) ReadField1 

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

func (*RecordServiceStopRecordArgs) SetReq 

func (p *RecordServiceStopRecordArgs) SetReq(val *StopRecordRecordRequest)

func (*RecordServiceStopRecordArgs) String 

func (p *RecordServiceStopRecordArgs) String() string

func (*RecordServiceStopRecordArgs) Write 

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

type RecordServiceStopRecordResult 

type RecordServiceStopRecordResult struct {
}

func NewRecordServiceStopRecordResult 

func NewRecordServiceStopRecordResult() *RecordServiceStopRecordResult

func (*RecordServiceStopRecordResult) BLength 

func (p *RecordServiceStopRecordResult) BLength() int

func (*RecordServiceStopRecordResult) DeepEqual 

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

func (*RecordServiceStopRecordResult) FastRead 

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

func (*RecordServiceStopRecordResult) FastWrite 

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

for compatibility

func (*RecordServiceStopRecordResult) FastWriteNocopy 

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

func (*RecordServiceStopRecordResult) GetResult 

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

func (*RecordServiceStopRecordResult) InitDefault 

func (p *RecordServiceStopRecordResult) InitDefault()

func (*RecordServiceStopRecordResult) Read 

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

func (*RecordServiceStopRecordResult) String 

func (p *RecordServiceStopRecordResult) String() string

func (*RecordServiceStopRecordResult) Write 

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

type StartRecordRecordRequest 

type StartRecordRecordRequest struct {
	LiveId int64 `thrift:"liveId,1" frugal:"1,default,i64" json:"liveId"`
}
var RecordServiceStartRecordArgs_Req_DEFAULT *StartRecordRecordRequest

func NewStartRecordRecordRequest 

func NewStartRecordRecordRequest() *StartRecordRecordRequest

func (*StartRecordRecordRequest) BLength 

func (p *StartRecordRecordRequest) BLength() int

func (*StartRecordRecordRequest) DeepEqual 

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

func (*StartRecordRecordRequest) FastRead 

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

func (*StartRecordRecordRequest) FastReadField1 

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

func (*StartRecordRecordRequest) FastWrite 

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

for compatibility

func (*StartRecordRecordRequest) FastWriteNocopy 

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

func (*StartRecordRecordRequest) Field1DeepEqual 

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

func (*StartRecordRecordRequest) GetLiveId 

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

func (*StartRecordRecordRequest) InitDefault 

func (p *StartRecordRecordRequest) InitDefault()

func (*StartRecordRecordRequest) Read 

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

func (*StartRecordRecordRequest) ReadField1 

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

func (*StartRecordRecordRequest) SetLiveId 

func (p *StartRecordRecordRequest) SetLiveId(val int64)

func (*StartRecordRecordRequest) String 

func (p *StartRecordRecordRequest) String() string

func (*StartRecordRecordRequest) Write 

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

type StopRecordRecordRequest 

type StopRecordRecordRequest struct {
	LiveId int64 `thrift:"liveId,1" frugal:"1,default,i64" json:"liveId"`
}
var RecordServiceStopRecordArgs_Req_DEFAULT *StopRecordRecordRequest

func NewStopRecordRecordRequest 

func NewStopRecordRecordRequest() *StopRecordRecordRequest

func (*StopRecordRecordRequest) BLength 

func (p *StopRecordRecordRequest) BLength() int

func (*StopRecordRecordRequest) DeepEqual 

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

func (*StopRecordRecordRequest) FastRead 

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

func (*StopRecordRecordRequest) FastReadField1 

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

func (*StopRecordRecordRequest) FastWrite 

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

for compatibility

func (*StopRecordRecordRequest) FastWriteNocopy 

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

func (*StopRecordRecordRequest) Field1DeepEqual 

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

func (*StopRecordRecordRequest) GetLiveId 

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

func (*StopRecordRecordRequest) InitDefault 

func (p *StopRecordRecordRequest) InitDefault()

func (*StopRecordRecordRequest) Read 

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

func (*StopRecordRecordRequest) ReadField1 

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

func (*StopRecordRecordRequest) SetLiveId 

func (p *StopRecordRecordRequest) SetLiveId(val int64)

func (*StopRecordRecordRequest) String 

func (p *StopRecordRecordRequest) String() string

func (*StopRecordRecordRequest) Write 

func (p *StopRecordRecordRequest) 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.