workers

package
v1.0.7 Latest Latest
Warning

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

Go to latest
Published: Jul 8, 2024 License: Apache-2.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type ApiWorker

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

func NewApiWorker

func NewApiWorker(opts *ApiWorkerOpts) *ApiWorker

func (*ApiWorker) Start

func (a *ApiWorker) Start(ctx context.Context) error

Start implements Worker.

type ApiWorkerOpts

type ApiWorkerOpts struct {
	RegistrationRequest *v1.RegistrationRequest
	Middleware          handler.HttpMiddleware
}

type BlobEventWorker

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

func NewBlobEventWorker

func NewBlobEventWorker(opts *BlobEventWorkerOpts) *BlobEventWorker

func (*BlobEventWorker) Start

func (b *BlobEventWorker) Start(ctx context.Context) error

Start implements Worker.

type BlobEventWorkerOpts

type BlobEventWorkerOpts struct {
	RegistrationRequest *v1.RegistrationRequest
	Middleware          handler.BlobEventMiddleware
}

type IntervalWorker

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

func NewIntervalWorker

func NewIntervalWorker(opts *IntervalWorkerOpts) *IntervalWorker

func (*IntervalWorker) Start

func (i *IntervalWorker) Start(ctx context.Context) error

Start implements Worker.

type IntervalWorkerOpts

type IntervalWorkerOpts struct {
	RegistrationRequest *v1.RegistrationRequest
	Middleware          handler.IntervalMiddleware
}

type SubscriptionWorker

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

func NewSubscriptionWorker

func NewSubscriptionWorker(opts *SubscriptionWorkerOpts) *SubscriptionWorker

func (*SubscriptionWorker) Start

func (s *SubscriptionWorker) Start(ctx context.Context) error

Start implements Worker.

type SubscriptionWorkerOpts

type SubscriptionWorkerOpts struct {
	RegistrationRequest *v1.RegistrationRequest
	Middleware          handler.MessageMiddleware
}

type WebsocketWorker

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

func NewWebsocketWorker

func NewWebsocketWorker(opts *WebsocketWorkerOpts) *WebsocketWorker

func (*WebsocketWorker) Start

func (w *WebsocketWorker) Start(ctx context.Context) error

Start implements Worker.

type WebsocketWorkerOpts

type WebsocketWorkerOpts struct {
	RegistrationRequest *v1.RegistrationRequest
	Middleware          handler.WebsocketMiddleware
}

type Worker

type Worker interface {
	Start(context.Context) error
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL