secretariat

package
v1.0.0 Latest Latest
Warning

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

Go to latest
Published: Aug 15, 2023 License: MIT Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Folder

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

func NewFolder

func NewFolder(ctx context.Context, bufferSize int, key string) *Folder

type Secretary

type Secretary struct {
	Name string
	// contains filtered or unexported fields
}

func NewSecretary

func NewSecretary(ctx context.Context, cfg SecretaryConfig) *Secretary

func (*Secretary) Put

func (secretary *Secretary) Put(msg interface{})

func (*Secretary) Start

func (secretary *Secretary) Start()

type SecretaryConfig

type SecretaryConfig struct {
	Name        string
	BufferSize  int
	ScannerRate time.Duration
	WithCompass bool
}

type Something

type Something interface{}

type Workflow

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

func NewWorkflow

func NewWorkflow(ctx context.Context, bufferSize int, scannerRate time.Duration, withCompass bool) *Workflow

func (*Workflow) Put

func (workflow *Workflow) Put(sth Something)

Jump to

Keyboard shortcuts

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