workflowproc

Documentation

Index

• Constants
• Variables
• type Config
• type Logger
• type Processor
  • func New(lg Logger, cfg *Config) *Processor
  • func (p *Processor) Run(ctx context.Context) error

Constants

const ConfigMaxStreams = 20

Variables

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

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