worker

package
v0.1.4 Latest Latest
Warning

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

Go to latest
Published: Jan 9, 2024 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Handle

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

func NewHandle

func NewHandle(logger log.Logger, receive *param.Receive, param *param.Handle) *Handle

func (*Handle) Start

func (h *Handle) Start(ctx context.Context, handler message.Handler[any]) (err error)

type Receive

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

func NewReceive

func NewReceive(param *param.Receive) *Receive

func (*Receive) Do

func (r *Receive) Do(ctx context.Context) (out *output.Receive, err error)

type Send

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

func NewSend

func NewSend(param *param.Send) *Send

func (*Send) Do

func (s *Send) Do(ctx context.Context) (out *output.Send, err error)

type Url added in v0.0.2

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

func NewUrl added in v0.0.2

func NewUrl(param *internal.Base, url callback.Url) *Url

func (*Url) Do added in v0.0.2

func (u *Url) Do(ctx context.Context) (*string, error)

Jump to

Keyboard shortcuts

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