delay

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 DelayTaskRequest 

type DelayTaskRequest struct {
	Id      int64 `thrift:"id,1" frugal:"1,default,i64" json:"id"`
	EndTime int64 `thrift:"end_time,2" frugal:"2,default,i64" json:"end_time"`
}
var DelayTaskServiceDelayTaskArgs_Req_DEFAULT *DelayTaskRequest

func NewDelayTaskRequest 

func NewDelayTaskRequest() *DelayTaskRequest

func (*DelayTaskRequest) BLength 

func (p *DelayTaskRequest) BLength() int

func (*DelayTaskRequest) DeepEqual 

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

func (*DelayTaskRequest) FastRead 

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

func (*DelayTaskRequest) FastReadField1 

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

func (*DelayTaskRequest) FastReadField2 

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

func (*DelayTaskRequest) FastWrite 

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

for compatibility

func (*DelayTaskRequest) FastWriteNocopy 

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

func (*DelayTaskRequest) Field1DeepEqual 

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

func (*DelayTaskRequest) Field2DeepEqual 

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

func (*DelayTaskRequest) GetEndTime 

func (p *DelayTaskRequest) GetEndTime() (v int64)

func (*DelayTaskRequest) GetId 

func (p *DelayTaskRequest) GetId() (v int64)

func (*DelayTaskRequest) InitDefault 

func (p *DelayTaskRequest) InitDefault()

func (*DelayTaskRequest) Read 

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

func (*DelayTaskRequest) ReadField1 

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

func (*DelayTaskRequest) ReadField2 

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

func (*DelayTaskRequest) SetEndTime 

func (p *DelayTaskRequest) SetEndTime(val int64)

func (*DelayTaskRequest) SetId 

func (p *DelayTaskRequest) SetId(val int64)

func (*DelayTaskRequest) String 

func (p *DelayTaskRequest) String() string

func (*DelayTaskRequest) Write 

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

type DelayTaskService 

type DelayTaskService interface {
	DelayTask(ctx context.Context, req *DelayTaskRequest) (err error)
}

type DelayTaskServiceClient 

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

func NewDelayTaskServiceClient 

func NewDelayTaskServiceClient(c thrift.TClient) *DelayTaskServiceClient

func NewDelayTaskServiceClientFactory 

func NewDelayTaskServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *DelayTaskServiceClient

func NewDelayTaskServiceClientProtocol 

func NewDelayTaskServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *DelayTaskServiceClient

func (*DelayTaskServiceClient) Client_ 

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

func (*DelayTaskServiceClient) DelayTask 

func (p *DelayTaskServiceClient) DelayTask(ctx context.Context, req *DelayTaskRequest) (err error)

type DelayTaskServiceDelayTaskArgs 

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

func NewDelayTaskServiceDelayTaskArgs 

func NewDelayTaskServiceDelayTaskArgs() *DelayTaskServiceDelayTaskArgs

func (*DelayTaskServiceDelayTaskArgs) BLength 

func (p *DelayTaskServiceDelayTaskArgs) BLength() int

func (*DelayTaskServiceDelayTaskArgs) DeepEqual 

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

func (*DelayTaskServiceDelayTaskArgs) FastRead 

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

func (*DelayTaskServiceDelayTaskArgs) FastReadField1 

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

func (*DelayTaskServiceDelayTaskArgs) FastWrite 

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

for compatibility

func (*DelayTaskServiceDelayTaskArgs) FastWriteNocopy 

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

func (*DelayTaskServiceDelayTaskArgs) Field1DeepEqual 

func (p *DelayTaskServiceDelayTaskArgs) Field1DeepEqual(src *DelayTaskRequest) bool

func (*DelayTaskServiceDelayTaskArgs) GetFirstArgument 

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

func (*DelayTaskServiceDelayTaskArgs) GetReq 

func (p *DelayTaskServiceDelayTaskArgs) GetReq() (v *DelayTaskRequest)

func (*DelayTaskServiceDelayTaskArgs) InitDefault 

func (p *DelayTaskServiceDelayTaskArgs) InitDefault()

func (*DelayTaskServiceDelayTaskArgs) IsSetReq 

func (p *DelayTaskServiceDelayTaskArgs) IsSetReq() bool

func (*DelayTaskServiceDelayTaskArgs) Read 

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

func (*DelayTaskServiceDelayTaskArgs) ReadField1 

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

func (*DelayTaskServiceDelayTaskArgs) SetReq 

func (p *DelayTaskServiceDelayTaskArgs) SetReq(val *DelayTaskRequest)

func (*DelayTaskServiceDelayTaskArgs) String 

func (p *DelayTaskServiceDelayTaskArgs) String() string

func (*DelayTaskServiceDelayTaskArgs) Write 

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

type DelayTaskServiceDelayTaskResult 

type DelayTaskServiceDelayTaskResult struct {
}

func NewDelayTaskServiceDelayTaskResult 

func NewDelayTaskServiceDelayTaskResult() *DelayTaskServiceDelayTaskResult

func (*DelayTaskServiceDelayTaskResult) BLength 

func (p *DelayTaskServiceDelayTaskResult) BLength() int

func (*DelayTaskServiceDelayTaskResult) DeepEqual 

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

func (*DelayTaskServiceDelayTaskResult) FastRead 

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

func (*DelayTaskServiceDelayTaskResult) FastWrite 

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

for compatibility

func (*DelayTaskServiceDelayTaskResult) FastWriteNocopy 

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

func (*DelayTaskServiceDelayTaskResult) GetResult 

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

func (*DelayTaskServiceDelayTaskResult) InitDefault 

func (p *DelayTaskServiceDelayTaskResult) InitDefault()

func (*DelayTaskServiceDelayTaskResult) Read 

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

func (*DelayTaskServiceDelayTaskResult) String 

func (p *DelayTaskServiceDelayTaskResult) String() string

func (*DelayTaskServiceDelayTaskResult) Write 

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

type DelayTaskServiceProcessor 

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

func NewDelayTaskServiceProcessor 

func NewDelayTaskServiceProcessor(handler DelayTaskService) *DelayTaskServiceProcessor

func (*DelayTaskServiceProcessor) AddToProcessorMap 

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

func (*DelayTaskServiceProcessor) GetProcessorFunction 

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

func (*DelayTaskServiceProcessor) Process 

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

func (*DelayTaskServiceProcessor) ProcessorMap 

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

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.