udf

Documentation

Index

• type Config
  • func NewConfig() Config
  • func (c Config) Validate() error
• type Diagnostic
• type FunctionConfig
  • func (c FunctionConfig) Validate() error
• type Service
  • func NewService(c Config, d Diagnostic) *Service
  • func (s *Service) Close() error
  • func (s *Service) Create(name, taskID, nodeID string, d udf.Diagnostic, abortCallback func()) (udf.Interface, error)
  • func (s *Service) Info(name string) (udf.Info, bool)
  • func (s *Service) List() []string
  • func (s *Service) Open() error
  • func (s *Service) Refresh(name string) error

Types

type Config

type Config struct {
	Functions map[string]FunctionConfig `toml:"functions"`
}

func NewConfig

func NewConfig() Config

func (Config) Validate

func (c Config) Validate() error

type Diagnostic

type Diagnostic interface {
	LoadedUDFInfo(udf string)

	WithUDFContext() udf.Diagnostic
}

type FunctionConfig

type FunctionConfig struct {
	// General config
	Timeout toml.Duration `toml:"timeout"`

	// Config for connecting to domain socket
	Socket string `toml:"socket"`

	// Config for creating process
	Prog string            `toml:"prog"`
	Args []string          `toml:"args"`
	Env  map[string]string `toml:"env"`
}

func (FunctionConfig) Validate

func (c FunctionConfig) Validate() error

type Service

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

func NewService

func NewService(c Config, d Diagnostic) *Service

func (*Service) Close

func (s *Service) Close() error

func (*Service) Create

func (s *Service) Create(
	name, taskID, nodeID string,
	d udf.Diagnostic,
	abortCallback func(),
) (udf.Interface, error)

func (*Service) Info

func (s *Service) Info(name string) (udf.Info, bool)

func (*Service) List

func (s *Service) List() []string

func (*Service) Open

func (s *Service) Open() error

func (*Service) Refresh

func (s *Service) Refresh(name string) error