cfqueues

Documentation

Index

• func NewCFQueues(logger logger.Logger) bindings.OutputBinding
• type CFQueues
  • func (q *CFQueues) Close() error
  • func (q *CFQueues) GetComponentMetadata() map[string]string
  • func (q *CFQueues) Init(_ context.Context, metadata bindings.Metadata) error
  • func (q *CFQueues) Invoke(ctx context.Context, req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)
  • func (q CFQueues) Operations() []bindings.OperationKind

Functions

func NewCFQueues

func NewCFQueues(logger logger.Logger) bindings.OutputBinding

NewCFQueues returns a new CFQueues.

Types

type CFQueues

type CFQueues struct {
	*workers.Base
	// contains filtered or unexported fields
}

CFQueues is a binding for publishing messages on Cloudflare Queues

func (*CFQueues) Close

func (q *CFQueues) Close() error

Close the component

func (*CFQueues) GetComponentMetadata

func (q *CFQueues) GetComponentMetadata() map[string]string

GetComponentMetadata returns the metadata of the component.

func (*CFQueues) Init

func (q *CFQueues) Init(_ context.Context, metadata bindings.Metadata) error

Init the component.

func (*CFQueues) Invoke

func (q *CFQueues) Invoke(ctx context.Context, req *bindings.InvokeRequest) (*bindings.InvokeResponse, error)

Invoke the output binding.

func (CFQueues) Operations

func (q CFQueues) Operations() []bindings.OperationKind

Operations returns the supported operations for this binding.