cfqueues

package

v1.10.6 Latest Latest Go to latest Published: May 5, 2023 License: Apache-2.0 Imports: 13 Imported by: 1

Details

This section is empty.

This section is empty.

func NewCFQueues(logger logger.Logger) bindings.OutputBinding

NewCFQueues returns a new CFQueues.

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

CFQueues is a binding for publishing messages on Cloudflare Queues

func (q *CFQueues) Close() error

Close the component

func (q *CFQueues) Init(metadata bindings.Metadata) error

Init the component.

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

Invoke the output binding.

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

Operations returns the supported operations for this binding.