workflowproc

package
v0.0.0-...-4450389 Latest Latest
Warning

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

Go to latest
Published: Nov 4, 2019 License: MIT Imports: 26 Imported by: 0

Documentation

Index

Constants

View Source
const ConfigMaxStreams = 20

Variables

View Source
var ErrUnknownEvent = errors.New("unknown event")

Functions

This section is empty.

Types

type Config

type Config struct {
	Registries  []string
	Conn        *grpc.ClientConn
	SysRPCCreds credentials.PerRPCCredentials
}

type Logger

type Logger interface {
	Infow(msg string, kv ...interface{})
	Warnw(msg string, kv ...interface{})
	Errorw(msg string, kv ...interface{})
}

type Processor

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

func New

func New(lg Logger, cfg *Config) *Processor

func (*Processor) Run

func (p *Processor) Run(ctx context.Context) error

Jump to

Keyboard shortcuts

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