mq

package
v0.0.0-...-20002e4 Latest Latest
Warning

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

 Go to latest Published: Jun 9, 2023 License: Apache-2.0 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 AddChannelReq 

type AddChannelReq struct {
	TopicName string   `thrift:"topic_name,1" frugal:"1,default,string" json:"topic_name"`
	Channel   *Channel `thrift:"channel,2" frugal:"2,default,Channel" json:"channel"`
}
var MqServiceAddChannelArgs_Req_DEFAULT *AddChannelReq

func NewAddChannelReq 

func NewAddChannelReq() *AddChannelReq

func (*AddChannelReq) BLength 

func (p *AddChannelReq) BLength() int

func (*AddChannelReq) DeepEqual 

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

func (*AddChannelReq) FastRead 

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

func (*AddChannelReq) FastReadField1 

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

func (*AddChannelReq) FastReadField2 

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

func (*AddChannelReq) FastWrite 

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

for compatibility

func (*AddChannelReq) FastWriteNocopy 

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

func (*AddChannelReq) Field1DeepEqual 

func (p *AddChannelReq) Field1DeepEqual(src string) bool

func (*AddChannelReq) Field2DeepEqual 

func (p *AddChannelReq) Field2DeepEqual(src *Channel) bool

func (*AddChannelReq) GetChannel 

func (p *AddChannelReq) GetChannel() (v *Channel)

func (*AddChannelReq) GetTopicName 

func (p *AddChannelReq) GetTopicName() (v string)

func (*AddChannelReq) InitDefault 

func (p *AddChannelReq) InitDefault()

func (*AddChannelReq) IsSetChannel 

func (p *AddChannelReq) IsSetChannel() bool

func (*AddChannelReq) Read 

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

func (*AddChannelReq) ReadField1 

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

func (*AddChannelReq) ReadField2 

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

func (*AddChannelReq) SetChannel 

func (p *AddChannelReq) SetChannel(val *Channel)

func (*AddChannelReq) SetTopicName 

func (p *AddChannelReq) SetTopicName(val string)

func (*AddChannelReq) String 

func (p *AddChannelReq) String() string

func (*AddChannelReq) Write 

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

type AddChannelResp 

type AddChannelResp struct {
	Channel *Channel `thrift:"channel,1" frugal:"1,default,Channel" json:"channel"`
}
var MqServiceAddChannelResult_Success_DEFAULT *AddChannelResp

func NewAddChannelResp 

func NewAddChannelResp() *AddChannelResp

func (*AddChannelResp) BLength 

func (p *AddChannelResp) BLength() int

func (*AddChannelResp) DeepEqual 

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

func (*AddChannelResp) FastRead 

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

func (*AddChannelResp) FastReadField1 

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

func (*AddChannelResp) FastWrite 

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

for compatibility

func (*AddChannelResp) FastWriteNocopy 

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

func (*AddChannelResp) Field1DeepEqual 

func (p *AddChannelResp) Field1DeepEqual(src *Channel) bool

func (*AddChannelResp) GetChannel 

func (p *AddChannelResp) GetChannel() (v *Channel)

func (*AddChannelResp) InitDefault 

func (p *AddChannelResp) InitDefault()

func (*AddChannelResp) IsSetChannel 

func (p *AddChannelResp) IsSetChannel() bool

func (*AddChannelResp) Read 

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

func (*AddChannelResp) ReadField1 

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

func (*AddChannelResp) SetChannel 

func (p *AddChannelResp) SetChannel(val *Channel)

func (*AddChannelResp) String 

func (p *AddChannelResp) String() string

func (*AddChannelResp) Write 

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

type Channel 

type Channel struct {
	Name      string     `thrift:"name,1" frugal:"1,default,string" json:"name"`
	SubConfig *SubConfig `thrift:"sub_config,2" frugal:"2,default,SubConfig" json:"sub_config"`
}
var AddChannelReq_Channel_DEFAULT *Channel
var AddChannelResp_Channel_DEFAULT *Channel

func NewChannel 

func NewChannel() *Channel

func (*Channel) BLength 

func (p *Channel) BLength() int

func (*Channel) DeepEqual 

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

func (*Channel) FastRead 

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

func (*Channel) FastReadField1 

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

func (*Channel) FastReadField2 

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

func (*Channel) FastWrite 

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

for compatibility

func (*Channel) FastWriteNocopy 

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

func (*Channel) Field1DeepEqual 

func (p *Channel) Field1DeepEqual(src string) bool

func (*Channel) Field2DeepEqual 

func (p *Channel) Field2DeepEqual(src *SubConfig) bool

func (*Channel) GetName 

func (p *Channel) GetName() (v string)

func (*Channel) GetSubConfig 

func (p *Channel) GetSubConfig() (v *SubConfig)

func (*Channel) InitDefault 

func (p *Channel) InitDefault()

func (*Channel) IsSetSubConfig 

func (p *Channel) IsSetSubConfig() bool

func (*Channel) Read 

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

func (*Channel) ReadField1 

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

func (*Channel) ReadField2 

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

func (*Channel) SetName 

func (p *Channel) SetName(val string)

func (*Channel) SetSubConfig 

func (p *Channel) SetSubConfig(val *SubConfig)

func (*Channel) String 

func (p *Channel) String() string

func (*Channel) Write 

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

type MqService 

type MqService interface {
	AddChannel(ctx context.Context, req *AddChannelReq) (r *AddChannelResp, err error)
}

type MqServiceAddChannelArgs 

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

func NewMqServiceAddChannelArgs 

func NewMqServiceAddChannelArgs() *MqServiceAddChannelArgs

func (*MqServiceAddChannelArgs) BLength 

func (p *MqServiceAddChannelArgs) BLength() int

func (*MqServiceAddChannelArgs) DeepEqual 

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

func (*MqServiceAddChannelArgs) FastRead 

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

func (*MqServiceAddChannelArgs) FastReadField1 

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

func (*MqServiceAddChannelArgs) FastWrite 

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

for compatibility

func (*MqServiceAddChannelArgs) FastWriteNocopy 

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

func (*MqServiceAddChannelArgs) Field1DeepEqual 

func (p *MqServiceAddChannelArgs) Field1DeepEqual(src *AddChannelReq) bool

func (*MqServiceAddChannelArgs) GetFirstArgument 

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

func (*MqServiceAddChannelArgs) GetReq 

func (p *MqServiceAddChannelArgs) GetReq() (v *AddChannelReq)

func (*MqServiceAddChannelArgs) InitDefault 

func (p *MqServiceAddChannelArgs) InitDefault()

func (*MqServiceAddChannelArgs) IsSetReq 

func (p *MqServiceAddChannelArgs) IsSetReq() bool

func (*MqServiceAddChannelArgs) Read 

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

func (*MqServiceAddChannelArgs) ReadField1 

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

func (*MqServiceAddChannelArgs) SetReq 

func (p *MqServiceAddChannelArgs) SetReq(val *AddChannelReq)

func (*MqServiceAddChannelArgs) String 

func (p *MqServiceAddChannelArgs) String() string

func (*MqServiceAddChannelArgs) Write 

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

type MqServiceAddChannelResult 

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

func NewMqServiceAddChannelResult 

func NewMqServiceAddChannelResult() *MqServiceAddChannelResult

func (*MqServiceAddChannelResult) BLength 

func (p *MqServiceAddChannelResult) BLength() int

func (*MqServiceAddChannelResult) DeepEqual 

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

func (*MqServiceAddChannelResult) FastRead 

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

func (*MqServiceAddChannelResult) FastReadField0 

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

func (*MqServiceAddChannelResult) FastWrite 

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

for compatibility

func (*MqServiceAddChannelResult) FastWriteNocopy 

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

func (*MqServiceAddChannelResult) Field0DeepEqual 

func (p *MqServiceAddChannelResult) Field0DeepEqual(src *AddChannelResp) bool

func (*MqServiceAddChannelResult) GetResult 

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

func (*MqServiceAddChannelResult) GetSuccess 

func (p *MqServiceAddChannelResult) GetSuccess() (v *AddChannelResp)

func (*MqServiceAddChannelResult) InitDefault 

func (p *MqServiceAddChannelResult) InitDefault()

func (*MqServiceAddChannelResult) IsSetSuccess 

func (p *MqServiceAddChannelResult) IsSetSuccess() bool

func (*MqServiceAddChannelResult) Read 

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

func (*MqServiceAddChannelResult) ReadField0 

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

func (*MqServiceAddChannelResult) SetSuccess 

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

func (*MqServiceAddChannelResult) String 

func (p *MqServiceAddChannelResult) String() string

func (*MqServiceAddChannelResult) Write 

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

type MqServiceClient 

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

func NewMqServiceClient 

func NewMqServiceClient(c thrift.TClient) *MqServiceClient

func NewMqServiceClientFactory 

func NewMqServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *MqServiceClient

func NewMqServiceClientProtocol 

func NewMqServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *MqServiceClient

func (*MqServiceClient) AddChannel 

func (p *MqServiceClient) AddChannel(ctx context.Context, req *AddChannelReq) (r *AddChannelResp, err error)

func (*MqServiceClient) Client_ 

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

type MqServiceProcessor 

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

func NewMqServiceProcessor 

func NewMqServiceProcessor(handler MqService) *MqServiceProcessor

func (*MqServiceProcessor) AddToProcessorMap 

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

func (*MqServiceProcessor) GetProcessorFunction 

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

func (*MqServiceProcessor) Process 

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

func (*MqServiceProcessor) ProcessorMap 

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

type SubConfig 

type SubConfig struct {
	ServiceName string `thrift:"service_name,1" frugal:"1,default,string" json:"service_name"`
	ServicePath string `thrift:"service_path,2" frugal:"2,default,string" json:"service_path"`
}
var Channel_SubConfig_DEFAULT *SubConfig

func NewSubConfig 

func NewSubConfig() *SubConfig

func (*SubConfig) BLength 

func (p *SubConfig) BLength() int

func (*SubConfig) DeepEqual 

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

func (*SubConfig) FastRead 

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

func (*SubConfig) FastReadField1 

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

func (*SubConfig) FastReadField2 

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

func (*SubConfig) FastWrite 

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

for compatibility

func (*SubConfig) FastWriteNocopy 

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

func (*SubConfig) Field1DeepEqual 

func (p *SubConfig) Field1DeepEqual(src string) bool

func (*SubConfig) Field2DeepEqual 

func (p *SubConfig) Field2DeepEqual(src string) bool

func (*SubConfig) GetServiceName 

func (p *SubConfig) GetServiceName() (v string)

func (*SubConfig) GetServicePath 

func (p *SubConfig) GetServicePath() (v string)

func (*SubConfig) InitDefault 

func (p *SubConfig) InitDefault()

func (*SubConfig) Read 

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

func (*SubConfig) ReadField1 

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

func (*SubConfig) ReadField2 

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

func (*SubConfig) SetServiceName 

func (p *SubConfig) SetServiceName(val string)

func (*SubConfig) SetServicePath 

func (p *SubConfig) SetServicePath(val string)

func (*SubConfig) String 

func (p *SubConfig) String() string

func (*SubConfig) Write 

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

Source Files

View all Source files

Directories

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

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.