client

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: 24 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ClientFactory 

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

func NewClientFactory 

func NewClientFactory(credential *auth.Credential, soTimeout time.Duration) ClientFactory

func (*ClientFactory) NewDefaultMessageClient 

func (cf *ClientFactory) NewDefaultMessageClient() message.MessageService

func (*ClientFactory) NewDefaultQueueClient 

func (cf *ClientFactory) NewDefaultQueueClient() queue.QueueService

func (*ClientFactory) NewDefaultSecureMessageClient 

func (cf *ClientFactory) NewDefaultSecureMessageClient() message.MessageService

func (*ClientFactory) NewDefaultSecureQueueClient 

func (cf *ClientFactory) NewDefaultSecureQueueClient() queue.QueueService

func (*ClientFactory) NewMessageClient 

func (cf *ClientFactory) NewMessageClient(url string) message.MessageService

func (*ClientFactory) NewQueueClient 

func (cf *ClientFactory) NewQueueClient(url string) queue.QueueService

type EmqErrorCodePeeker 

type EmqErrorCodePeeker interface {
	GetErrorCode() common.ErrorCode
}

type EmqTHttpClient 

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

func (*EmqTHttpClient) Close 

func (p *EmqTHttpClient) Close() error

func (*EmqTHttpClient) DelHeader 

func (p *EmqTHttpClient) DelHeader(key string)

Deletes the HTTP Header given a Header Key for this specific Thrift Transport It is important that you first assert the TTransport as a EmqTHttpClient type like so:

httpTrans := trans.(EmqTHttpClient) httpTrans.DelHeader("User-Agent")

func (*EmqTHttpClient) Flush 

func (p *EmqTHttpClient) Flush() error

func (*EmqTHttpClient) GetHeader 

func (p *EmqTHttpClient) GetHeader(key string) string

Get the HTTP Header represented by the supplied Header Key for this specific Thrift Transport It is important that you first assert the TTransport as a EmqTHttpClient type like so:

httpTrans := trans.(EmqTHttpClient) hdrValue := httpTrans.GetHeader("User-Agent")

func (*EmqTHttpClient) IsOpen 

func (p *EmqTHttpClient) IsOpen() bool

func (*EmqTHttpClient) Open 

func (p *EmqTHttpClient) Open() error

func (*EmqTHttpClient) Peek 

func (p *EmqTHttpClient) Peek() bool

func (*EmqTHttpClient) Read 

func (p *EmqTHttpClient) Read(buf []byte) (int, error)

func (*EmqTHttpClient) ReadByte 

func (p *EmqTHttpClient) ReadByte() (c byte, err error)

func (*EmqTHttpClient) SetHeader 

func (p *EmqTHttpClient) SetHeader(key string, value string)

Set the HTTP Header for this specific Thrift Transport It is important that you first assert the TTransport as a EmqTHttpClient type like so:

httpTrans := trans.(EmqTHttpClient) httpTrans.SetHeader("User-Agent","Thrift Client 1.0")

func (*EmqTHttpClient) Write 

func (p *EmqTHttpClient) Write(buf []byte) (int, error)

func (*EmqTHttpClient) WriteByte 

func (p *EmqTHttpClient) WriteByte(c byte) error

func (*EmqTHttpClient) WriteString 

func (p *EmqTHttpClient) WriteString(s string) (n int, err error)

type EmqTHttpClientTransportFactory 

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

func NewTHttpClientTransportFactory 

func NewTHttpClientTransportFactory(url string, credential *auth.Credential,
	httpClient *http.Client, agent string) *EmqTHttpClientTransportFactory

func (*EmqTHttpClientTransportFactory) GetTransport 

func (p *EmqTHttpClientTransportFactory) GetTransport(trans thrift.TTransport) thrift.TTransport

func (*EmqTHttpClientTransportFactory) GetTransportWithQuery 

func (p *EmqTHttpClientTransportFactory) GetTransportWithQuery(trans thrift.TTransport,
	query string) thrift.TTransport

type EmqTransportError 

type EmqTransportError struct {
	HttpStatusCode errors.HttpStatusCode
	ErrorCode      common.ErrorCode
	ErrorMessage   string
	ServerTime     int64
}

func NewEmqTransportError 

func NewEmqTransportError(httpStatusCode errors.HttpStatusCode,
	errorMessage string, timestamp int64) *EmqTransportError

func (*EmqTransportError) Error 

func (p *EmqTransportError) Error() string

func (*EmqTransportError) GetErrorCode 

func (p *EmqTransportError) GetErrorCode() common.ErrorCode

func (*EmqTransportError) String 

func (p *EmqTransportError) String() string

type MessageClientProxy 

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

func (*MessageClientProxy) ChangeMessageVisibilitySeconds 

func (p *MessageClientProxy) ChangeMessageVisibilitySeconds(changeMessageVisibilityRequest *message.ChangeMessageVisibilityRequest) (err error)

func (*MessageClientProxy) ChangeMessageVisibilitySecondsBatch 

func (p *MessageClientProxy) ChangeMessageVisibilitySecondsBatch(changeMessageVisibilityBatchRequest *message.ChangeMessageVisibilityBatchRequest) (r *message.ChangeMessageVisibilityBatchResponse, err error)

func (*MessageClientProxy) DeadMessage 

func (p *MessageClientProxy) DeadMessage(deadMessageRequest *message.DeadMessageRequest) (err error)

func (*MessageClientProxy) DeadMessageBatch 

func (p *MessageClientProxy) DeadMessageBatch(deadMessageBatchRequest *message.DeadMessageBatchRequest) (r *message.DeadMessageBatchResponse, err error)

func (*MessageClientProxy) DeleteMessage 

func (p *MessageClientProxy) DeleteMessage(deleteMessageRequest *message.DeleteMessageRequest) (err error)

func (*MessageClientProxy) DeleteMessageBatch 

func (p *MessageClientProxy) DeleteMessageBatch(deleteMessageBatchRequest *message.DeleteMessageBatchRequest) (r *message.DeleteMessageBatchResponse, err error)

func (*MessageClientProxy) DeletePeekMessage 

func (p *MessageClientProxy) DeletePeekMessage(deletePeekMessageRequest *message.DeletePeekMessageRequest) (err error)

func (*MessageClientProxy) DeletePeekMessageBatch 

func (p *MessageClientProxy) DeletePeekMessageBatch(deletePeekMessageBatchRequest *message.DeletePeekMessageBatchRequest) (r *message.DeletePeekMessageBatchResponse, err error)

func (*MessageClientProxy) GetServiceVersion 

func (p *MessageClientProxy) GetServiceVersion() (r *common.Version, err error)

func (*MessageClientProxy) PeekMessage 

func (p *MessageClientProxy) PeekMessage(peekMessageRequest *message.PeekMessageRequest) (r []*message.PeekMessageResponse, err error)

func (*MessageClientProxy) ReceiveMessage 

func (p *MessageClientProxy) ReceiveMessage(receiveMessageRequest *message.ReceiveMessageRequest) (r []*message.ReceiveMessageResponse, err error)

func (*MessageClientProxy) SendMessage 

func (p *MessageClientProxy) SendMessage(sendMessageRequest *message.SendMessageRequest) (r *message.SendMessageResponse, err error)

func (*MessageClientProxy) SendMessageBatch 

func (p *MessageClientProxy) SendMessageBatch(sendMessageBatchRequest *message.SendMessageBatchRequest) (r *message.SendMessageBatchResponse, err error)

func (*MessageClientProxy) ValidClientVersion 

func (p *MessageClientProxy) ValidClientVersion(clientVersion *common.Version) (err error)

type QueueClientProxy 

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

func (*QueueClientProxy) CopyQueue 

func (p *QueueClientProxy) CopyQueue(request *queue.CopyQueueRequest) (err error)

func (*QueueClientProxy) CreateQueue 

func (p *QueueClientProxy) CreateQueue(request *queue.CreateQueueRequest) (r *queue.CreateQueueResponse, err error)

func (*QueueClientProxy) CreateTag 

func (p *QueueClientProxy) CreateTag(request *queue.CreateTagRequest) (r *queue.CreateTagResponse, err error)

func (*QueueClientProxy) DeleteQueue 

func (p *QueueClientProxy) DeleteQueue(request *queue.DeleteQueueRequest) (err error)

func (*QueueClientProxy) DeleteTag 

func (p *QueueClientProxy) DeleteTag(request *queue.DeleteTagRequest) (err error)

func (*QueueClientProxy) GetQueueInfo 

func (p *QueueClientProxy) GetQueueInfo(request *queue.GetQueueInfoRequest) (r *queue.GetQueueInfoResponse, err error)

func (*QueueClientProxy) GetQueueMeta 

func (p *QueueClientProxy) GetQueueMeta(queueName string) (r *queue.GetQueueMetaResponse, err error)

func (*QueueClientProxy) GetServiceVersion 

func (p *QueueClientProxy) GetServiceVersion() (r *common.Version, err error)

func (*QueueClientProxy) GetTagInfo 

func (p *QueueClientProxy) GetTagInfo(request *queue.GetTagInfoRequest) (r *queue.GetTagInfoResponse, err error)

func (*QueueClientProxy) ListPermissions 

func (p *QueueClientProxy) ListPermissions(request *queue.ListPermissionsRequest) (r *queue.ListPermissionsResponse, err error)

func (*QueueClientProxy) ListQueue 

func (p *QueueClientProxy) ListQueue(request *queue.ListQueueRequest) (r *queue.ListQueueResponse, err error)

func (*QueueClientProxy) ListTag 

func (p *QueueClientProxy) ListTag(request *queue.ListTagRequest) (r *queue.ListTagResponse, err error)

func (*QueueClientProxy) PurgeQueue 

func (p *QueueClientProxy) PurgeQueue(request *queue.PurgeQueueRequest) (err error)

func (*QueueClientProxy) QueryMetric 

func (p *QueueClientProxy) QueryMetric(request *queue.QueryMetricRequest) (r *queue.TimeSeriesData, err error)

func (*QueueClientProxy) QueryPermission 

func (p *QueueClientProxy) QueryPermission(request *queue.QueryPermissionRequest) (r *queue.QueryPermissionResponse, err error)

func (*QueueClientProxy) QueryPermissionForId 

func (p *QueueClientProxy) QueryPermissionForId(request *queue.QueryPermissionForIdRequest) (r *queue.QueryPermissionForIdResponse, err error)

func (*QueueClientProxy) QueryPrivilegedQueue 

func (p *QueueClientProxy) QueryPrivilegedQueue(request *queue.QueryPrivilegedQueueRequest) (r *queue.QueryPrivilegedQueueResponse, err error)

func (*QueueClientProxy) RemoveQueueRedrivePolicy 

func (p *QueueClientProxy) RemoveQueueRedrivePolicy(request *queue.RemoveQueueRedrivePolicyRequest) (err error)

func (*QueueClientProxy) RevokePermission 

func (p *QueueClientProxy) RevokePermission(request *queue.RevokePermissionRequest) (err error)

func (*QueueClientProxy) SetPermission 

func (p *QueueClientProxy) SetPermission(request *queue.SetPermissionRequest) (err error)

func (*QueueClientProxy) SetQueueAttribute 

func (p *QueueClientProxy) SetQueueAttribute(request *queue.SetQueueAttributesRequest) (r *queue.SetQueueAttributesResponse, err error)

func (*QueueClientProxy) SetQueueQuota 

func (p *QueueClientProxy) SetQueueQuota(request *queue.SetQueueQuotaRequest) (r *queue.SetQueueQuotaResponse, err error)

func (*QueueClientProxy) SetQueueRedrivePolicy 

func (p *QueueClientProxy) SetQueueRedrivePolicy(request *queue.SetQueueRedrivePolicyRequest) (r *queue.SetQueueRedrivePolicyResponse, err error)

func (*QueueClientProxy) ValidClientVersion 

func (p *QueueClientProxy) ValidClientVersion(clientVersion *common.Version) (err error)

func (*QueueClientProxy) VerifyEMQAdmin 

func (p *QueueClientProxy) VerifyEMQAdmin() (r *queue.VerifyEMQAdminResponse, err error)

func (*QueueClientProxy) VerifyEMQAdminRole 

func (p *QueueClientProxy) VerifyEMQAdminRole(request *queue.VerifyEMQAdminRoleRequest) (r *queue.VerifyEMQAdminRoleResponse, err error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.