Documentation
¶
Index ¶
- type Config
- type Diagnostic
- type FunctionConfig
- type 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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Config ¶
type Config struct {
Functions map[string]FunctionConfig `toml:"functions"`
}
type Diagnostic ¶ added in v1.4.0
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 ¶ added in v0.13.0
func (c FunctionConfig) Validate() error
type Service ¶
type Service struct {
// contains filtered or unexported fields
}
func NewService ¶
func NewService(c Config, d Diagnostic) *Service
Click to show internal directories.
Click to hide internal directories.