lmq

package
v0.1.1 Latest Latest
Warning

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

 Go to latest Published: Apr 22, 2023 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ConsumeReq_BaseResp_DEFAULT *base.BaseResp
View Source 
var ConsumeReq_Tag_DEFAULT string
View Source 
var ConsumeReq_Topic_DEFAULT string
View Source 
var ConsumeResp_BaseResp_DEFAULT *base.BaseResp
View Source 
var PingResp_BaseResp_DEFAULT *base.BaseResp
View Source 
var ProduceReq_BaseResp_DEFAULT *base.BaseResp
View Source 
var ProduceReq_Tag_DEFAULT string
View Source 
var ProduceResp_BaseResp_DEFAULT *base.BaseResp
View Source 
var ProduceResp_MsgId_DEFAULT int64

Functions

This section is empty.

Types

type ConsumeReq 

type ConsumeReq struct {
	Topic    *string        `thrift:"topic,1,optional" form:"topic" json:"topic,omitempty"`
	Tag      *string        `thrift:"tag,2,optional" form:"tag" json:"tag,omitempty"`
	BaseResp *base.BaseResp `thrift:"baseResp,255,optional" form:"baseResp" json:"baseResp,omitempty" query:"baseResp"`
}
var LMQServiceConsumeArgs_Req_DEFAULT *ConsumeReq

func NewConsumeReq 

func NewConsumeReq() *ConsumeReq

func (*ConsumeReq) GetBaseResp 

func (p *ConsumeReq) GetBaseResp() (v *base.BaseResp)

func (*ConsumeReq) GetTag 

func (p *ConsumeReq) GetTag() (v string)

func (*ConsumeReq) GetTopic 

func (p *ConsumeReq) GetTopic() (v string)

func (*ConsumeReq) IsSetBaseResp 

func (p *ConsumeReq) IsSetBaseResp() bool

func (*ConsumeReq) IsSetTag 

func (p *ConsumeReq) IsSetTag() bool

func (*ConsumeReq) IsSetTopic 

func (p *ConsumeReq) IsSetTopic() bool

func (*ConsumeReq) Read 

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

func (*ConsumeReq) ReadField1 

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

func (*ConsumeReq) ReadField2 

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

func (*ConsumeReq) ReadField255 

func (p *ConsumeReq) ReadField255(iprot thrift.TProtocol) error

func (*ConsumeReq) String 

func (p *ConsumeReq) String() string

func (*ConsumeReq) Write 

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

type ConsumeResp 

type ConsumeResp struct {
	BaseResp *base.BaseResp `thrift:"baseResp,255,optional" form:"baseResp" json:"baseResp,omitempty" query:"baseResp"`
}
var LMQServiceConsumeResult_Success_DEFAULT *ConsumeResp

func NewConsumeResp 

func NewConsumeResp() *ConsumeResp

func (*ConsumeResp) GetBaseResp 

func (p *ConsumeResp) GetBaseResp() (v *base.BaseResp)

func (*ConsumeResp) IsSetBaseResp 

func (p *ConsumeResp) IsSetBaseResp() bool

func (*ConsumeResp) Read 

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

func (*ConsumeResp) ReadField255 

func (p *ConsumeResp) ReadField255(iprot thrift.TProtocol) error

func (*ConsumeResp) String 

func (p *ConsumeResp) String() string

func (*ConsumeResp) Write 

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

type LMQService 

type LMQService interface {
	Ping(ctx context.Context, request *PingReq) (r *PingResp, err error)

	Produce(ctx context.Context, req *ProduceReq) (r *ProduceResp, err error)

	Consume(ctx context.Context, req *ConsumeReq) (r *ConsumeResp, err error)
}

type LMQServiceClient 

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

func NewLMQServiceClient 

func NewLMQServiceClient(c thrift.TClient) *LMQServiceClient

func NewLMQServiceClientFactory 

func NewLMQServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *LMQServiceClient

func NewLMQServiceClientProtocol 

func NewLMQServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *LMQServiceClient

func (*LMQServiceClient) Client_ 

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

func (*LMQServiceClient) Consume 

func (p *LMQServiceClient) Consume(ctx context.Context, req *ConsumeReq) (r *ConsumeResp, err error)

func (*LMQServiceClient) Ping 

func (p *LMQServiceClient) Ping(ctx context.Context, request *PingReq) (r *PingResp, err error)

func (*LMQServiceClient) Produce 

func (p *LMQServiceClient) Produce(ctx context.Context, req *ProduceReq) (r *ProduceResp, err error)

type LMQServiceConsumeArgs 

type LMQServiceConsumeArgs struct {
	Req *ConsumeReq `thrift:"req,1"`
}

func NewLMQServiceConsumeArgs 

func NewLMQServiceConsumeArgs() *LMQServiceConsumeArgs

func (*LMQServiceConsumeArgs) GetReq 

func (p *LMQServiceConsumeArgs) GetReq() (v *ConsumeReq)

func (*LMQServiceConsumeArgs) IsSetReq 

func (p *LMQServiceConsumeArgs) IsSetReq() bool

func (*LMQServiceConsumeArgs) Read 

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

func (*LMQServiceConsumeArgs) ReadField1 

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

func (*LMQServiceConsumeArgs) String 

func (p *LMQServiceConsumeArgs) String() string

func (*LMQServiceConsumeArgs) Write 

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

type LMQServiceConsumeResult 

type LMQServiceConsumeResult struct {
	Success *ConsumeResp `thrift:"success,0,optional"`
}

func NewLMQServiceConsumeResult 

func NewLMQServiceConsumeResult() *LMQServiceConsumeResult

func (*LMQServiceConsumeResult) GetSuccess 

func (p *LMQServiceConsumeResult) GetSuccess() (v *ConsumeResp)

func (*LMQServiceConsumeResult) IsSetSuccess 

func (p *LMQServiceConsumeResult) IsSetSuccess() bool

func (*LMQServiceConsumeResult) Read 

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

func (*LMQServiceConsumeResult) ReadField0 

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

func (*LMQServiceConsumeResult) String 

func (p *LMQServiceConsumeResult) String() string

func (*LMQServiceConsumeResult) Write 

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

type LMQServicePingArgs 

type LMQServicePingArgs struct {
	Request *PingReq `thrift:"request,1"`
}

func NewLMQServicePingArgs 

func NewLMQServicePingArgs() *LMQServicePingArgs

func (*LMQServicePingArgs) GetRequest 

func (p *LMQServicePingArgs) GetRequest() (v *PingReq)

func (*LMQServicePingArgs) IsSetRequest 

func (p *LMQServicePingArgs) IsSetRequest() bool

func (*LMQServicePingArgs) Read 

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

func (*LMQServicePingArgs) ReadField1 

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

func (*LMQServicePingArgs) String 

func (p *LMQServicePingArgs) String() string

func (*LMQServicePingArgs) Write 

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

type LMQServicePingResult 

type LMQServicePingResult struct {
	Success *PingResp `thrift:"success,0,optional"`
}

func NewLMQServicePingResult 

func NewLMQServicePingResult() *LMQServicePingResult

func (*LMQServicePingResult) GetSuccess 

func (p *LMQServicePingResult) GetSuccess() (v *PingResp)

func (*LMQServicePingResult) IsSetSuccess 

func (p *LMQServicePingResult) IsSetSuccess() bool

func (*LMQServicePingResult) Read 

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

func (*LMQServicePingResult) ReadField0 

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

func (*LMQServicePingResult) String 

func (p *LMQServicePingResult) String() string

func (*LMQServicePingResult) Write 

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

type LMQServiceProcessor 

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

func NewLMQServiceProcessor 

func NewLMQServiceProcessor(handler LMQService) *LMQServiceProcessor

func (*LMQServiceProcessor) AddToProcessorMap 

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

func (*LMQServiceProcessor) GetProcessorFunction 

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

func (*LMQServiceProcessor) Process 

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

func (*LMQServiceProcessor) ProcessorMap 

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

type LMQServiceProduceArgs 

type LMQServiceProduceArgs struct {
	Req *ProduceReq `thrift:"req,1"`
}

func NewLMQServiceProduceArgs 

func NewLMQServiceProduceArgs() *LMQServiceProduceArgs

func (*LMQServiceProduceArgs) GetReq 

func (p *LMQServiceProduceArgs) GetReq() (v *ProduceReq)

func (*LMQServiceProduceArgs) IsSetReq 

func (p *LMQServiceProduceArgs) IsSetReq() bool

func (*LMQServiceProduceArgs) Read 

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

func (*LMQServiceProduceArgs) ReadField1 

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

func (*LMQServiceProduceArgs) String 

func (p *LMQServiceProduceArgs) String() string

func (*LMQServiceProduceArgs) Write 

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

type LMQServiceProduceResult 

type LMQServiceProduceResult struct {
	Success *ProduceResp `thrift:"success,0,optional"`
}

func NewLMQServiceProduceResult 

func NewLMQServiceProduceResult() *LMQServiceProduceResult

func (*LMQServiceProduceResult) GetSuccess 

func (p *LMQServiceProduceResult) GetSuccess() (v *ProduceResp)

func (*LMQServiceProduceResult) IsSetSuccess 

func (p *LMQServiceProduceResult) IsSetSuccess() bool

func (*LMQServiceProduceResult) Read 

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

func (*LMQServiceProduceResult) ReadField0 

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

func (*LMQServiceProduceResult) String 

func (p *LMQServiceProduceResult) String() string

func (*LMQServiceProduceResult) Write 

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

type PingReq 

type PingReq struct {
	Msg string `thrift:"msg,1" form:"msg" json:"msg"`
}
var LMQServicePingArgs_Request_DEFAULT *PingReq

func NewPingReq 

func NewPingReq() *PingReq

func (*PingReq) GetMsg 

func (p *PingReq) GetMsg() (v string)

func (*PingReq) Read 

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

func (*PingReq) ReadField1 

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

func (*PingReq) String 

func (p *PingReq) String() string

func (*PingReq) Write 

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

type PingResp 

type PingResp struct {
	Msg      string         `thrift:"msg,1" form:"msg" json:"msg"`
	BaseResp *base.BaseResp `thrift:"baseResp,255,optional" form:"baseResp" json:"baseResp,omitempty" query:"baseResp"`
}
var LMQServicePingResult_Success_DEFAULT *PingResp

func NewPingResp 

func NewPingResp() *PingResp

func (*PingResp) GetBaseResp 

func (p *PingResp) GetBaseResp() (v *base.BaseResp)

func (*PingResp) GetMsg 

func (p *PingResp) GetMsg() (v string)

func (*PingResp) IsSetBaseResp 

func (p *PingResp) IsSetBaseResp() bool

func (*PingResp) Read 

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

func (*PingResp) ReadField1 

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

func (*PingResp) ReadField255 

func (p *PingResp) ReadField255(iprot thrift.TProtocol) error

func (*PingResp) String 

func (p *PingResp) String() string

func (*PingResp) Write 

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

type ProduceReq 

type ProduceReq struct {
	Topic    string         `thrift:"topic,1,required" form:"topic,required" json:"topic,required"`
	Tag      *string        `thrift:"tag,2,optional" form:"tag" json:"tag,omitempty"`
	BaseResp *base.BaseResp `thrift:"baseResp,255,optional" form:"baseResp" json:"baseResp,omitempty" query:"baseResp"`
}
var LMQServiceProduceArgs_Req_DEFAULT *ProduceReq

func NewProduceReq 

func NewProduceReq() *ProduceReq

func (*ProduceReq) GetBaseResp 

func (p *ProduceReq) GetBaseResp() (v *base.BaseResp)

func (*ProduceReq) GetTag 

func (p *ProduceReq) GetTag() (v string)

func (*ProduceReq) GetTopic 

func (p *ProduceReq) GetTopic() (v string)

func (*ProduceReq) IsSetBaseResp 

func (p *ProduceReq) IsSetBaseResp() bool

func (*ProduceReq) IsSetTag 

func (p *ProduceReq) IsSetTag() bool

func (*ProduceReq) Read 

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

func (*ProduceReq) ReadField1 

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

func (*ProduceReq) ReadField2 

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

func (*ProduceReq) ReadField255 

func (p *ProduceReq) ReadField255(iprot thrift.TProtocol) error

func (*ProduceReq) String 

func (p *ProduceReq) String() string

func (*ProduceReq) Write 

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

type ProduceResp 

type ProduceResp struct {
	MsgId    *int64         `thrift:"msgId,1,optional" form:"msg_id" json:"msg_id,omitempty"`
	BaseResp *base.BaseResp `thrift:"baseResp,255,optional" form:"baseResp" json:"baseResp,omitempty" query:"baseResp"`
}
var LMQServiceProduceResult_Success_DEFAULT *ProduceResp

func NewProduceResp 

func NewProduceResp() *ProduceResp

func (*ProduceResp) GetBaseResp 

func (p *ProduceResp) GetBaseResp() (v *base.BaseResp)

func (*ProduceResp) GetMsgId 

func (p *ProduceResp) GetMsgId() (v int64)

func (*ProduceResp) IsSetBaseResp 

func (p *ProduceResp) IsSetBaseResp() bool

func (*ProduceResp) IsSetMsgId 

func (p *ProduceResp) IsSetMsgId() bool

func (*ProduceResp) Read 

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

func (*ProduceResp) ReadField1 

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

func (*ProduceResp) ReadField255 

func (p *ProduceResp) ReadField255(iprot thrift.TProtocol) error

func (*ProduceResp) String 

func (p *ProduceResp) String() string

func (*ProduceResp) Write 

func (p *ProduceResp) Write(oprot thrift.TProtocol) (err 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.