Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
View Source
var DefaultContext = NewRemoteContext(logruslog.Global, config.GetConfig())
Functions ¶
This section is empty.
Types ¶
type Bridge ¶
type Bridge struct {
// contains filtered or unexported fields
}
func (*Bridge) RemoteSubtaskEntrypointHandler ¶
func (b *Bridge) RemoteSubtaskEntrypointHandler(subtaskMeta models.SubtaskMeta) plugin.SubTaskEntryPoint
type CallResult ¶
func NewCallResult ¶
func NewCallResult(results []byte, err errors.Error) *CallResult
type CmdInvoker ¶
type CmdInvoker struct {
// contains filtered or unexported fields
}
func NewCmdInvoker ¶
func NewCmdInvoker(execPath string) *CmdInvoker
func (*CmdInvoker) Call ¶
func (c *CmdInvoker) Call(methodName string, ctx plugin.ExecContext, args ...any) *CallResult
func (*CmdInvoker) Stream ¶
func (c *CmdInvoker) Stream(methodName string, ctx plugin.ExecContext, args ...any) *MethodStream
type Invoker ¶
type Invoker interface { Call(methodName string, ctx plugin.ExecContext, args ...any) *CallResult Stream(methodName string, ctx plugin.ExecContext, args ...any) *MethodStream }
type MethodStream ¶
type MethodStream struct {
// contains filtered or unexported fields
}
func (*MethodStream) Receive ¶
func (m *MethodStream) Receive() <-chan *StreamResult
type RemoteConfig ¶
type RemoteConfig struct {
LogLevel string `json:"log_level"`
}
RemoteConfig holds common configuration for all remote calls
type RemoteContext ¶
type RemoteContext interface { plugin.ExecContext GetRemoteConfig() *RemoteConfig }
func NewChildRemoteContext ¶
func NewChildRemoteContext(ec plugin.ExecContext) RemoteContext
func NewRemoteContext ¶
func NewRemoteContext(logger log.Logger, cfg *viper.Viper) RemoteContext
type RemoteProgress ¶
type StreamResult ¶
type StreamResult = CallResult
func NewStreamResult ¶
func NewStreamResult(results []byte, err errors.Error) *StreamResult
Click to show internal directories.
Click to hide internal directories.