service

Mar 28, 2022

Changes in this version

+ func AddHostFlags(flag *pflag.FlagSet)

+ func GetManifest(namespace string, v interface{}) error

+ func GetService(namespace, name string, service Service)

+ func HasNamespace(namespace string) (bool, error)

+ func Hosted() bool

+ func InitServiceClient(ctx context.Context) error

+ func ListServices(namespace string) ([]string, error)

+ func RegisterFileOpener(scheme string, f FileOpener)

+ func WithFilePath(p string) plugin.ExecOption

+ func WithFilePathPair(input, output string) plugin.ExecOption

+ type BindFunc func(ctx context.Context, plug *plugin.Plugin, cmd *plugin.Command, ...) error

+ type BindOption func(*bindOption)

+ func WithAnonymousPipe() BindOption

+ func WithAnonymousPipeByProcFS(procfs string) BindOption

+ func WithBindFunc(f BindFunc) BindOption

+ type FileOpener func(url *url.URL, flag int) (io.ReadWriteCloser, error)

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) AddService(ns, name string, svc Service)

+ func (r *Registry) AddServices(svcs Services)

+ func (r *Registry) Bind(opts ...BindOption) plugin.ExecOption

+ func (r *Registry) Define(ns string, manifest interface{})

+ func (r *Registry) Inherit() *Registry

+ type Service interface

+ type Services interface

+ Add func(*Registry)