worker

package
v0.0.29 Latest Latest
Warning

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

 Go to latest Published: Aug 26, 2023 License: AGPL-3.0 Imports: 5 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func ProcessRequests added in v0.0.28 

func ProcessRequests(ctx context.Context)

func Submit added in v0.0.28 

func Submit(ctx context.Context, r *entry.Request)

Types

type RequestBuffer added in v0.0.28 

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

func GetBuff added in v0.0.28 

func GetBuff(ctx context.Context) *RequestBuffer

func SetupRequestsBuffer added in v0.0.28 

func SetupRequestsBuffer(ctx context.Context) (context.Context, *RequestBuffer)

func (*RequestBuffer) Accept added in v0.0.28 

func (r *RequestBuffer) Accept(req *entry.Request)

func (*RequestBuffer) Close added in v0.0.28 

func (r *RequestBuffer) Close() 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.