proto

type ExecuteRequest struct {
	ExecutorId string            `protobuf:"bytes,1,opt,name=executor_id,json=executorId,proto3" json:"executor_id,omitempty"`
	ExecCtx    *ExecutionContext `protobuf:"bytes,2,opt,name=exec_ctx,json=execCtx,proto3" json:"exec_ctx,omitempty"`
	// contains filtered or unexported fields
}

type ExecuteResponse struct {

	// Types that are assignable to Payload:
	//	*ExecuteResponse_Log
	//	*ExecuteResponse_Result
	Payload isExecuteResponse_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

type ExecuteResponse_Log struct {
	Log *LogLine `protobuf:"bytes,1,opt,name=log,proto3,oneof"`
}

type ExecuteResponse_Result struct {
	Result *Result `protobuf:"bytes,2,opt,name=result,proto3,oneof"`
}

type ExecutionContext struct {
	WithConfig    []byte            `protobuf:"bytes,1,opt,name=with_config,json=withConfig,proto3" json:"with_config,omitempty"`
	Inputs        map[string]string `` /* 153-byte string literal not displayed */
	UserUuid      string            `protobuf:"bytes,3,opt,name=user_uuid,json=userUuid,proto3" json:"user_uuid,omitempty"`
	NamespaceName string            `protobuf:"bytes,4,opt,name=namespace_name,json=namespaceName,proto3" json:"namespace_name,omitempty"`
	ApiKey        string            `protobuf:"bytes,5,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"`
	ApiBaseUrl    string            `protobuf:"bytes,6,opt,name=api_base_url,json=apiBaseUrl,proto3" json:"api_base_url,omitempty"`
	Nodes         []*Node           `protobuf:"bytes,7,rep,name=nodes,proto3" json:"nodes,omitempty"`
	// contains filtered or unexported fields
}

type ExecutorPluginClient interface {
	GetName(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetNameResponse, error)
	GetSchema(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetSchemaResponse, error)
	GetCapabilities(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetCapabilitiesResponse, error)
	New(ctx context.Context, in *NewRequest, opts ...grpc.CallOption) (*NewResponse, error)
	Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (ExecutorPlugin_ExecuteClient, error)
}

type ExecutorPluginServer interface {
	GetName(context.Context, *emptypb.Empty) (*GetNameResponse, error)
	GetSchema(context.Context, *emptypb.Empty) (*GetSchemaResponse, error)
	GetCapabilities(context.Context, *emptypb.Empty) (*GetCapabilitiesResponse, error)
	New(context.Context, *NewRequest) (*NewResponse, error)
	Execute(*ExecuteRequest, ExecutorPlugin_ExecuteServer) error
	// contains filtered or unexported methods
}

type ExecutorPlugin_ExecuteClient interface {
	Recv() (*ExecuteResponse, error)
	grpc.ClientStream
}

type ExecutorPlugin_ExecuteServer interface {
	Send(*ExecuteResponse) error
	grpc.ServerStream
}

type GetCapabilitiesResponse struct {
	Capabilities uint64 `protobuf:"varint,1,opt,name=capabilities,proto3" json:"capabilities,omitempty"`
	// contains filtered or unexported fields
}

type GetNameResponse struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

type GetSchemaResponse struct {
	SchemaJson []byte `protobuf:"bytes,1,opt,name=schema_json,json=schemaJson,proto3" json:"schema_json,omitempty"`
	// contains filtered or unexported fields
}

type LogLine struct {
	Stream LogLine_Stream `protobuf:"varint,1,opt,name=stream,proto3,enum=proto.LogLine_Stream" json:"stream,omitempty"`
	Data   []byte         `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type LogLine_Stream int32

type NewRequest struct {
	Name   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Node   *Node  `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
	ExecId string `protobuf:"bytes,3,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	// contains filtered or unexported fields
}

type NewResponse struct {
	ExecutorId   string `protobuf:"bytes,1,opt,name=executor_id,json=executorId,proto3" json:"executor_id,omitempty"`
	ArtifactsDir string `protobuf:"bytes,2,opt,name=artifacts_dir,json=artifactsDir,proto3" json:"artifacts_dir,omitempty"`
	Error        string `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type Node struct {
	Hostname       string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Port           int32  `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Username       string `protobuf:"bytes,3,opt,name=username,proto3" json:"username,omitempty"`
	AuthMethod     string `protobuf:"bytes,4,opt,name=auth_method,json=authMethod,proto3" json:"auth_method,omitempty"`
	AuthKey        string `protobuf:"bytes,5,opt,name=auth_key,json=authKey,proto3" json:"auth_key,omitempty"`
	ConnectionType string `protobuf:"bytes,6,opt,name=connection_type,json=connectionType,proto3" json:"connection_type,omitempty"`
	OsFamily       string `protobuf:"bytes,7,opt,name=os_family,json=osFamily,proto3" json:"os_family,omitempty"`
	// contains filtered or unexported fields
}

type Result struct {
	Outputs map[string]string `` /* 155-byte string literal not displayed */
	Error   string            `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedExecutorPluginServer struct {
}

type UnsafeExecutorPluginServer interface {
	// contains filtered or unexported methods
}