message

package
v0.0.0-...-c4c90f7 Latest Latest
Warning

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

 Go to latest Published: Jan 9, 2020 License: Apache-2.0 Imports: 4 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ChangeMessageVisibilitySecondsBatchResult_E_DEFAULT *common.GalaxyEmqServiceException
View Source 
var ChangeMessageVisibilitySecondsResult_E_DEFAULT *common.GalaxyEmqServiceException
View Source 
var DeadMessageBatchResult_E_DEFAULT *common.GalaxyEmqServiceException
View Source 
var DeadMessageResult_E_DEFAULT *common.GalaxyEmqServiceException
View Source 
var DeleteMessageBatchResult_E_DEFAULT *common.GalaxyEmqServiceException
View Source 
var DeleteMessageResult_E_DEFAULT *common.GalaxyEmqServiceException
View Source 
var DeletePeekMessageBatchResult_E_DEFAULT *common.GalaxyEmqServiceException
View Source 
var DeletePeekMessageResult_E_DEFAULT *common.GalaxyEmqServiceException
View Source 
var GoUnusedProtection__ int
View Source 
var MessageAttribute_BinaryValue_DEFAULT []byte
View Source 
var MessageAttribute_StringValue_DEFAULT string
View Source 
var MessageBatchErrorEntry_Reason_DEFAULT *common.GalaxyEmqServiceException
View Source 
var PartitionTimeIntervalAndMaxNum_EndTimestamp_DEFAULT int64
View Source 
var PartitionTimeIntervalAndMaxNum_MaxNum_DEFAULT int32
View Source 
var PartitionTimeIntervalAndMaxNum_PartitionId_DEFAULT int32
View Source 
var PartitionTimeIntervalAndMaxNum_StartTimestamp_DEFAULT int64
View Source 
var PeekMessageResponse_Attributes_DEFAULT map[string]string
View Source 
var PeekMessageResponse_E_DEFAULT *common.GalaxyEmqServiceException
View Source 
var PeekMessageResponse_MessageAttributes_DEFAULT map[string]*MessageAttribute
View Source 
var PeekMessageResponse_MessageBody_DEFAULT string
View Source 
var PeekMessageResult_E_DEFAULT *common.GalaxyEmqServiceException
View Source 
var PeekMessageResult_Success_DEFAULT []*PeekMessageResponse
View Source 
var ReceiveMessageRequest_AttributeName_DEFAULT string
View Source 
var ReceiveMessageRequest_MaxReceiveMessageNumber_DEFAULT int32 = 100
View Source 
var ReceiveMessageRequest_MaxReceiveMessageWaitSeconds_DEFAULT int32 = 0
View Source 
var ReceiveMessageRequest_TagName_DEFAULT string
View Source 
var ReceiveMessageResponse_Attributes_DEFAULT map[string]string
View Source 
var ReceiveMessageResponse_MessageAttributes_DEFAULT map[string]*MessageAttribute
View Source 
var ReceiveMessageResult_E_DEFAULT *common.GalaxyEmqServiceException
View Source 
var ReceiveMessageResult_Success_DEFAULT []*ReceiveMessageResponse
View Source 
var SendMessageBatchRequestEntry_DelaySeconds_DEFAULT int32
View Source 
var SendMessageBatchRequestEntry_InvisibilitySeconds_DEFAULT int32
View Source 
var SendMessageBatchRequestEntry_MessageAttributes_DEFAULT map[string]*MessageAttribute
View Source 
var SendMessageBatchRequestEntry_Priority_DEFAULT int32
View Source 
var SendMessageBatchRequest_Topic_DEFAULT string
View Source 
var SendMessageBatchResponseEntry_BodyLength_DEFAULT int32
View Source 
var SendMessageBatchResponseEntry_BodyMd5_DEFAULT string
View Source 
var SendMessageBatchResponseEntry_SendTimestamp_DEFAULT int64
View Source 
var SendMessageBatchResult_E_DEFAULT *common.GalaxyEmqServiceException
View Source 
var SendMessageRequest_DelaySeconds_DEFAULT int32
View Source 
var SendMessageRequest_InvisibilitySeconds_DEFAULT int32
View Source 
var SendMessageRequest_MessageAttributes_DEFAULT map[string]*MessageAttribute
View Source 
var SendMessageRequest_Priority_DEFAULT int32
View Source 
var SendMessageRequest_Topic_DEFAULT string
View Source 
var SendMessageResponse_BodyLength_DEFAULT int32
View Source 
var SendMessageResponse_BodyMd5_DEFAULT string
View Source 
var SendMessageResponse_SendTimestamp_DEFAULT int64
View Source 
var SendMessageResult_E_DEFAULT *common.GalaxyEmqServiceException

Functions

This section is empty.

Types

type ChangeMessageVisibilityBatchRequest 

type ChangeMessageVisibilityBatchRequest struct {
	QueueName                               string                                      `thrift:"queueName,1,required" json:"queueName"`
	ChangeMessageVisibilityRequestEntryList []*ChangeMessageVisibilityBatchRequestEntry `thrift:"changeMessageVisibilityRequestEntryList,2,required" json:"changeMessageVisibilityRequestEntryList"`
}
var ChangeMessageVisibilitySecondsBatchArgs_ChangeMessageVisibilityBatchRequest_DEFAULT *ChangeMessageVisibilityBatchRequest

func NewChangeMessageVisibilityBatchRequest 

func NewChangeMessageVisibilityBatchRequest() *ChangeMessageVisibilityBatchRequest

func (*ChangeMessageVisibilityBatchRequest) GetChangeMessageVisibilityRequestEntryList 

func (p *ChangeMessageVisibilityBatchRequest) GetChangeMessageVisibilityRequestEntryList() []*ChangeMessageVisibilityBatchRequestEntry

func (*ChangeMessageVisibilityBatchRequest) GetQueueName 

func (p *ChangeMessageVisibilityBatchRequest) GetQueueName() string

func (*ChangeMessageVisibilityBatchRequest) Read 

func (p *ChangeMessageVisibilityBatchRequest) Read(iprot thrift.TProtocol) error

func (*ChangeMessageVisibilityBatchRequest) ReadField1 

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

func (*ChangeMessageVisibilityBatchRequest) ReadField2 

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

func (*ChangeMessageVisibilityBatchRequest) String 

func (p *ChangeMessageVisibilityBatchRequest) String() string

func (*ChangeMessageVisibilityBatchRequest) Write 

func (p *ChangeMessageVisibilityBatchRequest) Write(oprot thrift.TProtocol) error

type ChangeMessageVisibilityBatchRequestEntry 

type ChangeMessageVisibilityBatchRequestEntry struct {
	ReceiptHandle       string `thrift:"receiptHandle,1,required" json:"receiptHandle"`
	InvisibilitySeconds int32  `thrift:"invisibilitySeconds,2,required" json:"invisibilitySeconds"`
}

func NewChangeMessageVisibilityBatchRequestEntry 

func NewChangeMessageVisibilityBatchRequestEntry() *ChangeMessageVisibilityBatchRequestEntry

func (*ChangeMessageVisibilityBatchRequestEntry) GetInvisibilitySeconds 

func (p *ChangeMessageVisibilityBatchRequestEntry) GetInvisibilitySeconds() int32

func (*ChangeMessageVisibilityBatchRequestEntry) GetReceiptHandle 

func (p *ChangeMessageVisibilityBatchRequestEntry) GetReceiptHandle() string

func (*ChangeMessageVisibilityBatchRequestEntry) Read 

func (p *ChangeMessageVisibilityBatchRequestEntry) Read(iprot thrift.TProtocol) error

func (*ChangeMessageVisibilityBatchRequestEntry) ReadField1 

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

func (*ChangeMessageVisibilityBatchRequestEntry) ReadField2 

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

func (*ChangeMessageVisibilityBatchRequestEntry) String 

func (p *ChangeMessageVisibilityBatchRequestEntry) String() string

func (*ChangeMessageVisibilityBatchRequestEntry) Write 

func (p *ChangeMessageVisibilityBatchRequestEntry) Write(oprot thrift.TProtocol) error

type ChangeMessageVisibilityBatchResponse 

type ChangeMessageVisibilityBatchResponse struct {
	Successful []string                  `thrift:"successful,1" json:"successful"`
	Failed     []*MessageBatchErrorEntry `thrift:"failed,2" json:"failed"`
}
var ChangeMessageVisibilitySecondsBatchResult_Success_DEFAULT *ChangeMessageVisibilityBatchResponse

func NewChangeMessageVisibilityBatchResponse 

func NewChangeMessageVisibilityBatchResponse() *ChangeMessageVisibilityBatchResponse

func (*ChangeMessageVisibilityBatchResponse) GetFailed 

func (p *ChangeMessageVisibilityBatchResponse) GetFailed() []*MessageBatchErrorEntry

func (*ChangeMessageVisibilityBatchResponse) GetSuccessful 

func (p *ChangeMessageVisibilityBatchResponse) GetSuccessful() []string

func (*ChangeMessageVisibilityBatchResponse) Read 

func (p *ChangeMessageVisibilityBatchResponse) Read(iprot thrift.TProtocol) error

func (*ChangeMessageVisibilityBatchResponse) ReadField1 

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

func (*ChangeMessageVisibilityBatchResponse) ReadField2 

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

func (*ChangeMessageVisibilityBatchResponse) String 

func (p *ChangeMessageVisibilityBatchResponse) String() string

func (*ChangeMessageVisibilityBatchResponse) Write 

func (p *ChangeMessageVisibilityBatchResponse) Write(oprot thrift.TProtocol) error

type ChangeMessageVisibilityRequest 

type ChangeMessageVisibilityRequest struct {
	QueueName           string `thrift:"queueName,1,required" json:"queueName"`
	ReceiptHandle       string `thrift:"receiptHandle,2,required" json:"receiptHandle"`
	InvisibilitySeconds int32  `thrift:"invisibilitySeconds,3,required" json:"invisibilitySeconds"`
}
var ChangeMessageVisibilitySecondsArgs_ChangeMessageVisibilityRequest_DEFAULT *ChangeMessageVisibilityRequest

func NewChangeMessageVisibilityRequest 

func NewChangeMessageVisibilityRequest() *ChangeMessageVisibilityRequest

func (*ChangeMessageVisibilityRequest) GetInvisibilitySeconds 

func (p *ChangeMessageVisibilityRequest) GetInvisibilitySeconds() int32

func (*ChangeMessageVisibilityRequest) GetQueueName 

func (p *ChangeMessageVisibilityRequest) GetQueueName() string

func (*ChangeMessageVisibilityRequest) GetReceiptHandle 

func (p *ChangeMessageVisibilityRequest) GetReceiptHandle() string

func (*ChangeMessageVisibilityRequest) Read 

func (p *ChangeMessageVisibilityRequest) Read(iprot thrift.TProtocol) error

func (*ChangeMessageVisibilityRequest) ReadField1 

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

func (*ChangeMessageVisibilityRequest) ReadField2 

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

func (*ChangeMessageVisibilityRequest) ReadField3 

func (p *ChangeMessageVisibilityRequest) ReadField3(iprot thrift.TProtocol) error

func (*ChangeMessageVisibilityRequest) String 

func (p *ChangeMessageVisibilityRequest) String() string

func (*ChangeMessageVisibilityRequest) Write 

func (p *ChangeMessageVisibilityRequest) Write(oprot thrift.TProtocol) error

type ChangeMessageVisibilitySecondsArgs 

type ChangeMessageVisibilitySecondsArgs struct {
	ChangeMessageVisibilityRequest *ChangeMessageVisibilityRequest `thrift:"changeMessageVisibilityRequest,1" json:"changeMessageVisibilityRequest"`
}

func NewChangeMessageVisibilitySecondsArgs 

func NewChangeMessageVisibilitySecondsArgs() *ChangeMessageVisibilitySecondsArgs

func (*ChangeMessageVisibilitySecondsArgs) GetChangeMessageVisibilityRequest 

func (p *ChangeMessageVisibilitySecondsArgs) GetChangeMessageVisibilityRequest() *ChangeMessageVisibilityRequest

func (*ChangeMessageVisibilitySecondsArgs) IsSetChangeMessageVisibilityRequest 

func (p *ChangeMessageVisibilitySecondsArgs) IsSetChangeMessageVisibilityRequest() bool

func (*ChangeMessageVisibilitySecondsArgs) Read 

func (p *ChangeMessageVisibilitySecondsArgs) Read(iprot thrift.TProtocol) error

func (*ChangeMessageVisibilitySecondsArgs) ReadField1 

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

func (*ChangeMessageVisibilitySecondsArgs) String 

func (p *ChangeMessageVisibilitySecondsArgs) String() string

func (*ChangeMessageVisibilitySecondsArgs) Write 

func (p *ChangeMessageVisibilitySecondsArgs) Write(oprot thrift.TProtocol) error

type ChangeMessageVisibilitySecondsBatchArgs 

type ChangeMessageVisibilitySecondsBatchArgs struct {
	ChangeMessageVisibilityBatchRequest *ChangeMessageVisibilityBatchRequest `thrift:"changeMessageVisibilityBatchRequest,1" json:"changeMessageVisibilityBatchRequest"`
}

func NewChangeMessageVisibilitySecondsBatchArgs 

func NewChangeMessageVisibilitySecondsBatchArgs() *ChangeMessageVisibilitySecondsBatchArgs

func (*ChangeMessageVisibilitySecondsBatchArgs) GetChangeMessageVisibilityBatchRequest 

func (p *ChangeMessageVisibilitySecondsBatchArgs) GetChangeMessageVisibilityBatchRequest() *ChangeMessageVisibilityBatchRequest

func (*ChangeMessageVisibilitySecondsBatchArgs) IsSetChangeMessageVisibilityBatchRequest 

func (p *ChangeMessageVisibilitySecondsBatchArgs) IsSetChangeMessageVisibilityBatchRequest() bool

func (*ChangeMessageVisibilitySecondsBatchArgs) Read 

func (p *ChangeMessageVisibilitySecondsBatchArgs) Read(iprot thrift.TProtocol) error

func (*ChangeMessageVisibilitySecondsBatchArgs) ReadField1 

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

func (*ChangeMessageVisibilitySecondsBatchArgs) String 

func (p *ChangeMessageVisibilitySecondsBatchArgs) String() string

func (*ChangeMessageVisibilitySecondsBatchArgs) Write 

func (p *ChangeMessageVisibilitySecondsBatchArgs) Write(oprot thrift.TProtocol) error

type ChangeMessageVisibilitySecondsBatchResult 

type ChangeMessageVisibilitySecondsBatchResult struct {
	Success *ChangeMessageVisibilityBatchResponse `thrift:"success,0" json:"success"`
	E       *common.GalaxyEmqServiceException     `thrift:"e,1" json:"e"`
}

func NewChangeMessageVisibilitySecondsBatchResult 

func NewChangeMessageVisibilitySecondsBatchResult() *ChangeMessageVisibilitySecondsBatchResult

func (*ChangeMessageVisibilitySecondsBatchResult) GetE 

func (p *ChangeMessageVisibilitySecondsBatchResult) GetE() *common.GalaxyEmqServiceException

func (*ChangeMessageVisibilitySecondsBatchResult) GetSuccess 

func (p *ChangeMessageVisibilitySecondsBatchResult) GetSuccess() *ChangeMessageVisibilityBatchResponse

func (*ChangeMessageVisibilitySecondsBatchResult) IsSetE 

func (p *ChangeMessageVisibilitySecondsBatchResult) IsSetE() bool

func (*ChangeMessageVisibilitySecondsBatchResult) IsSetSuccess 

func (p *ChangeMessageVisibilitySecondsBatchResult) IsSetSuccess() bool

func (*ChangeMessageVisibilitySecondsBatchResult) Read 

func (p *ChangeMessageVisibilitySecondsBatchResult) Read(iprot thrift.TProtocol) error

func (*ChangeMessageVisibilitySecondsBatchResult) ReadField0 

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

func (*ChangeMessageVisibilitySecondsBatchResult) ReadField1 

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

func (*ChangeMessageVisibilitySecondsBatchResult) String 

func (p *ChangeMessageVisibilitySecondsBatchResult) String() string

func (*ChangeMessageVisibilitySecondsBatchResult) Write 

func (p *ChangeMessageVisibilitySecondsBatchResult) Write(oprot thrift.TProtocol) error

type ChangeMessageVisibilitySecondsResult 

type ChangeMessageVisibilitySecondsResult struct {
	E *common.GalaxyEmqServiceException `thrift:"e,1" json:"e"`
}

func NewChangeMessageVisibilitySecondsResult 

func NewChangeMessageVisibilitySecondsResult() *ChangeMessageVisibilitySecondsResult

func (*ChangeMessageVisibilitySecondsResult) GetE 

func (p *ChangeMessageVisibilitySecondsResult) GetE() *common.GalaxyEmqServiceException

func (*ChangeMessageVisibilitySecondsResult) IsSetE 

func (p *ChangeMessageVisibilitySecondsResult) IsSetE() bool

func (*ChangeMessageVisibilitySecondsResult) Read 

func (p *ChangeMessageVisibilitySecondsResult) Read(iprot thrift.TProtocol) error

func (*ChangeMessageVisibilitySecondsResult) ReadField1 

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

func (*ChangeMessageVisibilitySecondsResult) String 

func (p *ChangeMessageVisibilitySecondsResult) String() string

func (*ChangeMessageVisibilitySecondsResult) Write 

func (p *ChangeMessageVisibilitySecondsResult) Write(oprot thrift.TProtocol) error

type DeadMessageArgs 

type DeadMessageArgs struct {
	DeadMessageRequest *DeadMessageRequest `thrift:"deadMessageRequest,1" json:"deadMessageRequest"`
}

func NewDeadMessageArgs 

func NewDeadMessageArgs() *DeadMessageArgs

func (*DeadMessageArgs) GetDeadMessageRequest 

func (p *DeadMessageArgs) GetDeadMessageRequest() *DeadMessageRequest

func (*DeadMessageArgs) IsSetDeadMessageRequest 

func (p *DeadMessageArgs) IsSetDeadMessageRequest() bool

func (*DeadMessageArgs) Read 

func (p *DeadMessageArgs) Read(iprot thrift.TProtocol) error

func (*DeadMessageArgs) ReadField1 

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

func (*DeadMessageArgs) String 

func (p *DeadMessageArgs) String() string

func (*DeadMessageArgs) Write 

func (p *DeadMessageArgs) Write(oprot thrift.TProtocol) error

type DeadMessageBatchArgs 

type DeadMessageBatchArgs struct {
	DeadMessageBatchRequest *DeadMessageBatchRequest `thrift:"deadMessageBatchRequest,1" json:"deadMessageBatchRequest"`
}

func NewDeadMessageBatchArgs 

func NewDeadMessageBatchArgs() *DeadMessageBatchArgs

func (*DeadMessageBatchArgs) GetDeadMessageBatchRequest 

func (p *DeadMessageBatchArgs) GetDeadMessageBatchRequest() *DeadMessageBatchRequest

func (*DeadMessageBatchArgs) IsSetDeadMessageBatchRequest 

func (p *DeadMessageBatchArgs) IsSetDeadMessageBatchRequest() bool

func (*DeadMessageBatchArgs) Read 

func (p *DeadMessageBatchArgs) Read(iprot thrift.TProtocol) error

func (*DeadMessageBatchArgs) ReadField1 

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

func (*DeadMessageBatchArgs) String 

func (p *DeadMessageBatchArgs) String() string

func (*DeadMessageBatchArgs) Write 

func (p *DeadMessageBatchArgs) Write(oprot thrift.TProtocol) error

type DeadMessageBatchRequest 

type DeadMessageBatchRequest struct {
	QueueName                        string                          `thrift:"queueName,1,required" json:"queueName"`
	DeadMessageBatchRequestEntryList []*DeadMessageBatchRequestEntry `thrift:"deadMessageBatchRequestEntryList,2,required" json:"deadMessageBatchRequestEntryList"`
}
var DeadMessageBatchArgs_DeadMessageBatchRequest_DEFAULT *DeadMessageBatchRequest

func NewDeadMessageBatchRequest 

func NewDeadMessageBatchRequest() *DeadMessageBatchRequest

func (*DeadMessageBatchRequest) GetDeadMessageBatchRequestEntryList 

func (p *DeadMessageBatchRequest) GetDeadMessageBatchRequestEntryList() []*DeadMessageBatchRequestEntry

func (*DeadMessageBatchRequest) GetQueueName 

func (p *DeadMessageBatchRequest) GetQueueName() string

func (*DeadMessageBatchRequest) Read 

func (p *DeadMessageBatchRequest) Read(iprot thrift.TProtocol) error

func (*DeadMessageBatchRequest) ReadField1 

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

func (*DeadMessageBatchRequest) ReadField2 

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

func (*DeadMessageBatchRequest) String 

func (p *DeadMessageBatchRequest) String() string

func (*DeadMessageBatchRequest) Write 

func (p *DeadMessageBatchRequest) Write(oprot thrift.TProtocol) error

type DeadMessageBatchRequestEntry 

type DeadMessageBatchRequestEntry struct {
	ReceiptHandle string `thrift:"receiptHandle,1,required" json:"receiptHandle"`
}

func NewDeadMessageBatchRequestEntry 

func NewDeadMessageBatchRequestEntry() *DeadMessageBatchRequestEntry

func (*DeadMessageBatchRequestEntry) GetReceiptHandle 

func (p *DeadMessageBatchRequestEntry) GetReceiptHandle() string

func (*DeadMessageBatchRequestEntry) Read 

func (p *DeadMessageBatchRequestEntry) Read(iprot thrift.TProtocol) error

func (*DeadMessageBatchRequestEntry) ReadField1 

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

func (*DeadMessageBatchRequestEntry) String 

func (p *DeadMessageBatchRequestEntry) String() string

func (*DeadMessageBatchRequestEntry) Write 

func (p *DeadMessageBatchRequestEntry) Write(oprot thrift.TProtocol) error

type DeadMessageBatchResponse 

type DeadMessageBatchResponse struct {
	Successful []string                  `thrift:"successful,1" json:"successful"`
	Failed     []*MessageBatchErrorEntry `thrift:"failed,2" json:"failed"`
}
var DeadMessageBatchResult_Success_DEFAULT *DeadMessageBatchResponse

func NewDeadMessageBatchResponse 

func NewDeadMessageBatchResponse() *DeadMessageBatchResponse

func (*DeadMessageBatchResponse) GetFailed 

func (p *DeadMessageBatchResponse) GetFailed() []*MessageBatchErrorEntry

func (*DeadMessageBatchResponse) GetSuccessful 

func (p *DeadMessageBatchResponse) GetSuccessful() []string

func (*DeadMessageBatchResponse) Read 

func (p *DeadMessageBatchResponse) Read(iprot thrift.TProtocol) error

func (*DeadMessageBatchResponse) ReadField1 

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

func (*DeadMessageBatchResponse) ReadField2 

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

func (*DeadMessageBatchResponse) String 

func (p *DeadMessageBatchResponse) String() string

func (*DeadMessageBatchResponse) Write 

func (p *DeadMessageBatchResponse) Write(oprot thrift.TProtocol) error

type DeadMessageBatchResult 

type DeadMessageBatchResult struct {
	Success *DeadMessageBatchResponse         `thrift:"success,0" json:"success"`
	E       *common.GalaxyEmqServiceException `thrift:"e,1" json:"e"`
}

func NewDeadMessageBatchResult 

func NewDeadMessageBatchResult() *DeadMessageBatchResult

func (*DeadMessageBatchResult) GetE 

func (p *DeadMessageBatchResult) GetE() *common.GalaxyEmqServiceException

func (*DeadMessageBatchResult) GetSuccess 

func (p *DeadMessageBatchResult) GetSuccess() *DeadMessageBatchResponse

func (*DeadMessageBatchResult) IsSetE 

func (p *DeadMessageBatchResult) IsSetE() bool

func (*DeadMessageBatchResult) IsSetSuccess 

func (p *DeadMessageBatchResult) IsSetSuccess() bool

func (*DeadMessageBatchResult) Read 

func (p *DeadMessageBatchResult) Read(iprot thrift.TProtocol) error

func (*DeadMessageBatchResult) ReadField0 

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

func (*DeadMessageBatchResult) ReadField1 

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

func (*DeadMessageBatchResult) String 

func (p *DeadMessageBatchResult) String() string

func (*DeadMessageBatchResult) Write 

func (p *DeadMessageBatchResult) Write(oprot thrift.TProtocol) error

type DeadMessageRequest 

type DeadMessageRequest struct {
	QueueName     string `thrift:"queueName,1,required" json:"queueName"`
	ReceiptHandle string `thrift:"receiptHandle,2,required" json:"receiptHandle"`
}
var DeadMessageArgs_DeadMessageRequest_DEFAULT *DeadMessageRequest

func NewDeadMessageRequest 

func NewDeadMessageRequest() *DeadMessageRequest

func (*DeadMessageRequest) GetQueueName 

func (p *DeadMessageRequest) GetQueueName() string

func (*DeadMessageRequest) GetReceiptHandle 

func (p *DeadMessageRequest) GetReceiptHandle() string

func (*DeadMessageRequest) Read 

func (p *DeadMessageRequest) Read(iprot thrift.TProtocol) error

func (*DeadMessageRequest) ReadField1 

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

func (*DeadMessageRequest) ReadField2 

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

func (*DeadMessageRequest) String 

func (p *DeadMessageRequest) String() string

func (*DeadMessageRequest) Write 

func (p *DeadMessageRequest) Write(oprot thrift.TProtocol) error

type DeadMessageResult 

type DeadMessageResult struct {
	E *common.GalaxyEmqServiceException `thrift:"e,1" json:"e"`
}

func NewDeadMessageResult 

func NewDeadMessageResult() *DeadMessageResult

func (*DeadMessageResult) GetE 

func (p *DeadMessageResult) GetE() *common.GalaxyEmqServiceException

func (*DeadMessageResult) IsSetE 

func (p *DeadMessageResult) IsSetE() bool

func (*DeadMessageResult) Read 

func (p *DeadMessageResult) Read(iprot thrift.TProtocol) error

func (*DeadMessageResult) ReadField1 

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

func (*DeadMessageResult) String 

func (p *DeadMessageResult) String() string

func (*DeadMessageResult) Write 

func (p *DeadMessageResult) Write(oprot thrift.TProtocol) error

type DeleteMessageArgs 

type DeleteMessageArgs struct {
	DeleteMessageRequest *DeleteMessageRequest `thrift:"deleteMessageRequest,1" json:"deleteMessageRequest"`
}

func NewDeleteMessageArgs 

func NewDeleteMessageArgs() *DeleteMessageArgs

func (*DeleteMessageArgs) GetDeleteMessageRequest 

func (p *DeleteMessageArgs) GetDeleteMessageRequest() *DeleteMessageRequest

func (*DeleteMessageArgs) IsSetDeleteMessageRequest 

func (p *DeleteMessageArgs) IsSetDeleteMessageRequest() bool

func (*DeleteMessageArgs) Read 

func (p *DeleteMessageArgs) Read(iprot thrift.TProtocol) error

func (*DeleteMessageArgs) ReadField1 

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

func (*DeleteMessageArgs) String 

func (p *DeleteMessageArgs) String() string

func (*DeleteMessageArgs) Write 

func (p *DeleteMessageArgs) Write(oprot thrift.TProtocol) error

type DeleteMessageBatchArgs 

type DeleteMessageBatchArgs struct {
	DeleteMessageBatchRequest *DeleteMessageBatchRequest `thrift:"deleteMessageBatchRequest,1" json:"deleteMessageBatchRequest"`
}

func NewDeleteMessageBatchArgs 

func NewDeleteMessageBatchArgs() *DeleteMessageBatchArgs

func (*DeleteMessageBatchArgs) GetDeleteMessageBatchRequest 

func (p *DeleteMessageBatchArgs) GetDeleteMessageBatchRequest() *DeleteMessageBatchRequest

func (*DeleteMessageBatchArgs) IsSetDeleteMessageBatchRequest 

func (p *DeleteMessageBatchArgs) IsSetDeleteMessageBatchRequest() bool

func (*DeleteMessageBatchArgs) Read 

func (p *DeleteMessageBatchArgs) Read(iprot thrift.TProtocol) error

func (*DeleteMessageBatchArgs) ReadField1 

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

func (*DeleteMessageBatchArgs) String 

func (p *DeleteMessageBatchArgs) String() string

func (*DeleteMessageBatchArgs) Write 

func (p *DeleteMessageBatchArgs) Write(oprot thrift.TProtocol) error

type DeleteMessageBatchRequest 

type DeleteMessageBatchRequest struct {
	QueueName                          string                            `thrift:"queueName,1,required" json:"queueName"`
	DeleteMessageBatchRequestEntryList []*DeleteMessageBatchRequestEntry `thrift:"deleteMessageBatchRequestEntryList,2,required" json:"deleteMessageBatchRequestEntryList"`
}
var DeleteMessageBatchArgs_DeleteMessageBatchRequest_DEFAULT *DeleteMessageBatchRequest

func NewDeleteMessageBatchRequest 

func NewDeleteMessageBatchRequest() *DeleteMessageBatchRequest

func (*DeleteMessageBatchRequest) GetDeleteMessageBatchRequestEntryList 

func (p *DeleteMessageBatchRequest) GetDeleteMessageBatchRequestEntryList() []*DeleteMessageBatchRequestEntry

func (*DeleteMessageBatchRequest) GetQueueName 

func (p *DeleteMessageBatchRequest) GetQueueName() string

func (*DeleteMessageBatchRequest) Read 

func (p *DeleteMessageBatchRequest) Read(iprot thrift.TProtocol) error

func (*DeleteMessageBatchRequest) ReadField1 

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

func (*DeleteMessageBatchRequest) ReadField2 

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

func (*DeleteMessageBatchRequest) String 

func (p *DeleteMessageBatchRequest) String() string

func (*DeleteMessageBatchRequest) Write 

func (p *DeleteMessageBatchRequest) Write(oprot thrift.TProtocol) error

type DeleteMessageBatchRequestEntry 

type DeleteMessageBatchRequestEntry struct {
	ReceiptHandle string `thrift:"receiptHandle,1,required" json:"receiptHandle"`
}

func NewDeleteMessageBatchRequestEntry 

func NewDeleteMessageBatchRequestEntry() *DeleteMessageBatchRequestEntry

func (*DeleteMessageBatchRequestEntry) GetReceiptHandle 

func (p *DeleteMessageBatchRequestEntry) GetReceiptHandle() string

func (*DeleteMessageBatchRequestEntry) Read 

func (p *DeleteMessageBatchRequestEntry) Read(iprot thrift.TProtocol) error

func (*DeleteMessageBatchRequestEntry) ReadField1 

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

func (*DeleteMessageBatchRequestEntry) String 

func (p *DeleteMessageBatchRequestEntry) String() string

func (*DeleteMessageBatchRequestEntry) Write 

func (p *DeleteMessageBatchRequestEntry) Write(oprot thrift.TProtocol) error

type DeleteMessageBatchResponse 

type DeleteMessageBatchResponse struct {
	Successful []string                  `thrift:"successful,1" json:"successful"`
	Failed     []*MessageBatchErrorEntry `thrift:"failed,2" json:"failed"`
}
var DeleteMessageBatchResult_Success_DEFAULT *DeleteMessageBatchResponse

func NewDeleteMessageBatchResponse 

func NewDeleteMessageBatchResponse() *DeleteMessageBatchResponse

func (*DeleteMessageBatchResponse) GetFailed 

func (p *DeleteMessageBatchResponse) GetFailed() []*MessageBatchErrorEntry

func (*DeleteMessageBatchResponse) GetSuccessful 

func (p *DeleteMessageBatchResponse) GetSuccessful() []string

func (*DeleteMessageBatchResponse) Read 

func (p *DeleteMessageBatchResponse) Read(iprot thrift.TProtocol) error

func (*DeleteMessageBatchResponse) ReadField1 

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

func (*DeleteMessageBatchResponse) ReadField2 

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

func (*DeleteMessageBatchResponse) String 

func (p *DeleteMessageBatchResponse) String() string

func (*DeleteMessageBatchResponse) Write 

func (p *DeleteMessageBatchResponse) Write(oprot thrift.TProtocol) error

type DeleteMessageBatchResult 

type DeleteMessageBatchResult struct {
	Success *DeleteMessageBatchResponse       `thrift:"success,0" json:"success"`
	E       *common.GalaxyEmqServiceException `thrift:"e,1" json:"e"`
}

func NewDeleteMessageBatchResult 

func NewDeleteMessageBatchResult() *DeleteMessageBatchResult

func (*DeleteMessageBatchResult) GetE 

func (p *DeleteMessageBatchResult) GetE() *common.GalaxyEmqServiceException

func (*DeleteMessageBatchResult) GetSuccess 

func (p *DeleteMessageBatchResult) GetSuccess() *DeleteMessageBatchResponse

func (*DeleteMessageBatchResult) IsSetE 

func (p *DeleteMessageBatchResult) IsSetE() bool

func (*DeleteMessageBatchResult) IsSetSuccess 

func (p *DeleteMessageBatchResult) IsSetSuccess() bool

func (*DeleteMessageBatchResult) Read 

func (p *DeleteMessageBatchResult) Read(iprot thrift.TProtocol) error

func (*DeleteMessageBatchResult) ReadField0 

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

func (*DeleteMessageBatchResult) ReadField1 

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

func (*DeleteMessageBatchResult) String 

func (p *DeleteMessageBatchResult) String() string

func (*DeleteMessageBatchResult) Write 

func (p *DeleteMessageBatchResult) Write(oprot thrift.TProtocol) error

type DeleteMessageRequest 

type DeleteMessageRequest struct {
	QueueName     string `thrift:"queueName,1,required" json:"queueName"`
	ReceiptHandle string `thrift:"receiptHandle,2,required" json:"receiptHandle"`
}
var DeleteMessageArgs_DeleteMessageRequest_DEFAULT *DeleteMessageRequest

func NewDeleteMessageRequest 

func NewDeleteMessageRequest() *DeleteMessageRequest

func (*DeleteMessageRequest) GetQueueName 

func (p *DeleteMessageRequest) GetQueueName() string

func (*DeleteMessageRequest) GetReceiptHandle 

func (p *DeleteMessageRequest) GetReceiptHandle() string

func (*DeleteMessageRequest) Read 

func (p *DeleteMessageRequest) Read(iprot thrift.TProtocol) error

func (*DeleteMessageRequest) ReadField1 

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

func (*DeleteMessageRequest) ReadField2 

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

func (*DeleteMessageRequest) String 

func (p *DeleteMessageRequest) String() string

func (*DeleteMessageRequest) Write 

func (p *DeleteMessageRequest) Write(oprot thrift.TProtocol) error

type DeleteMessageResult 

type DeleteMessageResult struct {
	E *common.GalaxyEmqServiceException `thrift:"e,1" json:"e"`
}

func NewDeleteMessageResult 

func NewDeleteMessageResult() *DeleteMessageResult

func (*DeleteMessageResult) GetE 

func (p *DeleteMessageResult) GetE() *common.GalaxyEmqServiceException

func (*DeleteMessageResult) IsSetE 

func (p *DeleteMessageResult) IsSetE() bool

func (*DeleteMessageResult) Read 

func (p *DeleteMessageResult) Read(iprot thrift.TProtocol) error

func (*DeleteMessageResult) ReadField1 

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

func (*DeleteMessageResult) String 

func (p *DeleteMessageResult) String() string

func (*DeleteMessageResult) Write 

func (p *DeleteMessageResult) Write(oprot thrift.TProtocol) error

type DeletePeekMessageArgs 

type DeletePeekMessageArgs struct {
	DeletePeekMessageRequest *DeletePeekMessageRequest `thrift:"deletePeekMessageRequest,1" json:"deletePeekMessageRequest"`
}

func NewDeletePeekMessageArgs 

func NewDeletePeekMessageArgs() *DeletePeekMessageArgs

func (*DeletePeekMessageArgs) GetDeletePeekMessageRequest 

func (p *DeletePeekMessageArgs) GetDeletePeekMessageRequest() *DeletePeekMessageRequest

func (*DeletePeekMessageArgs) IsSetDeletePeekMessageRequest 

func (p *DeletePeekMessageArgs) IsSetDeletePeekMessageRequest() bool

func (*DeletePeekMessageArgs) Read 

func (p *DeletePeekMessageArgs) Read(iprot thrift.TProtocol) error

func (*DeletePeekMessageArgs) ReadField1 

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

func (*DeletePeekMessageArgs) String 

func (p *DeletePeekMessageArgs) String() string

func (*DeletePeekMessageArgs) Write 

func (p *DeletePeekMessageArgs) Write(oprot thrift.TProtocol) error

type DeletePeekMessageBatchArgs 

type DeletePeekMessageBatchArgs struct {
	DeletePeekMessageBatchRequest *DeletePeekMessageBatchRequest `thrift:"deletePeekMessageBatchRequest,1" json:"deletePeekMessageBatchRequest"`
}

func NewDeletePeekMessageBatchArgs 

func NewDeletePeekMessageBatchArgs() *DeletePeekMessageBatchArgs

func (*DeletePeekMessageBatchArgs) GetDeletePeekMessageBatchRequest 

func (p *DeletePeekMessageBatchArgs) GetDeletePeekMessageBatchRequest() *DeletePeekMessageBatchRequest

func (*DeletePeekMessageBatchArgs) IsSetDeletePeekMessageBatchRequest 

func (p *DeletePeekMessageBatchArgs) IsSetDeletePeekMessageBatchRequest() bool

func (*DeletePeekMessageBatchArgs) Read 

func (p *DeletePeekMessageBatchArgs) Read(iprot thrift.TProtocol) error

func (*DeletePeekMessageBatchArgs) ReadField1 

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

func (*DeletePeekMessageBatchArgs) String 

func (p *DeletePeekMessageBatchArgs) String() string

func (*DeletePeekMessageBatchArgs) Write 

func (p *DeletePeekMessageBatchArgs) Write(oprot thrift.TProtocol) error

type DeletePeekMessageBatchEntry 

type DeletePeekMessageBatchEntry struct {
	ReceiptHandle string `thrift:"receiptHandle,1,required" json:"receiptHandle"`
}

func NewDeletePeekMessageBatchEntry 

func NewDeletePeekMessageBatchEntry() *DeletePeekMessageBatchEntry

func (*DeletePeekMessageBatchEntry) GetReceiptHandle 

func (p *DeletePeekMessageBatchEntry) GetReceiptHandle() string

func (*DeletePeekMessageBatchEntry) Read 

func (p *DeletePeekMessageBatchEntry) Read(iprot thrift.TProtocol) error

func (*DeletePeekMessageBatchEntry) ReadField1 

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

func (*DeletePeekMessageBatchEntry) String 

func (p *DeletePeekMessageBatchEntry) String() string

func (*DeletePeekMessageBatchEntry) Write 

func (p *DeletePeekMessageBatchEntry) Write(oprot thrift.TProtocol) error

type DeletePeekMessageBatchRequest 

type DeletePeekMessageBatchRequest struct {
	QueueName                       string                         `thrift:"queueName,1,required" json:"queueName"`
	DeletePeekMessageBatchEntryList []*DeletePeekMessageBatchEntry `thrift:"deletePeekMessageBatchEntryList,2,required" json:"deletePeekMessageBatchEntryList"`
}
var DeletePeekMessageBatchArgs_DeletePeekMessageBatchRequest_DEFAULT *DeletePeekMessageBatchRequest

func NewDeletePeekMessageBatchRequest 

func NewDeletePeekMessageBatchRequest() *DeletePeekMessageBatchRequest

func (*DeletePeekMessageBatchRequest) GetDeletePeekMessageBatchEntryList 

func (p *DeletePeekMessageBatchRequest) GetDeletePeekMessageBatchEntryList() []*DeletePeekMessageBatchEntry

func (*DeletePeekMessageBatchRequest) GetQueueName 

func (p *DeletePeekMessageBatchRequest) GetQueueName() string

func (*DeletePeekMessageBatchRequest) Read 

func (p *DeletePeekMessageBatchRequest) Read(iprot thrift.TProtocol) error

func (*DeletePeekMessageBatchRequest) ReadField1 

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

func (*DeletePeekMessageBatchRequest) ReadField2 

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

func (*DeletePeekMessageBatchRequest) String 

func (p *DeletePeekMessageBatchRequest) String() string

func (*DeletePeekMessageBatchRequest) Write 

func (p *DeletePeekMessageBatchRequest) Write(oprot thrift.TProtocol) error

type DeletePeekMessageBatchResponse 

type DeletePeekMessageBatchResponse struct {
	Successful []string                  `thrift:"successful,1" json:"successful"`
	Failed     []*MessageBatchErrorEntry `thrift:"failed,2" json:"failed"`
}
var DeletePeekMessageBatchResult_Success_DEFAULT *DeletePeekMessageBatchResponse

func NewDeletePeekMessageBatchResponse 

func NewDeletePeekMessageBatchResponse() *DeletePeekMessageBatchResponse

func (*DeletePeekMessageBatchResponse) GetFailed 

func (p *DeletePeekMessageBatchResponse) GetFailed() []*MessageBatchErrorEntry

func (*DeletePeekMessageBatchResponse) GetSuccessful 

func (p *DeletePeekMessageBatchResponse) GetSuccessful() []string

func (*DeletePeekMessageBatchResponse) Read 

func (p *DeletePeekMessageBatchResponse) Read(iprot thrift.TProtocol) error

func (*DeletePeekMessageBatchResponse) ReadField1 

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

func (*DeletePeekMessageBatchResponse) ReadField2 

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

func (*DeletePeekMessageBatchResponse) String 

func (p *DeletePeekMessageBatchResponse) String() string

func (*DeletePeekMessageBatchResponse) Write 

func (p *DeletePeekMessageBatchResponse) Write(oprot thrift.TProtocol) error

type DeletePeekMessageBatchResult 

type DeletePeekMessageBatchResult struct {
	Success *DeletePeekMessageBatchResponse   `thrift:"success,0" json:"success"`
	E       *common.GalaxyEmqServiceException `thrift:"e,1" json:"e"`
}

func NewDeletePeekMessageBatchResult 

func NewDeletePeekMessageBatchResult() *DeletePeekMessageBatchResult

func (*DeletePeekMessageBatchResult) GetE 

func (p *DeletePeekMessageBatchResult) GetE() *common.GalaxyEmqServiceException

func (*DeletePeekMessageBatchResult) GetSuccess 

func (p *DeletePeekMessageBatchResult) GetSuccess() *DeletePeekMessageBatchResponse

func (*DeletePeekMessageBatchResult) IsSetE 

func (p *DeletePeekMessageBatchResult) IsSetE() bool

func (*DeletePeekMessageBatchResult) IsSetSuccess 

func (p *DeletePeekMessageBatchResult) IsSetSuccess() bool

func (*DeletePeekMessageBatchResult) Read 

func (p *DeletePeekMessageBatchResult) Read(iprot thrift.TProtocol) error

func (*DeletePeekMessageBatchResult) ReadField0 

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

func (*DeletePeekMessageBatchResult) ReadField1 

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

func (*DeletePeekMessageBatchResult) String 

func (p *DeletePeekMessageBatchResult) String() string

func (*DeletePeekMessageBatchResult) Write 

func (p *DeletePeekMessageBatchResult) Write(oprot thrift.TProtocol) error

type DeletePeekMessageRequest 

type DeletePeekMessageRequest struct {
	QueueName     string `thrift:"queueName,1,required" json:"queueName"`
	ReceiptHandle string `thrift:"receiptHandle,2,required" json:"receiptHandle"`
}
var DeletePeekMessageArgs_DeletePeekMessageRequest_DEFAULT *DeletePeekMessageRequest

func NewDeletePeekMessageRequest 

func NewDeletePeekMessageRequest() *DeletePeekMessageRequest

func (*DeletePeekMessageRequest) GetQueueName 

func (p *DeletePeekMessageRequest) GetQueueName() string

func (*DeletePeekMessageRequest) GetReceiptHandle 

func (p *DeletePeekMessageRequest) GetReceiptHandle() string

func (*DeletePeekMessageRequest) Read 

func (p *DeletePeekMessageRequest) Read(iprot thrift.TProtocol) error

func (*DeletePeekMessageRequest) ReadField1 

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

func (*DeletePeekMessageRequest) ReadField2 

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

func (*DeletePeekMessageRequest) String 

func (p *DeletePeekMessageRequest) String() string

func (*DeletePeekMessageRequest) Write 

func (p *DeletePeekMessageRequest) Write(oprot thrift.TProtocol) error

type DeletePeekMessageResult 

type DeletePeekMessageResult struct {
	E *common.GalaxyEmqServiceException `thrift:"e,1" json:"e"`
}

func NewDeletePeekMessageResult 

func NewDeletePeekMessageResult() *DeletePeekMessageResult

func (*DeletePeekMessageResult) GetE 

func (p *DeletePeekMessageResult) GetE() *common.GalaxyEmqServiceException

func (*DeletePeekMessageResult) IsSetE 

func (p *DeletePeekMessageResult) IsSetE() bool

func (*DeletePeekMessageResult) Read 

func (p *DeletePeekMessageResult) Read(iprot thrift.TProtocol) error

func (*DeletePeekMessageResult) ReadField1 

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

func (*DeletePeekMessageResult) String 

func (p *DeletePeekMessageResult) String() string

func (*DeletePeekMessageResult) Write 

func (p *DeletePeekMessageResult) Write(oprot thrift.TProtocol) error

type MessageAttribute 

type MessageAttribute struct {
	TypeA1      string  `thrift:"type,1,required" json:"type"`
	StringValue *string `thrift:"stringValue,2" json:"stringValue"`
	BinaryValue []byte  `thrift:"binaryValue,3" json:"binaryValue"`
}
var ReceiveMessageRequest_AttributeValue_DEFAULT *MessageAttribute

func NewMessageAttribute 

func NewMessageAttribute() *MessageAttribute

func (*MessageAttribute) GetBinaryValue 

func (p *MessageAttribute) GetBinaryValue() []byte

func (*MessageAttribute) GetStringValue 

func (p *MessageAttribute) GetStringValue() string

func (*MessageAttribute) GetTypeA1 

func (p *MessageAttribute) GetTypeA1() string

func (*MessageAttribute) IsSetBinaryValue 

func (p *MessageAttribute) IsSetBinaryValue() bool

func (*MessageAttribute) IsSetStringValue 

func (p *MessageAttribute) IsSetStringValue() bool

func (*MessageAttribute) Read 

func (p *MessageAttribute) Read(iprot thrift.TProtocol) error

func (*MessageAttribute) ReadField1 

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

func (*MessageAttribute) ReadField2 

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

func (*MessageAttribute) ReadField3 

func (p *MessageAttribute) ReadField3(iprot thrift.TProtocol) error

func (*MessageAttribute) String 

func (p *MessageAttribute) String() string

func (*MessageAttribute) Write 

func (p *MessageAttribute) Write(oprot thrift.TProtocol) error

type MessageBatchErrorEntry 

type MessageBatchErrorEntry struct {
	Id     string                            `thrift:"id,1,required" json:"id"`
	Reason *common.GalaxyEmqServiceException `thrift:"reason,2,required" json:"reason"`
}

func NewMessageBatchErrorEntry 

func NewMessageBatchErrorEntry() *MessageBatchErrorEntry

func (*MessageBatchErrorEntry) GetId 

func (p *MessageBatchErrorEntry) GetId() string

func (*MessageBatchErrorEntry) GetReason 

func (p *MessageBatchErrorEntry) GetReason() *common.GalaxyEmqServiceException

func (*MessageBatchErrorEntry) IsSetReason 

func (p *MessageBatchErrorEntry) IsSetReason() bool

func (*MessageBatchErrorEntry) Read 

func (p *MessageBatchErrorEntry) Read(iprot thrift.TProtocol) error

func (*MessageBatchErrorEntry) ReadField1 

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

func (*MessageBatchErrorEntry) ReadField2 

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

func (*MessageBatchErrorEntry) String 

func (p *MessageBatchErrorEntry) String() string

func (*MessageBatchErrorEntry) Write 

func (p *MessageBatchErrorEntry) Write(oprot thrift.TProtocol) error

type MessageService 

type MessageService interface {
	common.EMQBaseService

	// Send message;
	//
	//
	// Parameters:
	//  - SendMessageRequest
	SendMessage(sendMessageRequest *SendMessageRequest) (r *SendMessageResponse, err error)
	// Send message batch;
	//
	//
	// Parameters:
	//  - SendMessageBatchRequest
	SendMessageBatch(sendMessageBatchRequest *SendMessageBatchRequest) (r *SendMessageBatchResponse, err error)
	// Receive message;
	//
	//
	// Parameters:
	//  - ReceiveMessageRequest
	ReceiveMessage(receiveMessageRequest *ReceiveMessageRequest) (r []*ReceiveMessageResponse, err error)
	// Change message invisibility seconds;
	//
	//
	// Parameters:
	//  - ChangeMessageVisibilityRequest
	ChangeMessageVisibilitySeconds(changeMessageVisibilityRequest *ChangeMessageVisibilityRequest) (err error)
	// Change message invisibility seconds batch;
	//
	//
	// Parameters:
	//  - ChangeMessageVisibilityBatchRequest
	ChangeMessageVisibilitySecondsBatch(changeMessageVisibilityBatchRequest *ChangeMessageVisibilityBatchRequest) (r *ChangeMessageVisibilityBatchResponse, err error)
	// Delete message;
	//
	//
	// Parameters:
	//  - DeleteMessageRequest
	DeleteMessage(deleteMessageRequest *DeleteMessageRequest) (err error)
	// Delete message batch;
	//
	//
	// Parameters:
	//  - DeleteMessageBatchRequest
	DeleteMessageBatch(deleteMessageBatchRequest *DeleteMessageBatchRequest) (r *DeleteMessageBatchResponse, err error)
	// Dead message;
	//
	//
	// Parameters:
	//  - DeadMessageRequest
	DeadMessage(deadMessageRequest *DeadMessageRequest) (err error)
	// Dead message batch;
	//
	//
	// Parameters:
	//  - DeadMessageBatchRequest
	DeadMessageBatch(deadMessageBatchRequest *DeadMessageBatchRequest) (r *DeadMessageBatchResponse, err error)
	// Peek message;
	//
	//
	// Parameters:
	//  - PeekMessageRequest
	PeekMessage(peekMessageRequest *PeekMessageRequest) (r []*PeekMessageResponse, err error)
	// Delete peek message;
	//
	//
	// Parameters:
	//  - DeletePeekMessageRequest
	DeletePeekMessage(deletePeekMessageRequest *DeletePeekMessageRequest) (err error)
	// Delete peek message batch;
	//
	//
	// Parameters:
	//  - DeletePeekMessageBatchRequest
	DeletePeekMessageBatch(deletePeekMessageBatchRequest *DeletePeekMessageBatchRequest) (r *DeletePeekMessageBatchResponse, err error)
}

type MessageServiceClient 

type MessageServiceClient struct {
	*common.EMQBaseServiceClient
}

func NewMessageServiceClientFactory 

func NewMessageServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *MessageServiceClient

func NewMessageServiceClientProtocol 

func NewMessageServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *MessageServiceClient

func (*MessageServiceClient) ChangeMessageVisibilitySeconds 

func (p *MessageServiceClient) ChangeMessageVisibilitySeconds(changeMessageVisibilityRequest *ChangeMessageVisibilityRequest) (err error)

Change message invisibility seconds;

Parameters:

  • ChangeMessageVisibilityRequest

func (*MessageServiceClient) ChangeMessageVisibilitySecondsBatch 

func (p *MessageServiceClient) ChangeMessageVisibilitySecondsBatch(changeMessageVisibilityBatchRequest *ChangeMessageVisibilityBatchRequest) (r *ChangeMessageVisibilityBatchResponse, err error)

Change message invisibility seconds batch;

Parameters:

  • ChangeMessageVisibilityBatchRequest

func (*MessageServiceClient) DeadMessage 

func (p *MessageServiceClient) DeadMessage(deadMessageRequest *DeadMessageRequest) (err error)

Dead message;

Parameters:

  • DeadMessageRequest

func (*MessageServiceClient) DeadMessageBatch 

func (p *MessageServiceClient) DeadMessageBatch(deadMessageBatchRequest *DeadMessageBatchRequest) (r *DeadMessageBatchResponse, err error)

Dead message batch;

Parameters:

  • DeadMessageBatchRequest

func (*MessageServiceClient) DeleteMessage 

func (p *MessageServiceClient) DeleteMessage(deleteMessageRequest *DeleteMessageRequest) (err error)

Delete message;

Parameters:

  • DeleteMessageRequest

func (*MessageServiceClient) DeleteMessageBatch 

func (p *MessageServiceClient) DeleteMessageBatch(deleteMessageBatchRequest *DeleteMessageBatchRequest) (r *DeleteMessageBatchResponse, err error)

Delete message batch;

Parameters:

  • DeleteMessageBatchRequest

func (*MessageServiceClient) DeletePeekMessage 

func (p *MessageServiceClient) DeletePeekMessage(deletePeekMessageRequest *DeletePeekMessageRequest) (err error)

Delete peek message;

Parameters:

  • DeletePeekMessageRequest

func (*MessageServiceClient) DeletePeekMessageBatch 

func (p *MessageServiceClient) DeletePeekMessageBatch(deletePeekMessageBatchRequest *DeletePeekMessageBatchRequest) (r *DeletePeekMessageBatchResponse, err error)

Delete peek message batch;

Parameters:

  • DeletePeekMessageBatchRequest

func (*MessageServiceClient) PeekMessage 

func (p *MessageServiceClient) PeekMessage(peekMessageRequest *PeekMessageRequest) (r []*PeekMessageResponse, err error)

Peek message;

Parameters:

  • PeekMessageRequest

func (*MessageServiceClient) ReceiveMessage 

func (p *MessageServiceClient) ReceiveMessage(receiveMessageRequest *ReceiveMessageRequest) (r []*ReceiveMessageResponse, err error)

Receive message;

Parameters:

  • ReceiveMessageRequest

func (*MessageServiceClient) SendMessage 

func (p *MessageServiceClient) SendMessage(sendMessageRequest *SendMessageRequest) (r *SendMessageResponse, err error)

Send message;

Parameters:

  • SendMessageRequest

func (*MessageServiceClient) SendMessageBatch 

func (p *MessageServiceClient) SendMessageBatch(sendMessageBatchRequest *SendMessageBatchRequest) (r *SendMessageBatchResponse, err error)

Send message batch;

Parameters:

  • SendMessageBatchRequest

type MessageServiceProcessor 

type MessageServiceProcessor struct {
	*common.EMQBaseServiceProcessor
}

func NewMessageServiceProcessor 

func NewMessageServiceProcessor(handler MessageService) *MessageServiceProcessor

type PartitionTimeIntervalAndMaxNum 

type PartitionTimeIntervalAndMaxNum struct {
	StartTimestamp *int64 `thrift:"startTimestamp,1" json:"startTimestamp"`
	EndTimestamp   *int64 `thrift:"endTimestamp,2" json:"endTimestamp"`
	MaxNum         *int32 `thrift:"maxNum,3" json:"maxNum"`
	PartitionId    *int32 `thrift:"partitionId,4" json:"partitionId"`
}
var PeekMessageArg_PartitionTimeIntervalAndMaxNum_DEFAULT *PartitionTimeIntervalAndMaxNum

func NewPartitionTimeIntervalAndMaxNum 

func NewPartitionTimeIntervalAndMaxNum() *PartitionTimeIntervalAndMaxNum

func (*PartitionTimeIntervalAndMaxNum) GetEndTimestamp 

func (p *PartitionTimeIntervalAndMaxNum) GetEndTimestamp() int64

func (*PartitionTimeIntervalAndMaxNum) GetMaxNum 

func (p *PartitionTimeIntervalAndMaxNum) GetMaxNum() int32

func (*PartitionTimeIntervalAndMaxNum) GetPartitionId 

func (p *PartitionTimeIntervalAndMaxNum) GetPartitionId() int32

func (*PartitionTimeIntervalAndMaxNum) GetStartTimestamp 

func (p *PartitionTimeIntervalAndMaxNum) GetStartTimestamp() int64

func (*PartitionTimeIntervalAndMaxNum) IsSetEndTimestamp 

func (p *PartitionTimeIntervalAndMaxNum) IsSetEndTimestamp() bool

func (*PartitionTimeIntervalAndMaxNum) IsSetMaxNum 

func (p *PartitionTimeIntervalAndMaxNum) IsSetMaxNum() bool

func (*PartitionTimeIntervalAndMaxNum) IsSetPartitionId 

func (p *PartitionTimeIntervalAndMaxNum) IsSetPartitionId() bool

func (*PartitionTimeIntervalAndMaxNum) IsSetStartTimestamp 

func (p *PartitionTimeIntervalAndMaxNum) IsSetStartTimestamp() bool

func (*PartitionTimeIntervalAndMaxNum) Read 

func (p *PartitionTimeIntervalAndMaxNum) Read(iprot thrift.TProtocol) error

func (*PartitionTimeIntervalAndMaxNum) ReadField1 

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

func (*PartitionTimeIntervalAndMaxNum) ReadField2 

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

func (*PartitionTimeIntervalAndMaxNum) ReadField3 

func (p *PartitionTimeIntervalAndMaxNum) ReadField3(iprot thrift.TProtocol) error

func (*PartitionTimeIntervalAndMaxNum) ReadField4 

func (p *PartitionTimeIntervalAndMaxNum) ReadField4(iprot thrift.TProtocol) error

func (*PartitionTimeIntervalAndMaxNum) String 

func (p *PartitionTimeIntervalAndMaxNum) String() string

func (*PartitionTimeIntervalAndMaxNum) Write 

func (p *PartitionTimeIntervalAndMaxNum) Write(oprot thrift.TProtocol) error

type PeekMessageArg 

type PeekMessageArg struct {
	ReceiptHandle                  string                          `thrift:"receiptHandle,1" json:"receiptHandle"`
	ReceiptHandleList              []string                        `thrift:"receiptHandleList,2" json:"receiptHandleList"`
	PartitionTimeIntervalAndMaxNum *PartitionTimeIntervalAndMaxNum `thrift:"partitionTimeIntervalAndMaxNum,3" json:"partitionTimeIntervalAndMaxNum"`
}
var PeekMessageRequest_PeekMessageArg_DEFAULT *PeekMessageArg

func NewPeekMessageArg 

func NewPeekMessageArg() *PeekMessageArg

func (*PeekMessageArg) GetPartitionTimeIntervalAndMaxNum 

func (p *PeekMessageArg) GetPartitionTimeIntervalAndMaxNum() *PartitionTimeIntervalAndMaxNum

func (*PeekMessageArg) GetReceiptHandle 

func (p *PeekMessageArg) GetReceiptHandle() string

func (*PeekMessageArg) GetReceiptHandleList 

func (p *PeekMessageArg) GetReceiptHandleList() []string

func (*PeekMessageArg) IsSetPartitionTimeIntervalAndMaxNum 

func (p *PeekMessageArg) IsSetPartitionTimeIntervalAndMaxNum() bool

func (*PeekMessageArg) Read 

func (p *PeekMessageArg) Read(iprot thrift.TProtocol) error

func (*PeekMessageArg) ReadField1 

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

func (*PeekMessageArg) ReadField2 

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

func (*PeekMessageArg) ReadField3 

func (p *PeekMessageArg) ReadField3(iprot thrift.TProtocol) error

func (*PeekMessageArg) String 

func (p *PeekMessageArg) String() string

func (*PeekMessageArg) Write 

func (p *PeekMessageArg) Write(oprot thrift.TProtocol) error

type PeekMessageArgs 

type PeekMessageArgs struct {
	PeekMessageRequest *PeekMessageRequest `thrift:"peekMessageRequest,1" json:"peekMessageRequest"`
}

func NewPeekMessageArgs 

func NewPeekMessageArgs() *PeekMessageArgs

func (*PeekMessageArgs) GetPeekMessageRequest 

func (p *PeekMessageArgs) GetPeekMessageRequest() *PeekMessageRequest

func (*PeekMessageArgs) IsSetPeekMessageRequest 

func (p *PeekMessageArgs) IsSetPeekMessageRequest() bool

func (*PeekMessageArgs) Read 

func (p *PeekMessageArgs) Read(iprot thrift.TProtocol) error

func (*PeekMessageArgs) ReadField1 

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

func (*PeekMessageArgs) String 

func (p *PeekMessageArgs) String() string

func (*PeekMessageArgs) Write 

func (p *PeekMessageArgs) Write(oprot thrift.TProtocol) error

type PeekMessageRequest 

type PeekMessageRequest struct {
	QueueName      string          `thrift:"queueName,1,required" json:"queueName"`
	PeekMessageArg *PeekMessageArg `thrift:"peekMessageArg,2,required" json:"peekMessageArg"`
}
var PeekMessageArgs_PeekMessageRequest_DEFAULT *PeekMessageRequest

func NewPeekMessageRequest 

func NewPeekMessageRequest() *PeekMessageRequest

func (*PeekMessageRequest) GetPeekMessageArg 

func (p *PeekMessageRequest) GetPeekMessageArg() *PeekMessageArg

func (*PeekMessageRequest) GetQueueName 

func (p *PeekMessageRequest) GetQueueName() string

func (*PeekMessageRequest) IsSetPeekMessageArg 

func (p *PeekMessageRequest) IsSetPeekMessageArg() bool

func (*PeekMessageRequest) Read 

func (p *PeekMessageRequest) Read(iprot thrift.TProtocol) error

func (*PeekMessageRequest) ReadField1 

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

func (*PeekMessageRequest) ReadField2 

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

func (*PeekMessageRequest) String 

func (p *PeekMessageRequest) String() string

func (*PeekMessageRequest) Write 

func (p *PeekMessageRequest) Write(oprot thrift.TProtocol) error

type PeekMessageResponse 

type PeekMessageResponse struct {
	MessageID         string                            `thrift:"messageID,1,required" json:"messageID"`
	MessageBody       *string                           `thrift:"messageBody,2" json:"messageBody"`
	Attributes        map[string]string                 `thrift:"attributes,3" json:"attributes"`
	MessageAttributes map[string]*MessageAttribute      `thrift:"messageAttributes,4" json:"messageAttributes"`
	E                 *common.GalaxyEmqServiceException `thrift:"e,5" json:"e"`
}

func NewPeekMessageResponse 

func NewPeekMessageResponse() *PeekMessageResponse

func (*PeekMessageResponse) GetAttributes 

func (p *PeekMessageResponse) GetAttributes() map[string]string

func (*PeekMessageResponse) GetE 

func (p *PeekMessageResponse) GetE() *common.GalaxyEmqServiceException

func (*PeekMessageResponse) GetMessageAttributes 

func (p *PeekMessageResponse) GetMessageAttributes() map[string]*MessageAttribute

func (*PeekMessageResponse) GetMessageBody 

func (p *PeekMessageResponse) GetMessageBody() string

func (*PeekMessageResponse) GetMessageID 

func (p *PeekMessageResponse) GetMessageID() string

func (*PeekMessageResponse) IsSetAttributes 

func (p *PeekMessageResponse) IsSetAttributes() bool

func (*PeekMessageResponse) IsSetE 

func (p *PeekMessageResponse) IsSetE() bool

func (*PeekMessageResponse) IsSetMessageAttributes 

func (p *PeekMessageResponse) IsSetMessageAttributes() bool

func (*PeekMessageResponse) IsSetMessageBody 

func (p *PeekMessageResponse) IsSetMessageBody() bool

func (*PeekMessageResponse) Read 

func (p *PeekMessageResponse) Read(iprot thrift.TProtocol) error

func (*PeekMessageResponse) ReadField1 

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

func (*PeekMessageResponse) ReadField2 

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

func (*PeekMessageResponse) ReadField3 

func (p *PeekMessageResponse) ReadField3(iprot thrift.TProtocol) error

func (*PeekMessageResponse) ReadField4 

func (p *PeekMessageResponse) ReadField4(iprot thrift.TProtocol) error

func (*PeekMessageResponse) ReadField5 

func (p *PeekMessageResponse) ReadField5(iprot thrift.TProtocol) error

func (*PeekMessageResponse) String 

func (p *PeekMessageResponse) String() string

func (*PeekMessageResponse) Write 

func (p *PeekMessageResponse) Write(oprot thrift.TProtocol) error

type PeekMessageResult 

type PeekMessageResult struct {
	Success []*PeekMessageResponse            `thrift:"success,0" json:"success"`
	E       *common.GalaxyEmqServiceException `thrift:"e,1" json:"e"`
}

func NewPeekMessageResult 

func NewPeekMessageResult() *PeekMessageResult

func (*PeekMessageResult) GetE 

func (p *PeekMessageResult) GetE() *common.GalaxyEmqServiceException

func (*PeekMessageResult) GetSuccess 

func (p *PeekMessageResult) GetSuccess() []*PeekMessageResponse

func (*PeekMessageResult) IsSetE 

func (p *PeekMessageResult) IsSetE() bool

func (*PeekMessageResult) IsSetSuccess 

func (p *PeekMessageResult) IsSetSuccess() bool

func (*PeekMessageResult) Read 

func (p *PeekMessageResult) Read(iprot thrift.TProtocol) error

func (*PeekMessageResult) ReadField0 

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

func (*PeekMessageResult) ReadField1 

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

func (*PeekMessageResult) String 

func (p *PeekMessageResult) String() string

func (*PeekMessageResult) Write 

func (p *PeekMessageResult) Write(oprot thrift.TProtocol) error

type ReceiveMessageArgs 

type ReceiveMessageArgs struct {
	ReceiveMessageRequest *ReceiveMessageRequest `thrift:"receiveMessageRequest,1" json:"receiveMessageRequest"`
}

func NewReceiveMessageArgs 

func NewReceiveMessageArgs() *ReceiveMessageArgs

func (*ReceiveMessageArgs) GetReceiveMessageRequest 

func (p *ReceiveMessageArgs) GetReceiveMessageRequest() *ReceiveMessageRequest

func (*ReceiveMessageArgs) IsSetReceiveMessageRequest 

func (p *ReceiveMessageArgs) IsSetReceiveMessageRequest() bool

func (*ReceiveMessageArgs) Read 

func (p *ReceiveMessageArgs) Read(iprot thrift.TProtocol) error

func (*ReceiveMessageArgs) ReadField1 

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

func (*ReceiveMessageArgs) String 

func (p *ReceiveMessageArgs) String() string

func (*ReceiveMessageArgs) Write 

func (p *ReceiveMessageArgs) Write(oprot thrift.TProtocol) error

type ReceiveMessageRequest 

type ReceiveMessageRequest struct {
	QueueName                    string            `thrift:"queueName,1,required" json:"queueName"`
	MaxReceiveMessageNumber      int32             `thrift:"maxReceiveMessageNumber,2" json:"maxReceiveMessageNumber"`
	MaxReceiveMessageWaitSeconds int32             `thrift:"maxReceiveMessageWaitSeconds,3" json:"maxReceiveMessageWaitSeconds"`
	AttributeName                *string           `thrift:"attributeName,4" json:"attributeName"`
	AttributeValue               *MessageAttribute `thrift:"attributeValue,5" json:"attributeValue"`
	TagName                      *string           `thrift:"tagName,6" json:"tagName"`
}
var ReceiveMessageArgs_ReceiveMessageRequest_DEFAULT *ReceiveMessageRequest

func NewReceiveMessageRequest 

func NewReceiveMessageRequest() *ReceiveMessageRequest

func (*ReceiveMessageRequest) GetAttributeName 

func (p *ReceiveMessageRequest) GetAttributeName() string

func (*ReceiveMessageRequest) GetAttributeValue 

func (p *ReceiveMessageRequest) GetAttributeValue() *MessageAttribute

func (*ReceiveMessageRequest) GetMaxReceiveMessageNumber 

func (p *ReceiveMessageRequest) GetMaxReceiveMessageNumber() int32

func (*ReceiveMessageRequest) GetMaxReceiveMessageWaitSeconds 

func (p *ReceiveMessageRequest) GetMaxReceiveMessageWaitSeconds() int32

func (*ReceiveMessageRequest) GetQueueName 

func (p *ReceiveMessageRequest) GetQueueName() string

func (*ReceiveMessageRequest) GetTagName 

func (p *ReceiveMessageRequest) GetTagName() string

func (*ReceiveMessageRequest) IsSetAttributeName 

func (p *ReceiveMessageRequest) IsSetAttributeName() bool

func (*ReceiveMessageRequest) IsSetAttributeValue 

func (p *ReceiveMessageRequest) IsSetAttributeValue() bool

func (*ReceiveMessageRequest) IsSetMaxReceiveMessageNumber 

func (p *ReceiveMessageRequest) IsSetMaxReceiveMessageNumber() bool

func (*ReceiveMessageRequest) IsSetMaxReceiveMessageWaitSeconds 

func (p *ReceiveMessageRequest) IsSetMaxReceiveMessageWaitSeconds() bool

func (*ReceiveMessageRequest) IsSetTagName 

func (p *ReceiveMessageRequest) IsSetTagName() bool

func (*ReceiveMessageRequest) Read 

func (p *ReceiveMessageRequest) Read(iprot thrift.TProtocol) 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) ReadField3 

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

func (*ReceiveMessageRequest) ReadField4 

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

func (*ReceiveMessageRequest) ReadField5 

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

func (*ReceiveMessageRequest) ReadField6 

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

func (*ReceiveMessageRequest) String 

func (p *ReceiveMessageRequest) String() string

func (*ReceiveMessageRequest) Write 

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

type ReceiveMessageResponse 

type ReceiveMessageResponse struct {
	MessageID         string                       `thrift:"messageID,1,required" json:"messageID"`
	ReceiptHandle     string                       `thrift:"receiptHandle,2,required" json:"receiptHandle"`
	MessageBody       string                       `thrift:"messageBody,3,required" json:"messageBody"`
	Attributes        map[string]string            `thrift:"attributes,4" json:"attributes"`
	MessageAttributes map[string]*MessageAttribute `thrift:"messageAttributes,5" json:"messageAttributes"`
}

func NewReceiveMessageResponse 

func NewReceiveMessageResponse() *ReceiveMessageResponse

func (*ReceiveMessageResponse) GetAttributes 

func (p *ReceiveMessageResponse) GetAttributes() map[string]string

func (*ReceiveMessageResponse) GetMessageAttributes 

func (p *ReceiveMessageResponse) GetMessageAttributes() map[string]*MessageAttribute

func (*ReceiveMessageResponse) GetMessageBody 

func (p *ReceiveMessageResponse) GetMessageBody() string

func (*ReceiveMessageResponse) GetMessageID 

func (p *ReceiveMessageResponse) GetMessageID() string

func (*ReceiveMessageResponse) GetReceiptHandle 

func (p *ReceiveMessageResponse) GetReceiptHandle() string

func (*ReceiveMessageResponse) IsSetAttributes 

func (p *ReceiveMessageResponse) IsSetAttributes() bool

func (*ReceiveMessageResponse) IsSetMessageAttributes 

func (p *ReceiveMessageResponse) IsSetMessageAttributes() bool

func (*ReceiveMessageResponse) Read 

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

func (*ReceiveMessageResponse) ReadField1 

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

func (*ReceiveMessageResponse) ReadField2 

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

func (*ReceiveMessageResponse) ReadField3 

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

func (*ReceiveMessageResponse) ReadField4 

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

func (*ReceiveMessageResponse) ReadField5 

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

func (*ReceiveMessageResponse) String 

func (p *ReceiveMessageResponse) String() string

func (*ReceiveMessageResponse) Write 

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

type ReceiveMessageResult 

type ReceiveMessageResult struct {
	Success []*ReceiveMessageResponse         `thrift:"success,0" json:"success"`
	E       *common.GalaxyEmqServiceException `thrift:"e,1" json:"e"`
}

func NewReceiveMessageResult 

func NewReceiveMessageResult() *ReceiveMessageResult

func (*ReceiveMessageResult) GetE 

func (p *ReceiveMessageResult) GetE() *common.GalaxyEmqServiceException

func (*ReceiveMessageResult) GetSuccess 

func (p *ReceiveMessageResult) GetSuccess() []*ReceiveMessageResponse

func (*ReceiveMessageResult) IsSetE 

func (p *ReceiveMessageResult) IsSetE() bool

func (*ReceiveMessageResult) IsSetSuccess 

func (p *ReceiveMessageResult) IsSetSuccess() bool

func (*ReceiveMessageResult) Read 

func (p *ReceiveMessageResult) Read(iprot thrift.TProtocol) error

func (*ReceiveMessageResult) ReadField0 

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

func (*ReceiveMessageResult) ReadField1 

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

func (*ReceiveMessageResult) String 

func (p *ReceiveMessageResult) String() string

func (*ReceiveMessageResult) Write 

func (p *ReceiveMessageResult) Write(oprot thrift.TProtocol) error

type SendMessageArgs 

type SendMessageArgs struct {
	SendMessageRequest *SendMessageRequest `thrift:"sendMessageRequest,1" json:"sendMessageRequest"`
}

func NewSendMessageArgs 

func NewSendMessageArgs() *SendMessageArgs

func (*SendMessageArgs) GetSendMessageRequest 

func (p *SendMessageArgs) GetSendMessageRequest() *SendMessageRequest

func (*SendMessageArgs) IsSetSendMessageRequest 

func (p *SendMessageArgs) IsSetSendMessageRequest() bool

func (*SendMessageArgs) Read 

func (p *SendMessageArgs) Read(iprot thrift.TProtocol) error

func (*SendMessageArgs) ReadField1 

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

func (*SendMessageArgs) String 

func (p *SendMessageArgs) String() string

func (*SendMessageArgs) Write 

func (p *SendMessageArgs) Write(oprot thrift.TProtocol) error

type SendMessageBatchArgs 

type SendMessageBatchArgs struct {
	SendMessageBatchRequest *SendMessageBatchRequest `thrift:"sendMessageBatchRequest,1" json:"sendMessageBatchRequest"`
}

func NewSendMessageBatchArgs 

func NewSendMessageBatchArgs() *SendMessageBatchArgs

func (*SendMessageBatchArgs) GetSendMessageBatchRequest 

func (p *SendMessageBatchArgs) GetSendMessageBatchRequest() *SendMessageBatchRequest

func (*SendMessageBatchArgs) IsSetSendMessageBatchRequest 

func (p *SendMessageBatchArgs) IsSetSendMessageBatchRequest() bool

func (*SendMessageBatchArgs) Read 

func (p *SendMessageBatchArgs) Read(iprot thrift.TProtocol) error

func (*SendMessageBatchArgs) ReadField1 

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

func (*SendMessageBatchArgs) String 

func (p *SendMessageBatchArgs) String() string

func (*SendMessageBatchArgs) Write 

func (p *SendMessageBatchArgs) Write(oprot thrift.TProtocol) error

type SendMessageBatchRequest 

type SendMessageBatchRequest struct {
	QueueName                        string                          `thrift:"queueName,1,required" json:"queueName"`
	SendMessageBatchRequestEntryList []*SendMessageBatchRequestEntry `thrift:"sendMessageBatchRequestEntryList,2,required" json:"sendMessageBatchRequestEntryList"`
	Topic                            *string                         `thrift:"topic,3" json:"topic"`
}
var SendMessageBatchArgs_SendMessageBatchRequest_DEFAULT *SendMessageBatchRequest

func NewSendMessageBatchRequest 

func NewSendMessageBatchRequest() *SendMessageBatchRequest

func (*SendMessageBatchRequest) GetQueueName 

func (p *SendMessageBatchRequest) GetQueueName() string

func (*SendMessageBatchRequest) GetSendMessageBatchRequestEntryList 

func (p *SendMessageBatchRequest) GetSendMessageBatchRequestEntryList() []*SendMessageBatchRequestEntry

func (*SendMessageBatchRequest) GetTopic 

func (p *SendMessageBatchRequest) GetTopic() string

func (*SendMessageBatchRequest) IsSetTopic 

func (p *SendMessageBatchRequest) IsSetTopic() bool

func (*SendMessageBatchRequest) Read 

func (p *SendMessageBatchRequest) Read(iprot thrift.TProtocol) error

func (*SendMessageBatchRequest) ReadField1 

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

func (*SendMessageBatchRequest) ReadField2 

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

func (*SendMessageBatchRequest) ReadField3 

func (p *SendMessageBatchRequest) ReadField3(iprot thrift.TProtocol) error

func (*SendMessageBatchRequest) String 

func (p *SendMessageBatchRequest) String() string

func (*SendMessageBatchRequest) Write 

func (p *SendMessageBatchRequest) Write(oprot thrift.TProtocol) error

type SendMessageBatchRequestEntry 

type SendMessageBatchRequestEntry struct {
	EntryId             string                       `thrift:"entryId,1,required" json:"entryId"`
	MessageBody         string                       `thrift:"messageBody,2,required" json:"messageBody"`
	DelaySeconds        *int32                       `thrift:"delaySeconds,3" json:"delaySeconds"`
	InvisibilitySeconds *int32                       `thrift:"invisibilitySeconds,4" json:"invisibilitySeconds"`
	MessageAttributes   map[string]*MessageAttribute `thrift:"messageAttributes,5" json:"messageAttributes"`
	Priority            *int32                       `thrift:"priority,6" json:"priority"`
}

func NewSendMessageBatchRequestEntry 

func NewSendMessageBatchRequestEntry() *SendMessageBatchRequestEntry

func (*SendMessageBatchRequestEntry) GetDelaySeconds 

func (p *SendMessageBatchRequestEntry) GetDelaySeconds() int32

func (*SendMessageBatchRequestEntry) GetEntryId 

func (p *SendMessageBatchRequestEntry) GetEntryId() string

func (*SendMessageBatchRequestEntry) GetInvisibilitySeconds 

func (p *SendMessageBatchRequestEntry) GetInvisibilitySeconds() int32

func (*SendMessageBatchRequestEntry) GetMessageAttributes 

func (p *SendMessageBatchRequestEntry) GetMessageAttributes() map[string]*MessageAttribute

func (*SendMessageBatchRequestEntry) GetMessageBody 

func (p *SendMessageBatchRequestEntry) GetMessageBody() string

func (*SendMessageBatchRequestEntry) GetPriority 

func (p *SendMessageBatchRequestEntry) GetPriority() int32

func (*SendMessageBatchRequestEntry) IsSetDelaySeconds 

func (p *SendMessageBatchRequestEntry) IsSetDelaySeconds() bool

func (*SendMessageBatchRequestEntry) IsSetInvisibilitySeconds 

func (p *SendMessageBatchRequestEntry) IsSetInvisibilitySeconds() bool

func (*SendMessageBatchRequestEntry) IsSetMessageAttributes 

func (p *SendMessageBatchRequestEntry) IsSetMessageAttributes() bool

func (*SendMessageBatchRequestEntry) IsSetPriority 

func (p *SendMessageBatchRequestEntry) IsSetPriority() bool

func (*SendMessageBatchRequestEntry) Read 

func (p *SendMessageBatchRequestEntry) Read(iprot thrift.TProtocol) error

func (*SendMessageBatchRequestEntry) ReadField1 

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

func (*SendMessageBatchRequestEntry) ReadField2 

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

func (*SendMessageBatchRequestEntry) ReadField3 

func (p *SendMessageBatchRequestEntry) ReadField3(iprot thrift.TProtocol) error

func (*SendMessageBatchRequestEntry) ReadField4 

func (p *SendMessageBatchRequestEntry) ReadField4(iprot thrift.TProtocol) error

func (*SendMessageBatchRequestEntry) ReadField5 

func (p *SendMessageBatchRequestEntry) ReadField5(iprot thrift.TProtocol) error

func (*SendMessageBatchRequestEntry) ReadField6 

func (p *SendMessageBatchRequestEntry) ReadField6(iprot thrift.TProtocol) error

func (*SendMessageBatchRequestEntry) String 

func (p *SendMessageBatchRequestEntry) String() string

func (*SendMessageBatchRequestEntry) Write 

func (p *SendMessageBatchRequestEntry) Write(oprot thrift.TProtocol) error

type SendMessageBatchResponse 

type SendMessageBatchResponse struct {
	Successful []*SendMessageBatchResponseEntry `thrift:"successful,1" json:"successful"`
	Failed     []*MessageBatchErrorEntry        `thrift:"failed,2" json:"failed"`
}
var SendMessageBatchResult_Success_DEFAULT *SendMessageBatchResponse

func NewSendMessageBatchResponse 

func NewSendMessageBatchResponse() *SendMessageBatchResponse

func (*SendMessageBatchResponse) GetFailed 

func (p *SendMessageBatchResponse) GetFailed() []*MessageBatchErrorEntry

func (*SendMessageBatchResponse) GetSuccessful 

func (p *SendMessageBatchResponse) GetSuccessful() []*SendMessageBatchResponseEntry

func (*SendMessageBatchResponse) Read 

func (p *SendMessageBatchResponse) Read(iprot thrift.TProtocol) error

func (*SendMessageBatchResponse) ReadField1 

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

func (*SendMessageBatchResponse) ReadField2 

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

func (*SendMessageBatchResponse) String 

func (p *SendMessageBatchResponse) String() string

func (*SendMessageBatchResponse) Write 

func (p *SendMessageBatchResponse) Write(oprot thrift.TProtocol) error

type SendMessageBatchResponseEntry 

type SendMessageBatchResponseEntry struct {
	EntryId       string  `thrift:"entryId,1,required" json:"entryId"`
	MessageID     string  `thrift:"messageID,2,required" json:"messageID"`
	BodyLength    *int32  `thrift:"bodyLength,3" json:"bodyLength"`
	BodyMd5       *string `thrift:"bodyMd5,4" json:"bodyMd5"`
	SendTimestamp *int64  `thrift:"sendTimestamp,5" json:"sendTimestamp"`
}

func NewSendMessageBatchResponseEntry 

func NewSendMessageBatchResponseEntry() *SendMessageBatchResponseEntry

func (*SendMessageBatchResponseEntry) GetBodyLength 

func (p *SendMessageBatchResponseEntry) GetBodyLength() int32

func (*SendMessageBatchResponseEntry) GetBodyMd5 

func (p *SendMessageBatchResponseEntry) GetBodyMd5() string

func (*SendMessageBatchResponseEntry) GetEntryId 

func (p *SendMessageBatchResponseEntry) GetEntryId() string

func (*SendMessageBatchResponseEntry) GetMessageID 

func (p *SendMessageBatchResponseEntry) GetMessageID() string

func (*SendMessageBatchResponseEntry) GetSendTimestamp 

func (p *SendMessageBatchResponseEntry) GetSendTimestamp() int64

func (*SendMessageBatchResponseEntry) IsSetBodyLength 

func (p *SendMessageBatchResponseEntry) IsSetBodyLength() bool

func (*SendMessageBatchResponseEntry) IsSetBodyMd5 

func (p *SendMessageBatchResponseEntry) IsSetBodyMd5() bool

func (*SendMessageBatchResponseEntry) IsSetSendTimestamp 

func (p *SendMessageBatchResponseEntry) IsSetSendTimestamp() bool

func (*SendMessageBatchResponseEntry) Read 

func (p *SendMessageBatchResponseEntry) Read(iprot thrift.TProtocol) error

func (*SendMessageBatchResponseEntry) ReadField1 

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

func (*SendMessageBatchResponseEntry) ReadField2 

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

func (*SendMessageBatchResponseEntry) ReadField3 

func (p *SendMessageBatchResponseEntry) ReadField3(iprot thrift.TProtocol) error

func (*SendMessageBatchResponseEntry) ReadField4 

func (p *SendMessageBatchResponseEntry) ReadField4(iprot thrift.TProtocol) error

func (*SendMessageBatchResponseEntry) ReadField5 

func (p *SendMessageBatchResponseEntry) ReadField5(iprot thrift.TProtocol) error

func (*SendMessageBatchResponseEntry) String 

func (p *SendMessageBatchResponseEntry) String() string

func (*SendMessageBatchResponseEntry) Write 

func (p *SendMessageBatchResponseEntry) Write(oprot thrift.TProtocol) error

type SendMessageBatchResult 

type SendMessageBatchResult struct {
	Success *SendMessageBatchResponse         `thrift:"success,0" json:"success"`
	E       *common.GalaxyEmqServiceException `thrift:"e,1" json:"e"`
}

func NewSendMessageBatchResult 

func NewSendMessageBatchResult() *SendMessageBatchResult

func (*SendMessageBatchResult) GetE 

func (p *SendMessageBatchResult) GetE() *common.GalaxyEmqServiceException

func (*SendMessageBatchResult) GetSuccess 

func (p *SendMessageBatchResult) GetSuccess() *SendMessageBatchResponse

func (*SendMessageBatchResult) IsSetE 

func (p *SendMessageBatchResult) IsSetE() bool

func (*SendMessageBatchResult) IsSetSuccess 

func (p *SendMessageBatchResult) IsSetSuccess() bool

func (*SendMessageBatchResult) Read 

func (p *SendMessageBatchResult) Read(iprot thrift.TProtocol) error

func (*SendMessageBatchResult) ReadField0 

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

func (*SendMessageBatchResult) ReadField1 

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

func (*SendMessageBatchResult) String 

func (p *SendMessageBatchResult) String() string

func (*SendMessageBatchResult) Write 

func (p *SendMessageBatchResult) Write(oprot thrift.TProtocol) error

type SendMessageRequest 

type SendMessageRequest struct {
	QueueName           string                       `thrift:"queueName,1,required" json:"queueName"`
	MessageBody         string                       `thrift:"messageBody,2,required" json:"messageBody"`
	DelaySeconds        *int32                       `thrift:"delaySeconds,3" json:"delaySeconds"`
	InvisibilitySeconds *int32                       `thrift:"invisibilitySeconds,4" json:"invisibilitySeconds"`
	MessageAttributes   map[string]*MessageAttribute `thrift:"messageAttributes,5" json:"messageAttributes"`
	Topic               *string                      `thrift:"topic,6" json:"topic"`
	Priority            *int32                       `thrift:"priority,7" json:"priority"`
}
var SendMessageArgs_SendMessageRequest_DEFAULT *SendMessageRequest

func NewSendMessageRequest 

func NewSendMessageRequest() *SendMessageRequest

func (*SendMessageRequest) GetDelaySeconds 

func (p *SendMessageRequest) GetDelaySeconds() int32

func (*SendMessageRequest) GetInvisibilitySeconds 

func (p *SendMessageRequest) GetInvisibilitySeconds() int32

func (*SendMessageRequest) GetMessageAttributes 

func (p *SendMessageRequest) GetMessageAttributes() map[string]*MessageAttribute

func (*SendMessageRequest) GetMessageBody 

func (p *SendMessageRequest) GetMessageBody() string

func (*SendMessageRequest) GetPriority 

func (p *SendMessageRequest) GetPriority() int32

func (*SendMessageRequest) GetQueueName 

func (p *SendMessageRequest) GetQueueName() string

func (*SendMessageRequest) GetTopic 

func (p *SendMessageRequest) GetTopic() string

func (*SendMessageRequest) IsSetDelaySeconds 

func (p *SendMessageRequest) IsSetDelaySeconds() bool

func (*SendMessageRequest) IsSetInvisibilitySeconds 

func (p *SendMessageRequest) IsSetInvisibilitySeconds() bool

func (*SendMessageRequest) IsSetMessageAttributes 

func (p *SendMessageRequest) IsSetMessageAttributes() bool

func (*SendMessageRequest) IsSetPriority 

func (p *SendMessageRequest) IsSetPriority() bool

func (*SendMessageRequest) IsSetTopic 

func (p *SendMessageRequest) IsSetTopic() bool

func (*SendMessageRequest) Read 

func (p *SendMessageRequest) Read(iprot thrift.TProtocol) error

func (*SendMessageRequest) ReadField1 

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

func (*SendMessageRequest) ReadField2 

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

func (*SendMessageRequest) ReadField3 

func (p *SendMessageRequest) ReadField3(iprot thrift.TProtocol) error

func (*SendMessageRequest) ReadField4 

func (p *SendMessageRequest) ReadField4(iprot thrift.TProtocol) error

func (*SendMessageRequest) ReadField5 

func (p *SendMessageRequest) ReadField5(iprot thrift.TProtocol) error

func (*SendMessageRequest) ReadField6 

func (p *SendMessageRequest) ReadField6(iprot thrift.TProtocol) error

func (*SendMessageRequest) ReadField7 

func (p *SendMessageRequest) ReadField7(iprot thrift.TProtocol) error

func (*SendMessageRequest) String 

func (p *SendMessageRequest) String() string

func (*SendMessageRequest) Write 

func (p *SendMessageRequest) Write(oprot thrift.TProtocol) error

type SendMessageResponse 

type SendMessageResponse struct {
	MessageID     string  `thrift:"messageID,1,required" json:"messageID"`
	BodyLength    *int32  `thrift:"bodyLength,2" json:"bodyLength"`
	BodyMd5       *string `thrift:"bodyMd5,3" json:"bodyMd5"`
	SendTimestamp *int64  `thrift:"sendTimestamp,4" json:"sendTimestamp"`
}
var SendMessageResult_Success_DEFAULT *SendMessageResponse

func NewSendMessageResponse 

func NewSendMessageResponse() *SendMessageResponse

func (*SendMessageResponse) GetBodyLength 

func (p *SendMessageResponse) GetBodyLength() int32

func (*SendMessageResponse) GetBodyMd5 

func (p *SendMessageResponse) GetBodyMd5() string

func (*SendMessageResponse) GetMessageID 

func (p *SendMessageResponse) GetMessageID() string

func (*SendMessageResponse) GetSendTimestamp 

func (p *SendMessageResponse) GetSendTimestamp() int64

func (*SendMessageResponse) IsSetBodyLength 

func (p *SendMessageResponse) IsSetBodyLength() bool

func (*SendMessageResponse) IsSetBodyMd5 

func (p *SendMessageResponse) IsSetBodyMd5() bool

func (*SendMessageResponse) IsSetSendTimestamp 

func (p *SendMessageResponse) IsSetSendTimestamp() bool

func (*SendMessageResponse) Read 

func (p *SendMessageResponse) Read(iprot thrift.TProtocol) error

func (*SendMessageResponse) ReadField1 

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

func (*SendMessageResponse) ReadField2 

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

func (*SendMessageResponse) ReadField3 

func (p *SendMessageResponse) ReadField3(iprot thrift.TProtocol) error

func (*SendMessageResponse) ReadField4 

func (p *SendMessageResponse) ReadField4(iprot thrift.TProtocol) error

func (*SendMessageResponse) String 

func (p *SendMessageResponse) String() string

func (*SendMessageResponse) Write 

func (p *SendMessageResponse) Write(oprot thrift.TProtocol) error

type SendMessageResult 

type SendMessageResult struct {
	Success *SendMessageResponse              `thrift:"success,0" json:"success"`
	E       *common.GalaxyEmqServiceException `thrift:"e,1" json:"e"`
}

func NewSendMessageResult 

func NewSendMessageResult() *SendMessageResult

func (*SendMessageResult) GetE 

func (p *SendMessageResult) GetE() *common.GalaxyEmqServiceException

func (*SendMessageResult) GetSuccess 

func (p *SendMessageResult) GetSuccess() *SendMessageResponse

func (*SendMessageResult) IsSetE 

func (p *SendMessageResult) IsSetE() bool

func (*SendMessageResult) IsSetSuccess 

func (p *SendMessageResult) IsSetSuccess() bool

func (*SendMessageResult) Read 

func (p *SendMessageResult) Read(iprot thrift.TProtocol) error

func (*SendMessageResult) ReadField0 

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

func (*SendMessageResult) ReadField1 

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

func (*SendMessageResult) String 

func (p *SendMessageResult) String() string

func (*SendMessageResult) Write 

func (p *SendMessageResult) Write(oprot thrift.TProtocol) error

Source Files

View all Source files

Directories

Path Synopsis

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.