proto

package
v0.1.147 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Apr 7, 2026 License: AGPL-3.0, AGPL-3.0-or-later Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source
const (
	ContextService_Stat_FullMethodName     = "/context.ContextService/Stat"
	ContextService_ReadDir_FullMethodName  = "/context.ContextService/ReadDir"
	ContextService_Read_FullMethodName     = "/context.ContextService/Read"
	ContextService_Write_FullMethodName    = "/context.ContextService/Write"
	ContextService_Create_FullMethodName   = "/context.ContextService/Create"
	ContextService_Delete_FullMethodName   = "/context.ContextService/Delete"
	ContextService_Mkdir_FullMethodName    = "/context.ContextService/Mkdir"
	ContextService_Rename_FullMethodName   = "/context.ContextService/Rename"
	ContextService_Truncate_FullMethodName = "/context.ContextService/Truncate"
	ContextService_Symlink_FullMethodName  = "/context.ContextService/Symlink"
	ContextService_Readlink_FullMethodName = "/context.ContextService/Readlink"
	ContextService_ListTree_FullMethodName = "/context.ContextService/ListTree"
)
View Source
const (
	FilesystemService_Stat_FullMethodName    = "/filesystem.FilesystemService/Stat"
	FilesystemService_ReadDir_FullMethodName = "/filesystem.FilesystemService/ReadDir"
	FilesystemService_Mkdir_FullMethodName   = "/filesystem.FilesystemService/Mkdir"
	FilesystemService_Create_FullMethodName  = "/filesystem.FilesystemService/Create"
	FilesystemService_Rename_FullMethodName  = "/filesystem.FilesystemService/Rename"
	FilesystemService_Remove_FullMethodName  = "/filesystem.FilesystemService/Remove"
	FilesystemService_Chmod_FullMethodName   = "/filesystem.FilesystemService/Chmod"
)
View Source
const (
	GatewayService_CreateWorkspace_FullMethodName   = "/gateway.GatewayService/CreateWorkspace"
	GatewayService_ListWorkspaces_FullMethodName    = "/gateway.GatewayService/ListWorkspaces"
	GatewayService_GetWorkspace_FullMethodName      = "/gateway.GatewayService/GetWorkspace"
	GatewayService_DeleteWorkspace_FullMethodName   = "/gateway.GatewayService/DeleteWorkspace"
	GatewayService_AddMember_FullMethodName         = "/gateway.GatewayService/AddMember"
	GatewayService_ListMembers_FullMethodName       = "/gateway.GatewayService/ListMembers"
	GatewayService_RemoveMember_FullMethodName      = "/gateway.GatewayService/RemoveMember"
	GatewayService_CreateToken_FullMethodName       = "/gateway.GatewayService/CreateToken"
	GatewayService_ListTokens_FullMethodName        = "/gateway.GatewayService/ListTokens"
	GatewayService_RevokeToken_FullMethodName       = "/gateway.GatewayService/RevokeToken"
	GatewayService_CreateWorkerToken_FullMethodName = "/gateway.GatewayService/CreateWorkerToken"
	GatewayService_ListWorkerTokens_FullMethodName  = "/gateway.GatewayService/ListWorkerTokens"
	GatewayService_AddConnection_FullMethodName     = "/gateway.GatewayService/AddConnection"
	GatewayService_ListConnections_FullMethodName   = "/gateway.GatewayService/ListConnections"
	GatewayService_RemoveConnection_FullMethodName  = "/gateway.GatewayService/RemoveConnection"
	GatewayService_CreateHook_FullMethodName        = "/gateway.GatewayService/CreateHook"
	GatewayService_ListHooks_FullMethodName         = "/gateway.GatewayService/ListHooks"
	GatewayService_GetHook_FullMethodName           = "/gateway.GatewayService/GetHook"
	GatewayService_UpdateHook_FullMethodName        = "/gateway.GatewayService/UpdateHook"
	GatewayService_DeleteHook_FullMethodName        = "/gateway.GatewayService/DeleteHook"
	GatewayService_ListHookRuns_FullMethodName      = "/gateway.GatewayService/ListHookRuns"
)
View Source
const (
	AgentService_CreateAgentProfile_FullMethodName    = "/gateway.AgentService/CreateAgentProfile"
	AgentService_ListAgentProfiles_FullMethodName     = "/gateway.AgentService/ListAgentProfiles"
	AgentService_GetAgentProfile_FullMethodName       = "/gateway.AgentService/GetAgentProfile"
	AgentService_CreateTask_FullMethodName            = "/gateway.AgentService/CreateTask"
	AgentService_ListTasks_FullMethodName             = "/gateway.AgentService/ListTasks"
	AgentService_GetTask_FullMethodName               = "/gateway.AgentService/GetTask"
	AgentService_DeleteTask_FullMethodName            = "/gateway.AgentService/DeleteTask"
	AgentService_GetTaskLogs_FullMethodName           = "/gateway.AgentService/GetTaskLogs"
	AgentService_EnqueueRunInput_FullMethodName       = "/gateway.AgentService/EnqueueRunInput"
	AgentService_ListAgentRuns_FullMethodName         = "/gateway.AgentService/ListAgentRuns"
	AgentService_GetAgentRun_FullMethodName           = "/gateway.AgentService/GetAgentRun"
	AgentService_ListAgentRunSnapshots_FullMethodName = "/gateway.AgentService/ListAgentRunSnapshots"
	AgentService_ListAgentRunEvents_FullMethodName    = "/gateway.AgentService/ListAgentRunEvents"
	AgentService_CancelAgentRun_FullMethodName        = "/gateway.AgentService/CancelAgentRun"
)
View Source
const (
	SourceService_Stat_FullMethodName          = "/sources.SourceService/Stat"
	SourceService_ReadDir_FullMethodName       = "/sources.SourceService/ReadDir"
	SourceService_Read_FullMethodName          = "/sources.SourceService/Read"
	SourceService_Readlink_FullMethodName      = "/sources.SourceService/Readlink"
	SourceService_CreateView_FullMethodName    = "/sources.SourceService/CreateView"
	SourceService_GetView_FullMethodName       = "/sources.SourceService/GetView"
	SourceService_ListViews_FullMethodName     = "/sources.SourceService/ListViews"
	SourceService_DeleteView_FullMethodName    = "/sources.SourceService/DeleteView"
	SourceService_UpdateView_FullMethodName    = "/sources.SourceService/UpdateView"
	SourceService_ExecuteView_FullMethodName   = "/sources.SourceService/ExecuteView"
	SourceService_SyncView_FullMethodName      = "/sources.SourceService/SyncView"
	SourceService_ListResources_FullMethodName = "/sources.SourceService/ListResources"
)
View Source
const (
	ToolService_ListTools_FullMethodName   = "/tools.ToolService/ListTools"
	ToolService_GetToolHelp_FullMethodName = "/tools.ToolService/GetToolHelp"
	ToolService_ExecuteTool_FullMethodName = "/tools.ToolService/ExecuteTool"
)
View Source
const (
	WorkerService_RegisterWorker_FullMethodName         = "/worker.WorkerService/RegisterWorker"
	WorkerService_Heartbeat_FullMethodName              = "/worker.WorkerService/Heartbeat"
	WorkerService_UpdateStatus_FullMethodName           = "/worker.WorkerService/UpdateStatus"
	WorkerService_Deregister_FullMethodName             = "/worker.WorkerService/Deregister"
	WorkerService_GetWorker_FullMethodName              = "/worker.WorkerService/GetWorker"
	WorkerService_ListWorkers_FullMethodName            = "/worker.WorkerService/ListWorkers"
	WorkerService_SetTaskStarted_FullMethodName         = "/worker.WorkerService/SetTaskStarted"
	WorkerService_SetTaskResult_FullMethodName          = "/worker.WorkerService/SetTaskResult"
	WorkerService_UpdateTaskState_FullMethodName        = "/worker.WorkerService/UpdateTaskState"
	WorkerService_AllocateIP_FullMethodName             = "/worker.WorkerService/AllocateIP"
	WorkerService_ReleaseIP_FullMethodName              = "/worker.WorkerService/ReleaseIP"
	WorkerService_ClaimTaskInput_FullMethodName         = "/worker.WorkerService/ClaimTaskInput"
	WorkerService_AckTaskInput_FullMethodName           = "/worker.WorkerService/AckTaskInput"
	WorkerService_CreateTaskOutput_FullMethodName       = "/worker.WorkerService/CreateTaskOutput"
	WorkerService_AppendTaskOutputRows_FullMethodName   = "/worker.WorkerService/AppendTaskOutputRows"
	WorkerService_FinalizeTaskOutput_FullMethodName     = "/worker.WorkerService/FinalizeTaskOutput"
	WorkerService_UpdateTaskOutputStatus_FullMethodName = "/worker.WorkerService/UpdateTaskOutputStatus"
)
View Source
const (
	AccessLogService_IngestAccessEvents_FullMethodName = "/gateway.AccessLogService/IngestAccessEvents"
)

Variables

View Source
var (
	ExecuteToolResponse_StreamType_name = map[int32]string{
		0: "STDOUT",
		1: "STDERR",
	}
	ExecuteToolResponse_StreamType_value = map[string]int32{
		"STDOUT": 0,
		"STDERR": 1,
	}
)

Enum value maps for ExecuteToolResponse_StreamType.

View Source
var AccessLogService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gateway.AccessLogService",
	HandlerType: (*AccessLogServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "IngestAccessEvents",
			Handler:    _AccessLogService_IngestAccessEvents_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "gateway.proto",
}

AccessLogService_ServiceDesc is the grpc.ServiceDesc for AccessLogService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var AgentService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gateway.AgentService",
	HandlerType: (*AgentServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateAgentProfile",
			Handler:    _AgentService_CreateAgentProfile_Handler,
		},
		{
			MethodName: "ListAgentProfiles",
			Handler:    _AgentService_ListAgentProfiles_Handler,
		},
		{
			MethodName: "GetAgentProfile",
			Handler:    _AgentService_GetAgentProfile_Handler,
		},
		{
			MethodName: "CreateTask",
			Handler:    _AgentService_CreateTask_Handler,
		},
		{
			MethodName: "ListTasks",
			Handler:    _AgentService_ListTasks_Handler,
		},
		{
			MethodName: "GetTask",
			Handler:    _AgentService_GetTask_Handler,
		},
		{
			MethodName: "DeleteTask",
			Handler:    _AgentService_DeleteTask_Handler,
		},
		{
			MethodName: "GetTaskLogs",
			Handler:    _AgentService_GetTaskLogs_Handler,
		},
		{
			MethodName: "EnqueueRunInput",
			Handler:    _AgentService_EnqueueRunInput_Handler,
		},
		{
			MethodName: "ListAgentRuns",
			Handler:    _AgentService_ListAgentRuns_Handler,
		},
		{
			MethodName: "GetAgentRun",
			Handler:    _AgentService_GetAgentRun_Handler,
		},
		{
			MethodName: "ListAgentRunSnapshots",
			Handler:    _AgentService_ListAgentRunSnapshots_Handler,
		},
		{
			MethodName: "ListAgentRunEvents",
			Handler:    _AgentService_ListAgentRunEvents_Handler,
		},
		{
			MethodName: "CancelAgentRun",
			Handler:    _AgentService_CancelAgentRun_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "gateway.proto",
}

AgentService_ServiceDesc is the grpc.ServiceDesc for AgentService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var ContextService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "context.ContextService",
	HandlerType: (*ContextServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Stat",
			Handler:    _ContextService_Stat_Handler,
		},
		{
			MethodName: "ReadDir",
			Handler:    _ContextService_ReadDir_Handler,
		},
		{
			MethodName: "Read",
			Handler:    _ContextService_Read_Handler,
		},
		{
			MethodName: "Write",
			Handler:    _ContextService_Write_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _ContextService_Create_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _ContextService_Delete_Handler,
		},
		{
			MethodName: "Mkdir",
			Handler:    _ContextService_Mkdir_Handler,
		},
		{
			MethodName: "Rename",
			Handler:    _ContextService_Rename_Handler,
		},
		{
			MethodName: "Truncate",
			Handler:    _ContextService_Truncate_Handler,
		},
		{
			MethodName: "Symlink",
			Handler:    _ContextService_Symlink_Handler,
		},
		{
			MethodName: "Readlink",
			Handler:    _ContextService_Readlink_Handler,
		},
		{
			MethodName: "ListTree",
			Handler:    _ContextService_ListTree_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "context.proto",
}

ContextService_ServiceDesc is the grpc.ServiceDesc for ContextService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var File_context_proto protoreflect.FileDescriptor
View Source
var File_filesystem_proto protoreflect.FileDescriptor
View Source
var File_gateway_proto protoreflect.FileDescriptor
View Source
var File_sources_proto protoreflect.FileDescriptor
View Source
var File_tools_proto protoreflect.FileDescriptor
View Source
var File_worker_proto protoreflect.FileDescriptor
View Source
var FilesystemService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "filesystem.FilesystemService",
	HandlerType: (*FilesystemServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Stat",
			Handler:    _FilesystemService_Stat_Handler,
		},
		{
			MethodName: "ReadDir",
			Handler:    _FilesystemService_ReadDir_Handler,
		},
		{
			MethodName: "Mkdir",
			Handler:    _FilesystemService_Mkdir_Handler,
		},
		{
			MethodName: "Create",
			Handler:    _FilesystemService_Create_Handler,
		},
		{
			MethodName: "Rename",
			Handler:    _FilesystemService_Rename_Handler,
		},
		{
			MethodName: "Remove",
			Handler:    _FilesystemService_Remove_Handler,
		},
		{
			MethodName: "Chmod",
			Handler:    _FilesystemService_Chmod_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "filesystem.proto",
}

FilesystemService_ServiceDesc is the grpc.ServiceDesc for FilesystemService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var GatewayService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "gateway.GatewayService",
	HandlerType: (*GatewayServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateWorkspace",
			Handler:    _GatewayService_CreateWorkspace_Handler,
		},
		{
			MethodName: "ListWorkspaces",
			Handler:    _GatewayService_ListWorkspaces_Handler,
		},
		{
			MethodName: "GetWorkspace",
			Handler:    _GatewayService_GetWorkspace_Handler,
		},
		{
			MethodName: "DeleteWorkspace",
			Handler:    _GatewayService_DeleteWorkspace_Handler,
		},
		{
			MethodName: "AddMember",
			Handler:    _GatewayService_AddMember_Handler,
		},
		{
			MethodName: "ListMembers",
			Handler:    _GatewayService_ListMembers_Handler,
		},
		{
			MethodName: "RemoveMember",
			Handler:    _GatewayService_RemoveMember_Handler,
		},
		{
			MethodName: "CreateToken",
			Handler:    _GatewayService_CreateToken_Handler,
		},
		{
			MethodName: "ListTokens",
			Handler:    _GatewayService_ListTokens_Handler,
		},
		{
			MethodName: "RevokeToken",
			Handler:    _GatewayService_RevokeToken_Handler,
		},
		{
			MethodName: "CreateWorkerToken",
			Handler:    _GatewayService_CreateWorkerToken_Handler,
		},
		{
			MethodName: "ListWorkerTokens",
			Handler:    _GatewayService_ListWorkerTokens_Handler,
		},
		{
			MethodName: "AddConnection",
			Handler:    _GatewayService_AddConnection_Handler,
		},
		{
			MethodName: "ListConnections",
			Handler:    _GatewayService_ListConnections_Handler,
		},
		{
			MethodName: "RemoveConnection",
			Handler:    _GatewayService_RemoveConnection_Handler,
		},
		{
			MethodName: "CreateHook",
			Handler:    _GatewayService_CreateHook_Handler,
		},
		{
			MethodName: "ListHooks",
			Handler:    _GatewayService_ListHooks_Handler,
		},
		{
			MethodName: "GetHook",
			Handler:    _GatewayService_GetHook_Handler,
		},
		{
			MethodName: "UpdateHook",
			Handler:    _GatewayService_UpdateHook_Handler,
		},
		{
			MethodName: "DeleteHook",
			Handler:    _GatewayService_DeleteHook_Handler,
		},
		{
			MethodName: "ListHookRuns",
			Handler:    _GatewayService_ListHookRuns_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "gateway.proto",
}

GatewayService_ServiceDesc is the grpc.ServiceDesc for GatewayService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var SourceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "sources.SourceService",
	HandlerType: (*SourceServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Stat",
			Handler:    _SourceService_Stat_Handler,
		},
		{
			MethodName: "ReadDir",
			Handler:    _SourceService_ReadDir_Handler,
		},
		{
			MethodName: "Read",
			Handler:    _SourceService_Read_Handler,
		},
		{
			MethodName: "Readlink",
			Handler:    _SourceService_Readlink_Handler,
		},
		{
			MethodName: "CreateView",
			Handler:    _SourceService_CreateView_Handler,
		},
		{
			MethodName: "GetView",
			Handler:    _SourceService_GetView_Handler,
		},
		{
			MethodName: "ListViews",
			Handler:    _SourceService_ListViews_Handler,
		},
		{
			MethodName: "DeleteView",
			Handler:    _SourceService_DeleteView_Handler,
		},
		{
			MethodName: "UpdateView",
			Handler:    _SourceService_UpdateView_Handler,
		},
		{
			MethodName: "ExecuteView",
			Handler:    _SourceService_ExecuteView_Handler,
		},
		{
			MethodName: "SyncView",
			Handler:    _SourceService_SyncView_Handler,
		},
		{
			MethodName: "ListResources",
			Handler:    _SourceService_ListResources_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "sources.proto",
}

SourceService_ServiceDesc is the grpc.ServiceDesc for SourceService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var ToolService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "tools.ToolService",
	HandlerType: (*ToolServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListTools",
			Handler:    _ToolService_ListTools_Handler,
		},
		{
			MethodName: "GetToolHelp",
			Handler:    _ToolService_GetToolHelp_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ExecuteTool",
			Handler:       _ToolService_ExecuteTool_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "tools.proto",
}

ToolService_ServiceDesc is the grpc.ServiceDesc for ToolService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var WorkerService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "worker.WorkerService",
	HandlerType: (*WorkerServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "RegisterWorker",
			Handler:    _WorkerService_RegisterWorker_Handler,
		},
		{
			MethodName: "Heartbeat",
			Handler:    _WorkerService_Heartbeat_Handler,
		},
		{
			MethodName: "UpdateStatus",
			Handler:    _WorkerService_UpdateStatus_Handler,
		},
		{
			MethodName: "Deregister",
			Handler:    _WorkerService_Deregister_Handler,
		},
		{
			MethodName: "GetWorker",
			Handler:    _WorkerService_GetWorker_Handler,
		},
		{
			MethodName: "ListWorkers",
			Handler:    _WorkerService_ListWorkers_Handler,
		},
		{
			MethodName: "SetTaskStarted",
			Handler:    _WorkerService_SetTaskStarted_Handler,
		},
		{
			MethodName: "SetTaskResult",
			Handler:    _WorkerService_SetTaskResult_Handler,
		},
		{
			MethodName: "UpdateTaskState",
			Handler:    _WorkerService_UpdateTaskState_Handler,
		},
		{
			MethodName: "AllocateIP",
			Handler:    _WorkerService_AllocateIP_Handler,
		},
		{
			MethodName: "ReleaseIP",
			Handler:    _WorkerService_ReleaseIP_Handler,
		},
		{
			MethodName: "ClaimTaskInput",
			Handler:    _WorkerService_ClaimTaskInput_Handler,
		},
		{
			MethodName: "AckTaskInput",
			Handler:    _WorkerService_AckTaskInput_Handler,
		},
		{
			MethodName: "CreateTaskOutput",
			Handler:    _WorkerService_CreateTaskOutput_Handler,
		},
		{
			MethodName: "AppendTaskOutputRows",
			Handler:    _WorkerService_AppendTaskOutputRows_Handler,
		},
		{
			MethodName: "FinalizeTaskOutput",
			Handler:    _WorkerService_FinalizeTaskOutput_Handler,
		},
		{
			MethodName: "UpdateTaskOutputStatus",
			Handler:    _WorkerService_UpdateTaskOutputStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "worker.proto",
}

WorkerService_ServiceDesc is the grpc.ServiceDesc for WorkerService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterAccessLogServiceServer added in v0.1.47

func RegisterAccessLogServiceServer(s grpc.ServiceRegistrar, srv AccessLogServiceServer)

func RegisterAgentServiceServer added in v0.1.60

func RegisterAgentServiceServer(s grpc.ServiceRegistrar, srv AgentServiceServer)

func RegisterContextServiceServer

func RegisterContextServiceServer(s grpc.ServiceRegistrar, srv ContextServiceServer)

func RegisterFilesystemServiceServer

func RegisterFilesystemServiceServer(s grpc.ServiceRegistrar, srv FilesystemServiceServer)

func RegisterGatewayServiceServer

func RegisterGatewayServiceServer(s grpc.ServiceRegistrar, srv GatewayServiceServer)

func RegisterSourceServiceServer

func RegisterSourceServiceServer(s grpc.ServiceRegistrar, srv SourceServiceServer)

func RegisterToolServiceServer

func RegisterToolServiceServer(s grpc.ServiceRegistrar, srv ToolServiceServer)

func RegisterWorkerServiceServer

func RegisterWorkerServiceServer(s grpc.ServiceRegistrar, srv WorkerServiceServer)

Types

type AccessLogEvent added in v0.1.47

type AccessLogEvent struct {
	EventId          string `protobuf:"bytes,1,opt,name=event_id,json=eventId,proto3" json:"event_id,omitempty"`
	Ts               int64  `protobuf:"varint,2,opt,name=ts,proto3" json:"ts,omitempty"`
	SessionId        string `protobuf:"bytes,3,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Path             string `protobuf:"bytes,4,opt,name=path,proto3" json:"path,omitempty"`
	CacheSource      string `protobuf:"bytes,5,opt,name=cache_source,json=cacheSource,proto3" json:"cache_source,omitempty"`
	Offset           int64  `protobuf:"varint,6,opt,name=offset,proto3" json:"offset,omitempty"`
	RequestedBytes   int32  `protobuf:"varint,7,opt,name=requested_bytes,json=requestedBytes,proto3" json:"requested_bytes,omitempty"`
	ReadBytes        int32  `protobuf:"varint,8,opt,name=read_bytes,json=readBytes,proto3" json:"read_bytes,omitempty"`
	LatencyMs        int64  `protobuf:"varint,9,opt,name=latency_ms,json=latencyMs,proto3" json:"latency_ms,omitempty"`
	ErrorMsg         string `protobuf:"bytes,10,opt,name=error_msg,json=errorMsg,proto3" json:"error_msg,omitempty"`
	MountId          string `protobuf:"bytes,11,opt,name=mount_id,json=mountId,proto3" json:"mount_id,omitempty"`
	AccessOrigin     string `protobuf:"bytes,12,opt,name=access_origin,json=accessOrigin,proto3" json:"access_origin,omitempty"`
	Integration      string `protobuf:"bytes,13,opt,name=integration,proto3" json:"integration,omitempty"`
	SourceUri        string `protobuf:"bytes,14,opt,name=source_uri,json=sourceUri,proto3" json:"source_uri,omitempty"`
	QueryPath        string `protobuf:"bytes,15,opt,name=query_path,json=queryPath,proto3" json:"query_path,omitempty"`
	ResultId         string `protobuf:"bytes,16,opt,name=result_id,json=resultId,proto3" json:"result_id,omitempty"`
	OriginalBytes    int64  `protobuf:"varint,17,opt,name=original_bytes,json=originalBytes,proto3" json:"original_bytes,omitempty"`
	CompressedBytes  int64  `protobuf:"varint,18,opt,name=compressed_bytes,json=compressedBytes,proto3" json:"compressed_bytes,omitempty"`
	OriginalTokens   int64  `protobuf:"varint,19,opt,name=original_tokens,json=originalTokens,proto3" json:"original_tokens,omitempty"`
	CompressedTokens int64  `protobuf:"varint,20,opt,name=compressed_tokens,json=compressedTokens,proto3" json:"compressed_tokens,omitempty"`
	Strategy         string `protobuf:"bytes,21,opt,name=strategy,proto3" json:"strategy,omitempty"`
	Outcome          string `protobuf:"bytes,22,opt,name=outcome,proto3" json:"outcome,omitempty"`
	CompressionMs    int64  `protobuf:"varint,23,opt,name=compression_ms,json=compressionMs,proto3" json:"compression_ms,omitempty"`
	FetchMs          int64  `protobuf:"varint,24,opt,name=fetch_ms,json=fetchMs,proto3" json:"fetch_ms,omitempty"` // e2e content fetch duration (e.g. time to fetch from source during Open)
	// contains filtered or unexported fields
}

func (*AccessLogEvent) Descriptor deprecated added in v0.1.47

func (*AccessLogEvent) Descriptor() ([]byte, []int)

Deprecated: Use AccessLogEvent.ProtoReflect.Descriptor instead.

func (*AccessLogEvent) GetAccessOrigin added in v0.1.47

func (x *AccessLogEvent) GetAccessOrigin() string

func (*AccessLogEvent) GetCacheSource added in v0.1.47

func (x *AccessLogEvent) GetCacheSource() string

func (*AccessLogEvent) GetCompressedBytes added in v0.1.47

func (x *AccessLogEvent) GetCompressedBytes() int64

func (*AccessLogEvent) GetCompressedTokens added in v0.1.47

func (x *AccessLogEvent) GetCompressedTokens() int64

func (*AccessLogEvent) GetCompressionMs added in v0.1.47

func (x *AccessLogEvent) GetCompressionMs() int64

func (*AccessLogEvent) GetErrorMsg added in v0.1.47

func (x *AccessLogEvent) GetErrorMsg() string

func (*AccessLogEvent) GetEventId added in v0.1.47

func (x *AccessLogEvent) GetEventId() string

func (*AccessLogEvent) GetFetchMs added in v0.1.48

func (x *AccessLogEvent) GetFetchMs() int64

func (*AccessLogEvent) GetIntegration added in v0.1.47

func (x *AccessLogEvent) GetIntegration() string

func (*AccessLogEvent) GetLatencyMs added in v0.1.47

func (x *AccessLogEvent) GetLatencyMs() int64

func (*AccessLogEvent) GetMountId added in v0.1.47

func (x *AccessLogEvent) GetMountId() string

func (*AccessLogEvent) GetOffset added in v0.1.47

func (x *AccessLogEvent) GetOffset() int64

func (*AccessLogEvent) GetOriginalBytes added in v0.1.47

func (x *AccessLogEvent) GetOriginalBytes() int64

func (*AccessLogEvent) GetOriginalTokens added in v0.1.47

func (x *AccessLogEvent) GetOriginalTokens() int64

func (*AccessLogEvent) GetOutcome added in v0.1.47

func (x *AccessLogEvent) GetOutcome() string

func (*AccessLogEvent) GetPath added in v0.1.47

func (x *AccessLogEvent) GetPath() string

func (*AccessLogEvent) GetQueryPath added in v0.1.47

func (x *AccessLogEvent) GetQueryPath() string

func (*AccessLogEvent) GetReadBytes added in v0.1.47

func (x *AccessLogEvent) GetReadBytes() int32

func (*AccessLogEvent) GetRequestedBytes added in v0.1.47

func (x *AccessLogEvent) GetRequestedBytes() int32

func (*AccessLogEvent) GetResultId added in v0.1.47

func (x *AccessLogEvent) GetResultId() string

func (*AccessLogEvent) GetSessionId added in v0.1.47

func (x *AccessLogEvent) GetSessionId() string

func (*AccessLogEvent) GetSourceUri added in v0.1.47

func (x *AccessLogEvent) GetSourceUri() string

func (*AccessLogEvent) GetStrategy added in v0.1.47

func (x *AccessLogEvent) GetStrategy() string

func (*AccessLogEvent) GetTs added in v0.1.47

func (x *AccessLogEvent) GetTs() int64

func (*AccessLogEvent) ProtoMessage added in v0.1.47

func (*AccessLogEvent) ProtoMessage()

func (*AccessLogEvent) ProtoReflect added in v0.1.47

func (x *AccessLogEvent) ProtoReflect() protoreflect.Message

func (*AccessLogEvent) Reset added in v0.1.47

func (x *AccessLogEvent) Reset()

func (*AccessLogEvent) String added in v0.1.47

func (x *AccessLogEvent) String() string

type AccessLogServiceClient added in v0.1.47

type AccessLogServiceClient interface {
	IngestAccessEvents(ctx context.Context, in *IngestAccessEventsRequest, opts ...grpc.CallOption) (*IngestAccessEventsResponse, error)
}

AccessLogServiceClient is the client API for AccessLogService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAccessLogServiceClient added in v0.1.47

func NewAccessLogServiceClient(cc grpc.ClientConnInterface) AccessLogServiceClient

type AccessLogServiceServer added in v0.1.47

type AccessLogServiceServer interface {
	IngestAccessEvents(context.Context, *IngestAccessEventsRequest) (*IngestAccessEventsResponse, error)
	// contains filtered or unexported methods
}

AccessLogServiceServer is the server API for AccessLogService service. All implementations must embed UnimplementedAccessLogServiceServer for forward compatibility

type AckTaskInputRequest added in v0.1.98

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

func (*AckTaskInputRequest) Descriptor deprecated added in v0.1.98

func (*AckTaskInputRequest) Descriptor() ([]byte, []int)

Deprecated: Use AckTaskInputRequest.ProtoReflect.Descriptor instead.

func (*AckTaskInputRequest) GetInputId added in v0.1.98

func (x *AckTaskInputRequest) GetInputId() string

func (*AckTaskInputRequest) ProtoMessage added in v0.1.98

func (*AckTaskInputRequest) ProtoMessage()

func (*AckTaskInputRequest) ProtoReflect added in v0.1.98

func (x *AckTaskInputRequest) ProtoReflect() protoreflect.Message

func (*AckTaskInputRequest) Reset added in v0.1.98

func (x *AckTaskInputRequest) Reset()

func (*AckTaskInputRequest) String added in v0.1.98

func (x *AckTaskInputRequest) String() string

type AckTaskInputResponse added in v0.1.98

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

func (*AckTaskInputResponse) Descriptor deprecated added in v0.1.98

func (*AckTaskInputResponse) Descriptor() ([]byte, []int)

Deprecated: Use AckTaskInputResponse.ProtoReflect.Descriptor instead.

func (*AckTaskInputResponse) ProtoMessage added in v0.1.98

func (*AckTaskInputResponse) ProtoMessage()

func (*AckTaskInputResponse) ProtoReflect added in v0.1.98

func (x *AckTaskInputResponse) ProtoReflect() protoreflect.Message

func (*AckTaskInputResponse) Reset added in v0.1.98

func (x *AckTaskInputResponse) Reset()

func (*AckTaskInputResponse) String added in v0.1.98

func (x *AckTaskInputResponse) String() string

type AddConnectionRequest

type AddConnectionRequest struct {
	WorkspaceId     string            `protobuf:"bytes,1,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	MemberId        string            `protobuf:"bytes,2,opt,name=member_id,json=memberId,proto3" json:"member_id,omitempty"`                      // Empty = workspace-shared
	IntegrationType string            `protobuf:"bytes,3,opt,name=integration_type,json=integrationType,proto3" json:"integration_type,omitempty"` // github, weather, exa, etc.
	AccessToken     string            `protobuf:"bytes,4,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"`
	ApiKey          string            `protobuf:"bytes,5,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"`
	Scope           string            `protobuf:"bytes,6,opt,name=scope,proto3" json:"scope,omitempty"`
	Extra           map[string]string `` // Additional provider-specific data (e.g., host URL)
	/* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

Connection messages

func (*AddConnectionRequest) Descriptor deprecated

func (*AddConnectionRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddConnectionRequest.ProtoReflect.Descriptor instead.

func (*AddConnectionRequest) GetAccessToken

func (x *AddConnectionRequest) GetAccessToken() string

func (*AddConnectionRequest) GetApiKey

func (x *AddConnectionRequest) GetApiKey() string

func (*AddConnectionRequest) GetExtra added in v0.1.32

func (x *AddConnectionRequest) GetExtra() map[string]string

func (*AddConnectionRequest) GetIntegrationType

func (x *AddConnectionRequest) GetIntegrationType() string

func (*AddConnectionRequest) GetMemberId

func (x *AddConnectionRequest) GetMemberId() string

func (*AddConnectionRequest) GetScope

func (x *AddConnectionRequest) GetScope() string

func (*AddConnectionRequest) GetWorkspaceId

func (x *AddConnectionRequest) GetWorkspaceId() string

func (*AddConnectionRequest) ProtoMessage

func (*AddConnectionRequest) ProtoMessage()

func (*AddConnectionRequest) ProtoReflect

func (x *AddConnectionRequest) ProtoReflect() protoreflect.Message

func (*AddConnectionRequest) Reset

func (x *AddConnectionRequest) Reset()

func (*AddConnectionRequest) String

func (x *AddConnectionRequest) String() string

type AddMemberRequest

type AddMemberRequest struct {
	WorkspaceId string `protobuf:"bytes,1,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	Email       string `protobuf:"bytes,2,opt,name=email,proto3" json:"email,omitempty"`
	Name        string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Role        string `protobuf:"bytes,4,opt,name=role,proto3" json:"role,omitempty"` // admin, member, viewer
	// contains filtered or unexported fields
}

Member messages

func (*AddMemberRequest) Descriptor deprecated

func (*AddMemberRequest) Descriptor() ([]byte, []int)

Deprecated: Use AddMemberRequest.ProtoReflect.Descriptor instead.

func (*AddMemberRequest) GetEmail

func (x *AddMemberRequest) GetEmail() string

func (*AddMemberRequest) GetName

func (x *AddMemberRequest) GetName() string

func (*AddMemberRequest) GetRole

func (x *AddMemberRequest) GetRole() string

func (*AddMemberRequest) GetWorkspaceId

func (x *AddMemberRequest) GetWorkspaceId() string

func (*AddMemberRequest) ProtoMessage

func (*AddMemberRequest) ProtoMessage()

func (*AddMemberRequest) ProtoReflect

func (x *AddMemberRequest) ProtoReflect() protoreflect.Message

func (*AddMemberRequest) Reset

func (x *AddMemberRequest) Reset()

func (*AddMemberRequest) String

func (x *AddMemberRequest) String() string

type AgentProfile added in v0.1.60

type AgentProfile struct {
	Id          string           `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	WorkspaceId string           `protobuf:"bytes,2,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	AgentKey    string           `protobuf:"bytes,3,opt,name=agent_key,json=agentKey,proto3" json:"agent_key,omitempty"`
	Name        string           `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Config      *structpb.Struct `protobuf:"bytes,5,opt,name=config,proto3" json:"config,omitempty"`
	Active      bool             `protobuf:"varint,6,opt,name=active,proto3" json:"active,omitempty"`
	CreatedAt   string           `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt   string           `protobuf:"bytes,8,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

Agent, task, and run messages

func (*AgentProfile) Descriptor deprecated added in v0.1.60

func (*AgentProfile) Descriptor() ([]byte, []int)

Deprecated: Use AgentProfile.ProtoReflect.Descriptor instead.

func (*AgentProfile) GetActive added in v0.1.60

func (x *AgentProfile) GetActive() bool

func (*AgentProfile) GetAgentKey added in v0.1.60

func (x *AgentProfile) GetAgentKey() string

func (*AgentProfile) GetConfig added in v0.1.60

func (x *AgentProfile) GetConfig() *structpb.Struct

func (*AgentProfile) GetCreatedAt added in v0.1.60

func (x *AgentProfile) GetCreatedAt() string

func (*AgentProfile) GetId added in v0.1.60

func (x *AgentProfile) GetId() string

func (*AgentProfile) GetName added in v0.1.60

func (x *AgentProfile) GetName() string

func (*AgentProfile) GetUpdatedAt added in v0.1.60

func (x *AgentProfile) GetUpdatedAt() string

func (*AgentProfile) GetWorkspaceId added in v0.1.60

func (x *AgentProfile) GetWorkspaceId() string

func (*AgentProfile) ProtoMessage added in v0.1.60

func (*AgentProfile) ProtoMessage()

func (*AgentProfile) ProtoReflect added in v0.1.60

func (x *AgentProfile) ProtoReflect() protoreflect.Message

func (*AgentProfile) Reset added in v0.1.60

func (x *AgentProfile) Reset()

func (*AgentProfile) String added in v0.1.60

func (x *AgentProfile) String() string

type AgentProfileResponse added in v0.1.60

type AgentProfileResponse struct {
	Ok    bool          `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string        `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Agent *AgentProfile `protobuf:"bytes,3,opt,name=agent,proto3" json:"agent,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentProfileResponse) Descriptor deprecated added in v0.1.60

func (*AgentProfileResponse) Descriptor() ([]byte, []int)

Deprecated: Use AgentProfileResponse.ProtoReflect.Descriptor instead.

func (*AgentProfileResponse) GetAgent added in v0.1.60

func (x *AgentProfileResponse) GetAgent() *AgentProfile

func (*AgentProfileResponse) GetError added in v0.1.60

func (x *AgentProfileResponse) GetError() string

func (*AgentProfileResponse) GetOk added in v0.1.60

func (x *AgentProfileResponse) GetOk() bool

func (*AgentProfileResponse) ProtoMessage added in v0.1.60

func (*AgentProfileResponse) ProtoMessage()

func (*AgentProfileResponse) ProtoReflect added in v0.1.60

func (x *AgentProfileResponse) ProtoReflect() protoreflect.Message

func (*AgentProfileResponse) Reset added in v0.1.60

func (x *AgentProfileResponse) Reset()

func (*AgentProfileResponse) String added in v0.1.60

func (x *AgentProfileResponse) String() string

type AgentRun added in v0.1.60

type AgentRun struct {
	Id              string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	WorkspaceId     string `protobuf:"bytes,2,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	AgentId         string `protobuf:"bytes,3,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	OriginTaskId    string `protobuf:"bytes,4,opt,name=origin_task_id,json=originTaskId,proto3" json:"origin_task_id,omitempty"`
	Status          string `protobuf:"bytes,5,opt,name=status,proto3" json:"status,omitempty"`
	SessionId       string `protobuf:"bytes,6,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	SessionKey      string `protobuf:"bytes,7,opt,name=session_key,json=sessionKey,proto3" json:"session_key,omitempty"`
	Provider        string `protobuf:"bytes,8,opt,name=provider,proto3" json:"provider,omitempty"`
	Model           string `protobuf:"bytes,9,opt,name=model,proto3" json:"model,omitempty"`
	ExecHost        string `protobuf:"bytes,10,opt,name=exec_host,json=execHost,proto3" json:"exec_host,omitempty"`
	ExecSecurity    string `protobuf:"bytes,11,opt,name=exec_security,json=execSecurity,proto3" json:"exec_security,omitempty"`
	ExecAsk         string `protobuf:"bytes,12,opt,name=exec_ask,json=execAsk,proto3" json:"exec_ask,omitempty"`
	RuntimeType     string `protobuf:"bytes,13,opt,name=runtime_type,json=runtimeType,proto3" json:"runtime_type,omitempty"`
	WorkspaceAccess string `protobuf:"bytes,14,opt,name=workspace_access,json=workspaceAccess,proto3" json:"workspace_access,omitempty"`
	NetworkEnabled  bool   `protobuf:"varint,15,opt,name=network_enabled,json=networkEnabled,proto3" json:"network_enabled,omitempty"`
	Interactive     bool   `protobuf:"varint,16,opt,name=interactive,proto3" json:"interactive,omitempty"`
	TimeoutMs       int32  `protobuf:"varint,17,opt,name=timeout_ms,json=timeoutMs,proto3" json:"timeout_ms,omitempty"`
	Error           string `protobuf:"bytes,18,opt,name=error,proto3" json:"error,omitempty"`
	CreatedAt       string `protobuf:"bytes,19,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	StartedAt       string `protobuf:"bytes,20,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	EndedAt         string `protobuf:"bytes,21,opt,name=ended_at,json=endedAt,proto3" json:"ended_at,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentRun) Descriptor deprecated added in v0.1.60

func (*AgentRun) Descriptor() ([]byte, []int)

Deprecated: Use AgentRun.ProtoReflect.Descriptor instead.

func (*AgentRun) GetAgentId added in v0.1.60

func (x *AgentRun) GetAgentId() string

func (*AgentRun) GetCreatedAt added in v0.1.60

func (x *AgentRun) GetCreatedAt() string

func (*AgentRun) GetEndedAt added in v0.1.60

func (x *AgentRun) GetEndedAt() string

func (*AgentRun) GetError added in v0.1.60

func (x *AgentRun) GetError() string

func (*AgentRun) GetExecAsk added in v0.1.60

func (x *AgentRun) GetExecAsk() string

func (*AgentRun) GetExecHost added in v0.1.60

func (x *AgentRun) GetExecHost() string

func (*AgentRun) GetExecSecurity added in v0.1.60

func (x *AgentRun) GetExecSecurity() string

func (*AgentRun) GetId added in v0.1.60

func (x *AgentRun) GetId() string

func (*AgentRun) GetInteractive added in v0.1.60

func (x *AgentRun) GetInteractive() bool

func (*AgentRun) GetModel added in v0.1.60

func (x *AgentRun) GetModel() string

func (*AgentRun) GetNetworkEnabled added in v0.1.60

func (x *AgentRun) GetNetworkEnabled() bool

func (*AgentRun) GetOriginTaskId added in v0.1.60

func (x *AgentRun) GetOriginTaskId() string

func (*AgentRun) GetProvider added in v0.1.60

func (x *AgentRun) GetProvider() string

func (*AgentRun) GetRuntimeType added in v0.1.60

func (x *AgentRun) GetRuntimeType() string

func (*AgentRun) GetSessionId added in v0.1.60

func (x *AgentRun) GetSessionId() string

func (*AgentRun) GetSessionKey added in v0.1.60

func (x *AgentRun) GetSessionKey() string

func (*AgentRun) GetStartedAt added in v0.1.60

func (x *AgentRun) GetStartedAt() string

func (*AgentRun) GetStatus added in v0.1.60

func (x *AgentRun) GetStatus() string

func (*AgentRun) GetTimeoutMs added in v0.1.60

func (x *AgentRun) GetTimeoutMs() int32

func (*AgentRun) GetWorkspaceAccess added in v0.1.60

func (x *AgentRun) GetWorkspaceAccess() string

func (*AgentRun) GetWorkspaceId added in v0.1.60

func (x *AgentRun) GetWorkspaceId() string

func (*AgentRun) ProtoMessage added in v0.1.60

func (*AgentRun) ProtoMessage()

func (*AgentRun) ProtoReflect added in v0.1.60

func (x *AgentRun) ProtoReflect() protoreflect.Message

func (*AgentRun) Reset added in v0.1.60

func (x *AgentRun) Reset()

func (*AgentRun) String added in v0.1.60

func (x *AgentRun) String() string

type AgentRunResponse added in v0.1.60

type AgentRunResponse struct {
	Ok    bool      `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string    `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Run   *AgentRun `protobuf:"bytes,3,opt,name=run,proto3" json:"run,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentRunResponse) Descriptor deprecated added in v0.1.60

func (*AgentRunResponse) Descriptor() ([]byte, []int)

Deprecated: Use AgentRunResponse.ProtoReflect.Descriptor instead.

func (*AgentRunResponse) GetError added in v0.1.60

func (x *AgentRunResponse) GetError() string

func (*AgentRunResponse) GetOk added in v0.1.60

func (x *AgentRunResponse) GetOk() bool

func (*AgentRunResponse) GetRun added in v0.1.60

func (x *AgentRunResponse) GetRun() *AgentRun

func (*AgentRunResponse) ProtoMessage added in v0.1.60

func (*AgentRunResponse) ProtoMessage()

func (*AgentRunResponse) ProtoReflect added in v0.1.60

func (x *AgentRunResponse) ProtoReflect() protoreflect.Message

func (*AgentRunResponse) Reset added in v0.1.60

func (x *AgentRunResponse) Reset()

func (*AgentRunResponse) String added in v0.1.60

func (x *AgentRunResponse) String() string

type AgentRunSnapshot added in v0.1.60

type AgentRunSnapshot struct {
	Id             string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	RunId          string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Seq            int64  `protobuf:"varint,3,opt,name=seq,proto3" json:"seq,omitempty"`
	Status         string `protobuf:"bytes,4,opt,name=status,proto3" json:"status,omitempty"`
	StartedAtMs    int64  `protobuf:"varint,5,opt,name=started_at_ms,json=startedAtMs,proto3" json:"started_at_ms,omitempty"`
	EndedAtMs      int64  `protobuf:"varint,6,opt,name=ended_at_ms,json=endedAtMs,proto3" json:"ended_at_ms,omitempty"`
	HasStartedAtMs bool   `protobuf:"varint,7,opt,name=has_started_at_ms,json=hasStartedAtMs,proto3" json:"has_started_at_ms,omitempty"`
	HasEndedAtMs   bool   `protobuf:"varint,8,opt,name=has_ended_at_ms,json=hasEndedAtMs,proto3" json:"has_ended_at_ms,omitempty"`
	Error          string `protobuf:"bytes,9,opt,name=error,proto3" json:"error,omitempty"`
	Ts             int64  `protobuf:"varint,10,opt,name=ts,proto3" json:"ts,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentRunSnapshot) Descriptor deprecated added in v0.1.60

func (*AgentRunSnapshot) Descriptor() ([]byte, []int)

Deprecated: Use AgentRunSnapshot.ProtoReflect.Descriptor instead.

func (*AgentRunSnapshot) GetEndedAtMs added in v0.1.60

func (x *AgentRunSnapshot) GetEndedAtMs() int64

func (*AgentRunSnapshot) GetError added in v0.1.60

func (x *AgentRunSnapshot) GetError() string

func (*AgentRunSnapshot) GetHasEndedAtMs added in v0.1.60

func (x *AgentRunSnapshot) GetHasEndedAtMs() bool

func (*AgentRunSnapshot) GetHasStartedAtMs added in v0.1.60

func (x *AgentRunSnapshot) GetHasStartedAtMs() bool

func (*AgentRunSnapshot) GetId added in v0.1.60

func (x *AgentRunSnapshot) GetId() string

func (*AgentRunSnapshot) GetRunId added in v0.1.60

func (x *AgentRunSnapshot) GetRunId() string

func (*AgentRunSnapshot) GetSeq added in v0.1.60

func (x *AgentRunSnapshot) GetSeq() int64

func (*AgentRunSnapshot) GetStartedAtMs added in v0.1.60

func (x *AgentRunSnapshot) GetStartedAtMs() int64

func (*AgentRunSnapshot) GetStatus added in v0.1.60

func (x *AgentRunSnapshot) GetStatus() string

func (*AgentRunSnapshot) GetTs added in v0.1.60

func (x *AgentRunSnapshot) GetTs() int64

func (*AgentRunSnapshot) ProtoMessage added in v0.1.60

func (*AgentRunSnapshot) ProtoMessage()

func (*AgentRunSnapshot) ProtoReflect added in v0.1.60

func (x *AgentRunSnapshot) ProtoReflect() protoreflect.Message

func (*AgentRunSnapshot) Reset added in v0.1.60

func (x *AgentRunSnapshot) Reset()

func (*AgentRunSnapshot) String added in v0.1.60

func (x *AgentRunSnapshot) String() string

type AgentServiceClient added in v0.1.60

type AgentServiceClient interface {
	CreateAgentProfile(ctx context.Context, in *CreateAgentProfileRequest, opts ...grpc.CallOption) (*AgentProfileResponse, error)
	ListAgentProfiles(ctx context.Context, in *ListAgentProfilesRequest, opts ...grpc.CallOption) (*ListAgentProfilesResponse, error)
	GetAgentProfile(ctx context.Context, in *GetAgentProfileRequest, opts ...grpc.CallOption) (*AgentProfileResponse, error)
	CreateTask(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*AgentTaskAcceptedResponse, error)
	ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
	GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*AgentTaskResponse, error)
	DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	GetTaskLogs(ctx context.Context, in *GetTaskLogsRequest, opts ...grpc.CallOption) (*GetTaskLogsResponse, error)
	EnqueueRunInput(ctx context.Context, in *EnqueueRunInputRequest, opts ...grpc.CallOption) (*AgentTaskAcceptedResponse, error)
	ListAgentRuns(ctx context.Context, in *ListAgentRunsRequest, opts ...grpc.CallOption) (*ListAgentRunsResponse, error)
	GetAgentRun(ctx context.Context, in *GetAgentRunRequest, opts ...grpc.CallOption) (*AgentRunResponse, error)
	ListAgentRunSnapshots(ctx context.Context, in *ListAgentRunSnapshotsRequest, opts ...grpc.CallOption) (*ListAgentRunSnapshotsResponse, error)
	ListAgentRunEvents(ctx context.Context, in *ListAgentRunEventsRequest, opts ...grpc.CallOption) (*ListAgentRunEventsResponse, error)
	CancelAgentRun(ctx context.Context, in *CancelAgentRunRequest, opts ...grpc.CallOption) (*CancelAgentRunResponse, error)
}

AgentServiceClient is the client API for AgentService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewAgentServiceClient added in v0.1.60

func NewAgentServiceClient(cc grpc.ClientConnInterface) AgentServiceClient

type AgentServiceServer added in v0.1.60

AgentServiceServer is the server API for AgentService service. All implementations must embed UnimplementedAgentServiceServer for forward compatibility

type AgentTask added in v0.1.60

type AgentTask struct {
	Id             string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	WorkspaceId    string `protobuf:"bytes,2,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	AgentId        string `protobuf:"bytes,3,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	Kind           string `protobuf:"bytes,4,opt,name=kind,proto3" json:"kind,omitempty"`
	QueueMode      string `protobuf:"bytes,5,opt,name=queue_mode,json=queueMode,proto3" json:"queue_mode,omitempty"`
	State          string `protobuf:"bytes,6,opt,name=state,proto3" json:"state,omitempty"`
	IdempotencyKey string `protobuf:"bytes,7,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	TargetRunId    string `protobuf:"bytes,8,opt,name=target_run_id,json=targetRunId,proto3" json:"target_run_id,omitempty"`
	DroppedReason  string `protobuf:"bytes,9,opt,name=dropped_reason,json=droppedReason,proto3" json:"dropped_reason,omitempty"`
	CreatedAt      string `protobuf:"bytes,10,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt      string `protobuf:"bytes,11,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentTask) Descriptor deprecated added in v0.1.60

func (*AgentTask) Descriptor() ([]byte, []int)

Deprecated: Use AgentTask.ProtoReflect.Descriptor instead.

func (*AgentTask) GetAgentId added in v0.1.60

func (x *AgentTask) GetAgentId() string

func (*AgentTask) GetCreatedAt added in v0.1.60

func (x *AgentTask) GetCreatedAt() string

func (*AgentTask) GetDroppedReason added in v0.1.60

func (x *AgentTask) GetDroppedReason() string

func (*AgentTask) GetId added in v0.1.60

func (x *AgentTask) GetId() string

func (*AgentTask) GetIdempotencyKey added in v0.1.60

func (x *AgentTask) GetIdempotencyKey() string

func (*AgentTask) GetKind added in v0.1.60

func (x *AgentTask) GetKind() string

func (*AgentTask) GetQueueMode added in v0.1.60

func (x *AgentTask) GetQueueMode() string

func (*AgentTask) GetState added in v0.1.60

func (x *AgentTask) GetState() string

func (*AgentTask) GetTargetRunId added in v0.1.60

func (x *AgentTask) GetTargetRunId() string

func (*AgentTask) GetUpdatedAt added in v0.1.60

func (x *AgentTask) GetUpdatedAt() string

func (*AgentTask) GetWorkspaceId added in v0.1.60

func (x *AgentTask) GetWorkspaceId() string

func (*AgentTask) ProtoMessage added in v0.1.60

func (*AgentTask) ProtoMessage()

func (*AgentTask) ProtoReflect added in v0.1.60

func (x *AgentTask) ProtoReflect() protoreflect.Message

func (*AgentTask) Reset added in v0.1.60

func (x *AgentTask) Reset()

func (*AgentTask) String added in v0.1.60

func (x *AgentTask) String() string

type AgentTaskAcceptedResponse added in v0.1.60

type AgentTaskAcceptedResponse struct {
	Ok            bool       `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error         string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Accepted      bool       `protobuf:"varint,3,opt,name=accepted,proto3" json:"accepted,omitempty"`
	IdempotentHit bool       `protobuf:"varint,4,opt,name=idempotent_hit,json=idempotentHit,proto3" json:"idempotent_hit,omitempty"`
	Task          *AgentTask `protobuf:"bytes,5,opt,name=task,proto3" json:"task,omitempty"`
	RunId         string     `protobuf:"bytes,6,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentTaskAcceptedResponse) Descriptor deprecated added in v0.1.60

func (*AgentTaskAcceptedResponse) Descriptor() ([]byte, []int)

Deprecated: Use AgentTaskAcceptedResponse.ProtoReflect.Descriptor instead.

func (*AgentTaskAcceptedResponse) GetAccepted added in v0.1.60

func (x *AgentTaskAcceptedResponse) GetAccepted() bool

func (*AgentTaskAcceptedResponse) GetError added in v0.1.60

func (x *AgentTaskAcceptedResponse) GetError() string

func (*AgentTaskAcceptedResponse) GetIdempotentHit added in v0.1.60

func (x *AgentTaskAcceptedResponse) GetIdempotentHit() bool

func (*AgentTaskAcceptedResponse) GetOk added in v0.1.60

func (x *AgentTaskAcceptedResponse) GetOk() bool

func (*AgentTaskAcceptedResponse) GetRunId added in v0.1.60

func (x *AgentTaskAcceptedResponse) GetRunId() string

func (*AgentTaskAcceptedResponse) GetTask added in v0.1.60

func (x *AgentTaskAcceptedResponse) GetTask() *AgentTask

func (*AgentTaskAcceptedResponse) ProtoMessage added in v0.1.60

func (*AgentTaskAcceptedResponse) ProtoMessage()

func (*AgentTaskAcceptedResponse) ProtoReflect added in v0.1.60

func (*AgentTaskAcceptedResponse) Reset added in v0.1.60

func (x *AgentTaskAcceptedResponse) Reset()

func (*AgentTaskAcceptedResponse) String added in v0.1.60

func (x *AgentTaskAcceptedResponse) String() string

type AgentTaskResponse added in v0.1.60

type AgentTaskResponse struct {
	Ok    bool       `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Task  *AgentTask `protobuf:"bytes,3,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*AgentTaskResponse) Descriptor deprecated added in v0.1.60

func (*AgentTaskResponse) Descriptor() ([]byte, []int)

Deprecated: Use AgentTaskResponse.ProtoReflect.Descriptor instead.

func (*AgentTaskResponse) GetError added in v0.1.60

func (x *AgentTaskResponse) GetError() string

func (*AgentTaskResponse) GetOk added in v0.1.60

func (x *AgentTaskResponse) GetOk() bool

func (*AgentTaskResponse) GetTask added in v0.1.60

func (x *AgentTaskResponse) GetTask() *AgentTask

func (*AgentTaskResponse) ProtoMessage added in v0.1.60

func (*AgentTaskResponse) ProtoMessage()

func (*AgentTaskResponse) ProtoReflect added in v0.1.60

func (x *AgentTaskResponse) ProtoReflect() protoreflect.Message

func (*AgentTaskResponse) Reset added in v0.1.60

func (x *AgentTaskResponse) Reset()

func (*AgentTaskResponse) String added in v0.1.60

func (x *AgentTaskResponse) String() string

type AllocateIPRequest added in v0.1.23

type AllocateIPRequest struct {
	SandboxId string `protobuf:"bytes,1,opt,name=sandbox_id,json=sandboxId,proto3" json:"sandbox_id,omitempty"`
	WorkerId  string `protobuf:"bytes,2,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	// contains filtered or unexported fields
}

IP allocation for sandbox networking

func (*AllocateIPRequest) Descriptor deprecated added in v0.1.23

func (*AllocateIPRequest) Descriptor() ([]byte, []int)

Deprecated: Use AllocateIPRequest.ProtoReflect.Descriptor instead.

func (*AllocateIPRequest) GetSandboxId added in v0.1.23

func (x *AllocateIPRequest) GetSandboxId() string

func (*AllocateIPRequest) GetWorkerId added in v0.1.23

func (x *AllocateIPRequest) GetWorkerId() string

func (*AllocateIPRequest) ProtoMessage added in v0.1.23

func (*AllocateIPRequest) ProtoMessage()

func (*AllocateIPRequest) ProtoReflect added in v0.1.23

func (x *AllocateIPRequest) ProtoReflect() protoreflect.Message

func (*AllocateIPRequest) Reset added in v0.1.23

func (x *AllocateIPRequest) Reset()

func (*AllocateIPRequest) String added in v0.1.23

func (x *AllocateIPRequest) String() string

type AllocateIPResponse added in v0.1.23

type AllocateIPResponse struct {
	Ip            string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Gateway       string `protobuf:"bytes,2,opt,name=gateway,proto3" json:"gateway,omitempty"`
	PrefixLen     int32  `protobuf:"varint,3,opt,name=prefix_len,json=prefixLen,proto3" json:"prefix_len,omitempty"`
	Ipv6          string `protobuf:"bytes,4,opt,name=ipv6,proto3" json:"ipv6,omitempty"`
	GatewayIpv6   string `protobuf:"bytes,5,opt,name=gateway_ipv6,json=gatewayIpv6,proto3" json:"gateway_ipv6,omitempty"`
	PrefixLenIpv6 int32  `protobuf:"varint,6,opt,name=prefix_len_ipv6,json=prefixLenIpv6,proto3" json:"prefix_len_ipv6,omitempty"`
	// contains filtered or unexported fields
}

func (*AllocateIPResponse) Descriptor deprecated added in v0.1.23

func (*AllocateIPResponse) Descriptor() ([]byte, []int)

Deprecated: Use AllocateIPResponse.ProtoReflect.Descriptor instead.

func (*AllocateIPResponse) GetGateway added in v0.1.23

func (x *AllocateIPResponse) GetGateway() string

func (*AllocateIPResponse) GetGatewayIpv6 added in v0.1.68

func (x *AllocateIPResponse) GetGatewayIpv6() string

func (*AllocateIPResponse) GetIp added in v0.1.23

func (x *AllocateIPResponse) GetIp() string

func (*AllocateIPResponse) GetIpv6 added in v0.1.68

func (x *AllocateIPResponse) GetIpv6() string

func (*AllocateIPResponse) GetPrefixLen added in v0.1.23

func (x *AllocateIPResponse) GetPrefixLen() int32

func (*AllocateIPResponse) GetPrefixLenIpv6 added in v0.1.68

func (x *AllocateIPResponse) GetPrefixLenIpv6() int32

func (*AllocateIPResponse) ProtoMessage added in v0.1.23

func (*AllocateIPResponse) ProtoMessage()

func (*AllocateIPResponse) ProtoReflect added in v0.1.23

func (x *AllocateIPResponse) ProtoReflect() protoreflect.Message

func (*AllocateIPResponse) Reset added in v0.1.23

func (x *AllocateIPResponse) Reset()

func (*AllocateIPResponse) String added in v0.1.23

func (x *AllocateIPResponse) String() string

type AppendTaskOutputRowsRequest added in v0.1.96

type AppendTaskOutputRowsRequest struct {
	WorkspaceId uint32 `protobuf:"varint,1,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	OutputId    string `protobuf:"bytes,2,opt,name=output_id,json=outputId,proto3" json:"output_id,omitempty"`
	RowsJson    string `protobuf:"bytes,3,opt,name=rows_json,json=rowsJson,proto3" json:"rows_json,omitempty"` // JSON-encoded array of rows
	// contains filtered or unexported fields
}

func (*AppendTaskOutputRowsRequest) Descriptor deprecated added in v0.1.96

func (*AppendTaskOutputRowsRequest) Descriptor() ([]byte, []int)

Deprecated: Use AppendTaskOutputRowsRequest.ProtoReflect.Descriptor instead.

func (*AppendTaskOutputRowsRequest) GetOutputId added in v0.1.96

func (x *AppendTaskOutputRowsRequest) GetOutputId() string

func (*AppendTaskOutputRowsRequest) GetRowsJson added in v0.1.96

func (x *AppendTaskOutputRowsRequest) GetRowsJson() string

func (*AppendTaskOutputRowsRequest) GetWorkspaceId added in v0.1.96

func (x *AppendTaskOutputRowsRequest) GetWorkspaceId() uint32

func (*AppendTaskOutputRowsRequest) ProtoMessage added in v0.1.96

func (*AppendTaskOutputRowsRequest) ProtoMessage()

func (*AppendTaskOutputRowsRequest) ProtoReflect added in v0.1.96

func (*AppendTaskOutputRowsRequest) Reset added in v0.1.96

func (x *AppendTaskOutputRowsRequest) Reset()

func (*AppendTaskOutputRowsRequest) String added in v0.1.96

func (x *AppendTaskOutputRowsRequest) String() string

type AppendTaskOutputRowsResponse added in v0.1.96

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

func (*AppendTaskOutputRowsResponse) Descriptor deprecated added in v0.1.96

func (*AppendTaskOutputRowsResponse) Descriptor() ([]byte, []int)

Deprecated: Use AppendTaskOutputRowsResponse.ProtoReflect.Descriptor instead.

func (*AppendTaskOutputRowsResponse) ProtoMessage added in v0.1.96

func (*AppendTaskOutputRowsResponse) ProtoMessage()

func (*AppendTaskOutputRowsResponse) ProtoReflect added in v0.1.96

func (*AppendTaskOutputRowsResponse) Reset added in v0.1.96

func (x *AppendTaskOutputRowsResponse) Reset()

func (*AppendTaskOutputRowsResponse) String added in v0.1.96

type CancelAgentRunRequest added in v0.1.60

type CancelAgentRunRequest struct {
	WorkspaceId string `protobuf:"bytes,1,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	RunId       string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelAgentRunRequest) Descriptor deprecated added in v0.1.60

func (*CancelAgentRunRequest) Descriptor() ([]byte, []int)

Deprecated: Use CancelAgentRunRequest.ProtoReflect.Descriptor instead.

func (*CancelAgentRunRequest) GetRunId added in v0.1.60

func (x *CancelAgentRunRequest) GetRunId() string

func (*CancelAgentRunRequest) GetWorkspaceId added in v0.1.60

func (x *CancelAgentRunRequest) GetWorkspaceId() string

func (*CancelAgentRunRequest) ProtoMessage added in v0.1.60

func (*CancelAgentRunRequest) ProtoMessage()

func (*CancelAgentRunRequest) ProtoReflect added in v0.1.60

func (x *CancelAgentRunRequest) ProtoReflect() protoreflect.Message

func (*CancelAgentRunRequest) Reset added in v0.1.60

func (x *CancelAgentRunRequest) Reset()

func (*CancelAgentRunRequest) String added in v0.1.60

func (x *CancelAgentRunRequest) String() string

type CancelAgentRunResponse added in v0.1.60

type CancelAgentRunResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error  string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelAgentRunResponse) Descriptor deprecated added in v0.1.60

func (*CancelAgentRunResponse) Descriptor() ([]byte, []int)

Deprecated: Use CancelAgentRunResponse.ProtoReflect.Descriptor instead.

func (*CancelAgentRunResponse) GetError added in v0.1.60

func (x *CancelAgentRunResponse) GetError() string

func (*CancelAgentRunResponse) GetOk added in v0.1.60

func (x *CancelAgentRunResponse) GetOk() bool

func (*CancelAgentRunResponse) GetStatus added in v0.1.60

func (x *CancelAgentRunResponse) GetStatus() string

func (*CancelAgentRunResponse) ProtoMessage added in v0.1.60

func (*CancelAgentRunResponse) ProtoMessage()

func (*CancelAgentRunResponse) ProtoReflect added in v0.1.60

func (x *CancelAgentRunResponse) ProtoReflect() protoreflect.Message

func (*CancelAgentRunResponse) Reset added in v0.1.60

func (x *CancelAgentRunResponse) Reset()

func (*CancelAgentRunResponse) String added in v0.1.60

func (x *CancelAgentRunResponse) String() string

type ChmodRequest

type ChmodRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Mode uint32 `protobuf:"varint,2,opt,name=mode,proto3" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

Chmod

func (*ChmodRequest) Descriptor deprecated

func (*ChmodRequest) Descriptor() ([]byte, []int)

Deprecated: Use ChmodRequest.ProtoReflect.Descriptor instead.

func (*ChmodRequest) GetMode

func (x *ChmodRequest) GetMode() uint32

func (*ChmodRequest) GetPath

func (x *ChmodRequest) GetPath() string

func (*ChmodRequest) ProtoMessage

func (*ChmodRequest) ProtoMessage()

func (*ChmodRequest) ProtoReflect

func (x *ChmodRequest) ProtoReflect() protoreflect.Message

func (*ChmodRequest) Reset

func (x *ChmodRequest) Reset()

func (*ChmodRequest) String

func (x *ChmodRequest) String() string

type ChmodResponse

type ChmodResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ChmodResponse) Descriptor deprecated

func (*ChmodResponse) Descriptor() ([]byte, []int)

Deprecated: Use ChmodResponse.ProtoReflect.Descriptor instead.

func (*ChmodResponse) GetError

func (x *ChmodResponse) GetError() string

func (*ChmodResponse) GetOk

func (x *ChmodResponse) GetOk() bool

func (*ChmodResponse) ProtoMessage

func (*ChmodResponse) ProtoMessage()

func (*ChmodResponse) ProtoReflect

func (x *ChmodResponse) ProtoReflect() protoreflect.Message

func (*ChmodResponse) Reset

func (x *ChmodResponse) Reset()

func (*ChmodResponse) String

func (x *ChmodResponse) String() string

type ClaimTaskInputRequest added in v0.1.98

type ClaimTaskInputRequest struct {
	TaskId      string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	RunId       string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	ExecutionId string `protobuf:"bytes,3,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	// contains filtered or unexported fields
}

Task input inbox

func (*ClaimTaskInputRequest) Descriptor deprecated added in v0.1.98

func (*ClaimTaskInputRequest) Descriptor() ([]byte, []int)

Deprecated: Use ClaimTaskInputRequest.ProtoReflect.Descriptor instead.

func (*ClaimTaskInputRequest) GetExecutionId added in v0.1.98

func (x *ClaimTaskInputRequest) GetExecutionId() string

func (*ClaimTaskInputRequest) GetRunId added in v0.1.98

func (x *ClaimTaskInputRequest) GetRunId() string

func (*ClaimTaskInputRequest) GetTaskId added in v0.1.98

func (x *ClaimTaskInputRequest) GetTaskId() string

func (*ClaimTaskInputRequest) ProtoMessage added in v0.1.98

func (*ClaimTaskInputRequest) ProtoMessage()

func (*ClaimTaskInputRequest) ProtoReflect added in v0.1.98

func (x *ClaimTaskInputRequest) ProtoReflect() protoreflect.Message

func (*ClaimTaskInputRequest) Reset added in v0.1.98

func (x *ClaimTaskInputRequest) Reset()

func (*ClaimTaskInputRequest) String added in v0.1.98

func (x *ClaimTaskInputRequest) String() string

type ClaimTaskInputResponse added in v0.1.98

type ClaimTaskInputResponse struct {
	Found   bool   `protobuf:"varint,1,opt,name=found,proto3" json:"found,omitempty"`
	InputId string `protobuf:"bytes,2,opt,name=input_id,json=inputId,proto3" json:"input_id,omitempty"`
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Kind    string `protobuf:"bytes,4,opt,name=kind,proto3" json:"kind,omitempty"`
	Action  string `protobuf:"bytes,5,opt,name=action,proto3" json:"action,omitempty"`
	Seq     int32  `protobuf:"varint,6,opt,name=seq,proto3" json:"seq,omitempty"`
	// contains filtered or unexported fields
}

func (*ClaimTaskInputResponse) Descriptor deprecated added in v0.1.98

func (*ClaimTaskInputResponse) Descriptor() ([]byte, []int)

Deprecated: Use ClaimTaskInputResponse.ProtoReflect.Descriptor instead.

func (*ClaimTaskInputResponse) GetAction added in v0.1.98

func (x *ClaimTaskInputResponse) GetAction() string

func (*ClaimTaskInputResponse) GetFound added in v0.1.98

func (x *ClaimTaskInputResponse) GetFound() bool

func (*ClaimTaskInputResponse) GetInputId added in v0.1.98

func (x *ClaimTaskInputResponse) GetInputId() string

func (*ClaimTaskInputResponse) GetKind added in v0.1.98

func (x *ClaimTaskInputResponse) GetKind() string

func (*ClaimTaskInputResponse) GetMessage added in v0.1.98

func (x *ClaimTaskInputResponse) GetMessage() string

func (*ClaimTaskInputResponse) GetSeq added in v0.1.98

func (x *ClaimTaskInputResponse) GetSeq() int32

func (*ClaimTaskInputResponse) ProtoMessage added in v0.1.98

func (*ClaimTaskInputResponse) ProtoMessage()

func (*ClaimTaskInputResponse) ProtoReflect added in v0.1.98

func (x *ClaimTaskInputResponse) ProtoReflect() protoreflect.Message

func (*ClaimTaskInputResponse) Reset added in v0.1.98

func (x *ClaimTaskInputResponse) Reset()

func (*ClaimTaskInputResponse) String added in v0.1.98

func (x *ClaimTaskInputResponse) String() string

type Connection

type Connection struct {
	Id              string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	WorkspaceId     string `protobuf:"bytes,2,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	MemberId        string `protobuf:"bytes,3,opt,name=member_id,json=memberId,proto3" json:"member_id,omitempty"`
	IntegrationType string `protobuf:"bytes,4,opt,name=integration_type,json=integrationType,proto3" json:"integration_type,omitempty"`
	Scope           string `protobuf:"bytes,5,opt,name=scope,proto3" json:"scope,omitempty"`
	IsShared        bool   `protobuf:"varint,6,opt,name=is_shared,json=isShared,proto3" json:"is_shared,omitempty"`
	CreatedAt       string `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Connection) Descriptor deprecated

func (*Connection) Descriptor() ([]byte, []int)

Deprecated: Use Connection.ProtoReflect.Descriptor instead.

func (*Connection) GetCreatedAt

func (x *Connection) GetCreatedAt() string

func (*Connection) GetId

func (x *Connection) GetId() string

func (*Connection) GetIntegrationType

func (x *Connection) GetIntegrationType() string

func (*Connection) GetIsShared

func (x *Connection) GetIsShared() bool

func (*Connection) GetMemberId

func (x *Connection) GetMemberId() string

func (*Connection) GetScope

func (x *Connection) GetScope() string

func (*Connection) GetWorkspaceId

func (x *Connection) GetWorkspaceId() string

func (*Connection) ProtoMessage

func (*Connection) ProtoMessage()

func (*Connection) ProtoReflect

func (x *Connection) ProtoReflect() protoreflect.Message

func (*Connection) Reset

func (x *Connection) Reset()

func (*Connection) String

func (x *Connection) String() string

type ConnectionResponse

type ConnectionResponse struct {
	Ok         bool        `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error      string      `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Connection *Connection `protobuf:"bytes,3,opt,name=connection,proto3" json:"connection,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionResponse) Descriptor deprecated

func (*ConnectionResponse) Descriptor() ([]byte, []int)

Deprecated: Use ConnectionResponse.ProtoReflect.Descriptor instead.

func (*ConnectionResponse) GetConnection

func (x *ConnectionResponse) GetConnection() *Connection

func (*ConnectionResponse) GetError

func (x *ConnectionResponse) GetError() string

func (*ConnectionResponse) GetOk

func (x *ConnectionResponse) GetOk() bool

func (*ConnectionResponse) ProtoMessage

func (*ConnectionResponse) ProtoMessage()

func (*ConnectionResponse) ProtoReflect

func (x *ConnectionResponse) ProtoReflect() protoreflect.Message

func (*ConnectionResponse) Reset

func (x *ConnectionResponse) Reset()

func (*ConnectionResponse) String

func (x *ConnectionResponse) String() string

type ContextCreateRequest

type ContextCreateRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Mode uint32 `protobuf:"varint,2,opt,name=mode,proto3" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

func (*ContextCreateRequest) Descriptor deprecated

func (*ContextCreateRequest) Descriptor() ([]byte, []int)

Deprecated: Use ContextCreateRequest.ProtoReflect.Descriptor instead.

func (*ContextCreateRequest) GetMode

func (x *ContextCreateRequest) GetMode() uint32

func (*ContextCreateRequest) GetPath

func (x *ContextCreateRequest) GetPath() string

func (*ContextCreateRequest) ProtoMessage

func (*ContextCreateRequest) ProtoMessage()

func (*ContextCreateRequest) ProtoReflect

func (x *ContextCreateRequest) ProtoReflect() protoreflect.Message

func (*ContextCreateRequest) Reset

func (x *ContextCreateRequest) Reset()

func (*ContextCreateRequest) String

func (x *ContextCreateRequest) String() string

type ContextCreateResponse

type ContextCreateResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ContextCreateResponse) Descriptor deprecated

func (*ContextCreateResponse) Descriptor() ([]byte, []int)

Deprecated: Use ContextCreateResponse.ProtoReflect.Descriptor instead.

func (*ContextCreateResponse) GetError

func (x *ContextCreateResponse) GetError() string

func (*ContextCreateResponse) GetOk

func (x *ContextCreateResponse) GetOk() bool

func (*ContextCreateResponse) ProtoMessage

func (*ContextCreateResponse) ProtoMessage()

func (*ContextCreateResponse) ProtoReflect

func (x *ContextCreateResponse) ProtoReflect() protoreflect.Message

func (*ContextCreateResponse) Reset

func (x *ContextCreateResponse) Reset()

func (*ContextCreateResponse) String

func (x *ContextCreateResponse) String() string

type ContextDeleteRequest

type ContextDeleteRequest struct {
	Path      string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Recursive bool   `protobuf:"varint,2,opt,name=recursive,proto3" json:"recursive,omitempty"` // If true, delete all contents under the path (for directories)
	// contains filtered or unexported fields
}

func (*ContextDeleteRequest) Descriptor deprecated

func (*ContextDeleteRequest) Descriptor() ([]byte, []int)

Deprecated: Use ContextDeleteRequest.ProtoReflect.Descriptor instead.

func (*ContextDeleteRequest) GetPath

func (x *ContextDeleteRequest) GetPath() string

func (*ContextDeleteRequest) GetRecursive added in v0.1.13

func (x *ContextDeleteRequest) GetRecursive() bool

func (*ContextDeleteRequest) ProtoMessage

func (*ContextDeleteRequest) ProtoMessage()

func (*ContextDeleteRequest) ProtoReflect

func (x *ContextDeleteRequest) ProtoReflect() protoreflect.Message

func (*ContextDeleteRequest) Reset

func (x *ContextDeleteRequest) Reset()

func (*ContextDeleteRequest) String

func (x *ContextDeleteRequest) String() string

type ContextDeleteResponse

type ContextDeleteResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ContextDeleteResponse) Descriptor deprecated

func (*ContextDeleteResponse) Descriptor() ([]byte, []int)

Deprecated: Use ContextDeleteResponse.ProtoReflect.Descriptor instead.

func (*ContextDeleteResponse) GetError

func (x *ContextDeleteResponse) GetError() string

func (*ContextDeleteResponse) GetOk

func (x *ContextDeleteResponse) GetOk() bool

func (*ContextDeleteResponse) ProtoMessage

func (*ContextDeleteResponse) ProtoMessage()

func (*ContextDeleteResponse) ProtoReflect

func (x *ContextDeleteResponse) ProtoReflect() protoreflect.Message

func (*ContextDeleteResponse) Reset

func (x *ContextDeleteResponse) Reset()

func (*ContextDeleteResponse) String

func (x *ContextDeleteResponse) String() string

type ContextDirEntry

type ContextDirEntry struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Mode  uint32 `protobuf:"varint,2,opt,name=mode,proto3" json:"mode,omitempty"`
	IsDir bool   `protobuf:"varint,3,opt,name=is_dir,json=isDir,proto3" json:"is_dir,omitempty"`
	Size  int64  `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	Mtime int64  `protobuf:"varint,5,opt,name=mtime,proto3" json:"mtime,omitempty"`
	Etag  string `protobuf:"bytes,6,opt,name=etag,proto3" json:"etag,omitempty"`
	// contains filtered or unexported fields
}

func (*ContextDirEntry) Descriptor deprecated

func (*ContextDirEntry) Descriptor() ([]byte, []int)

Deprecated: Use ContextDirEntry.ProtoReflect.Descriptor instead.

func (*ContextDirEntry) GetEtag

func (x *ContextDirEntry) GetEtag() string

func (*ContextDirEntry) GetIsDir

func (x *ContextDirEntry) GetIsDir() bool

func (*ContextDirEntry) GetMode

func (x *ContextDirEntry) GetMode() uint32

func (*ContextDirEntry) GetMtime

func (x *ContextDirEntry) GetMtime() int64

func (*ContextDirEntry) GetName

func (x *ContextDirEntry) GetName() string

func (*ContextDirEntry) GetSize

func (x *ContextDirEntry) GetSize() int64

func (*ContextDirEntry) ProtoMessage

func (*ContextDirEntry) ProtoMessage()

func (*ContextDirEntry) ProtoReflect

func (x *ContextDirEntry) ProtoReflect() protoreflect.Message

func (*ContextDirEntry) Reset

func (x *ContextDirEntry) Reset()

func (*ContextDirEntry) String

func (x *ContextDirEntry) String() string

type ContextMkdirRequest

type ContextMkdirRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Mode uint32 `protobuf:"varint,2,opt,name=mode,proto3" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

func (*ContextMkdirRequest) Descriptor deprecated

func (*ContextMkdirRequest) Descriptor() ([]byte, []int)

Deprecated: Use ContextMkdirRequest.ProtoReflect.Descriptor instead.

func (*ContextMkdirRequest) GetMode

func (x *ContextMkdirRequest) GetMode() uint32

func (*ContextMkdirRequest) GetPath

func (x *ContextMkdirRequest) GetPath() string

func (*ContextMkdirRequest) ProtoMessage

func (*ContextMkdirRequest) ProtoMessage()

func (*ContextMkdirRequest) ProtoReflect

func (x *ContextMkdirRequest) ProtoReflect() protoreflect.Message

func (*ContextMkdirRequest) Reset

func (x *ContextMkdirRequest) Reset()

func (*ContextMkdirRequest) String

func (x *ContextMkdirRequest) String() string

type ContextMkdirResponse

type ContextMkdirResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ContextMkdirResponse) Descriptor deprecated

func (*ContextMkdirResponse) Descriptor() ([]byte, []int)

Deprecated: Use ContextMkdirResponse.ProtoReflect.Descriptor instead.

func (*ContextMkdirResponse) GetError

func (x *ContextMkdirResponse) GetError() string

func (*ContextMkdirResponse) GetOk

func (x *ContextMkdirResponse) GetOk() bool

func (*ContextMkdirResponse) ProtoMessage

func (*ContextMkdirResponse) ProtoMessage()

func (*ContextMkdirResponse) ProtoReflect

func (x *ContextMkdirResponse) ProtoReflect() protoreflect.Message

func (*ContextMkdirResponse) Reset

func (x *ContextMkdirResponse) Reset()

func (*ContextMkdirResponse) String

func (x *ContextMkdirResponse) String() string

type ContextReadDirRequest

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

func (*ContextReadDirRequest) Descriptor deprecated

func (*ContextReadDirRequest) Descriptor() ([]byte, []int)

Deprecated: Use ContextReadDirRequest.ProtoReflect.Descriptor instead.

func (*ContextReadDirRequest) GetPath

func (x *ContextReadDirRequest) GetPath() string

func (*ContextReadDirRequest) ProtoMessage

func (*ContextReadDirRequest) ProtoMessage()

func (*ContextReadDirRequest) ProtoReflect

func (x *ContextReadDirRequest) ProtoReflect() protoreflect.Message

func (*ContextReadDirRequest) Reset

func (x *ContextReadDirRequest) Reset()

func (*ContextReadDirRequest) String

func (x *ContextReadDirRequest) String() string

type ContextReadDirResponse

type ContextReadDirResponse struct {
	Ok      bool               `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error   string             `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Entries []*ContextDirEntry `protobuf:"bytes,3,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*ContextReadDirResponse) Descriptor deprecated

func (*ContextReadDirResponse) Descriptor() ([]byte, []int)

Deprecated: Use ContextReadDirResponse.ProtoReflect.Descriptor instead.

func (*ContextReadDirResponse) GetEntries

func (x *ContextReadDirResponse) GetEntries() []*ContextDirEntry

func (*ContextReadDirResponse) GetError

func (x *ContextReadDirResponse) GetError() string

func (*ContextReadDirResponse) GetOk

func (x *ContextReadDirResponse) GetOk() bool

func (*ContextReadDirResponse) ProtoMessage

func (*ContextReadDirResponse) ProtoMessage()

func (*ContextReadDirResponse) ProtoReflect

func (x *ContextReadDirResponse) ProtoReflect() protoreflect.Message

func (*ContextReadDirResponse) Reset

func (x *ContextReadDirResponse) Reset()

func (*ContextReadDirResponse) String

func (x *ContextReadDirResponse) String() string

type ContextReadRequest

type ContextReadRequest struct {
	Path   string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Offset int64  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Length int64  `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
	// contains filtered or unexported fields
}

func (*ContextReadRequest) Descriptor deprecated

func (*ContextReadRequest) Descriptor() ([]byte, []int)

Deprecated: Use ContextReadRequest.ProtoReflect.Descriptor instead.

func (*ContextReadRequest) GetLength

func (x *ContextReadRequest) GetLength() int64

func (*ContextReadRequest) GetOffset

func (x *ContextReadRequest) GetOffset() int64

func (*ContextReadRequest) GetPath

func (x *ContextReadRequest) GetPath() string

func (*ContextReadRequest) ProtoMessage

func (*ContextReadRequest) ProtoMessage()

func (*ContextReadRequest) ProtoReflect

func (x *ContextReadRequest) ProtoReflect() protoreflect.Message

func (*ContextReadRequest) Reset

func (x *ContextReadRequest) Reset()

func (*ContextReadRequest) String

func (x *ContextReadRequest) String() string

type ContextReadResponse

type ContextReadResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Data  []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ContextReadResponse) Descriptor deprecated

func (*ContextReadResponse) Descriptor() ([]byte, []int)

Deprecated: Use ContextReadResponse.ProtoReflect.Descriptor instead.

func (*ContextReadResponse) GetData

func (x *ContextReadResponse) GetData() []byte

func (*ContextReadResponse) GetError

func (x *ContextReadResponse) GetError() string

func (*ContextReadResponse) GetOk

func (x *ContextReadResponse) GetOk() bool

func (*ContextReadResponse) ProtoMessage

func (*ContextReadResponse) ProtoMessage()

func (*ContextReadResponse) ProtoReflect

func (x *ContextReadResponse) ProtoReflect() protoreflect.Message

func (*ContextReadResponse) Reset

func (x *ContextReadResponse) Reset()

func (*ContextReadResponse) String

func (x *ContextReadResponse) String() string

type ContextReadlinkRequest

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

func (*ContextReadlinkRequest) Descriptor deprecated

func (*ContextReadlinkRequest) Descriptor() ([]byte, []int)

Deprecated: Use ContextReadlinkRequest.ProtoReflect.Descriptor instead.

func (*ContextReadlinkRequest) GetPath

func (x *ContextReadlinkRequest) GetPath() string

func (*ContextReadlinkRequest) ProtoMessage

func (*ContextReadlinkRequest) ProtoMessage()

func (*ContextReadlinkRequest) ProtoReflect

func (x *ContextReadlinkRequest) ProtoReflect() protoreflect.Message

func (*ContextReadlinkRequest) Reset

func (x *ContextReadlinkRequest) Reset()

func (*ContextReadlinkRequest) String

func (x *ContextReadlinkRequest) String() string

type ContextReadlinkResponse

type ContextReadlinkResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error  string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

func (*ContextReadlinkResponse) Descriptor deprecated

func (*ContextReadlinkResponse) Descriptor() ([]byte, []int)

Deprecated: Use ContextReadlinkResponse.ProtoReflect.Descriptor instead.

func (*ContextReadlinkResponse) GetError

func (x *ContextReadlinkResponse) GetError() string

func (*ContextReadlinkResponse) GetOk

func (x *ContextReadlinkResponse) GetOk() bool

func (*ContextReadlinkResponse) GetTarget

func (x *ContextReadlinkResponse) GetTarget() string

func (*ContextReadlinkResponse) ProtoMessage

func (*ContextReadlinkResponse) ProtoMessage()

func (*ContextReadlinkResponse) ProtoReflect

func (x *ContextReadlinkResponse) ProtoReflect() protoreflect.Message

func (*ContextReadlinkResponse) Reset

func (x *ContextReadlinkResponse) Reset()

func (*ContextReadlinkResponse) String

func (x *ContextReadlinkResponse) String() string

type ContextRenameRequest

type ContextRenameRequest struct {
	OldPath string `protobuf:"bytes,1,opt,name=old_path,json=oldPath,proto3" json:"old_path,omitempty"`
	NewPath string `protobuf:"bytes,2,opt,name=new_path,json=newPath,proto3" json:"new_path,omitempty"`
	// contains filtered or unexported fields
}

func (*ContextRenameRequest) Descriptor deprecated

func (*ContextRenameRequest) Descriptor() ([]byte, []int)

Deprecated: Use ContextRenameRequest.ProtoReflect.Descriptor instead.

func (*ContextRenameRequest) GetNewPath

func (x *ContextRenameRequest) GetNewPath() string

func (*ContextRenameRequest) GetOldPath

func (x *ContextRenameRequest) GetOldPath() string

func (*ContextRenameRequest) ProtoMessage

func (*ContextRenameRequest) ProtoMessage()

func (*ContextRenameRequest) ProtoReflect

func (x *ContextRenameRequest) ProtoReflect() protoreflect.Message

func (*ContextRenameRequest) Reset

func (x *ContextRenameRequest) Reset()

func (*ContextRenameRequest) String

func (x *ContextRenameRequest) String() string

type ContextRenameResponse

type ContextRenameResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ContextRenameResponse) Descriptor deprecated

func (*ContextRenameResponse) Descriptor() ([]byte, []int)

Deprecated: Use ContextRenameResponse.ProtoReflect.Descriptor instead.

func (*ContextRenameResponse) GetError

func (x *ContextRenameResponse) GetError() string

func (*ContextRenameResponse) GetOk

func (x *ContextRenameResponse) GetOk() bool

func (*ContextRenameResponse) ProtoMessage

func (*ContextRenameResponse) ProtoMessage()

func (*ContextRenameResponse) ProtoReflect

func (x *ContextRenameResponse) ProtoReflect() protoreflect.Message

func (*ContextRenameResponse) Reset

func (x *ContextRenameResponse) Reset()

func (*ContextRenameResponse) String

func (x *ContextRenameResponse) String() string

type ContextServiceClient

type ContextServiceClient interface {
	// Stat returns file/directory attributes
	Stat(ctx context.Context, in *ContextStatRequest, opts ...grpc.CallOption) (*ContextStatResponse, error)
	// ReadDir lists directory contents
	ReadDir(ctx context.Context, in *ContextReadDirRequest, opts ...grpc.CallOption) (*ContextReadDirResponse, error)
	// Read reads file content
	Read(ctx context.Context, in *ContextReadRequest, opts ...grpc.CallOption) (*ContextReadResponse, error)
	// Write writes file content (creates if not exists)
	Write(ctx context.Context, in *ContextWriteRequest, opts ...grpc.CallOption) (*ContextWriteResponse, error)
	// Create creates a new empty file
	Create(ctx context.Context, in *ContextCreateRequest, opts ...grpc.CallOption) (*ContextCreateResponse, error)
	// Delete removes a file or empty directory
	Delete(ctx context.Context, in *ContextDeleteRequest, opts ...grpc.CallOption) (*ContextDeleteResponse, error)
	// Mkdir creates a directory
	Mkdir(ctx context.Context, in *ContextMkdirRequest, opts ...grpc.CallOption) (*ContextMkdirResponse, error)
	// Rename moves/renames a file or directory
	Rename(ctx context.Context, in *ContextRenameRequest, opts ...grpc.CallOption) (*ContextRenameResponse, error)
	// Truncate changes file size
	Truncate(ctx context.Context, in *ContextTruncateRequest, opts ...grpc.CallOption) (*ContextTruncateResponse, error)
	// Symlink creates a symbolic link
	Symlink(ctx context.Context, in *ContextSymlinkRequest, opts ...grpc.CallOption) (*ContextSymlinkResponse, error)
	// Readlink reads a symbolic link target
	Readlink(ctx context.Context, in *ContextReadlinkRequest, opts ...grpc.CallOption) (*ContextReadlinkResponse, error)
	// ListTree returns a flat listing of all objects under a prefix (for prefetching)
	ListTree(ctx context.Context, in *ListTreeRequest, opts ...grpc.CallOption) (*ListTreeResponse, error)
}

ContextServiceClient is the client API for ContextService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type ContextServiceServer

type ContextServiceServer interface {
	// Stat returns file/directory attributes
	Stat(context.Context, *ContextStatRequest) (*ContextStatResponse, error)
	// ReadDir lists directory contents
	ReadDir(context.Context, *ContextReadDirRequest) (*ContextReadDirResponse, error)
	// Read reads file content
	Read(context.Context, *ContextReadRequest) (*ContextReadResponse, error)
	// Write writes file content (creates if not exists)
	Write(context.Context, *ContextWriteRequest) (*ContextWriteResponse, error)
	// Create creates a new empty file
	Create(context.Context, *ContextCreateRequest) (*ContextCreateResponse, error)
	// Delete removes a file or empty directory
	Delete(context.Context, *ContextDeleteRequest) (*ContextDeleteResponse, error)
	// Mkdir creates a directory
	Mkdir(context.Context, *ContextMkdirRequest) (*ContextMkdirResponse, error)
	// Rename moves/renames a file or directory
	Rename(context.Context, *ContextRenameRequest) (*ContextRenameResponse, error)
	// Truncate changes file size
	Truncate(context.Context, *ContextTruncateRequest) (*ContextTruncateResponse, error)
	// Symlink creates a symbolic link
	Symlink(context.Context, *ContextSymlinkRequest) (*ContextSymlinkResponse, error)
	// Readlink reads a symbolic link target
	Readlink(context.Context, *ContextReadlinkRequest) (*ContextReadlinkResponse, error)
	// ListTree returns a flat listing of all objects under a prefix (for prefetching)
	ListTree(context.Context, *ListTreeRequest) (*ListTreeResponse, error)
	// contains filtered or unexported methods
}

ContextServiceServer is the server API for ContextService service. All implementations must embed UnimplementedContextServiceServer for forward compatibility

type ContextStatRequest

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

func (*ContextStatRequest) Descriptor deprecated

func (*ContextStatRequest) Descriptor() ([]byte, []int)

Deprecated: Use ContextStatRequest.ProtoReflect.Descriptor instead.

func (*ContextStatRequest) GetPath

func (x *ContextStatRequest) GetPath() string

func (*ContextStatRequest) ProtoMessage

func (*ContextStatRequest) ProtoMessage()

func (*ContextStatRequest) ProtoReflect

func (x *ContextStatRequest) ProtoReflect() protoreflect.Message

func (*ContextStatRequest) Reset

func (x *ContextStatRequest) Reset()

func (*ContextStatRequest) String

func (x *ContextStatRequest) String() string

type ContextStatResponse

type ContextStatResponse struct {
	Ok    bool      `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string    `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Info  *FileInfo `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*ContextStatResponse) Descriptor deprecated

func (*ContextStatResponse) Descriptor() ([]byte, []int)

Deprecated: Use ContextStatResponse.ProtoReflect.Descriptor instead.

func (*ContextStatResponse) GetError

func (x *ContextStatResponse) GetError() string

func (*ContextStatResponse) GetInfo

func (x *ContextStatResponse) GetInfo() *FileInfo

func (*ContextStatResponse) GetOk

func (x *ContextStatResponse) GetOk() bool

func (*ContextStatResponse) ProtoMessage

func (*ContextStatResponse) ProtoMessage()

func (*ContextStatResponse) ProtoReflect

func (x *ContextStatResponse) ProtoReflect() protoreflect.Message

func (*ContextStatResponse) Reset

func (x *ContextStatResponse) Reset()

func (*ContextStatResponse) String

func (x *ContextStatResponse) String() string

type ContextSymlinkRequest

type ContextSymlinkRequest struct {
	Target   string `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	LinkPath string `protobuf:"bytes,2,opt,name=link_path,json=linkPath,proto3" json:"link_path,omitempty"`
	// contains filtered or unexported fields
}

func (*ContextSymlinkRequest) Descriptor deprecated

func (*ContextSymlinkRequest) Descriptor() ([]byte, []int)

Deprecated: Use ContextSymlinkRequest.ProtoReflect.Descriptor instead.

func (*ContextSymlinkRequest) GetLinkPath

func (x *ContextSymlinkRequest) GetLinkPath() string

func (*ContextSymlinkRequest) GetTarget

func (x *ContextSymlinkRequest) GetTarget() string

func (*ContextSymlinkRequest) ProtoMessage

func (*ContextSymlinkRequest) ProtoMessage()

func (*ContextSymlinkRequest) ProtoReflect

func (x *ContextSymlinkRequest) ProtoReflect() protoreflect.Message

func (*ContextSymlinkRequest) Reset

func (x *ContextSymlinkRequest) Reset()

func (*ContextSymlinkRequest) String

func (x *ContextSymlinkRequest) String() string

type ContextSymlinkResponse

type ContextSymlinkResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ContextSymlinkResponse) Descriptor deprecated

func (*ContextSymlinkResponse) Descriptor() ([]byte, []int)

Deprecated: Use ContextSymlinkResponse.ProtoReflect.Descriptor instead.

func (*ContextSymlinkResponse) GetError

func (x *ContextSymlinkResponse) GetError() string

func (*ContextSymlinkResponse) GetOk

func (x *ContextSymlinkResponse) GetOk() bool

func (*ContextSymlinkResponse) ProtoMessage

func (*ContextSymlinkResponse) ProtoMessage()

func (*ContextSymlinkResponse) ProtoReflect

func (x *ContextSymlinkResponse) ProtoReflect() protoreflect.Message

func (*ContextSymlinkResponse) Reset

func (x *ContextSymlinkResponse) Reset()

func (*ContextSymlinkResponse) String

func (x *ContextSymlinkResponse) String() string

type ContextTruncateRequest

type ContextTruncateRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Size int64  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*ContextTruncateRequest) Descriptor deprecated

func (*ContextTruncateRequest) Descriptor() ([]byte, []int)

Deprecated: Use ContextTruncateRequest.ProtoReflect.Descriptor instead.

func (*ContextTruncateRequest) GetPath

func (x *ContextTruncateRequest) GetPath() string

func (*ContextTruncateRequest) GetSize

func (x *ContextTruncateRequest) GetSize() int64

func (*ContextTruncateRequest) ProtoMessage

func (*ContextTruncateRequest) ProtoMessage()

func (*ContextTruncateRequest) ProtoReflect

func (x *ContextTruncateRequest) ProtoReflect() protoreflect.Message

func (*ContextTruncateRequest) Reset

func (x *ContextTruncateRequest) Reset()

func (*ContextTruncateRequest) String

func (x *ContextTruncateRequest) String() string

type ContextTruncateResponse

type ContextTruncateResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ContextTruncateResponse) Descriptor deprecated

func (*ContextTruncateResponse) Descriptor() ([]byte, []int)

Deprecated: Use ContextTruncateResponse.ProtoReflect.Descriptor instead.

func (*ContextTruncateResponse) GetError

func (x *ContextTruncateResponse) GetError() string

func (*ContextTruncateResponse) GetOk

func (x *ContextTruncateResponse) GetOk() bool

func (*ContextTruncateResponse) ProtoMessage

func (*ContextTruncateResponse) ProtoMessage()

func (*ContextTruncateResponse) ProtoReflect

func (x *ContextTruncateResponse) ProtoReflect() protoreflect.Message

func (*ContextTruncateResponse) Reset

func (x *ContextTruncateResponse) Reset()

func (*ContextTruncateResponse) String

func (x *ContextTruncateResponse) String() string

type ContextWriteRequest

type ContextWriteRequest struct {
	Path   string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Data   []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	Offset int64  `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

func (*ContextWriteRequest) Descriptor deprecated

func (*ContextWriteRequest) Descriptor() ([]byte, []int)

Deprecated: Use ContextWriteRequest.ProtoReflect.Descriptor instead.

func (*ContextWriteRequest) GetData

func (x *ContextWriteRequest) GetData() []byte

func (*ContextWriteRequest) GetOffset

func (x *ContextWriteRequest) GetOffset() int64

func (*ContextWriteRequest) GetPath

func (x *ContextWriteRequest) GetPath() string

func (*ContextWriteRequest) ProtoMessage

func (*ContextWriteRequest) ProtoMessage()

func (*ContextWriteRequest) ProtoReflect

func (x *ContextWriteRequest) ProtoReflect() protoreflect.Message

func (*ContextWriteRequest) Reset

func (x *ContextWriteRequest) Reset()

func (*ContextWriteRequest) String

func (x *ContextWriteRequest) String() string

type ContextWriteResponse

type ContextWriteResponse struct {
	Ok      bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error   string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Written int32  `protobuf:"varint,3,opt,name=written,proto3" json:"written,omitempty"`
	// contains filtered or unexported fields
}

func (*ContextWriteResponse) Descriptor deprecated

func (*ContextWriteResponse) Descriptor() ([]byte, []int)

Deprecated: Use ContextWriteResponse.ProtoReflect.Descriptor instead.

func (*ContextWriteResponse) GetError

func (x *ContextWriteResponse) GetError() string

func (*ContextWriteResponse) GetOk

func (x *ContextWriteResponse) GetOk() bool

func (*ContextWriteResponse) GetWritten

func (x *ContextWriteResponse) GetWritten() int32

func (*ContextWriteResponse) ProtoMessage

func (*ContextWriteResponse) ProtoMessage()

func (*ContextWriteResponse) ProtoReflect

func (x *ContextWriteResponse) ProtoReflect() protoreflect.Message

func (*ContextWriteResponse) Reset

func (x *ContextWriteResponse) Reset()

func (*ContextWriteResponse) String

func (x *ContextWriteResponse) String() string

type CreateAgentProfileRequest added in v0.1.60

type CreateAgentProfileRequest struct {
	WorkspaceId string           `protobuf:"bytes,1,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	AgentKey    string           `protobuf:"bytes,2,opt,name=agent_key,json=agentKey,proto3" json:"agent_key,omitempty"`
	Name        string           `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	Config      *structpb.Struct `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	Active      bool             `protobuf:"varint,5,opt,name=active,proto3" json:"active,omitempty"`
	HasActive   bool             `protobuf:"varint,6,opt,name=has_active,json=hasActive,proto3" json:"has_active,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateAgentProfileRequest) Descriptor deprecated added in v0.1.60

func (*CreateAgentProfileRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateAgentProfileRequest.ProtoReflect.Descriptor instead.

func (*CreateAgentProfileRequest) GetActive added in v0.1.60

func (x *CreateAgentProfileRequest) GetActive() bool

func (*CreateAgentProfileRequest) GetAgentKey added in v0.1.60

func (x *CreateAgentProfileRequest) GetAgentKey() string

func (*CreateAgentProfileRequest) GetConfig added in v0.1.60

func (x *CreateAgentProfileRequest) GetConfig() *structpb.Struct

func (*CreateAgentProfileRequest) GetHasActive added in v0.1.60

func (x *CreateAgentProfileRequest) GetHasActive() bool

func (*CreateAgentProfileRequest) GetName added in v0.1.60

func (x *CreateAgentProfileRequest) GetName() string

func (*CreateAgentProfileRequest) GetWorkspaceId added in v0.1.60

func (x *CreateAgentProfileRequest) GetWorkspaceId() string

func (*CreateAgentProfileRequest) ProtoMessage added in v0.1.60

func (*CreateAgentProfileRequest) ProtoMessage()

func (*CreateAgentProfileRequest) ProtoReflect added in v0.1.60

func (*CreateAgentProfileRequest) Reset added in v0.1.60

func (x *CreateAgentProfileRequest) Reset()

func (*CreateAgentProfileRequest) String added in v0.1.60

func (x *CreateAgentProfileRequest) String() string

type CreateHookRequest added in v0.1.28

type CreateHookRequest struct {
	WorkspaceId string `protobuf:"bytes,1,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	Path        string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Prompt      string `protobuf:"bytes,3,opt,name=prompt,proto3" json:"prompt,omitempty"`
	SkillPath   string `protobuf:"bytes,4,opt,name=skill_path,json=skillPath,proto3" json:"skill_path,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateHookRequest) Descriptor deprecated added in v0.1.28

func (*CreateHookRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateHookRequest.ProtoReflect.Descriptor instead.

func (*CreateHookRequest) GetPath added in v0.1.28

func (x *CreateHookRequest) GetPath() string

func (*CreateHookRequest) GetPrompt added in v0.1.28

func (x *CreateHookRequest) GetPrompt() string

func (*CreateHookRequest) GetSkillPath added in v0.1.32

func (x *CreateHookRequest) GetSkillPath() string

func (*CreateHookRequest) GetWorkspaceId added in v0.1.28

func (x *CreateHookRequest) GetWorkspaceId() string

func (*CreateHookRequest) ProtoMessage added in v0.1.28

func (*CreateHookRequest) ProtoMessage()

func (*CreateHookRequest) ProtoReflect added in v0.1.28

func (x *CreateHookRequest) ProtoReflect() protoreflect.Message

func (*CreateHookRequest) Reset added in v0.1.28

func (x *CreateHookRequest) Reset()

func (*CreateHookRequest) String added in v0.1.28

func (x *CreateHookRequest) String() string

type CreateRequest

type CreateRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Mode uint32 `protobuf:"varint,2,opt,name=mode,proto3" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

Create

func (*CreateRequest) Descriptor deprecated

func (*CreateRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateRequest.ProtoReflect.Descriptor instead.

func (*CreateRequest) GetMode

func (x *CreateRequest) GetMode() uint32

func (*CreateRequest) GetPath

func (x *CreateRequest) GetPath() string

func (*CreateRequest) ProtoMessage

func (*CreateRequest) ProtoMessage()

func (*CreateRequest) ProtoReflect

func (x *CreateRequest) ProtoReflect() protoreflect.Message

func (*CreateRequest) Reset

func (x *CreateRequest) Reset()

func (*CreateRequest) String

func (x *CreateRequest) String() string

type CreateResponse

type CreateResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateResponse) Descriptor deprecated

func (*CreateResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateResponse.ProtoReflect.Descriptor instead.

func (*CreateResponse) GetError

func (x *CreateResponse) GetError() string

func (*CreateResponse) GetOk

func (x *CreateResponse) GetOk() bool

func (*CreateResponse) ProtoMessage

func (*CreateResponse) ProtoMessage()

func (*CreateResponse) ProtoReflect

func (x *CreateResponse) ProtoReflect() protoreflect.Message

func (*CreateResponse) Reset

func (x *CreateResponse) Reset()

func (*CreateResponse) String

func (x *CreateResponse) String() string

type CreateTaskOutputRequest added in v0.1.96

type CreateTaskOutputRequest struct {
	WorkspaceId  uint32 `protobuf:"varint,1,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	TaskId       string `protobuf:"bytes,2,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	RunId        string `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	OutputType   string `protobuf:"bytes,4,opt,name=output_type,json=outputType,proto3" json:"output_type,omitempty"`
	Title        string `protobuf:"bytes,5,opt,name=title,proto3" json:"title,omitempty"`
	DataJson     string `protobuf:"bytes,7,opt,name=data_json,json=dataJson,proto3" json:"data_json,omitempty"`             // JSON-encoded initial data
	MetadataJson string `protobuf:"bytes,8,opt,name=metadata_json,json=metadataJson,proto3" json:"metadata_json,omitempty"` // JSON-encoded metadata
	Uri          string `protobuf:"bytes,9,opt,name=uri,proto3" json:"uri,omitempty"`                                       // External deep-link URI
	AgentId      string `protobuf:"bytes,10,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	Status       string `protobuf:"bytes,11,opt,name=status,proto3" json:"status,omitempty"` // Lifecycle status (active, pending, approved, rejected, superseded)
	// contains filtered or unexported fields
}

Task output messages

func (*CreateTaskOutputRequest) Descriptor deprecated added in v0.1.96

func (*CreateTaskOutputRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateTaskOutputRequest.ProtoReflect.Descriptor instead.

func (*CreateTaskOutputRequest) GetAgentId added in v0.1.96

func (x *CreateTaskOutputRequest) GetAgentId() string

func (*CreateTaskOutputRequest) GetDataJson added in v0.1.96

func (x *CreateTaskOutputRequest) GetDataJson() string

func (*CreateTaskOutputRequest) GetMetadataJson added in v0.1.96

func (x *CreateTaskOutputRequest) GetMetadataJson() string

func (*CreateTaskOutputRequest) GetOutputType added in v0.1.96

func (x *CreateTaskOutputRequest) GetOutputType() string

func (*CreateTaskOutputRequest) GetRunId added in v0.1.96

func (x *CreateTaskOutputRequest) GetRunId() string

func (*CreateTaskOutputRequest) GetStatus added in v0.1.106

func (x *CreateTaskOutputRequest) GetStatus() string

func (*CreateTaskOutputRequest) GetTaskId added in v0.1.96

func (x *CreateTaskOutputRequest) GetTaskId() string

func (*CreateTaskOutputRequest) GetTitle added in v0.1.96

func (x *CreateTaskOutputRequest) GetTitle() string

func (*CreateTaskOutputRequest) GetUri added in v0.1.96

func (x *CreateTaskOutputRequest) GetUri() string

func (*CreateTaskOutputRequest) GetWorkspaceId added in v0.1.96

func (x *CreateTaskOutputRequest) GetWorkspaceId() uint32

func (*CreateTaskOutputRequest) ProtoMessage added in v0.1.96

func (*CreateTaskOutputRequest) ProtoMessage()

func (*CreateTaskOutputRequest) ProtoReflect added in v0.1.96

func (x *CreateTaskOutputRequest) ProtoReflect() protoreflect.Message

func (*CreateTaskOutputRequest) Reset added in v0.1.96

func (x *CreateTaskOutputRequest) Reset()

func (*CreateTaskOutputRequest) String added in v0.1.96

func (x *CreateTaskOutputRequest) String() string

type CreateTaskOutputResponse added in v0.1.96

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

func (*CreateTaskOutputResponse) Descriptor deprecated added in v0.1.96

func (*CreateTaskOutputResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateTaskOutputResponse.ProtoReflect.Descriptor instead.

func (*CreateTaskOutputResponse) GetId added in v0.1.96

func (x *CreateTaskOutputResponse) GetId() string

func (*CreateTaskOutputResponse) ProtoMessage added in v0.1.96

func (*CreateTaskOutputResponse) ProtoMessage()

func (*CreateTaskOutputResponse) ProtoReflect added in v0.1.96

func (x *CreateTaskOutputResponse) ProtoReflect() protoreflect.Message

func (*CreateTaskOutputResponse) Reset added in v0.1.96

func (x *CreateTaskOutputResponse) Reset()

func (*CreateTaskOutputResponse) String added in v0.1.96

func (x *CreateTaskOutputResponse) String() string

type CreateTaskRequest added in v0.1.31

type CreateTaskRequest struct {
	Message           string             `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	AgentId           string             `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	SessionId         string             `protobuf:"bytes,3,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	SessionKey        string             `protobuf:"bytes,4,opt,name=session_key,json=sessionKey,proto3" json:"session_key,omitempty"`
	IdempotencyKey    string             `protobuf:"bytes,5,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	Lane              string             `protobuf:"bytes,6,opt,name=lane,proto3" json:"lane,omitempty"`
	ExtraSystemPrompt string             `protobuf:"bytes,7,opt,name=extra_system_prompt,json=extraSystemPrompt,proto3" json:"extra_system_prompt,omitempty"`
	Deliver           *bool              `protobuf:"varint,8,opt,name=deliver,proto3,oneof" json:"deliver,omitempty"`
	TimeoutMs         *int32             `protobuf:"varint,9,opt,name=timeout_ms,json=timeoutMs,proto3,oneof" json:"timeout_ms,omitempty"`
	Policy            *structpb.Struct   `protobuf:"bytes,10,opt,name=policy,proto3" json:"policy,omitempty"`
	InputProvenance   *structpb.Struct   `protobuf:"bytes,11,opt,name=input_provenance,json=inputProvenance,proto3" json:"input_provenance,omitempty"`
	Routing           *structpb.Struct   `protobuf:"bytes,12,opt,name=routing,proto3" json:"routing,omitempty"`
	Attachments       []*structpb.Struct `protobuf:"bytes,13,rep,name=attachments,proto3" json:"attachments,omitempty"`
	Label             string             `protobuf:"bytes,14,opt,name=label,proto3" json:"label,omitempty"`
	SpawnedBy         string             `protobuf:"bytes,15,opt,name=spawned_by,json=spawnedBy,proto3" json:"spawned_by,omitempty"`
	ParentTaskId      string             `protobuf:"bytes,16,opt,name=parent_task_id,json=parentTaskId,proto3" json:"parent_task_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTaskRequest) Descriptor deprecated added in v0.1.31

func (*CreateTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateTaskRequest.ProtoReflect.Descriptor instead.

func (*CreateTaskRequest) GetAgentId added in v0.1.60

func (x *CreateTaskRequest) GetAgentId() string

func (*CreateTaskRequest) GetAttachments added in v0.1.60

func (x *CreateTaskRequest) GetAttachments() []*structpb.Struct

func (*CreateTaskRequest) GetDeliver added in v0.1.60

func (x *CreateTaskRequest) GetDeliver() bool

func (*CreateTaskRequest) GetExtraSystemPrompt added in v0.1.60

func (x *CreateTaskRequest) GetExtraSystemPrompt() string

func (*CreateTaskRequest) GetIdempotencyKey added in v0.1.60

func (x *CreateTaskRequest) GetIdempotencyKey() string

func (*CreateTaskRequest) GetInputProvenance added in v0.1.60

func (x *CreateTaskRequest) GetInputProvenance() *structpb.Struct

func (*CreateTaskRequest) GetLabel added in v0.1.60

func (x *CreateTaskRequest) GetLabel() string

func (*CreateTaskRequest) GetLane added in v0.1.60

func (x *CreateTaskRequest) GetLane() string

func (*CreateTaskRequest) GetMessage added in v0.1.60

func (x *CreateTaskRequest) GetMessage() string

func (*CreateTaskRequest) GetParentTaskId added in v0.1.110

func (x *CreateTaskRequest) GetParentTaskId() string

func (*CreateTaskRequest) GetPolicy added in v0.1.60

func (x *CreateTaskRequest) GetPolicy() *structpb.Struct

func (*CreateTaskRequest) GetRouting added in v0.1.60

func (x *CreateTaskRequest) GetRouting() *structpb.Struct

func (*CreateTaskRequest) GetSessionId added in v0.1.60

func (x *CreateTaskRequest) GetSessionId() string

func (*CreateTaskRequest) GetSessionKey added in v0.1.60

func (x *CreateTaskRequest) GetSessionKey() string

func (*CreateTaskRequest) GetSpawnedBy added in v0.1.60

func (x *CreateTaskRequest) GetSpawnedBy() string

func (*CreateTaskRequest) GetTimeoutMs added in v0.1.60

func (x *CreateTaskRequest) GetTimeoutMs() int32

func (*CreateTaskRequest) ProtoMessage added in v0.1.31

func (*CreateTaskRequest) ProtoMessage()

func (*CreateTaskRequest) ProtoReflect added in v0.1.31

func (x *CreateTaskRequest) ProtoReflect() protoreflect.Message

func (*CreateTaskRequest) Reset added in v0.1.31

func (x *CreateTaskRequest) Reset()

func (*CreateTaskRequest) String added in v0.1.31

func (x *CreateTaskRequest) String() string

type CreateTokenRequest

type CreateTokenRequest struct {
	WorkspaceId      string `protobuf:"bytes,1,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	MemberId         string `protobuf:"bytes,2,opt,name=member_id,json=memberId,proto3" json:"member_id,omitempty"`
	Name             string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	ExpiresInSeconds int64  `protobuf:"varint,4,opt,name=expires_in_seconds,json=expiresInSeconds,proto3" json:"expires_in_seconds,omitempty"` // 0 = no expiry
	// contains filtered or unexported fields
}

Token messages

func (*CreateTokenRequest) Descriptor deprecated

func (*CreateTokenRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateTokenRequest.ProtoReflect.Descriptor instead.

func (*CreateTokenRequest) GetExpiresInSeconds

func (x *CreateTokenRequest) GetExpiresInSeconds() int64

func (*CreateTokenRequest) GetMemberId

func (x *CreateTokenRequest) GetMemberId() string

func (*CreateTokenRequest) GetName

func (x *CreateTokenRequest) GetName() string

func (*CreateTokenRequest) GetWorkspaceId

func (x *CreateTokenRequest) GetWorkspaceId() string

func (*CreateTokenRequest) ProtoMessage

func (*CreateTokenRequest) ProtoMessage()

func (*CreateTokenRequest) ProtoReflect

func (x *CreateTokenRequest) ProtoReflect() protoreflect.Message

func (*CreateTokenRequest) Reset

func (x *CreateTokenRequest) Reset()

func (*CreateTokenRequest) String

func (x *CreateTokenRequest) String() string

type CreateTokenResponse

type CreateTokenResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Token string `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"` // Raw token, only returned on create
	Info  *Token `protobuf:"bytes,4,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTokenResponse) Descriptor deprecated

func (*CreateTokenResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateTokenResponse.ProtoReflect.Descriptor instead.

func (*CreateTokenResponse) GetError

func (x *CreateTokenResponse) GetError() string

func (*CreateTokenResponse) GetInfo

func (x *CreateTokenResponse) GetInfo() *Token

func (*CreateTokenResponse) GetOk

func (x *CreateTokenResponse) GetOk() bool

func (*CreateTokenResponse) GetToken

func (x *CreateTokenResponse) GetToken() string

func (*CreateTokenResponse) ProtoMessage

func (*CreateTokenResponse) ProtoMessage()

func (*CreateTokenResponse) ProtoReflect

func (x *CreateTokenResponse) ProtoReflect() protoreflect.Message

func (*CreateTokenResponse) Reset

func (x *CreateTokenResponse) Reset()

func (*CreateTokenResponse) String

func (x *CreateTokenResponse) String() string

type CreateViewRequest added in v0.1.50

type CreateViewRequest struct {
	Integration  string `protobuf:"bytes,1,opt,name=integration,proto3" json:"integration,omitempty"`                       // e.g., "gmail"
	Name         string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`                                     // Folder name like "unread-emails"
	Guidance     string `protobuf:"bytes,3,opt,name=guidance,proto3" json:"guidance,omitempty"`                             // Optional extra context for LLM (smart mode)
	OutputFormat string `protobuf:"bytes,4,opt,name=output_format,json=outputFormat,proto3" json:"output_format,omitempty"` // "folder" or "file"
	FileExt      string `protobuf:"bytes,5,opt,name=file_ext,json=fileExt,proto3" json:"file_ext,omitempty"`                // For files: ".json", ".md"
	Filter       string `protobuf:"bytes,6,opt,name=filter,proto3" json:"filter,omitempty"`                                 // JSON structured filter (query mode)
	// contains filtered or unexported fields
}

CreateView - creates a view from a folder/file name via LLM inference or structured filter

func (*CreateViewRequest) Descriptor deprecated added in v0.1.50

func (*CreateViewRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateViewRequest.ProtoReflect.Descriptor instead.

func (*CreateViewRequest) GetFileExt added in v0.1.50

func (x *CreateViewRequest) GetFileExt() string

func (*CreateViewRequest) GetFilter added in v0.1.50

func (x *CreateViewRequest) GetFilter() string

func (*CreateViewRequest) GetGuidance added in v0.1.50

func (x *CreateViewRequest) GetGuidance() string

func (*CreateViewRequest) GetIntegration added in v0.1.50

func (x *CreateViewRequest) GetIntegration() string

func (*CreateViewRequest) GetName added in v0.1.50

func (x *CreateViewRequest) GetName() string

func (*CreateViewRequest) GetOutputFormat added in v0.1.50

func (x *CreateViewRequest) GetOutputFormat() string

func (*CreateViewRequest) ProtoMessage added in v0.1.50

func (*CreateViewRequest) ProtoMessage()

func (*CreateViewRequest) ProtoReflect added in v0.1.50

func (x *CreateViewRequest) ProtoReflect() protoreflect.Message

func (*CreateViewRequest) Reset added in v0.1.50

func (x *CreateViewRequest) Reset()

func (*CreateViewRequest) String added in v0.1.50

func (x *CreateViewRequest) String() string

type CreateViewResponse added in v0.1.50

type CreateViewResponse struct {
	Ok    bool        `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string      `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	View  *SourceView `protobuf:"bytes,3,opt,name=view,proto3" json:"view,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateViewResponse) Descriptor deprecated added in v0.1.50

func (*CreateViewResponse) Descriptor() ([]byte, []int)

Deprecated: Use CreateViewResponse.ProtoReflect.Descriptor instead.

func (*CreateViewResponse) GetError added in v0.1.50

func (x *CreateViewResponse) GetError() string

func (*CreateViewResponse) GetOk added in v0.1.50

func (x *CreateViewResponse) GetOk() bool

func (*CreateViewResponse) GetView added in v0.1.50

func (x *CreateViewResponse) GetView() *SourceView

func (*CreateViewResponse) ProtoMessage added in v0.1.50

func (*CreateViewResponse) ProtoMessage()

func (*CreateViewResponse) ProtoReflect added in v0.1.50

func (x *CreateViewResponse) ProtoReflect() protoreflect.Message

func (*CreateViewResponse) Reset added in v0.1.50

func (x *CreateViewResponse) Reset()

func (*CreateViewResponse) String added in v0.1.50

func (x *CreateViewResponse) String() string

type CreateWorkerTokenRequest

type CreateWorkerTokenRequest struct {
	Name             string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	PoolName         string `protobuf:"bytes,2,opt,name=pool_name,json=poolName,proto3" json:"pool_name,omitempty"`                            // Optional, empty = all pools
	ExpiresInSeconds int64  `protobuf:"varint,3,opt,name=expires_in_seconds,json=expiresInSeconds,proto3" json:"expires_in_seconds,omitempty"` // 0 = no expiry
	// contains filtered or unexported fields
}

Worker token messages

func (*CreateWorkerTokenRequest) Descriptor deprecated

func (*CreateWorkerTokenRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateWorkerTokenRequest.ProtoReflect.Descriptor instead.

func (*CreateWorkerTokenRequest) GetExpiresInSeconds

func (x *CreateWorkerTokenRequest) GetExpiresInSeconds() int64

func (*CreateWorkerTokenRequest) GetName

func (x *CreateWorkerTokenRequest) GetName() string

func (*CreateWorkerTokenRequest) GetPoolName

func (x *CreateWorkerTokenRequest) GetPoolName() string

func (*CreateWorkerTokenRequest) ProtoMessage

func (*CreateWorkerTokenRequest) ProtoMessage()

func (*CreateWorkerTokenRequest) ProtoReflect

func (x *CreateWorkerTokenRequest) ProtoReflect() protoreflect.Message

func (*CreateWorkerTokenRequest) Reset

func (x *CreateWorkerTokenRequest) Reset()

func (*CreateWorkerTokenRequest) String

func (x *CreateWorkerTokenRequest) String() string

type CreateWorkspaceRequest

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

Workspace messages

func (*CreateWorkspaceRequest) Descriptor deprecated

func (*CreateWorkspaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use CreateWorkspaceRequest.ProtoReflect.Descriptor instead.

func (*CreateWorkspaceRequest) GetName

func (x *CreateWorkspaceRequest) GetName() string

func (*CreateWorkspaceRequest) ProtoMessage

func (*CreateWorkspaceRequest) ProtoMessage()

func (*CreateWorkspaceRequest) ProtoReflect

func (x *CreateWorkspaceRequest) ProtoReflect() protoreflect.Message

func (*CreateWorkspaceRequest) Reset

func (x *CreateWorkspaceRequest) Reset()

func (*CreateWorkspaceRequest) String

func (x *CreateWorkspaceRequest) String() string

type DeleteHookRequest added in v0.1.28

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

func (*DeleteHookRequest) Descriptor deprecated added in v0.1.28

func (*DeleteHookRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteHookRequest.ProtoReflect.Descriptor instead.

func (*DeleteHookRequest) GetId added in v0.1.28

func (x *DeleteHookRequest) GetId() string

func (*DeleteHookRequest) ProtoMessage added in v0.1.28

func (*DeleteHookRequest) ProtoMessage()

func (*DeleteHookRequest) ProtoReflect added in v0.1.28

func (x *DeleteHookRequest) ProtoReflect() protoreflect.Message

func (*DeleteHookRequest) Reset added in v0.1.28

func (x *DeleteHookRequest) Reset()

func (*DeleteHookRequest) String added in v0.1.28

func (x *DeleteHookRequest) String() string

type DeleteResponse

type DeleteResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

Common

func (*DeleteResponse) Descriptor deprecated

func (*DeleteResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteResponse.ProtoReflect.Descriptor instead.

func (*DeleteResponse) GetError

func (x *DeleteResponse) GetError() string

func (*DeleteResponse) GetOk

func (x *DeleteResponse) GetOk() bool

func (*DeleteResponse) ProtoMessage

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) ProtoReflect

func (x *DeleteResponse) ProtoReflect() protoreflect.Message

func (*DeleteResponse) Reset

func (x *DeleteResponse) Reset()

func (*DeleteResponse) String

func (x *DeleteResponse) String() string

type DeleteTaskRequest added in v0.1.31

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

func (*DeleteTaskRequest) Descriptor deprecated added in v0.1.31

func (*DeleteTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteTaskRequest.ProtoReflect.Descriptor instead.

func (*DeleteTaskRequest) GetId added in v0.1.31

func (x *DeleteTaskRequest) GetId() string

func (*DeleteTaskRequest) ProtoMessage added in v0.1.31

func (*DeleteTaskRequest) ProtoMessage()

func (*DeleteTaskRequest) ProtoReflect added in v0.1.31

func (x *DeleteTaskRequest) ProtoReflect() protoreflect.Message

func (*DeleteTaskRequest) Reset added in v0.1.31

func (x *DeleteTaskRequest) Reset()

func (*DeleteTaskRequest) String added in v0.1.31

func (x *DeleteTaskRequest) String() string

type DeleteViewRequest added in v0.1.50

type DeleteViewRequest struct {
	ExternalId string `protobuf:"bytes,1,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"` // Stable view ID (from SourceView.external_id)
	// contains filtered or unexported fields
}

DeleteView - removes a view by external_id

func (*DeleteViewRequest) Descriptor deprecated added in v0.1.50

func (*DeleteViewRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteViewRequest.ProtoReflect.Descriptor instead.

func (*DeleteViewRequest) GetExternalId added in v0.1.50

func (x *DeleteViewRequest) GetExternalId() string

func (*DeleteViewRequest) ProtoMessage added in v0.1.50

func (*DeleteViewRequest) ProtoMessage()

func (*DeleteViewRequest) ProtoReflect added in v0.1.50

func (x *DeleteViewRequest) ProtoReflect() protoreflect.Message

func (*DeleteViewRequest) Reset added in v0.1.50

func (x *DeleteViewRequest) Reset()

func (*DeleteViewRequest) String added in v0.1.50

func (x *DeleteViewRequest) String() string

type DeleteViewResponse added in v0.1.50

type DeleteViewResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteViewResponse) Descriptor deprecated added in v0.1.50

func (*DeleteViewResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeleteViewResponse.ProtoReflect.Descriptor instead.

func (*DeleteViewResponse) GetError added in v0.1.50

func (x *DeleteViewResponse) GetError() string

func (*DeleteViewResponse) GetOk added in v0.1.50

func (x *DeleteViewResponse) GetOk() bool

func (*DeleteViewResponse) ProtoMessage added in v0.1.50

func (*DeleteViewResponse) ProtoMessage()

func (*DeleteViewResponse) ProtoReflect added in v0.1.50

func (x *DeleteViewResponse) ProtoReflect() protoreflect.Message

func (*DeleteViewResponse) Reset added in v0.1.50

func (x *DeleteViewResponse) Reset()

func (*DeleteViewResponse) String added in v0.1.50

func (x *DeleteViewResponse) String() string

type DeleteWorkspaceRequest

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

func (*DeleteWorkspaceRequest) Descriptor deprecated

func (*DeleteWorkspaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeleteWorkspaceRequest.ProtoReflect.Descriptor instead.

func (*DeleteWorkspaceRequest) GetId

func (x *DeleteWorkspaceRequest) GetId() string

func (*DeleteWorkspaceRequest) ProtoMessage

func (*DeleteWorkspaceRequest) ProtoMessage()

func (*DeleteWorkspaceRequest) ProtoReflect

func (x *DeleteWorkspaceRequest) ProtoReflect() protoreflect.Message

func (*DeleteWorkspaceRequest) Reset

func (x *DeleteWorkspaceRequest) Reset()

func (*DeleteWorkspaceRequest) String

func (x *DeleteWorkspaceRequest) String() string

type DeregisterRequest

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

Deregistration

func (*DeregisterRequest) Descriptor deprecated

func (*DeregisterRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeregisterRequest.ProtoReflect.Descriptor instead.

func (*DeregisterRequest) GetWorkerId

func (x *DeregisterRequest) GetWorkerId() string

func (*DeregisterRequest) ProtoMessage

func (*DeregisterRequest) ProtoMessage()

func (*DeregisterRequest) ProtoReflect

func (x *DeregisterRequest) ProtoReflect() protoreflect.Message

func (*DeregisterRequest) Reset

func (x *DeregisterRequest) Reset()

func (*DeregisterRequest) String

func (x *DeregisterRequest) String() string

type DeregisterResponse

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

func (*DeregisterResponse) Descriptor deprecated

func (*DeregisterResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeregisterResponse.ProtoReflect.Descriptor instead.

func (*DeregisterResponse) ProtoMessage

func (*DeregisterResponse) ProtoMessage()

func (*DeregisterResponse) ProtoReflect

func (x *DeregisterResponse) ProtoReflect() protoreflect.Message

func (*DeregisterResponse) Reset

func (x *DeregisterResponse) Reset()

func (*DeregisterResponse) String

func (x *DeregisterResponse) String() string

type DirEntry

type DirEntry struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Mode  uint32 `protobuf:"varint,2,opt,name=mode,proto3" json:"mode,omitempty"`
	Size  int64  `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	Mtime int64  `protobuf:"varint,4,opt,name=mtime,proto3" json:"mtime,omitempty"`
	IsDir bool   `protobuf:"varint,5,opt,name=is_dir,json=isDir,proto3" json:"is_dir,omitempty"`
	// contains filtered or unexported fields
}

DirEntry represents an entry in a directory listing.

func (*DirEntry) Descriptor deprecated

func (*DirEntry) Descriptor() ([]byte, []int)

Deprecated: Use DirEntry.ProtoReflect.Descriptor instead.

func (*DirEntry) GetIsDir

func (x *DirEntry) GetIsDir() bool

func (*DirEntry) GetMode

func (x *DirEntry) GetMode() uint32

func (*DirEntry) GetMtime

func (x *DirEntry) GetMtime() int64

func (*DirEntry) GetName

func (x *DirEntry) GetName() string

func (*DirEntry) GetSize

func (x *DirEntry) GetSize() int64

func (*DirEntry) ProtoMessage

func (*DirEntry) ProtoMessage()

func (*DirEntry) ProtoReflect

func (x *DirEntry) ProtoReflect() protoreflect.Message

func (*DirEntry) Reset

func (x *DirEntry) Reset()

func (*DirEntry) String

func (x *DirEntry) String() string

type EnqueueRunInputRequest added in v0.1.60

type EnqueueRunInputRequest struct {
	WorkspaceId    string `protobuf:"bytes,1,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	RunId          string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Message        string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	QueueMode      string `protobuf:"bytes,4,opt,name=queue_mode,json=queueMode,proto3" json:"queue_mode,omitempty"`
	IdempotencyKey string `protobuf:"bytes,5,opt,name=idempotency_key,json=idempotencyKey,proto3" json:"idempotency_key,omitempty"`
	// contains filtered or unexported fields
}

func (*EnqueueRunInputRequest) Descriptor deprecated added in v0.1.60

func (*EnqueueRunInputRequest) Descriptor() ([]byte, []int)

Deprecated: Use EnqueueRunInputRequest.ProtoReflect.Descriptor instead.

func (*EnqueueRunInputRequest) GetIdempotencyKey added in v0.1.60

func (x *EnqueueRunInputRequest) GetIdempotencyKey() string

func (*EnqueueRunInputRequest) GetMessage added in v0.1.60

func (x *EnqueueRunInputRequest) GetMessage() string

func (*EnqueueRunInputRequest) GetQueueMode added in v0.1.60

func (x *EnqueueRunInputRequest) GetQueueMode() string

func (*EnqueueRunInputRequest) GetRunId added in v0.1.60

func (x *EnqueueRunInputRequest) GetRunId() string

func (*EnqueueRunInputRequest) GetWorkspaceId added in v0.1.60

func (x *EnqueueRunInputRequest) GetWorkspaceId() string

func (*EnqueueRunInputRequest) ProtoMessage added in v0.1.60

func (*EnqueueRunInputRequest) ProtoMessage()

func (*EnqueueRunInputRequest) ProtoReflect added in v0.1.60

func (x *EnqueueRunInputRequest) ProtoReflect() protoreflect.Message

func (*EnqueueRunInputRequest) Reset added in v0.1.60

func (x *EnqueueRunInputRequest) Reset()

func (*EnqueueRunInputRequest) String added in v0.1.60

func (x *EnqueueRunInputRequest) String() string

type ExecuteToolRequest

type ExecuteToolRequest struct {
	Name string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Args []string `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteToolRequest) Descriptor deprecated

func (*ExecuteToolRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteToolRequest.ProtoReflect.Descriptor instead.

func (*ExecuteToolRequest) GetArgs

func (x *ExecuteToolRequest) GetArgs() []string

func (*ExecuteToolRequest) GetName

func (x *ExecuteToolRequest) GetName() string

func (*ExecuteToolRequest) ProtoMessage

func (*ExecuteToolRequest) ProtoMessage()

func (*ExecuteToolRequest) ProtoReflect

func (x *ExecuteToolRequest) ProtoReflect() protoreflect.Message

func (*ExecuteToolRequest) Reset

func (x *ExecuteToolRequest) Reset()

func (*ExecuteToolRequest) String

func (x *ExecuteToolRequest) String() string

type ExecuteToolResponse

type ExecuteToolResponse struct {
	Stream ExecuteToolResponse_StreamType `protobuf:"varint,1,opt,name=stream,proto3,enum=tools.ExecuteToolResponse_StreamType" json:"stream,omitempty"`
	Data   []byte                         `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// Set when execution completes
	Done     bool   `protobuf:"varint,3,opt,name=done,proto3" json:"done,omitempty"`
	ExitCode int32  `protobuf:"varint,4,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	Error    string `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteToolResponse) Descriptor deprecated

func (*ExecuteToolResponse) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteToolResponse.ProtoReflect.Descriptor instead.

func (*ExecuteToolResponse) GetData

func (x *ExecuteToolResponse) GetData() []byte

func (*ExecuteToolResponse) GetDone

func (x *ExecuteToolResponse) GetDone() bool

func (*ExecuteToolResponse) GetError

func (x *ExecuteToolResponse) GetError() string

func (*ExecuteToolResponse) GetExitCode

func (x *ExecuteToolResponse) GetExitCode() int32

func (*ExecuteToolResponse) GetStream

func (*ExecuteToolResponse) ProtoMessage

func (*ExecuteToolResponse) ProtoMessage()

func (*ExecuteToolResponse) ProtoReflect

func (x *ExecuteToolResponse) ProtoReflect() protoreflect.Message

func (*ExecuteToolResponse) Reset

func (x *ExecuteToolResponse) Reset()

func (*ExecuteToolResponse) String

func (x *ExecuteToolResponse) String() string

type ExecuteToolResponse_StreamType

type ExecuteToolResponse_StreamType int32

Output stream type

const (
	ExecuteToolResponse_STDOUT ExecuteToolResponse_StreamType = 0
	ExecuteToolResponse_STDERR ExecuteToolResponse_StreamType = 1
)

func (ExecuteToolResponse_StreamType) Descriptor

func (ExecuteToolResponse_StreamType) Enum

func (ExecuteToolResponse_StreamType) EnumDescriptor deprecated

func (ExecuteToolResponse_StreamType) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExecuteToolResponse_StreamType.Descriptor instead.

func (ExecuteToolResponse_StreamType) Number

func (ExecuteToolResponse_StreamType) String

func (ExecuteToolResponse_StreamType) Type

type ExecuteViewRequest added in v0.1.50

type ExecuteViewRequest struct {
	Path     string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`                         // View path: "/sources/gmail/unread-emails"
	Filename string `protobuf:"bytes,2,opt,name=filename,proto3" json:"filename,omitempty"`                 // Optional: specific file to read from folder results
	ResultId string `protobuf:"bytes,3,opt,name=result_id,json=resultId,proto3" json:"result_id,omitempty"` // Optional: provider-specific ID for direct content retrieval
	// contains filtered or unexported fields
}

ExecuteView - runs a view's query and returns results

func (*ExecuteViewRequest) Descriptor deprecated added in v0.1.50

func (*ExecuteViewRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteViewRequest.ProtoReflect.Descriptor instead.

func (*ExecuteViewRequest) GetFilename added in v0.1.50

func (x *ExecuteViewRequest) GetFilename() string

func (*ExecuteViewRequest) GetPath added in v0.1.50

func (x *ExecuteViewRequest) GetPath() string

func (*ExecuteViewRequest) GetResultId added in v0.1.50

func (x *ExecuteViewRequest) GetResultId() string

func (*ExecuteViewRequest) ProtoMessage added in v0.1.50

func (*ExecuteViewRequest) ProtoMessage()

func (*ExecuteViewRequest) ProtoReflect added in v0.1.50

func (x *ExecuteViewRequest) ProtoReflect() protoreflect.Message

func (*ExecuteViewRequest) Reset added in v0.1.50

func (x *ExecuteViewRequest) Reset()

func (*ExecuteViewRequest) String added in v0.1.50

func (x *ExecuteViewRequest) String() string

type ExecuteViewResponse added in v0.1.50

type ExecuteViewResponse struct {
	Ok       bool              `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error    string            `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Entries  []*SourceDirEntry `protobuf:"bytes,3,rep,name=entries,proto3" json:"entries,omitempty"`                   // For folder mode: directory entries
	FileData []byte            `protobuf:"bytes,4,opt,name=file_data,json=fileData,proto3" json:"file_data,omitempty"` // For file mode or specific filename: content
	// contains filtered or unexported fields
}

func (*ExecuteViewResponse) Descriptor deprecated added in v0.1.50

func (*ExecuteViewResponse) Descriptor() ([]byte, []int)

Deprecated: Use ExecuteViewResponse.ProtoReflect.Descriptor instead.

func (*ExecuteViewResponse) GetEntries added in v0.1.50

func (x *ExecuteViewResponse) GetEntries() []*SourceDirEntry

func (*ExecuteViewResponse) GetError added in v0.1.50

func (x *ExecuteViewResponse) GetError() string

func (*ExecuteViewResponse) GetFileData added in v0.1.50

func (x *ExecuteViewResponse) GetFileData() []byte

func (*ExecuteViewResponse) GetOk added in v0.1.50

func (x *ExecuteViewResponse) GetOk() bool

func (*ExecuteViewResponse) ProtoMessage added in v0.1.50

func (*ExecuteViewResponse) ProtoMessage()

func (*ExecuteViewResponse) ProtoReflect added in v0.1.50

func (x *ExecuteViewResponse) ProtoReflect() protoreflect.Message

func (*ExecuteViewResponse) Reset added in v0.1.50

func (x *ExecuteViewResponse) Reset()

func (*ExecuteViewResponse) String added in v0.1.50

func (x *ExecuteViewResponse) String() string

type FileInfo

type FileInfo struct {
	Size   int64  `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	Mode   uint32 `protobuf:"varint,2,opt,name=mode,proto3" json:"mode,omitempty"`
	Mtime  int64  `protobuf:"varint,3,opt,name=mtime,proto3" json:"mtime,omitempty"`
	IsDir  bool   `protobuf:"varint,4,opt,name=is_dir,json=isDir,proto3" json:"is_dir,omitempty"`
	IsLink bool   `protobuf:"varint,5,opt,name=is_link,json=isLink,proto3" json:"is_link,omitempty"`
	// contains filtered or unexported fields
}

func (*FileInfo) Descriptor deprecated

func (*FileInfo) Descriptor() ([]byte, []int)

Deprecated: Use FileInfo.ProtoReflect.Descriptor instead.

func (*FileInfo) GetIsDir

func (x *FileInfo) GetIsDir() bool
func (x *FileInfo) GetIsLink() bool

func (*FileInfo) GetMode

func (x *FileInfo) GetMode() uint32

func (*FileInfo) GetMtime

func (x *FileInfo) GetMtime() int64

func (*FileInfo) GetSize

func (x *FileInfo) GetSize() int64

func (*FileInfo) ProtoMessage

func (*FileInfo) ProtoMessage()

func (*FileInfo) ProtoReflect

func (x *FileInfo) ProtoReflect() protoreflect.Message

func (*FileInfo) Reset

func (x *FileInfo) Reset()

func (*FileInfo) String

func (x *FileInfo) String() string

type FileStat

type FileStat struct {
	Path          string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Name          string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Size          int64  `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	Mode          uint32 `protobuf:"varint,4,opt,name=mode,proto3" json:"mode,omitempty"`
	Mtime         int64  `protobuf:"varint,5,opt,name=mtime,proto3" json:"mtime,omitempty"` // Unix timestamp
	IsDir         bool   `protobuf:"varint,6,opt,name=is_dir,json=isDir,proto3" json:"is_dir,omitempty"`
	IsSymlink     bool   `protobuf:"varint,7,opt,name=is_symlink,json=isSymlink,proto3" json:"is_symlink,omitempty"`
	SymlinkTarget string `protobuf:"bytes,8,opt,name=symlink_target,json=symlinkTarget,proto3" json:"symlink_target,omitempty"`
	// contains filtered or unexported fields
}

FileStat contains metadata about a file or directory.

func (*FileStat) Descriptor deprecated

func (*FileStat) Descriptor() ([]byte, []int)

Deprecated: Use FileStat.ProtoReflect.Descriptor instead.

func (*FileStat) GetIsDir

func (x *FileStat) GetIsDir() bool
func (x *FileStat) GetIsSymlink() bool

func (*FileStat) GetMode

func (x *FileStat) GetMode() uint32

func (*FileStat) GetMtime

func (x *FileStat) GetMtime() int64

func (*FileStat) GetName

func (x *FileStat) GetName() string

func (*FileStat) GetPath

func (x *FileStat) GetPath() string

func (*FileStat) GetSize

func (x *FileStat) GetSize() int64

func (*FileStat) GetSymlinkTarget

func (x *FileStat) GetSymlinkTarget() string

func (*FileStat) ProtoMessage

func (*FileStat) ProtoMessage()

func (*FileStat) ProtoReflect

func (x *FileStat) ProtoReflect() protoreflect.Message

func (*FileStat) Reset

func (x *FileStat) Reset()

func (*FileStat) String

func (x *FileStat) String() string

type FilesystemServiceClient

type FilesystemServiceClient interface {
	// Stat returns metadata for a path (file or directory).
	Stat(ctx context.Context, in *StatRequest, opts ...grpc.CallOption) (*StatResponse, error)
	// ReadDir returns directory entries.
	ReadDir(ctx context.Context, in *ReadDirRequest, opts ...grpc.CallOption) (*ReadDirResponse, error)
	// Mkdir creates a directory.
	Mkdir(ctx context.Context, in *MkdirRequest, opts ...grpc.CallOption) (*MkdirResponse, error)
	// Create creates a file.
	Create(ctx context.Context, in *CreateRequest, opts ...grpc.CallOption) (*CreateResponse, error)
	// Rename renames a file or directory.
	Rename(ctx context.Context, in *RenameRequest, opts ...grpc.CallOption) (*RenameResponse, error)
	// Remove removes a file or directory.
	Remove(ctx context.Context, in *RemoveRequest, opts ...grpc.CallOption) (*RemoveResponse, error)
	// Chmod changes file permissions.
	Chmod(ctx context.Context, in *ChmodRequest, opts ...grpc.CallOption) (*ChmodResponse, error)
}

FilesystemServiceClient is the client API for FilesystemService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type FilesystemServiceServer

type FilesystemServiceServer interface {
	// Stat returns metadata for a path (file or directory).
	Stat(context.Context, *StatRequest) (*StatResponse, error)
	// ReadDir returns directory entries.
	ReadDir(context.Context, *ReadDirRequest) (*ReadDirResponse, error)
	// Mkdir creates a directory.
	Mkdir(context.Context, *MkdirRequest) (*MkdirResponse, error)
	// Create creates a file.
	Create(context.Context, *CreateRequest) (*CreateResponse, error)
	// Rename renames a file or directory.
	Rename(context.Context, *RenameRequest) (*RenameResponse, error)
	// Remove removes a file or directory.
	Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)
	// Chmod changes file permissions.
	Chmod(context.Context, *ChmodRequest) (*ChmodResponse, error)
	// contains filtered or unexported methods
}

FilesystemServiceServer is the server API for FilesystemService service. All implementations must embed UnimplementedFilesystemServiceServer for forward compatibility

type FinalizeTaskOutputRequest added in v0.1.96

type FinalizeTaskOutputRequest struct {
	WorkspaceId uint32 `protobuf:"varint,1,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	OutputId    string `protobuf:"bytes,2,opt,name=output_id,json=outputId,proto3" json:"output_id,omitempty"`
	Summary     string `protobuf:"bytes,3,opt,name=summary,proto3" json:"summary,omitempty"`
	// contains filtered or unexported fields
}

func (*FinalizeTaskOutputRequest) Descriptor deprecated added in v0.1.96

func (*FinalizeTaskOutputRequest) Descriptor() ([]byte, []int)

Deprecated: Use FinalizeTaskOutputRequest.ProtoReflect.Descriptor instead.

func (*FinalizeTaskOutputRequest) GetOutputId added in v0.1.96

func (x *FinalizeTaskOutputRequest) GetOutputId() string

func (*FinalizeTaskOutputRequest) GetSummary added in v0.1.96

func (x *FinalizeTaskOutputRequest) GetSummary() string

func (*FinalizeTaskOutputRequest) GetWorkspaceId added in v0.1.96

func (x *FinalizeTaskOutputRequest) GetWorkspaceId() uint32

func (*FinalizeTaskOutputRequest) ProtoMessage added in v0.1.96

func (*FinalizeTaskOutputRequest) ProtoMessage()

func (*FinalizeTaskOutputRequest) ProtoReflect added in v0.1.96

func (*FinalizeTaskOutputRequest) Reset added in v0.1.96

func (x *FinalizeTaskOutputRequest) Reset()

func (*FinalizeTaskOutputRequest) String added in v0.1.96

func (x *FinalizeTaskOutputRequest) String() string

type FinalizeTaskOutputResponse added in v0.1.96

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

func (*FinalizeTaskOutputResponse) Descriptor deprecated added in v0.1.96

func (*FinalizeTaskOutputResponse) Descriptor() ([]byte, []int)

Deprecated: Use FinalizeTaskOutputResponse.ProtoReflect.Descriptor instead.

func (*FinalizeTaskOutputResponse) ProtoMessage added in v0.1.96

func (*FinalizeTaskOutputResponse) ProtoMessage()

func (*FinalizeTaskOutputResponse) ProtoReflect added in v0.1.96

func (*FinalizeTaskOutputResponse) Reset added in v0.1.96

func (x *FinalizeTaskOutputResponse) Reset()

func (*FinalizeTaskOutputResponse) String added in v0.1.96

func (x *FinalizeTaskOutputResponse) String() string

type GatewayServiceClient

type GatewayServiceClient interface {
	// Workspaces
	CreateWorkspace(ctx context.Context, in *CreateWorkspaceRequest, opts ...grpc.CallOption) (*WorkspaceResponse, error)
	ListWorkspaces(ctx context.Context, in *ListWorkspacesRequest, opts ...grpc.CallOption) (*ListWorkspacesResponse, error)
	GetWorkspace(ctx context.Context, in *GetWorkspaceRequest, opts ...grpc.CallOption) (*WorkspaceResponse, error)
	DeleteWorkspace(ctx context.Context, in *DeleteWorkspaceRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	// Members
	AddMember(ctx context.Context, in *AddMemberRequest, opts ...grpc.CallOption) (*MemberResponse, error)
	ListMembers(ctx context.Context, in *ListMembersRequest, opts ...grpc.CallOption) (*ListMembersResponse, error)
	RemoveMember(ctx context.Context, in *RemoveMemberRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	// Tokens (workspace-scoped)
	CreateToken(ctx context.Context, in *CreateTokenRequest, opts ...grpc.CallOption) (*CreateTokenResponse, error)
	ListTokens(ctx context.Context, in *ListTokensRequest, opts ...grpc.CallOption) (*ListTokensResponse, error)
	RevokeToken(ctx context.Context, in *RevokeTokenRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	// Worker Tokens (cluster-level)
	CreateWorkerToken(ctx context.Context, in *CreateWorkerTokenRequest, opts ...grpc.CallOption) (*CreateTokenResponse, error)
	ListWorkerTokens(ctx context.Context, in *ListWorkerTokensRequest, opts ...grpc.CallOption) (*ListTokensResponse, error)
	// Connections
	AddConnection(ctx context.Context, in *AddConnectionRequest, opts ...grpc.CallOption) (*ConnectionResponse, error)
	ListConnections(ctx context.Context, in *ListConnectionsRequest, opts ...grpc.CallOption) (*ListConnectionsResponse, error)
	RemoveConnection(ctx context.Context, in *RemoveConnectionRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	// Hooks
	CreateHook(ctx context.Context, in *CreateHookRequest, opts ...grpc.CallOption) (*HookResponse, error)
	ListHooks(ctx context.Context, in *ListHooksRequest, opts ...grpc.CallOption) (*ListHooksResponse, error)
	GetHook(ctx context.Context, in *GetHookRequest, opts ...grpc.CallOption) (*HookResponse, error)
	UpdateHook(ctx context.Context, in *UpdateHookRequest, opts ...grpc.CallOption) (*HookResponse, error)
	DeleteHook(ctx context.Context, in *DeleteHookRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	ListHookRuns(ctx context.Context, in *ListHookRunsRequest, opts ...grpc.CallOption) (*ListHookRunsResponse, error)
}

GatewayServiceClient is the client API for GatewayService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type GatewayServiceServer

type GatewayServiceServer interface {
	// Workspaces
	CreateWorkspace(context.Context, *CreateWorkspaceRequest) (*WorkspaceResponse, error)
	ListWorkspaces(context.Context, *ListWorkspacesRequest) (*ListWorkspacesResponse, error)
	GetWorkspace(context.Context, *GetWorkspaceRequest) (*WorkspaceResponse, error)
	DeleteWorkspace(context.Context, *DeleteWorkspaceRequest) (*DeleteResponse, error)
	// Members
	AddMember(context.Context, *AddMemberRequest) (*MemberResponse, error)
	ListMembers(context.Context, *ListMembersRequest) (*ListMembersResponse, error)
	RemoveMember(context.Context, *RemoveMemberRequest) (*DeleteResponse, error)
	// Tokens (workspace-scoped)
	CreateToken(context.Context, *CreateTokenRequest) (*CreateTokenResponse, error)
	ListTokens(context.Context, *ListTokensRequest) (*ListTokensResponse, error)
	RevokeToken(context.Context, *RevokeTokenRequest) (*DeleteResponse, error)
	// Worker Tokens (cluster-level)
	CreateWorkerToken(context.Context, *CreateWorkerTokenRequest) (*CreateTokenResponse, error)
	ListWorkerTokens(context.Context, *ListWorkerTokensRequest) (*ListTokensResponse, error)
	// Connections
	AddConnection(context.Context, *AddConnectionRequest) (*ConnectionResponse, error)
	ListConnections(context.Context, *ListConnectionsRequest) (*ListConnectionsResponse, error)
	RemoveConnection(context.Context, *RemoveConnectionRequest) (*DeleteResponse, error)
	// Hooks
	CreateHook(context.Context, *CreateHookRequest) (*HookResponse, error)
	ListHooks(context.Context, *ListHooksRequest) (*ListHooksResponse, error)
	GetHook(context.Context, *GetHookRequest) (*HookResponse, error)
	UpdateHook(context.Context, *UpdateHookRequest) (*HookResponse, error)
	DeleteHook(context.Context, *DeleteHookRequest) (*DeleteResponse, error)
	ListHookRuns(context.Context, *ListHookRunsRequest) (*ListHookRunsResponse, error)
	// contains filtered or unexported methods
}

GatewayServiceServer is the server API for GatewayService service. All implementations must embed UnimplementedGatewayServiceServer for forward compatibility

type GetAgentProfileRequest added in v0.1.60

type GetAgentProfileRequest struct {
	WorkspaceId string `protobuf:"bytes,1,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	AgentId     string `protobuf:"bytes,2,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAgentProfileRequest) Descriptor deprecated added in v0.1.60

func (*GetAgentProfileRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetAgentProfileRequest.ProtoReflect.Descriptor instead.

func (*GetAgentProfileRequest) GetAgentId added in v0.1.60

func (x *GetAgentProfileRequest) GetAgentId() string

func (*GetAgentProfileRequest) GetWorkspaceId added in v0.1.60

func (x *GetAgentProfileRequest) GetWorkspaceId() string

func (*GetAgentProfileRequest) ProtoMessage added in v0.1.60

func (*GetAgentProfileRequest) ProtoMessage()

func (*GetAgentProfileRequest) ProtoReflect added in v0.1.60

func (x *GetAgentProfileRequest) ProtoReflect() protoreflect.Message

func (*GetAgentProfileRequest) Reset added in v0.1.60

func (x *GetAgentProfileRequest) Reset()

func (*GetAgentProfileRequest) String added in v0.1.60

func (x *GetAgentProfileRequest) String() string

type GetAgentRunRequest added in v0.1.60

type GetAgentRunRequest struct {
	WorkspaceId string `protobuf:"bytes,1,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	RunId       string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetAgentRunRequest) Descriptor deprecated added in v0.1.60

func (*GetAgentRunRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetAgentRunRequest.ProtoReflect.Descriptor instead.

func (*GetAgentRunRequest) GetRunId added in v0.1.60

func (x *GetAgentRunRequest) GetRunId() string

func (*GetAgentRunRequest) GetWorkspaceId added in v0.1.60

func (x *GetAgentRunRequest) GetWorkspaceId() string

func (*GetAgentRunRequest) ProtoMessage added in v0.1.60

func (*GetAgentRunRequest) ProtoMessage()

func (*GetAgentRunRequest) ProtoReflect added in v0.1.60

func (x *GetAgentRunRequest) ProtoReflect() protoreflect.Message

func (*GetAgentRunRequest) Reset added in v0.1.60

func (x *GetAgentRunRequest) Reset()

func (*GetAgentRunRequest) String added in v0.1.60

func (x *GetAgentRunRequest) String() string

type GetHookRequest added in v0.1.28

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

func (*GetHookRequest) Descriptor deprecated added in v0.1.28

func (*GetHookRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetHookRequest.ProtoReflect.Descriptor instead.

func (*GetHookRequest) GetId added in v0.1.28

func (x *GetHookRequest) GetId() string

func (*GetHookRequest) ProtoMessage added in v0.1.28

func (*GetHookRequest) ProtoMessage()

func (*GetHookRequest) ProtoReflect added in v0.1.28

func (x *GetHookRequest) ProtoReflect() protoreflect.Message

func (*GetHookRequest) Reset added in v0.1.28

func (x *GetHookRequest) Reset()

func (*GetHookRequest) String added in v0.1.28

func (x *GetHookRequest) String() string

type GetTaskLogsRequest

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

func (*GetTaskLogsRequest) Descriptor deprecated

func (*GetTaskLogsRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetTaskLogsRequest.ProtoReflect.Descriptor instead.

func (*GetTaskLogsRequest) GetId

func (x *GetTaskLogsRequest) GetId() string

func (*GetTaskLogsRequest) ProtoMessage

func (*GetTaskLogsRequest) ProtoMessage()

func (*GetTaskLogsRequest) ProtoReflect

func (x *GetTaskLogsRequest) ProtoReflect() protoreflect.Message

func (*GetTaskLogsRequest) Reset

func (x *GetTaskLogsRequest) Reset()

func (*GetTaskLogsRequest) String

func (x *GetTaskLogsRequest) String() string

type GetTaskLogsResponse

type GetTaskLogsResponse struct {
	Ok    bool            `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string          `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Logs  []*TaskLogEntry `protobuf:"bytes,3,rep,name=logs,proto3" json:"logs,omitempty"`
	// contains filtered or unexported fields
}

func (*GetTaskLogsResponse) Descriptor deprecated

func (*GetTaskLogsResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetTaskLogsResponse.ProtoReflect.Descriptor instead.

func (*GetTaskLogsResponse) GetError

func (x *GetTaskLogsResponse) GetError() string

func (*GetTaskLogsResponse) GetLogs

func (x *GetTaskLogsResponse) GetLogs() []*TaskLogEntry

func (*GetTaskLogsResponse) GetOk

func (x *GetTaskLogsResponse) GetOk() bool

func (*GetTaskLogsResponse) ProtoMessage

func (*GetTaskLogsResponse) ProtoMessage()

func (*GetTaskLogsResponse) ProtoReflect

func (x *GetTaskLogsResponse) ProtoReflect() protoreflect.Message

func (*GetTaskLogsResponse) Reset

func (x *GetTaskLogsResponse) Reset()

func (*GetTaskLogsResponse) String

func (x *GetTaskLogsResponse) String() string

type GetTaskRequest

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

func (*GetTaskRequest) Descriptor deprecated

func (*GetTaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetTaskRequest.ProtoReflect.Descriptor instead.

func (*GetTaskRequest) GetId

func (x *GetTaskRequest) GetId() string

func (*GetTaskRequest) ProtoMessage

func (*GetTaskRequest) ProtoMessage()

func (*GetTaskRequest) ProtoReflect

func (x *GetTaskRequest) ProtoReflect() protoreflect.Message

func (*GetTaskRequest) Reset

func (x *GetTaskRequest) Reset()

func (*GetTaskRequest) String

func (x *GetTaskRequest) String() string

type GetToolHelpRequest

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

func (*GetToolHelpRequest) Descriptor deprecated

func (*GetToolHelpRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetToolHelpRequest.ProtoReflect.Descriptor instead.

func (*GetToolHelpRequest) GetName

func (x *GetToolHelpRequest) GetName() string

func (*GetToolHelpRequest) ProtoMessage

func (*GetToolHelpRequest) ProtoMessage()

func (*GetToolHelpRequest) ProtoReflect

func (x *GetToolHelpRequest) ProtoReflect() protoreflect.Message

func (*GetToolHelpRequest) Reset

func (x *GetToolHelpRequest) Reset()

func (*GetToolHelpRequest) String

func (x *GetToolHelpRequest) String() string

type GetToolHelpResponse

type GetToolHelpResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Help  string `protobuf:"bytes,3,opt,name=help,proto3" json:"help,omitempty"`
	// contains filtered or unexported fields
}

func (*GetToolHelpResponse) Descriptor deprecated

func (*GetToolHelpResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetToolHelpResponse.ProtoReflect.Descriptor instead.

func (*GetToolHelpResponse) GetError

func (x *GetToolHelpResponse) GetError() string

func (*GetToolHelpResponse) GetHelp

func (x *GetToolHelpResponse) GetHelp() string

func (*GetToolHelpResponse) GetOk

func (x *GetToolHelpResponse) GetOk() bool

func (*GetToolHelpResponse) ProtoMessage

func (*GetToolHelpResponse) ProtoMessage()

func (*GetToolHelpResponse) ProtoReflect

func (x *GetToolHelpResponse) ProtoReflect() protoreflect.Message

func (*GetToolHelpResponse) Reset

func (x *GetToolHelpResponse) Reset()

func (*GetToolHelpResponse) String

func (x *GetToolHelpResponse) String() string

type GetViewRequest added in v0.1.50

type GetViewRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // Full path: "/sources/gmail/unread-emails"
	// contains filtered or unexported fields
}

GetView - retrieves a view by path

func (*GetViewRequest) Descriptor deprecated added in v0.1.50

func (*GetViewRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetViewRequest.ProtoReflect.Descriptor instead.

func (*GetViewRequest) GetPath added in v0.1.50

func (x *GetViewRequest) GetPath() string

func (*GetViewRequest) ProtoMessage added in v0.1.50

func (*GetViewRequest) ProtoMessage()

func (*GetViewRequest) ProtoReflect added in v0.1.50

func (x *GetViewRequest) ProtoReflect() protoreflect.Message

func (*GetViewRequest) Reset added in v0.1.50

func (x *GetViewRequest) Reset()

func (*GetViewRequest) String added in v0.1.50

func (x *GetViewRequest) String() string

type GetViewResponse added in v0.1.50

type GetViewResponse struct {
	Ok    bool        `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string      `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	View  *SourceView `protobuf:"bytes,3,opt,name=view,proto3" json:"view,omitempty"` // nil if not found
	// contains filtered or unexported fields
}

func (*GetViewResponse) Descriptor deprecated added in v0.1.50

func (*GetViewResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetViewResponse.ProtoReflect.Descriptor instead.

func (*GetViewResponse) GetError added in v0.1.50

func (x *GetViewResponse) GetError() string

func (*GetViewResponse) GetOk added in v0.1.50

func (x *GetViewResponse) GetOk() bool

func (*GetViewResponse) GetView added in v0.1.50

func (x *GetViewResponse) GetView() *SourceView

func (*GetViewResponse) ProtoMessage added in v0.1.50

func (*GetViewResponse) ProtoMessage()

func (*GetViewResponse) ProtoReflect added in v0.1.50

func (x *GetViewResponse) ProtoReflect() protoreflect.Message

func (*GetViewResponse) Reset added in v0.1.50

func (x *GetViewResponse) Reset()

func (*GetViewResponse) String added in v0.1.50

func (x *GetViewResponse) String() string

type GetWorkerRequest

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

Get worker info

func (*GetWorkerRequest) Descriptor deprecated

func (*GetWorkerRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetWorkerRequest.ProtoReflect.Descriptor instead.

func (*GetWorkerRequest) GetWorkerId

func (x *GetWorkerRequest) GetWorkerId() string

func (*GetWorkerRequest) ProtoMessage

func (*GetWorkerRequest) ProtoMessage()

func (*GetWorkerRequest) ProtoReflect

func (x *GetWorkerRequest) ProtoReflect() protoreflect.Message

func (*GetWorkerRequest) Reset

func (x *GetWorkerRequest) Reset()

func (*GetWorkerRequest) String

func (x *GetWorkerRequest) String() string

type GetWorkerResponse

type GetWorkerResponse struct {
	Id           string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Status       string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	PoolName     string `protobuf:"bytes,3,opt,name=pool_name,json=poolName,proto3" json:"pool_name,omitempty"`
	Hostname     string `protobuf:"bytes,4,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Cpu          int64  `protobuf:"varint,5,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Memory       int64  `protobuf:"varint,6,opt,name=memory,proto3" json:"memory,omitempty"`
	LastSeenAt   int64  `protobuf:"varint,7,opt,name=last_seen_at,json=lastSeenAt,proto3" json:"last_seen_at,omitempty"`
	RegisteredAt int64  `protobuf:"varint,8,opt,name=registered_at,json=registeredAt,proto3" json:"registered_at,omitempty"`
	Version      string `protobuf:"bytes,9,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*GetWorkerResponse) Descriptor deprecated

func (*GetWorkerResponse) Descriptor() ([]byte, []int)

Deprecated: Use GetWorkerResponse.ProtoReflect.Descriptor instead.

func (*GetWorkerResponse) GetCpu

func (x *GetWorkerResponse) GetCpu() int64

func (*GetWorkerResponse) GetHostname

func (x *GetWorkerResponse) GetHostname() string

func (*GetWorkerResponse) GetId

func (x *GetWorkerResponse) GetId() string

func (*GetWorkerResponse) GetLastSeenAt

func (x *GetWorkerResponse) GetLastSeenAt() int64

func (*GetWorkerResponse) GetMemory

func (x *GetWorkerResponse) GetMemory() int64

func (*GetWorkerResponse) GetPoolName

func (x *GetWorkerResponse) GetPoolName() string

func (*GetWorkerResponse) GetRegisteredAt

func (x *GetWorkerResponse) GetRegisteredAt() int64

func (*GetWorkerResponse) GetStatus

func (x *GetWorkerResponse) GetStatus() string

func (*GetWorkerResponse) GetVersion

func (x *GetWorkerResponse) GetVersion() string

func (*GetWorkerResponse) ProtoMessage

func (*GetWorkerResponse) ProtoMessage()

func (*GetWorkerResponse) ProtoReflect

func (x *GetWorkerResponse) ProtoReflect() protoreflect.Message

func (*GetWorkerResponse) Reset

func (x *GetWorkerResponse) Reset()

func (*GetWorkerResponse) String

func (x *GetWorkerResponse) String() string

type GetWorkspaceRequest

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

func (*GetWorkspaceRequest) Descriptor deprecated

func (*GetWorkspaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use GetWorkspaceRequest.ProtoReflect.Descriptor instead.

func (*GetWorkspaceRequest) GetId

func (x *GetWorkspaceRequest) GetId() string

func (*GetWorkspaceRequest) ProtoMessage

func (*GetWorkspaceRequest) ProtoMessage()

func (*GetWorkspaceRequest) ProtoReflect

func (x *GetWorkspaceRequest) ProtoReflect() protoreflect.Message

func (*GetWorkspaceRequest) Reset

func (x *GetWorkspaceRequest) Reset()

func (*GetWorkspaceRequest) String

func (x *GetWorkspaceRequest) String() string

type HeartbeatRequest

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

Heartbeat

func (*HeartbeatRequest) Descriptor deprecated

func (*HeartbeatRequest) Descriptor() ([]byte, []int)

Deprecated: Use HeartbeatRequest.ProtoReflect.Descriptor instead.

func (*HeartbeatRequest) GetWorkerId

func (x *HeartbeatRequest) GetWorkerId() string

func (*HeartbeatRequest) ProtoMessage

func (*HeartbeatRequest) ProtoMessage()

func (*HeartbeatRequest) ProtoReflect

func (x *HeartbeatRequest) ProtoReflect() protoreflect.Message

func (*HeartbeatRequest) Reset

func (x *HeartbeatRequest) Reset()

func (*HeartbeatRequest) String

func (x *HeartbeatRequest) String() string

type HeartbeatResponse

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

func (*HeartbeatResponse) Descriptor deprecated

func (*HeartbeatResponse) Descriptor() ([]byte, []int)

Deprecated: Use HeartbeatResponse.ProtoReflect.Descriptor instead.

func (*HeartbeatResponse) ProtoMessage

func (*HeartbeatResponse) ProtoMessage()

func (*HeartbeatResponse) ProtoReflect

func (x *HeartbeatResponse) ProtoReflect() protoreflect.Message

func (*HeartbeatResponse) Reset

func (x *HeartbeatResponse) Reset()

func (*HeartbeatResponse) String

func (x *HeartbeatResponse) String() string

type Hook added in v0.1.28

type Hook struct {
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	WorkspaceId string `protobuf:"bytes,2,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	Path        string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	Prompt      string `protobuf:"bytes,4,opt,name=prompt,proto3" json:"prompt,omitempty"`
	Active      bool   `protobuf:"varint,5,opt,name=active,proto3" json:"active,omitempty"`
	CreatedAt   string `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt   string `protobuf:"bytes,7,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	SkillPath   string `protobuf:"bytes,8,opt,name=skill_path,json=skillPath,proto3" json:"skill_path,omitempty"`
	// contains filtered or unexported fields
}

Hook messages

func (*Hook) Descriptor deprecated added in v0.1.28

func (*Hook) Descriptor() ([]byte, []int)

Deprecated: Use Hook.ProtoReflect.Descriptor instead.

func (*Hook) GetActive added in v0.1.28

func (x *Hook) GetActive() bool

func (*Hook) GetCreatedAt added in v0.1.28

func (x *Hook) GetCreatedAt() string

func (*Hook) GetId added in v0.1.28

func (x *Hook) GetId() string

func (*Hook) GetPath added in v0.1.28

func (x *Hook) GetPath() string

func (*Hook) GetPrompt added in v0.1.28

func (x *Hook) GetPrompt() string

func (*Hook) GetSkillPath added in v0.1.32

func (x *Hook) GetSkillPath() string

func (*Hook) GetUpdatedAt added in v0.1.28

func (x *Hook) GetUpdatedAt() string

func (*Hook) GetWorkspaceId added in v0.1.28

func (x *Hook) GetWorkspaceId() string

func (*Hook) ProtoMessage added in v0.1.28

func (*Hook) ProtoMessage()

func (*Hook) ProtoReflect added in v0.1.28

func (x *Hook) ProtoReflect() protoreflect.Message

func (*Hook) Reset added in v0.1.28

func (x *Hook) Reset()

func (*Hook) String added in v0.1.28

func (x *Hook) String() string

type HookResponse added in v0.1.28

type HookResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Hook  *Hook  `protobuf:"bytes,3,opt,name=hook,proto3" json:"hook,omitempty"`
	// contains filtered or unexported fields
}

func (*HookResponse) Descriptor deprecated added in v0.1.28

func (*HookResponse) Descriptor() ([]byte, []int)

Deprecated: Use HookResponse.ProtoReflect.Descriptor instead.

func (*HookResponse) GetError added in v0.1.28

func (x *HookResponse) GetError() string

func (*HookResponse) GetHook added in v0.1.28

func (x *HookResponse) GetHook() *Hook

func (*HookResponse) GetOk added in v0.1.28

func (x *HookResponse) GetOk() bool

func (*HookResponse) ProtoMessage added in v0.1.28

func (*HookResponse) ProtoMessage()

func (*HookResponse) ProtoReflect added in v0.1.28

func (x *HookResponse) ProtoReflect() protoreflect.Message

func (*HookResponse) Reset added in v0.1.28

func (x *HookResponse) Reset()

func (*HookResponse) String added in v0.1.28

func (x *HookResponse) String() string

type HookRun added in v0.1.28

type HookRun struct {
	TaskId      string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Status      string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	Attempt     int32  `protobuf:"varint,3,opt,name=attempt,proto3" json:"attempt,omitempty"`
	MaxAttempts int32  `protobuf:"varint,4,opt,name=max_attempts,json=maxAttempts,proto3" json:"max_attempts,omitempty"`
	Error       string `protobuf:"bytes,5,opt,name=error,proto3" json:"error,omitempty"`
	CreatedAt   string `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	FinishedAt  string `protobuf:"bytes,7,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	// contains filtered or unexported fields
}

func (*HookRun) Descriptor deprecated added in v0.1.28

func (*HookRun) Descriptor() ([]byte, []int)

Deprecated: Use HookRun.ProtoReflect.Descriptor instead.

func (*HookRun) GetAttempt added in v0.1.28

func (x *HookRun) GetAttempt() int32

func (*HookRun) GetCreatedAt added in v0.1.28

func (x *HookRun) GetCreatedAt() string

func (*HookRun) GetError added in v0.1.28

func (x *HookRun) GetError() string

func (*HookRun) GetFinishedAt added in v0.1.28

func (x *HookRun) GetFinishedAt() string

func (*HookRun) GetMaxAttempts added in v0.1.28

func (x *HookRun) GetMaxAttempts() int32

func (*HookRun) GetStatus added in v0.1.28

func (x *HookRun) GetStatus() string

func (*HookRun) GetTaskId added in v0.1.28

func (x *HookRun) GetTaskId() string

func (*HookRun) ProtoMessage added in v0.1.28

func (*HookRun) ProtoMessage()

func (*HookRun) ProtoReflect added in v0.1.28

func (x *HookRun) ProtoReflect() protoreflect.Message

func (*HookRun) Reset added in v0.1.28

func (x *HookRun) Reset()

func (*HookRun) String added in v0.1.28

func (x *HookRun) String() string

type IngestAccessEventsRequest added in v0.1.47

type IngestAccessEventsRequest struct {
	Events []*AccessLogEvent `protobuf:"bytes,1,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

func (*IngestAccessEventsRequest) Descriptor deprecated added in v0.1.47

func (*IngestAccessEventsRequest) Descriptor() ([]byte, []int)

Deprecated: Use IngestAccessEventsRequest.ProtoReflect.Descriptor instead.

func (*IngestAccessEventsRequest) GetEvents added in v0.1.47

func (x *IngestAccessEventsRequest) GetEvents() []*AccessLogEvent

func (*IngestAccessEventsRequest) ProtoMessage added in v0.1.47

func (*IngestAccessEventsRequest) ProtoMessage()

func (*IngestAccessEventsRequest) ProtoReflect added in v0.1.47

func (*IngestAccessEventsRequest) Reset added in v0.1.47

func (x *IngestAccessEventsRequest) Reset()

func (*IngestAccessEventsRequest) String added in v0.1.47

func (x *IngestAccessEventsRequest) String() string

type IngestAccessEventsResponse added in v0.1.47

type IngestAccessEventsResponse struct {
	Ok       bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error    string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Accepted int32  `protobuf:"varint,3,opt,name=accepted,proto3" json:"accepted,omitempty"`
	// contains filtered or unexported fields
}

func (*IngestAccessEventsResponse) Descriptor deprecated added in v0.1.47

func (*IngestAccessEventsResponse) Descriptor() ([]byte, []int)

Deprecated: Use IngestAccessEventsResponse.ProtoReflect.Descriptor instead.

func (*IngestAccessEventsResponse) GetAccepted added in v0.1.47

func (x *IngestAccessEventsResponse) GetAccepted() int32

func (*IngestAccessEventsResponse) GetError added in v0.1.47

func (x *IngestAccessEventsResponse) GetError() string

func (*IngestAccessEventsResponse) GetOk added in v0.1.47

func (x *IngestAccessEventsResponse) GetOk() bool

func (*IngestAccessEventsResponse) ProtoMessage added in v0.1.47

func (*IngestAccessEventsResponse) ProtoMessage()

func (*IngestAccessEventsResponse) ProtoReflect added in v0.1.47

func (*IngestAccessEventsResponse) Reset added in v0.1.47

func (x *IngestAccessEventsResponse) Reset()

func (*IngestAccessEventsResponse) String added in v0.1.47

func (x *IngestAccessEventsResponse) String() string

type ListAgentProfilesRequest added in v0.1.60

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

func (*ListAgentProfilesRequest) Descriptor deprecated added in v0.1.60

func (*ListAgentProfilesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListAgentProfilesRequest.ProtoReflect.Descriptor instead.

func (*ListAgentProfilesRequest) GetWorkspaceId added in v0.1.60

func (x *ListAgentProfilesRequest) GetWorkspaceId() string

func (*ListAgentProfilesRequest) ProtoMessage added in v0.1.60

func (*ListAgentProfilesRequest) ProtoMessage()

func (*ListAgentProfilesRequest) ProtoReflect added in v0.1.60

func (x *ListAgentProfilesRequest) ProtoReflect() protoreflect.Message

func (*ListAgentProfilesRequest) Reset added in v0.1.60

func (x *ListAgentProfilesRequest) Reset()

func (*ListAgentProfilesRequest) String added in v0.1.60

func (x *ListAgentProfilesRequest) String() string

type ListAgentProfilesResponse added in v0.1.60

type ListAgentProfilesResponse struct {
	Ok     bool            `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error  string          `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Agents []*AgentProfile `protobuf:"bytes,3,rep,name=agents,proto3" json:"agents,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAgentProfilesResponse) Descriptor deprecated added in v0.1.60

func (*ListAgentProfilesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListAgentProfilesResponse.ProtoReflect.Descriptor instead.

func (*ListAgentProfilesResponse) GetAgents added in v0.1.60

func (x *ListAgentProfilesResponse) GetAgents() []*AgentProfile

func (*ListAgentProfilesResponse) GetError added in v0.1.60

func (x *ListAgentProfilesResponse) GetError() string

func (*ListAgentProfilesResponse) GetOk added in v0.1.60

func (x *ListAgentProfilesResponse) GetOk() bool

func (*ListAgentProfilesResponse) ProtoMessage added in v0.1.60

func (*ListAgentProfilesResponse) ProtoMessage()

func (*ListAgentProfilesResponse) ProtoReflect added in v0.1.60

func (*ListAgentProfilesResponse) Reset added in v0.1.60

func (x *ListAgentProfilesResponse) Reset()

func (*ListAgentProfilesResponse) String added in v0.1.60

func (x *ListAgentProfilesResponse) String() string

type ListAgentRunEventsRequest added in v0.1.60

type ListAgentRunEventsRequest struct {
	WorkspaceId string `protobuf:"bytes,1,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	RunId       string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAgentRunEventsRequest) Descriptor deprecated added in v0.1.60

func (*ListAgentRunEventsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListAgentRunEventsRequest.ProtoReflect.Descriptor instead.

func (*ListAgentRunEventsRequest) GetRunId added in v0.1.60

func (x *ListAgentRunEventsRequest) GetRunId() string

func (*ListAgentRunEventsRequest) GetWorkspaceId added in v0.1.60

func (x *ListAgentRunEventsRequest) GetWorkspaceId() string

func (*ListAgentRunEventsRequest) ProtoMessage added in v0.1.60

func (*ListAgentRunEventsRequest) ProtoMessage()

func (*ListAgentRunEventsRequest) ProtoReflect added in v0.1.60

func (*ListAgentRunEventsRequest) Reset added in v0.1.60

func (x *ListAgentRunEventsRequest) Reset()

func (*ListAgentRunEventsRequest) String added in v0.1.60

func (x *ListAgentRunEventsRequest) String() string

type ListAgentRunEventsResponse added in v0.1.60

type ListAgentRunEventsResponse struct {
	Ok         bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error      string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	EventsJson []string `protobuf:"bytes,3,rep,name=events_json,json=eventsJson,proto3" json:"events_json,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAgentRunEventsResponse) Descriptor deprecated added in v0.1.60

func (*ListAgentRunEventsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListAgentRunEventsResponse.ProtoReflect.Descriptor instead.

func (*ListAgentRunEventsResponse) GetError added in v0.1.60

func (x *ListAgentRunEventsResponse) GetError() string

func (*ListAgentRunEventsResponse) GetEventsJson added in v0.1.60

func (x *ListAgentRunEventsResponse) GetEventsJson() []string

func (*ListAgentRunEventsResponse) GetOk added in v0.1.60

func (x *ListAgentRunEventsResponse) GetOk() bool

func (*ListAgentRunEventsResponse) ProtoMessage added in v0.1.60

func (*ListAgentRunEventsResponse) ProtoMessage()

func (*ListAgentRunEventsResponse) ProtoReflect added in v0.1.60

func (*ListAgentRunEventsResponse) Reset added in v0.1.60

func (x *ListAgentRunEventsResponse) Reset()

func (*ListAgentRunEventsResponse) String added in v0.1.60

func (x *ListAgentRunEventsResponse) String() string

type ListAgentRunSnapshotsRequest added in v0.1.60

type ListAgentRunSnapshotsRequest struct {
	WorkspaceId string `protobuf:"bytes,1,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	RunId       string `protobuf:"bytes,2,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	Limit       int32  `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAgentRunSnapshotsRequest) Descriptor deprecated added in v0.1.60

func (*ListAgentRunSnapshotsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListAgentRunSnapshotsRequest.ProtoReflect.Descriptor instead.

func (*ListAgentRunSnapshotsRequest) GetLimit added in v0.1.60

func (x *ListAgentRunSnapshotsRequest) GetLimit() int32

func (*ListAgentRunSnapshotsRequest) GetRunId added in v0.1.60

func (x *ListAgentRunSnapshotsRequest) GetRunId() string

func (*ListAgentRunSnapshotsRequest) GetWorkspaceId added in v0.1.60

func (x *ListAgentRunSnapshotsRequest) GetWorkspaceId() string

func (*ListAgentRunSnapshotsRequest) ProtoMessage added in v0.1.60

func (*ListAgentRunSnapshotsRequest) ProtoMessage()

func (*ListAgentRunSnapshotsRequest) ProtoReflect added in v0.1.60

func (*ListAgentRunSnapshotsRequest) Reset added in v0.1.60

func (x *ListAgentRunSnapshotsRequest) Reset()

func (*ListAgentRunSnapshotsRequest) String added in v0.1.60

type ListAgentRunSnapshotsResponse added in v0.1.60

type ListAgentRunSnapshotsResponse struct {
	Ok        bool                `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error     string              `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Snapshots []*AgentRunSnapshot `protobuf:"bytes,3,rep,name=snapshots,proto3" json:"snapshots,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAgentRunSnapshotsResponse) Descriptor deprecated added in v0.1.60

func (*ListAgentRunSnapshotsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListAgentRunSnapshotsResponse.ProtoReflect.Descriptor instead.

func (*ListAgentRunSnapshotsResponse) GetError added in v0.1.60

func (x *ListAgentRunSnapshotsResponse) GetError() string

func (*ListAgentRunSnapshotsResponse) GetOk added in v0.1.60

func (*ListAgentRunSnapshotsResponse) GetSnapshots added in v0.1.60

func (x *ListAgentRunSnapshotsResponse) GetSnapshots() []*AgentRunSnapshot

func (*ListAgentRunSnapshotsResponse) ProtoMessage added in v0.1.60

func (*ListAgentRunSnapshotsResponse) ProtoMessage()

func (*ListAgentRunSnapshotsResponse) ProtoReflect added in v0.1.60

func (*ListAgentRunSnapshotsResponse) Reset added in v0.1.60

func (x *ListAgentRunSnapshotsResponse) Reset()

func (*ListAgentRunSnapshotsResponse) String added in v0.1.60

type ListAgentRunsRequest added in v0.1.60

type ListAgentRunsRequest struct {
	WorkspaceId string `protobuf:"bytes,1,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	Limit       int32  `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAgentRunsRequest) Descriptor deprecated added in v0.1.60

func (*ListAgentRunsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListAgentRunsRequest.ProtoReflect.Descriptor instead.

func (*ListAgentRunsRequest) GetLimit added in v0.1.60

func (x *ListAgentRunsRequest) GetLimit() int32

func (*ListAgentRunsRequest) GetWorkspaceId added in v0.1.60

func (x *ListAgentRunsRequest) GetWorkspaceId() string

func (*ListAgentRunsRequest) ProtoMessage added in v0.1.60

func (*ListAgentRunsRequest) ProtoMessage()

func (*ListAgentRunsRequest) ProtoReflect added in v0.1.60

func (x *ListAgentRunsRequest) ProtoReflect() protoreflect.Message

func (*ListAgentRunsRequest) Reset added in v0.1.60

func (x *ListAgentRunsRequest) Reset()

func (*ListAgentRunsRequest) String added in v0.1.60

func (x *ListAgentRunsRequest) String() string

type ListAgentRunsResponse added in v0.1.60

type ListAgentRunsResponse struct {
	Ok    bool        `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string      `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Runs  []*AgentRun `protobuf:"bytes,3,rep,name=runs,proto3" json:"runs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListAgentRunsResponse) Descriptor deprecated added in v0.1.60

func (*ListAgentRunsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListAgentRunsResponse.ProtoReflect.Descriptor instead.

func (*ListAgentRunsResponse) GetError added in v0.1.60

func (x *ListAgentRunsResponse) GetError() string

func (*ListAgentRunsResponse) GetOk added in v0.1.60

func (x *ListAgentRunsResponse) GetOk() bool

func (*ListAgentRunsResponse) GetRuns added in v0.1.60

func (x *ListAgentRunsResponse) GetRuns() []*AgentRun

func (*ListAgentRunsResponse) ProtoMessage added in v0.1.60

func (*ListAgentRunsResponse) ProtoMessage()

func (*ListAgentRunsResponse) ProtoReflect added in v0.1.60

func (x *ListAgentRunsResponse) ProtoReflect() protoreflect.Message

func (*ListAgentRunsResponse) Reset added in v0.1.60

func (x *ListAgentRunsResponse) Reset()

func (*ListAgentRunsResponse) String added in v0.1.60

func (x *ListAgentRunsResponse) String() string

type ListConnectionsRequest

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

func (*ListConnectionsRequest) Descriptor deprecated

func (*ListConnectionsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListConnectionsRequest.ProtoReflect.Descriptor instead.

func (*ListConnectionsRequest) GetWorkspaceId

func (x *ListConnectionsRequest) GetWorkspaceId() string

func (*ListConnectionsRequest) ProtoMessage

func (*ListConnectionsRequest) ProtoMessage()

func (*ListConnectionsRequest) ProtoReflect

func (x *ListConnectionsRequest) ProtoReflect() protoreflect.Message

func (*ListConnectionsRequest) Reset

func (x *ListConnectionsRequest) Reset()

func (*ListConnectionsRequest) String

func (x *ListConnectionsRequest) String() string

type ListConnectionsResponse

type ListConnectionsResponse struct {
	Ok          bool          `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error       string        `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Connections []*Connection `protobuf:"bytes,3,rep,name=connections,proto3" json:"connections,omitempty"`
	// contains filtered or unexported fields
}

func (*ListConnectionsResponse) Descriptor deprecated

func (*ListConnectionsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListConnectionsResponse.ProtoReflect.Descriptor instead.

func (*ListConnectionsResponse) GetConnections

func (x *ListConnectionsResponse) GetConnections() []*Connection

func (*ListConnectionsResponse) GetError

func (x *ListConnectionsResponse) GetError() string

func (*ListConnectionsResponse) GetOk

func (x *ListConnectionsResponse) GetOk() bool

func (*ListConnectionsResponse) ProtoMessage

func (*ListConnectionsResponse) ProtoMessage()

func (*ListConnectionsResponse) ProtoReflect

func (x *ListConnectionsResponse) ProtoReflect() protoreflect.Message

func (*ListConnectionsResponse) Reset

func (x *ListConnectionsResponse) Reset()

func (*ListConnectionsResponse) String

func (x *ListConnectionsResponse) String() string

type ListHookRunsRequest added in v0.1.28

type ListHookRunsRequest struct {
	HookId string `protobuf:"bytes,1,opt,name=hook_id,json=hookId,proto3" json:"hook_id,omitempty"` // hook external ID
	// contains filtered or unexported fields
}

func (*ListHookRunsRequest) Descriptor deprecated added in v0.1.28

func (*ListHookRunsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListHookRunsRequest.ProtoReflect.Descriptor instead.

func (*ListHookRunsRequest) GetHookId added in v0.1.28

func (x *ListHookRunsRequest) GetHookId() string

func (*ListHookRunsRequest) ProtoMessage added in v0.1.28

func (*ListHookRunsRequest) ProtoMessage()

func (*ListHookRunsRequest) ProtoReflect added in v0.1.28

func (x *ListHookRunsRequest) ProtoReflect() protoreflect.Message

func (*ListHookRunsRequest) Reset added in v0.1.28

func (x *ListHookRunsRequest) Reset()

func (*ListHookRunsRequest) String added in v0.1.28

func (x *ListHookRunsRequest) String() string

type ListHookRunsResponse added in v0.1.28

type ListHookRunsResponse struct {
	Ok    bool       `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Runs  []*HookRun `protobuf:"bytes,3,rep,name=runs,proto3" json:"runs,omitempty"`
	// contains filtered or unexported fields
}

func (*ListHookRunsResponse) Descriptor deprecated added in v0.1.28

func (*ListHookRunsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListHookRunsResponse.ProtoReflect.Descriptor instead.

func (*ListHookRunsResponse) GetError added in v0.1.28

func (x *ListHookRunsResponse) GetError() string

func (*ListHookRunsResponse) GetOk added in v0.1.28

func (x *ListHookRunsResponse) GetOk() bool

func (*ListHookRunsResponse) GetRuns added in v0.1.28

func (x *ListHookRunsResponse) GetRuns() []*HookRun

func (*ListHookRunsResponse) ProtoMessage added in v0.1.28

func (*ListHookRunsResponse) ProtoMessage()

func (*ListHookRunsResponse) ProtoReflect added in v0.1.28

func (x *ListHookRunsResponse) ProtoReflect() protoreflect.Message

func (*ListHookRunsResponse) Reset added in v0.1.28

func (x *ListHookRunsResponse) Reset()

func (*ListHookRunsResponse) String added in v0.1.28

func (x *ListHookRunsResponse) String() string

type ListHooksRequest added in v0.1.28

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

func (*ListHooksRequest) Descriptor deprecated added in v0.1.28

func (*ListHooksRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListHooksRequest.ProtoReflect.Descriptor instead.

func (*ListHooksRequest) GetWorkspaceId added in v0.1.28

func (x *ListHooksRequest) GetWorkspaceId() string

func (*ListHooksRequest) ProtoMessage added in v0.1.28

func (*ListHooksRequest) ProtoMessage()

func (*ListHooksRequest) ProtoReflect added in v0.1.28

func (x *ListHooksRequest) ProtoReflect() protoreflect.Message

func (*ListHooksRequest) Reset added in v0.1.28

func (x *ListHooksRequest) Reset()

func (*ListHooksRequest) String added in v0.1.28

func (x *ListHooksRequest) String() string

type ListHooksResponse added in v0.1.28

type ListHooksResponse struct {
	Ok    bool    `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string  `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Hooks []*Hook `protobuf:"bytes,3,rep,name=hooks,proto3" json:"hooks,omitempty"`
	// contains filtered or unexported fields
}

func (*ListHooksResponse) Descriptor deprecated added in v0.1.28

func (*ListHooksResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListHooksResponse.ProtoReflect.Descriptor instead.

func (*ListHooksResponse) GetError added in v0.1.28

func (x *ListHooksResponse) GetError() string

func (*ListHooksResponse) GetHooks added in v0.1.28

func (x *ListHooksResponse) GetHooks() []*Hook

func (*ListHooksResponse) GetOk added in v0.1.28

func (x *ListHooksResponse) GetOk() bool

func (*ListHooksResponse) ProtoMessage added in v0.1.28

func (*ListHooksResponse) ProtoMessage()

func (*ListHooksResponse) ProtoReflect added in v0.1.28

func (x *ListHooksResponse) ProtoReflect() protoreflect.Message

func (*ListHooksResponse) Reset added in v0.1.28

func (x *ListHooksResponse) Reset()

func (*ListHooksResponse) String added in v0.1.28

func (x *ListHooksResponse) String() string

type ListMembersRequest

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

func (*ListMembersRequest) Descriptor deprecated

func (*ListMembersRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListMembersRequest.ProtoReflect.Descriptor instead.

func (*ListMembersRequest) GetWorkspaceId

func (x *ListMembersRequest) GetWorkspaceId() string

func (*ListMembersRequest) ProtoMessage

func (*ListMembersRequest) ProtoMessage()

func (*ListMembersRequest) ProtoReflect

func (x *ListMembersRequest) ProtoReflect() protoreflect.Message

func (*ListMembersRequest) Reset

func (x *ListMembersRequest) Reset()

func (*ListMembersRequest) String

func (x *ListMembersRequest) String() string

type ListMembersResponse

type ListMembersResponse struct {
	Ok      bool      `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error   string    `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Members []*Member `protobuf:"bytes,3,rep,name=members,proto3" json:"members,omitempty"`
	// contains filtered or unexported fields
}

func (*ListMembersResponse) Descriptor deprecated

func (*ListMembersResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListMembersResponse.ProtoReflect.Descriptor instead.

func (*ListMembersResponse) GetError

func (x *ListMembersResponse) GetError() string

func (*ListMembersResponse) GetMembers

func (x *ListMembersResponse) GetMembers() []*Member

func (*ListMembersResponse) GetOk

func (x *ListMembersResponse) GetOk() bool

func (*ListMembersResponse) ProtoMessage

func (*ListMembersResponse) ProtoMessage()

func (*ListMembersResponse) ProtoReflect

func (x *ListMembersResponse) ProtoReflect() protoreflect.Message

func (*ListMembersResponse) Reset

func (x *ListMembersResponse) Reset()

func (*ListMembersResponse) String

func (x *ListMembersResponse) String() string

type ListResourcesRequest added in v0.1.50

type ListResourcesRequest struct {
	Integration  string `protobuf:"bytes,1,opt,name=integration,proto3" json:"integration,omitempty"`                       // e.g., "github", "slack"
	ResourceType string `protobuf:"bytes,2,opt,name=resource_type,json=resourceType,proto3" json:"resource_type,omitempty"` // e.g., "repos", "channels"
	// contains filtered or unexported fields
}

ListResources - returns available resources for an integration

func (*ListResourcesRequest) Descriptor deprecated added in v0.1.50

func (*ListResourcesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListResourcesRequest.ProtoReflect.Descriptor instead.

func (*ListResourcesRequest) GetIntegration added in v0.1.50

func (x *ListResourcesRequest) GetIntegration() string

func (*ListResourcesRequest) GetResourceType added in v0.1.50

func (x *ListResourcesRequest) GetResourceType() string

func (*ListResourcesRequest) ProtoMessage added in v0.1.50

func (*ListResourcesRequest) ProtoMessage()

func (*ListResourcesRequest) ProtoReflect added in v0.1.50

func (x *ListResourcesRequest) ProtoReflect() protoreflect.Message

func (*ListResourcesRequest) Reset added in v0.1.50

func (x *ListResourcesRequest) Reset()

func (*ListResourcesRequest) String added in v0.1.50

func (x *ListResourcesRequest) String() string

type ListResourcesResponse added in v0.1.50

type ListResourcesResponse struct {
	Ok        bool              `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error     string            `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Resources []*SourceResource `protobuf:"bytes,3,rep,name=resources,proto3" json:"resources,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResourcesResponse) Descriptor deprecated added in v0.1.50

func (*ListResourcesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListResourcesResponse.ProtoReflect.Descriptor instead.

func (*ListResourcesResponse) GetError added in v0.1.50

func (x *ListResourcesResponse) GetError() string

func (*ListResourcesResponse) GetOk added in v0.1.50

func (x *ListResourcesResponse) GetOk() bool

func (*ListResourcesResponse) GetResources added in v0.1.50

func (x *ListResourcesResponse) GetResources() []*SourceResource

func (*ListResourcesResponse) ProtoMessage added in v0.1.50

func (*ListResourcesResponse) ProtoMessage()

func (*ListResourcesResponse) ProtoReflect added in v0.1.50

func (x *ListResourcesResponse) ProtoReflect() protoreflect.Message

func (*ListResourcesResponse) Reset added in v0.1.50

func (x *ListResourcesResponse) Reset()

func (*ListResourcesResponse) String added in v0.1.50

func (x *ListResourcesResponse) String() string

type ListTasksRequest

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

func (*ListTasksRequest) Descriptor deprecated

func (*ListTasksRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListTasksRequest.ProtoReflect.Descriptor instead.

func (*ListTasksRequest) ProtoMessage

func (*ListTasksRequest) ProtoMessage()

func (*ListTasksRequest) ProtoReflect

func (x *ListTasksRequest) ProtoReflect() protoreflect.Message

func (*ListTasksRequest) Reset

func (x *ListTasksRequest) Reset()

func (*ListTasksRequest) String

func (x *ListTasksRequest) String() string

type ListTasksResponse

type ListTasksResponse struct {
	Ok    bool         `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string       `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Tasks []*AgentTask `protobuf:"bytes,3,rep,name=tasks,proto3" json:"tasks,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTasksResponse) Descriptor deprecated

func (*ListTasksResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListTasksResponse.ProtoReflect.Descriptor instead.

func (*ListTasksResponse) GetError

func (x *ListTasksResponse) GetError() string

func (*ListTasksResponse) GetOk

func (x *ListTasksResponse) GetOk() bool

func (*ListTasksResponse) GetTasks

func (x *ListTasksResponse) GetTasks() []*AgentTask

func (*ListTasksResponse) ProtoMessage

func (*ListTasksResponse) ProtoMessage()

func (*ListTasksResponse) ProtoReflect

func (x *ListTasksResponse) ProtoReflect() protoreflect.Message

func (*ListTasksResponse) Reset

func (x *ListTasksResponse) Reset()

func (*ListTasksResponse) String

func (x *ListTasksResponse) String() string

type ListTokensRequest

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

func (*ListTokensRequest) Descriptor deprecated

func (*ListTokensRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListTokensRequest.ProtoReflect.Descriptor instead.

func (*ListTokensRequest) GetWorkspaceId

func (x *ListTokensRequest) GetWorkspaceId() string

func (*ListTokensRequest) ProtoMessage

func (*ListTokensRequest) ProtoMessage()

func (*ListTokensRequest) ProtoReflect

func (x *ListTokensRequest) ProtoReflect() protoreflect.Message

func (*ListTokensRequest) Reset

func (x *ListTokensRequest) Reset()

func (*ListTokensRequest) String

func (x *ListTokensRequest) String() string

type ListTokensResponse

type ListTokensResponse struct {
	Ok     bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error  string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Tokens []*Token `protobuf:"bytes,3,rep,name=tokens,proto3" json:"tokens,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTokensResponse) Descriptor deprecated

func (*ListTokensResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListTokensResponse.ProtoReflect.Descriptor instead.

func (*ListTokensResponse) GetError

func (x *ListTokensResponse) GetError() string

func (*ListTokensResponse) GetOk

func (x *ListTokensResponse) GetOk() bool

func (*ListTokensResponse) GetTokens

func (x *ListTokensResponse) GetTokens() []*Token

func (*ListTokensResponse) ProtoMessage

func (*ListTokensResponse) ProtoMessage()

func (*ListTokensResponse) ProtoReflect

func (x *ListTokensResponse) ProtoReflect() protoreflect.Message

func (*ListTokensResponse) Reset

func (x *ListTokensResponse) Reset()

func (*ListTokensResponse) String

func (x *ListTokensResponse) String() string

type ListToolsRequest

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

func (*ListToolsRequest) Descriptor deprecated

func (*ListToolsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListToolsRequest.ProtoReflect.Descriptor instead.

func (*ListToolsRequest) ProtoMessage

func (*ListToolsRequest) ProtoMessage()

func (*ListToolsRequest) ProtoReflect

func (x *ListToolsRequest) ProtoReflect() protoreflect.Message

func (*ListToolsRequest) Reset

func (x *ListToolsRequest) Reset()

func (*ListToolsRequest) String

func (x *ListToolsRequest) String() string

type ListToolsResponse

type ListToolsResponse struct {
	Ok    bool        `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string      `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Tools []*ToolInfo `protobuf:"bytes,3,rep,name=tools,proto3" json:"tools,omitempty"`
	// contains filtered or unexported fields
}

func (*ListToolsResponse) Descriptor deprecated

func (*ListToolsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListToolsResponse.ProtoReflect.Descriptor instead.

func (*ListToolsResponse) GetError

func (x *ListToolsResponse) GetError() string

func (*ListToolsResponse) GetOk

func (x *ListToolsResponse) GetOk() bool

func (*ListToolsResponse) GetTools

func (x *ListToolsResponse) GetTools() []*ToolInfo

func (*ListToolsResponse) ProtoMessage

func (*ListToolsResponse) ProtoMessage()

func (*ListToolsResponse) ProtoReflect

func (x *ListToolsResponse) ProtoReflect() protoreflect.Message

func (*ListToolsResponse) Reset

func (x *ListToolsResponse) Reset()

func (*ListToolsResponse) String

func (x *ListToolsResponse) String() string

type ListTreeRequest

type ListTreeRequest struct {
	Path              string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Depth             int32  `protobuf:"varint,2,opt,name=depth,proto3" json:"depth,omitempty"`
	MaxKeys           int32  `protobuf:"varint,3,opt,name=max_keys,json=maxKeys,proto3" json:"max_keys,omitempty"`
	ContinuationToken string `protobuf:"bytes,4,opt,name=continuation_token,json=continuationToken,proto3" json:"continuation_token,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTreeRequest) Descriptor deprecated

func (*ListTreeRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListTreeRequest.ProtoReflect.Descriptor instead.

func (*ListTreeRequest) GetContinuationToken

func (x *ListTreeRequest) GetContinuationToken() string

func (*ListTreeRequest) GetDepth

func (x *ListTreeRequest) GetDepth() int32

func (*ListTreeRequest) GetMaxKeys

func (x *ListTreeRequest) GetMaxKeys() int32

func (*ListTreeRequest) GetPath

func (x *ListTreeRequest) GetPath() string

func (*ListTreeRequest) ProtoMessage

func (*ListTreeRequest) ProtoMessage()

func (*ListTreeRequest) ProtoReflect

func (x *ListTreeRequest) ProtoReflect() protoreflect.Message

func (*ListTreeRequest) Reset

func (x *ListTreeRequest) Reset()

func (*ListTreeRequest) String

func (x *ListTreeRequest) String() string

type ListTreeResponse

type ListTreeResponse struct {
	Ok        bool         `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error     string       `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Entries   []*TreeEntry `protobuf:"bytes,3,rep,name=entries,proto3" json:"entries,omitempty"`
	NextToken string       `protobuf:"bytes,4,opt,name=next_token,json=nextToken,proto3" json:"next_token,omitempty"`
	Truncated bool         `protobuf:"varint,5,opt,name=truncated,proto3" json:"truncated,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTreeResponse) Descriptor deprecated

func (*ListTreeResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListTreeResponse.ProtoReflect.Descriptor instead.

func (*ListTreeResponse) GetEntries

func (x *ListTreeResponse) GetEntries() []*TreeEntry

func (*ListTreeResponse) GetError

func (x *ListTreeResponse) GetError() string

func (*ListTreeResponse) GetNextToken

func (x *ListTreeResponse) GetNextToken() string

func (*ListTreeResponse) GetOk

func (x *ListTreeResponse) GetOk() bool

func (*ListTreeResponse) GetTruncated

func (x *ListTreeResponse) GetTruncated() bool

func (*ListTreeResponse) ProtoMessage

func (*ListTreeResponse) ProtoMessage()

func (*ListTreeResponse) ProtoReflect

func (x *ListTreeResponse) ProtoReflect() protoreflect.Message

func (*ListTreeResponse) Reset

func (x *ListTreeResponse) Reset()

func (*ListTreeResponse) String

func (x *ListTreeResponse) String() string

type ListViewsRequest added in v0.1.50

type ListViewsRequest struct {
	ParentPath string `protobuf:"bytes,1,opt,name=parent_path,json=parentPath,proto3" json:"parent_path,omitempty"` // e.g., "/sources/gmail"
	// contains filtered or unexported fields
}

ListViews - lists views under a parent path

func (*ListViewsRequest) Descriptor deprecated added in v0.1.50

func (*ListViewsRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListViewsRequest.ProtoReflect.Descriptor instead.

func (*ListViewsRequest) GetParentPath added in v0.1.50

func (x *ListViewsRequest) GetParentPath() string

func (*ListViewsRequest) ProtoMessage added in v0.1.50

func (*ListViewsRequest) ProtoMessage()

func (*ListViewsRequest) ProtoReflect added in v0.1.50

func (x *ListViewsRequest) ProtoReflect() protoreflect.Message

func (*ListViewsRequest) Reset added in v0.1.50

func (x *ListViewsRequest) Reset()

func (*ListViewsRequest) String added in v0.1.50

func (x *ListViewsRequest) String() string

type ListViewsResponse added in v0.1.50

type ListViewsResponse struct {
	Ok    bool          `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string        `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Views []*SourceView `protobuf:"bytes,3,rep,name=views,proto3" json:"views,omitempty"`
	// contains filtered or unexported fields
}

func (*ListViewsResponse) Descriptor deprecated added in v0.1.50

func (*ListViewsResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListViewsResponse.ProtoReflect.Descriptor instead.

func (*ListViewsResponse) GetError added in v0.1.50

func (x *ListViewsResponse) GetError() string

func (*ListViewsResponse) GetOk added in v0.1.50

func (x *ListViewsResponse) GetOk() bool

func (*ListViewsResponse) GetViews added in v0.1.50

func (x *ListViewsResponse) GetViews() []*SourceView

func (*ListViewsResponse) ProtoMessage added in v0.1.50

func (*ListViewsResponse) ProtoMessage()

func (*ListViewsResponse) ProtoReflect added in v0.1.50

func (x *ListViewsResponse) ProtoReflect() protoreflect.Message

func (*ListViewsResponse) Reset added in v0.1.50

func (x *ListViewsResponse) Reset()

func (*ListViewsResponse) String added in v0.1.50

func (x *ListViewsResponse) String() string

type ListWorkerTokensRequest

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

func (*ListWorkerTokensRequest) Descriptor deprecated

func (*ListWorkerTokensRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListWorkerTokensRequest.ProtoReflect.Descriptor instead.

func (*ListWorkerTokensRequest) ProtoMessage

func (*ListWorkerTokensRequest) ProtoMessage()

func (*ListWorkerTokensRequest) ProtoReflect

func (x *ListWorkerTokensRequest) ProtoReflect() protoreflect.Message

func (*ListWorkerTokensRequest) Reset

func (x *ListWorkerTokensRequest) Reset()

func (*ListWorkerTokensRequest) String

func (x *ListWorkerTokensRequest) String() string

type ListWorkersRequest added in v0.1.23

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

List workers

func (*ListWorkersRequest) Descriptor deprecated added in v0.1.23

func (*ListWorkersRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListWorkersRequest.ProtoReflect.Descriptor instead.

func (*ListWorkersRequest) ProtoMessage added in v0.1.23

func (*ListWorkersRequest) ProtoMessage()

func (*ListWorkersRequest) ProtoReflect added in v0.1.23

func (x *ListWorkersRequest) ProtoReflect() protoreflect.Message

func (*ListWorkersRequest) Reset added in v0.1.23

func (x *ListWorkersRequest) Reset()

func (*ListWorkersRequest) String added in v0.1.23

func (x *ListWorkersRequest) String() string

type ListWorkersResponse added in v0.1.23

type ListWorkersResponse struct {
	Workers []*GetWorkerResponse `protobuf:"bytes,1,rep,name=workers,proto3" json:"workers,omitempty"`
	// contains filtered or unexported fields
}

func (*ListWorkersResponse) Descriptor deprecated added in v0.1.23

func (*ListWorkersResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListWorkersResponse.ProtoReflect.Descriptor instead.

func (*ListWorkersResponse) GetWorkers added in v0.1.23

func (x *ListWorkersResponse) GetWorkers() []*GetWorkerResponse

func (*ListWorkersResponse) ProtoMessage added in v0.1.23

func (*ListWorkersResponse) ProtoMessage()

func (*ListWorkersResponse) ProtoReflect added in v0.1.23

func (x *ListWorkersResponse) ProtoReflect() protoreflect.Message

func (*ListWorkersResponse) Reset added in v0.1.23

func (x *ListWorkersResponse) Reset()

func (*ListWorkersResponse) String added in v0.1.23

func (x *ListWorkersResponse) String() string

type ListWorkspacesRequest

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

func (*ListWorkspacesRequest) Descriptor deprecated

func (*ListWorkspacesRequest) Descriptor() ([]byte, []int)

Deprecated: Use ListWorkspacesRequest.ProtoReflect.Descriptor instead.

func (*ListWorkspacesRequest) ProtoMessage

func (*ListWorkspacesRequest) ProtoMessage()

func (*ListWorkspacesRequest) ProtoReflect

func (x *ListWorkspacesRequest) ProtoReflect() protoreflect.Message

func (*ListWorkspacesRequest) Reset

func (x *ListWorkspacesRequest) Reset()

func (*ListWorkspacesRequest) String

func (x *ListWorkspacesRequest) String() string

type ListWorkspacesResponse

type ListWorkspacesResponse struct {
	Ok         bool         `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error      string       `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Workspaces []*Workspace `protobuf:"bytes,3,rep,name=workspaces,proto3" json:"workspaces,omitempty"`
	// contains filtered or unexported fields
}

func (*ListWorkspacesResponse) Descriptor deprecated

func (*ListWorkspacesResponse) Descriptor() ([]byte, []int)

Deprecated: Use ListWorkspacesResponse.ProtoReflect.Descriptor instead.

func (*ListWorkspacesResponse) GetError

func (x *ListWorkspacesResponse) GetError() string

func (*ListWorkspacesResponse) GetOk

func (x *ListWorkspacesResponse) GetOk() bool

func (*ListWorkspacesResponse) GetWorkspaces

func (x *ListWorkspacesResponse) GetWorkspaces() []*Workspace

func (*ListWorkspacesResponse) ProtoMessage

func (*ListWorkspacesResponse) ProtoMessage()

func (*ListWorkspacesResponse) ProtoReflect

func (x *ListWorkspacesResponse) ProtoReflect() protoreflect.Message

func (*ListWorkspacesResponse) Reset

func (x *ListWorkspacesResponse) Reset()

func (*ListWorkspacesResponse) String

func (x *ListWorkspacesResponse) String() string

type Member

type Member struct {
	Id          string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	WorkspaceId string `protobuf:"bytes,2,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	Email       string `protobuf:"bytes,3,opt,name=email,proto3" json:"email,omitempty"`
	Name        string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Role        string `protobuf:"bytes,5,opt,name=role,proto3" json:"role,omitempty"`
	CreatedAt   string `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Member) Descriptor deprecated

func (*Member) Descriptor() ([]byte, []int)

Deprecated: Use Member.ProtoReflect.Descriptor instead.

func (*Member) GetCreatedAt

func (x *Member) GetCreatedAt() string

func (*Member) GetEmail

func (x *Member) GetEmail() string

func (*Member) GetId

func (x *Member) GetId() string

func (*Member) GetName

func (x *Member) GetName() string

func (*Member) GetRole

func (x *Member) GetRole() string

func (*Member) GetWorkspaceId

func (x *Member) GetWorkspaceId() string

func (*Member) ProtoMessage

func (*Member) ProtoMessage()

func (*Member) ProtoReflect

func (x *Member) ProtoReflect() protoreflect.Message

func (*Member) Reset

func (x *Member) Reset()

func (*Member) String

func (x *Member) String() string

type MemberResponse

type MemberResponse struct {
	Ok     bool    `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error  string  `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Member *Member `protobuf:"bytes,3,opt,name=member,proto3" json:"member,omitempty"`
	// contains filtered or unexported fields
}

func (*MemberResponse) Descriptor deprecated

func (*MemberResponse) Descriptor() ([]byte, []int)

Deprecated: Use MemberResponse.ProtoReflect.Descriptor instead.

func (*MemberResponse) GetError

func (x *MemberResponse) GetError() string

func (*MemberResponse) GetMember

func (x *MemberResponse) GetMember() *Member

func (*MemberResponse) GetOk

func (x *MemberResponse) GetOk() bool

func (*MemberResponse) ProtoMessage

func (*MemberResponse) ProtoMessage()

func (*MemberResponse) ProtoReflect

func (x *MemberResponse) ProtoReflect() protoreflect.Message

func (*MemberResponse) Reset

func (x *MemberResponse) Reset()

func (*MemberResponse) String

func (x *MemberResponse) String() string

type MkdirRequest

type MkdirRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Mode uint32 `protobuf:"varint,2,opt,name=mode,proto3" json:"mode,omitempty"`
	// contains filtered or unexported fields
}

Mkdir

func (*MkdirRequest) Descriptor deprecated

func (*MkdirRequest) Descriptor() ([]byte, []int)

Deprecated: Use MkdirRequest.ProtoReflect.Descriptor instead.

func (*MkdirRequest) GetMode

func (x *MkdirRequest) GetMode() uint32

func (*MkdirRequest) GetPath

func (x *MkdirRequest) GetPath() string

func (*MkdirRequest) ProtoMessage

func (*MkdirRequest) ProtoMessage()

func (*MkdirRequest) ProtoReflect

func (x *MkdirRequest) ProtoReflect() protoreflect.Message

func (*MkdirRequest) Reset

func (x *MkdirRequest) Reset()

func (*MkdirRequest) String

func (x *MkdirRequest) String() string

type MkdirResponse

type MkdirResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*MkdirResponse) Descriptor deprecated

func (*MkdirResponse) Descriptor() ([]byte, []int)

Deprecated: Use MkdirResponse.ProtoReflect.Descriptor instead.

func (*MkdirResponse) GetError

func (x *MkdirResponse) GetError() string

func (*MkdirResponse) GetOk

func (x *MkdirResponse) GetOk() bool

func (*MkdirResponse) ProtoMessage

func (*MkdirResponse) ProtoMessage()

func (*MkdirResponse) ProtoReflect

func (x *MkdirResponse) ProtoReflect() protoreflect.Message

func (*MkdirResponse) Reset

func (x *MkdirResponse) Reset()

func (*MkdirResponse) String

func (x *MkdirResponse) String() string

type ReadDirRequest

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

ReadDir

func (*ReadDirRequest) Descriptor deprecated

func (*ReadDirRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReadDirRequest.ProtoReflect.Descriptor instead.

func (*ReadDirRequest) GetPath

func (x *ReadDirRequest) GetPath() string

func (*ReadDirRequest) ProtoMessage

func (*ReadDirRequest) ProtoMessage()

func (*ReadDirRequest) ProtoReflect

func (x *ReadDirRequest) ProtoReflect() protoreflect.Message

func (*ReadDirRequest) Reset

func (x *ReadDirRequest) Reset()

func (*ReadDirRequest) String

func (x *ReadDirRequest) String() string

type ReadDirResponse

type ReadDirResponse struct {
	Ok      bool        `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error   string      `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Entries []*DirEntry `protobuf:"bytes,3,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*ReadDirResponse) Descriptor deprecated

func (*ReadDirResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReadDirResponse.ProtoReflect.Descriptor instead.

func (*ReadDirResponse) GetEntries

func (x *ReadDirResponse) GetEntries() []*DirEntry

func (*ReadDirResponse) GetError

func (x *ReadDirResponse) GetError() string

func (*ReadDirResponse) GetOk

func (x *ReadDirResponse) GetOk() bool

func (*ReadDirResponse) ProtoMessage

func (*ReadDirResponse) ProtoMessage()

func (*ReadDirResponse) ProtoReflect

func (x *ReadDirResponse) ProtoReflect() protoreflect.Message

func (*ReadDirResponse) Reset

func (x *ReadDirResponse) Reset()

func (*ReadDirResponse) String

func (x *ReadDirResponse) String() string

type RegisterWorkerRequest

type RegisterWorkerRequest struct {
	Hostname string `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	PoolName string `protobuf:"bytes,2,opt,name=pool_name,json=poolName,proto3" json:"pool_name,omitempty"`
	Cpu      int64  `protobuf:"varint,3,opt,name=cpu,proto3" json:"cpu,omitempty"`
	Memory   int64  `protobuf:"varint,4,opt,name=memory,proto3" json:"memory,omitempty"`
	Version  string `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

Worker registration

func (*RegisterWorkerRequest) Descriptor deprecated

func (*RegisterWorkerRequest) Descriptor() ([]byte, []int)

Deprecated: Use RegisterWorkerRequest.ProtoReflect.Descriptor instead.

func (*RegisterWorkerRequest) GetCpu

func (x *RegisterWorkerRequest) GetCpu() int64

func (*RegisterWorkerRequest) GetHostname

func (x *RegisterWorkerRequest) GetHostname() string

func (*RegisterWorkerRequest) GetMemory

func (x *RegisterWorkerRequest) GetMemory() int64

func (*RegisterWorkerRequest) GetPoolName

func (x *RegisterWorkerRequest) GetPoolName() string

func (*RegisterWorkerRequest) GetVersion

func (x *RegisterWorkerRequest) GetVersion() string

func (*RegisterWorkerRequest) ProtoMessage

func (*RegisterWorkerRequest) ProtoMessage()

func (*RegisterWorkerRequest) ProtoReflect

func (x *RegisterWorkerRequest) ProtoReflect() protoreflect.Message

func (*RegisterWorkerRequest) Reset

func (x *RegisterWorkerRequest) Reset()

func (*RegisterWorkerRequest) String

func (x *RegisterWorkerRequest) String() string

type RegisterWorkerResponse

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

func (*RegisterWorkerResponse) Descriptor deprecated

func (*RegisterWorkerResponse) Descriptor() ([]byte, []int)

Deprecated: Use RegisterWorkerResponse.ProtoReflect.Descriptor instead.

func (*RegisterWorkerResponse) GetWorkerId

func (x *RegisterWorkerResponse) GetWorkerId() string

func (*RegisterWorkerResponse) ProtoMessage

func (*RegisterWorkerResponse) ProtoMessage()

func (*RegisterWorkerResponse) ProtoReflect

func (x *RegisterWorkerResponse) ProtoReflect() protoreflect.Message

func (*RegisterWorkerResponse) Reset

func (x *RegisterWorkerResponse) Reset()

func (*RegisterWorkerResponse) String

func (x *RegisterWorkerResponse) String() string

type ReleaseIPRequest added in v0.1.23

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

func (*ReleaseIPRequest) Descriptor deprecated added in v0.1.23

func (*ReleaseIPRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReleaseIPRequest.ProtoReflect.Descriptor instead.

func (*ReleaseIPRequest) GetSandboxId added in v0.1.23

func (x *ReleaseIPRequest) GetSandboxId() string

func (*ReleaseIPRequest) ProtoMessage added in v0.1.23

func (*ReleaseIPRequest) ProtoMessage()

func (*ReleaseIPRequest) ProtoReflect added in v0.1.23

func (x *ReleaseIPRequest) ProtoReflect() protoreflect.Message

func (*ReleaseIPRequest) Reset added in v0.1.23

func (x *ReleaseIPRequest) Reset()

func (*ReleaseIPRequest) String added in v0.1.23

func (x *ReleaseIPRequest) String() string

type ReleaseIPResponse added in v0.1.23

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

func (*ReleaseIPResponse) Descriptor deprecated added in v0.1.23

func (*ReleaseIPResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReleaseIPResponse.ProtoReflect.Descriptor instead.

func (*ReleaseIPResponse) ProtoMessage added in v0.1.23

func (*ReleaseIPResponse) ProtoMessage()

func (*ReleaseIPResponse) ProtoReflect added in v0.1.23

func (x *ReleaseIPResponse) ProtoReflect() protoreflect.Message

func (*ReleaseIPResponse) Reset added in v0.1.23

func (x *ReleaseIPResponse) Reset()

func (*ReleaseIPResponse) String added in v0.1.23

func (x *ReleaseIPResponse) String() string

type RemoveConnectionRequest

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

func (*RemoveConnectionRequest) Descriptor deprecated

func (*RemoveConnectionRequest) Descriptor() ([]byte, []int)

Deprecated: Use RemoveConnectionRequest.ProtoReflect.Descriptor instead.

func (*RemoveConnectionRequest) GetId

func (x *RemoveConnectionRequest) GetId() string

func (*RemoveConnectionRequest) ProtoMessage

func (*RemoveConnectionRequest) ProtoMessage()

func (*RemoveConnectionRequest) ProtoReflect

func (x *RemoveConnectionRequest) ProtoReflect() protoreflect.Message

func (*RemoveConnectionRequest) Reset

func (x *RemoveConnectionRequest) Reset()

func (*RemoveConnectionRequest) String

func (x *RemoveConnectionRequest) String() string

type RemoveMemberRequest

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

func (*RemoveMemberRequest) Descriptor deprecated

func (*RemoveMemberRequest) Descriptor() ([]byte, []int)

Deprecated: Use RemoveMemberRequest.ProtoReflect.Descriptor instead.

func (*RemoveMemberRequest) GetId

func (x *RemoveMemberRequest) GetId() string

func (*RemoveMemberRequest) ProtoMessage

func (*RemoveMemberRequest) ProtoMessage()

func (*RemoveMemberRequest) ProtoReflect

func (x *RemoveMemberRequest) ProtoReflect() protoreflect.Message

func (*RemoveMemberRequest) Reset

func (x *RemoveMemberRequest) Reset()

func (*RemoveMemberRequest) String

func (x *RemoveMemberRequest) String() string

type RemoveRequest

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

Remove

func (*RemoveRequest) Descriptor deprecated

func (*RemoveRequest) Descriptor() ([]byte, []int)

Deprecated: Use RemoveRequest.ProtoReflect.Descriptor instead.

func (*RemoveRequest) GetPath

func (x *RemoveRequest) GetPath() string

func (*RemoveRequest) ProtoMessage

func (*RemoveRequest) ProtoMessage()

func (*RemoveRequest) ProtoReflect

func (x *RemoveRequest) ProtoReflect() protoreflect.Message

func (*RemoveRequest) Reset

func (x *RemoveRequest) Reset()

func (*RemoveRequest) String

func (x *RemoveRequest) String() string

type RemoveResponse

type RemoveResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveResponse) Descriptor deprecated

func (*RemoveResponse) Descriptor() ([]byte, []int)

Deprecated: Use RemoveResponse.ProtoReflect.Descriptor instead.

func (*RemoveResponse) GetError

func (x *RemoveResponse) GetError() string

func (*RemoveResponse) GetOk

func (x *RemoveResponse) GetOk() bool

func (*RemoveResponse) ProtoMessage

func (*RemoveResponse) ProtoMessage()

func (*RemoveResponse) ProtoReflect

func (x *RemoveResponse) ProtoReflect() protoreflect.Message

func (*RemoveResponse) Reset

func (x *RemoveResponse) Reset()

func (*RemoveResponse) String

func (x *RemoveResponse) String() string

type RenameRequest

type RenameRequest struct {
	OldPath string `protobuf:"bytes,1,opt,name=old_path,json=oldPath,proto3" json:"old_path,omitempty"`
	NewPath string `protobuf:"bytes,2,opt,name=new_path,json=newPath,proto3" json:"new_path,omitempty"`
	// contains filtered or unexported fields
}

Rename

func (*RenameRequest) Descriptor deprecated

func (*RenameRequest) Descriptor() ([]byte, []int)

Deprecated: Use RenameRequest.ProtoReflect.Descriptor instead.

func (*RenameRequest) GetNewPath

func (x *RenameRequest) GetNewPath() string

func (*RenameRequest) GetOldPath

func (x *RenameRequest) GetOldPath() string

func (*RenameRequest) ProtoMessage

func (*RenameRequest) ProtoMessage()

func (*RenameRequest) ProtoReflect

func (x *RenameRequest) ProtoReflect() protoreflect.Message

func (*RenameRequest) Reset

func (x *RenameRequest) Reset()

func (*RenameRequest) String

func (x *RenameRequest) String() string

type RenameResponse

type RenameResponse struct {
	Ok    bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*RenameResponse) Descriptor deprecated

func (*RenameResponse) Descriptor() ([]byte, []int)

Deprecated: Use RenameResponse.ProtoReflect.Descriptor instead.

func (*RenameResponse) GetError

func (x *RenameResponse) GetError() string

func (*RenameResponse) GetOk

func (x *RenameResponse) GetOk() bool

func (*RenameResponse) ProtoMessage

func (*RenameResponse) ProtoMessage()

func (*RenameResponse) ProtoReflect

func (x *RenameResponse) ProtoReflect() protoreflect.Message

func (*RenameResponse) Reset

func (x *RenameResponse) Reset()

func (*RenameResponse) String

func (x *RenameResponse) String() string

type RevokeTokenRequest

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

func (*RevokeTokenRequest) Descriptor deprecated

func (*RevokeTokenRequest) Descriptor() ([]byte, []int)

Deprecated: Use RevokeTokenRequest.ProtoReflect.Descriptor instead.

func (*RevokeTokenRequest) GetId

func (x *RevokeTokenRequest) GetId() string

func (*RevokeTokenRequest) ProtoMessage

func (*RevokeTokenRequest) ProtoMessage()

func (*RevokeTokenRequest) ProtoReflect

func (x *RevokeTokenRequest) ProtoReflect() protoreflect.Message

func (*RevokeTokenRequest) Reset

func (x *RevokeTokenRequest) Reset()

func (*RevokeTokenRequest) String

func (x *RevokeTokenRequest) String() string

type SetTaskResultRequest

type SetTaskResultRequest struct {
	TaskId                      string                `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	ExitCode                    int32                 `protobuf:"varint,2,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	Error                       string                `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	AttemptId                   string                `protobuf:"bytes,4,opt,name=attempt_id,json=attemptId,proto3" json:"attempt_id,omitempty"`
	WaitingForInput             bool                  `protobuf:"varint,5,opt,name=waiting_for_input,json=waitingForInput,proto3" json:"waiting_for_input,omitempty"`
	WakeSignal                  *WakeSignal           `protobuf:"bytes,6,opt,name=wake_signal,json=wakeSignal,proto3" json:"wake_signal,omitempty"`
	SubtaskRequests             []*SubtaskRequest     `protobuf:"bytes,7,rep,name=subtask_requests,json=subtaskRequests,proto3" json:"subtask_requests,omitempty"`
	SourceWatchRequests         []*SourceWatchRequest `protobuf:"bytes,8,rep,name=source_watch_requests,json=sourceWatchRequests,proto3" json:"source_watch_requests,omitempty"`
	LlmInputTokens              int64                 `protobuf:"varint,9,opt,name=llm_input_tokens,json=llmInputTokens,proto3" json:"llm_input_tokens,omitempty"`
	LlmOutputTokens             int64                 `protobuf:"varint,10,opt,name=llm_output_tokens,json=llmOutputTokens,proto3" json:"llm_output_tokens,omitempty"`
	LlmCacheCreationInputTokens int64                 `` /* 150-byte string literal not displayed */
	LlmCacheReadInputTokens     int64                 `` /* 138-byte string literal not displayed */
	LlmTotalTokens              int64                 `protobuf:"varint,13,opt,name=llm_total_tokens,json=llmTotalTokens,proto3" json:"llm_total_tokens,omitempty"`
	TotalCostUsd                float64               `protobuf:"fixed64,14,opt,name=total_cost_usd,json=totalCostUsd,proto3" json:"total_cost_usd,omitempty"`
	LlmModelUsageJson           string                `protobuf:"bytes,15,opt,name=llm_model_usage_json,json=llmModelUsageJson,proto3" json:"llm_model_usage_json,omitempty"`
	// contains filtered or unexported fields
}

func (*SetTaskResultRequest) Descriptor deprecated

func (*SetTaskResultRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetTaskResultRequest.ProtoReflect.Descriptor instead.

func (*SetTaskResultRequest) GetAttemptId added in v0.1.74

func (x *SetTaskResultRequest) GetAttemptId() string

func (*SetTaskResultRequest) GetError

func (x *SetTaskResultRequest) GetError() string

func (*SetTaskResultRequest) GetExitCode

func (x *SetTaskResultRequest) GetExitCode() int32

func (*SetTaskResultRequest) GetLlmCacheCreationInputTokens added in v0.1.110

func (x *SetTaskResultRequest) GetLlmCacheCreationInputTokens() int64

func (*SetTaskResultRequest) GetLlmCacheReadInputTokens added in v0.1.110

func (x *SetTaskResultRequest) GetLlmCacheReadInputTokens() int64

func (*SetTaskResultRequest) GetLlmInputTokens added in v0.1.110

func (x *SetTaskResultRequest) GetLlmInputTokens() int64

func (*SetTaskResultRequest) GetLlmModelUsageJson added in v0.1.110

func (x *SetTaskResultRequest) GetLlmModelUsageJson() string

func (*SetTaskResultRequest) GetLlmOutputTokens added in v0.1.110

func (x *SetTaskResultRequest) GetLlmOutputTokens() int64

func (*SetTaskResultRequest) GetLlmTotalTokens added in v0.1.110

func (x *SetTaskResultRequest) GetLlmTotalTokens() int64

func (*SetTaskResultRequest) GetSourceWatchRequests added in v0.1.110

func (x *SetTaskResultRequest) GetSourceWatchRequests() []*SourceWatchRequest

func (*SetTaskResultRequest) GetSubtaskRequests added in v0.1.110

func (x *SetTaskResultRequest) GetSubtaskRequests() []*SubtaskRequest

func (*SetTaskResultRequest) GetTaskId

func (x *SetTaskResultRequest) GetTaskId() string

func (*SetTaskResultRequest) GetTotalCostUsd added in v0.1.110

func (x *SetTaskResultRequest) GetTotalCostUsd() float64

func (*SetTaskResultRequest) GetWaitingForInput added in v0.1.96

func (x *SetTaskResultRequest) GetWaitingForInput() bool

func (*SetTaskResultRequest) GetWakeSignal added in v0.1.96

func (x *SetTaskResultRequest) GetWakeSignal() *WakeSignal

func (*SetTaskResultRequest) ProtoMessage

func (*SetTaskResultRequest) ProtoMessage()

func (*SetTaskResultRequest) ProtoReflect

func (x *SetTaskResultRequest) ProtoReflect() protoreflect.Message

func (*SetTaskResultRequest) Reset

func (x *SetTaskResultRequest) Reset()

func (*SetTaskResultRequest) String

func (x *SetTaskResultRequest) String() string

type SetTaskResultResponse

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

func (*SetTaskResultResponse) Descriptor deprecated

func (*SetTaskResultResponse) Descriptor() ([]byte, []int)

Deprecated: Use SetTaskResultResponse.ProtoReflect.Descriptor instead.

func (*SetTaskResultResponse) ProtoMessage

func (*SetTaskResultResponse) ProtoMessage()

func (*SetTaskResultResponse) ProtoReflect

func (x *SetTaskResultResponse) ProtoReflect() protoreflect.Message

func (*SetTaskResultResponse) Reset

func (x *SetTaskResultResponse) Reset()

func (*SetTaskResultResponse) String

func (x *SetTaskResultResponse) String() string

type SetTaskStartedRequest added in v0.1.28

type SetTaskStartedRequest struct {
	TaskId    string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	AttemptId string `protobuf:"bytes,2,opt,name=attempt_id,json=attemptId,proto3" json:"attempt_id,omitempty"`
	// contains filtered or unexported fields
}

Task result reporting

func (*SetTaskStartedRequest) Descriptor deprecated added in v0.1.28

func (*SetTaskStartedRequest) Descriptor() ([]byte, []int)

Deprecated: Use SetTaskStartedRequest.ProtoReflect.Descriptor instead.

func (*SetTaskStartedRequest) GetAttemptId added in v0.1.75

func (x *SetTaskStartedRequest) GetAttemptId() string

func (*SetTaskStartedRequest) GetTaskId added in v0.1.28

func (x *SetTaskStartedRequest) GetTaskId() string

func (*SetTaskStartedRequest) ProtoMessage added in v0.1.28

func (*SetTaskStartedRequest) ProtoMessage()

func (*SetTaskStartedRequest) ProtoReflect added in v0.1.28

func (x *SetTaskStartedRequest) ProtoReflect() protoreflect.Message

func (*SetTaskStartedRequest) Reset added in v0.1.28

func (x *SetTaskStartedRequest) Reset()

func (*SetTaskStartedRequest) String added in v0.1.28

func (x *SetTaskStartedRequest) String() string

type SetTaskStartedResponse added in v0.1.28

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

func (*SetTaskStartedResponse) Descriptor deprecated added in v0.1.28

func (*SetTaskStartedResponse) Descriptor() ([]byte, []int)

Deprecated: Use SetTaskStartedResponse.ProtoReflect.Descriptor instead.

func (*SetTaskStartedResponse) ProtoMessage added in v0.1.28

func (*SetTaskStartedResponse) ProtoMessage()

func (*SetTaskStartedResponse) ProtoReflect added in v0.1.28

func (x *SetTaskStartedResponse) ProtoReflect() protoreflect.Message

func (*SetTaskStartedResponse) Reset added in v0.1.28

func (x *SetTaskStartedResponse) Reset()

func (*SetTaskStartedResponse) String added in v0.1.28

func (x *SetTaskStartedResponse) String() string

type SourceDirEntry

type SourceDirEntry struct {
	Name       string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Mode       uint32 `protobuf:"varint,2,opt,name=mode,proto3" json:"mode,omitempty"`
	IsDir      bool   `protobuf:"varint,3,opt,name=is_dir,json=isDir,proto3" json:"is_dir,omitempty"`
	Size       int64  `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	Mtime      int64  `protobuf:"varint,5,opt,name=mtime,proto3" json:"mtime,omitempty"`                             // Unix timestamp
	ResultId   string `protobuf:"bytes,6,opt,name=result_id,json=resultId,proto3" json:"result_id,omitempty"`        // Provider-specific ID for content retrieval (optional)
	ChildCount int32  `protobuf:"varint,7,opt,name=child_count,json=childCount,proto3" json:"child_count,omitempty"` // Number of children (for directories)
	// contains filtered or unexported fields
}

SourceDirEntry represents a directory entry with full metadata

func (*SourceDirEntry) Descriptor deprecated

func (*SourceDirEntry) Descriptor() ([]byte, []int)

Deprecated: Use SourceDirEntry.ProtoReflect.Descriptor instead.

func (*SourceDirEntry) GetChildCount

func (x *SourceDirEntry) GetChildCount() int32

func (*SourceDirEntry) GetIsDir

func (x *SourceDirEntry) GetIsDir() bool

func (*SourceDirEntry) GetMode

func (x *SourceDirEntry) GetMode() uint32

func (*SourceDirEntry) GetMtime

func (x *SourceDirEntry) GetMtime() int64

func (*SourceDirEntry) GetName

func (x *SourceDirEntry) GetName() string

func (*SourceDirEntry) GetResultId

func (x *SourceDirEntry) GetResultId() string

func (*SourceDirEntry) GetSize

func (x *SourceDirEntry) GetSize() int64

func (*SourceDirEntry) ProtoMessage

func (*SourceDirEntry) ProtoMessage()

func (*SourceDirEntry) ProtoReflect

func (x *SourceDirEntry) ProtoReflect() protoreflect.Message

func (*SourceDirEntry) Reset

func (x *SourceDirEntry) Reset()

func (*SourceDirEntry) String

func (x *SourceDirEntry) String() string

type SourceFileInfo

type SourceFileInfo struct {
	Size   int64  `protobuf:"varint,1,opt,name=size,proto3" json:"size,omitempty"`
	Mode   uint32 `protobuf:"varint,2,opt,name=mode,proto3" json:"mode,omitempty"`
	Mtime  int64  `protobuf:"varint,3,opt,name=mtime,proto3" json:"mtime,omitempty"` // Unix timestamp
	IsDir  bool   `protobuf:"varint,4,opt,name=is_dir,json=isDir,proto3" json:"is_dir,omitempty"`
	IsLink bool   `protobuf:"varint,5,opt,name=is_link,json=isLink,proto3" json:"is_link,omitempty"`
	// contains filtered or unexported fields
}

SourceFileInfo contains file/directory metadata

func (*SourceFileInfo) Descriptor deprecated

func (*SourceFileInfo) Descriptor() ([]byte, []int)

Deprecated: Use SourceFileInfo.ProtoReflect.Descriptor instead.

func (*SourceFileInfo) GetIsDir

func (x *SourceFileInfo) GetIsDir() bool
func (x *SourceFileInfo) GetIsLink() bool

func (*SourceFileInfo) GetMode

func (x *SourceFileInfo) GetMode() uint32

func (*SourceFileInfo) GetMtime

func (x *SourceFileInfo) GetMtime() int64

func (*SourceFileInfo) GetSize

func (x *SourceFileInfo) GetSize() int64

func (*SourceFileInfo) ProtoMessage

func (*SourceFileInfo) ProtoMessage()

func (*SourceFileInfo) ProtoReflect

func (x *SourceFileInfo) ProtoReflect() protoreflect.Message

func (*SourceFileInfo) Reset

func (x *SourceFileInfo) Reset()

func (*SourceFileInfo) String

func (x *SourceFileInfo) String() string

type SourceReadCostHint added in v0.1.47

type SourceReadCostHint struct {
	Integration      string `protobuf:"bytes,1,opt,name=integration,proto3" json:"integration,omitempty"`
	SourceUri        string `protobuf:"bytes,2,opt,name=source_uri,json=sourceUri,proto3" json:"source_uri,omitempty"`
	QueryPath        string `protobuf:"bytes,3,opt,name=query_path,json=queryPath,proto3" json:"query_path,omitempty"`
	ResultId         string `protobuf:"bytes,4,opt,name=result_id,json=resultId,proto3" json:"result_id,omitempty"`
	Strategy         string `protobuf:"bytes,5,opt,name=strategy,proto3" json:"strategy,omitempty"`
	Outcome          string `protobuf:"bytes,6,opt,name=outcome,proto3" json:"outcome,omitempty"`
	OriginalBytes    int64  `protobuf:"varint,7,opt,name=original_bytes,json=originalBytes,proto3" json:"original_bytes,omitempty"`
	CompressedBytes  int64  `protobuf:"varint,8,opt,name=compressed_bytes,json=compressedBytes,proto3" json:"compressed_bytes,omitempty"`
	OriginalTokens   int64  `protobuf:"varint,9,opt,name=original_tokens,json=originalTokens,proto3" json:"original_tokens,omitempty"`
	CompressedTokens int64  `protobuf:"varint,10,opt,name=compressed_tokens,json=compressedTokens,proto3" json:"compressed_tokens,omitempty"`
	CompressionMs    int64  `protobuf:"varint,11,opt,name=compression_ms,json=compressionMs,proto3" json:"compression_ms,omitempty"`
	// contains filtered or unexported fields
}

func (*SourceReadCostHint) Descriptor deprecated added in v0.1.47

func (*SourceReadCostHint) Descriptor() ([]byte, []int)

Deprecated: Use SourceReadCostHint.ProtoReflect.Descriptor instead.

func (*SourceReadCostHint) GetCompressedBytes added in v0.1.47

func (x *SourceReadCostHint) GetCompressedBytes() int64

func (*SourceReadCostHint) GetCompressedTokens added in v0.1.47

func (x *SourceReadCostHint) GetCompressedTokens() int64

func (*SourceReadCostHint) GetCompressionMs added in v0.1.47

func (x *SourceReadCostHint) GetCompressionMs() int64

func (*SourceReadCostHint) GetIntegration added in v0.1.47

func (x *SourceReadCostHint) GetIntegration() string

func (*SourceReadCostHint) GetOriginalBytes added in v0.1.47

func (x *SourceReadCostHint) GetOriginalBytes() int64

func (*SourceReadCostHint) GetOriginalTokens added in v0.1.47

func (x *SourceReadCostHint) GetOriginalTokens() int64

func (*SourceReadCostHint) GetOutcome added in v0.1.47

func (x *SourceReadCostHint) GetOutcome() string

func (*SourceReadCostHint) GetQueryPath added in v0.1.47

func (x *SourceReadCostHint) GetQueryPath() string

func (*SourceReadCostHint) GetResultId added in v0.1.47

func (x *SourceReadCostHint) GetResultId() string

func (*SourceReadCostHint) GetSourceUri added in v0.1.47

func (x *SourceReadCostHint) GetSourceUri() string

func (*SourceReadCostHint) GetStrategy added in v0.1.47

func (x *SourceReadCostHint) GetStrategy() string

func (*SourceReadCostHint) ProtoMessage added in v0.1.47

func (*SourceReadCostHint) ProtoMessage()

func (*SourceReadCostHint) ProtoReflect added in v0.1.47

func (x *SourceReadCostHint) ProtoReflect() protoreflect.Message

func (*SourceReadCostHint) Reset added in v0.1.47

func (x *SourceReadCostHint) Reset()

func (*SourceReadCostHint) String added in v0.1.47

func (x *SourceReadCostHint) String() string

type SourceReadDirRequest

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

ReadDir

func (*SourceReadDirRequest) Descriptor deprecated

func (*SourceReadDirRequest) Descriptor() ([]byte, []int)

Deprecated: Use SourceReadDirRequest.ProtoReflect.Descriptor instead.

func (*SourceReadDirRequest) GetPath

func (x *SourceReadDirRequest) GetPath() string

func (*SourceReadDirRequest) ProtoMessage

func (*SourceReadDirRequest) ProtoMessage()

func (*SourceReadDirRequest) ProtoReflect

func (x *SourceReadDirRequest) ProtoReflect() protoreflect.Message

func (*SourceReadDirRequest) Reset

func (x *SourceReadDirRequest) Reset()

func (*SourceReadDirRequest) String

func (x *SourceReadDirRequest) String() string

type SourceReadDirResponse

type SourceReadDirResponse struct {
	Ok      bool              `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error   string            `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Entries []*SourceDirEntry `protobuf:"bytes,3,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*SourceReadDirResponse) Descriptor deprecated

func (*SourceReadDirResponse) Descriptor() ([]byte, []int)

Deprecated: Use SourceReadDirResponse.ProtoReflect.Descriptor instead.

func (*SourceReadDirResponse) GetEntries

func (x *SourceReadDirResponse) GetEntries() []*SourceDirEntry

func (*SourceReadDirResponse) GetError

func (x *SourceReadDirResponse) GetError() string

func (*SourceReadDirResponse) GetOk

func (x *SourceReadDirResponse) GetOk() bool

func (*SourceReadDirResponse) ProtoMessage

func (*SourceReadDirResponse) ProtoMessage()

func (*SourceReadDirResponse) ProtoReflect

func (x *SourceReadDirResponse) ProtoReflect() protoreflect.Message

func (*SourceReadDirResponse) Reset

func (x *SourceReadDirResponse) Reset()

func (*SourceReadDirResponse) String

func (x *SourceReadDirResponse) String() string

type SourceReadRequest

type SourceReadRequest struct {
	Path   string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Offset int64  `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Length int64  `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"` // 0 means read to end
	// contains filtered or unexported fields
}

Read

func (*SourceReadRequest) Descriptor deprecated

func (*SourceReadRequest) Descriptor() ([]byte, []int)

Deprecated: Use SourceReadRequest.ProtoReflect.Descriptor instead.

func (*SourceReadRequest) GetLength

func (x *SourceReadRequest) GetLength() int64

func (*SourceReadRequest) GetOffset

func (x *SourceReadRequest) GetOffset() int64

func (*SourceReadRequest) GetPath

func (x *SourceReadRequest) GetPath() string

func (*SourceReadRequest) ProtoMessage

func (*SourceReadRequest) ProtoMessage()

func (*SourceReadRequest) ProtoReflect

func (x *SourceReadRequest) ProtoReflect() protoreflect.Message

func (*SourceReadRequest) Reset

func (x *SourceReadRequest) Reset()

func (*SourceReadRequest) String

func (x *SourceReadRequest) String() string

type SourceReadResponse

type SourceReadResponse struct {
	Ok       bool                `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error    string              `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Data     []byte              `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	CostHint *SourceReadCostHint `protobuf:"bytes,4,opt,name=cost_hint,json=costHint,proto3" json:"cost_hint,omitempty"`
	// contains filtered or unexported fields
}

func (*SourceReadResponse) Descriptor deprecated

func (*SourceReadResponse) Descriptor() ([]byte, []int)

Deprecated: Use SourceReadResponse.ProtoReflect.Descriptor instead.

func (*SourceReadResponse) GetCostHint added in v0.1.47

func (x *SourceReadResponse) GetCostHint() *SourceReadCostHint

func (*SourceReadResponse) GetData

func (x *SourceReadResponse) GetData() []byte

func (*SourceReadResponse) GetError

func (x *SourceReadResponse) GetError() string

func (*SourceReadResponse) GetOk

func (x *SourceReadResponse) GetOk() bool

func (*SourceReadResponse) ProtoMessage

func (*SourceReadResponse) ProtoMessage()

func (*SourceReadResponse) ProtoReflect

func (x *SourceReadResponse) ProtoReflect() protoreflect.Message

func (*SourceReadResponse) Reset

func (x *SourceReadResponse) Reset()

func (*SourceReadResponse) String

func (x *SourceReadResponse) String() string

type SourceReadlinkRequest

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

Readlink

func (*SourceReadlinkRequest) Descriptor deprecated

func (*SourceReadlinkRequest) Descriptor() ([]byte, []int)

Deprecated: Use SourceReadlinkRequest.ProtoReflect.Descriptor instead.

func (*SourceReadlinkRequest) GetPath

func (x *SourceReadlinkRequest) GetPath() string

func (*SourceReadlinkRequest) ProtoMessage

func (*SourceReadlinkRequest) ProtoMessage()

func (*SourceReadlinkRequest) ProtoReflect

func (x *SourceReadlinkRequest) ProtoReflect() protoreflect.Message

func (*SourceReadlinkRequest) Reset

func (x *SourceReadlinkRequest) Reset()

func (*SourceReadlinkRequest) String

func (x *SourceReadlinkRequest) String() string

type SourceReadlinkResponse

type SourceReadlinkResponse struct {
	Ok     bool   `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error  string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Target string `protobuf:"bytes,3,opt,name=target,proto3" json:"target,omitempty"`
	// contains filtered or unexported fields
}

func (*SourceReadlinkResponse) Descriptor deprecated

func (*SourceReadlinkResponse) Descriptor() ([]byte, []int)

Deprecated: Use SourceReadlinkResponse.ProtoReflect.Descriptor instead.

func (*SourceReadlinkResponse) GetError

func (x *SourceReadlinkResponse) GetError() string

func (*SourceReadlinkResponse) GetOk

func (x *SourceReadlinkResponse) GetOk() bool

func (*SourceReadlinkResponse) GetTarget

func (x *SourceReadlinkResponse) GetTarget() string

func (*SourceReadlinkResponse) ProtoMessage

func (*SourceReadlinkResponse) ProtoMessage()

func (*SourceReadlinkResponse) ProtoReflect

func (x *SourceReadlinkResponse) ProtoReflect() protoreflect.Message

func (*SourceReadlinkResponse) Reset

func (x *SourceReadlinkResponse) Reset()

func (*SourceReadlinkResponse) String

func (x *SourceReadlinkResponse) String() string

type SourceResource added in v0.1.50

type SourceResource struct {
	Id   string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`     // Unique identifier (e.g., "owner/repo")
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // Display name (e.g., "owner/repo", "#general")
	// contains filtered or unexported fields
}

func (*SourceResource) Descriptor deprecated added in v0.1.50

func (*SourceResource) Descriptor() ([]byte, []int)

Deprecated: Use SourceResource.ProtoReflect.Descriptor instead.

func (*SourceResource) GetId added in v0.1.50

func (x *SourceResource) GetId() string

func (*SourceResource) GetName added in v0.1.50

func (x *SourceResource) GetName() string

func (*SourceResource) ProtoMessage added in v0.1.50

func (*SourceResource) ProtoMessage()

func (*SourceResource) ProtoReflect added in v0.1.50

func (x *SourceResource) ProtoReflect() protoreflect.Message

func (*SourceResource) Reset added in v0.1.50

func (x *SourceResource) Reset()

func (*SourceResource) String added in v0.1.50

func (x *SourceResource) String() string

type SourceServiceClient

type SourceServiceClient interface {
	// Stat returns file/directory attributes for a source path
	Stat(ctx context.Context, in *SourceStatRequest, opts ...grpc.CallOption) (*SourceStatResponse, error)
	// ReadDir lists directory contents with enriched metadata
	ReadDir(ctx context.Context, in *SourceReadDirRequest, opts ...grpc.CallOption) (*SourceReadDirResponse, error)
	// Read reads file content from a source
	Read(ctx context.Context, in *SourceReadRequest, opts ...grpc.CallOption) (*SourceReadResponse, error)
	// Readlink reads a symbolic link target (for friendly aliases)
	Readlink(ctx context.Context, in *SourceReadlinkRequest, opts ...grpc.CallOption) (*SourceReadlinkResponse, error)
	// CreateView creates a new source view (called on mkdir/touch)
	CreateView(ctx context.Context, in *CreateViewRequest, opts ...grpc.CallOption) (*CreateViewResponse, error)
	// GetView retrieves a view by its path
	GetView(ctx context.Context, in *GetViewRequest, opts ...grpc.CallOption) (*GetViewResponse, error)
	// ListViews lists views under a parent path
	ListViews(ctx context.Context, in *ListViewsRequest, opts ...grpc.CallOption) (*ListViewsResponse, error)
	// DeleteView removes a view by external_id
	DeleteView(ctx context.Context, in *DeleteViewRequest, opts ...grpc.CallOption) (*DeleteViewResponse, error)
	// UpdateView updates an existing view's name/guidance
	UpdateView(ctx context.Context, in *UpdateViewRequest, opts ...grpc.CallOption) (*UpdateViewResponse, error)
	// ExecuteView runs a view's query and returns materialized results
	ExecuteView(ctx context.Context, in *ExecuteViewRequest, opts ...grpc.CallOption) (*ExecuteViewResponse, error)
	// SyncView re-executes a view's query, refreshing cached metadata
	SyncView(ctx context.Context, in *SyncViewRequest, opts ...grpc.CallOption) (*SyncViewResponse, error)
	// ListResources returns available resources for an integration (repos, channels, etc.)
	ListResources(ctx context.Context, in *ListResourcesRequest, opts ...grpc.CallOption) (*ListResourcesResponse, error)
}

SourceServiceClient is the client API for SourceService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type SourceServiceServer

type SourceServiceServer interface {
	// Stat returns file/directory attributes for a source path
	Stat(context.Context, *SourceStatRequest) (*SourceStatResponse, error)
	// ReadDir lists directory contents with enriched metadata
	ReadDir(context.Context, *SourceReadDirRequest) (*SourceReadDirResponse, error)
	// Read reads file content from a source
	Read(context.Context, *SourceReadRequest) (*SourceReadResponse, error)
	// Readlink reads a symbolic link target (for friendly aliases)
	Readlink(context.Context, *SourceReadlinkRequest) (*SourceReadlinkResponse, error)
	// CreateView creates a new source view (called on mkdir/touch)
	CreateView(context.Context, *CreateViewRequest) (*CreateViewResponse, error)
	// GetView retrieves a view by its path
	GetView(context.Context, *GetViewRequest) (*GetViewResponse, error)
	// ListViews lists views under a parent path
	ListViews(context.Context, *ListViewsRequest) (*ListViewsResponse, error)
	// DeleteView removes a view by external_id
	DeleteView(context.Context, *DeleteViewRequest) (*DeleteViewResponse, error)
	// UpdateView updates an existing view's name/guidance
	UpdateView(context.Context, *UpdateViewRequest) (*UpdateViewResponse, error)
	// ExecuteView runs a view's query and returns materialized results
	ExecuteView(context.Context, *ExecuteViewRequest) (*ExecuteViewResponse, error)
	// SyncView re-executes a view's query, refreshing cached metadata
	SyncView(context.Context, *SyncViewRequest) (*SyncViewResponse, error)
	// ListResources returns available resources for an integration (repos, channels, etc.)
	ListResources(context.Context, *ListResourcesRequest) (*ListResourcesResponse, error)
	// contains filtered or unexported methods
}

SourceServiceServer is the server API for SourceService service. All implementations must embed UnimplementedSourceServiceServer for forward compatibility

type SourceStatRequest

type SourceStatRequest struct {
	Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // Path relative to /sources (e.g., "github/views/repos.json")
	// contains filtered or unexported fields
}

Stat

func (*SourceStatRequest) Descriptor deprecated

func (*SourceStatRequest) Descriptor() ([]byte, []int)

Deprecated: Use SourceStatRequest.ProtoReflect.Descriptor instead.

func (*SourceStatRequest) GetPath

func (x *SourceStatRequest) GetPath() string

func (*SourceStatRequest) ProtoMessage

func (*SourceStatRequest) ProtoMessage()

func (*SourceStatRequest) ProtoReflect

func (x *SourceStatRequest) ProtoReflect() protoreflect.Message

func (*SourceStatRequest) Reset

func (x *SourceStatRequest) Reset()

func (*SourceStatRequest) String

func (x *SourceStatRequest) String() string

type SourceStatResponse

type SourceStatResponse struct {
	Ok    bool            `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string          `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Info  *SourceFileInfo `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*SourceStatResponse) Descriptor deprecated

func (*SourceStatResponse) Descriptor() ([]byte, []int)

Deprecated: Use SourceStatResponse.ProtoReflect.Descriptor instead.

func (*SourceStatResponse) GetError

func (x *SourceStatResponse) GetError() string

func (*SourceStatResponse) GetInfo

func (x *SourceStatResponse) GetInfo() *SourceFileInfo

func (*SourceStatResponse) GetOk

func (x *SourceStatResponse) GetOk() bool

func (*SourceStatResponse) ProtoMessage

func (*SourceStatResponse) ProtoMessage()

func (*SourceStatResponse) ProtoReflect

func (x *SourceStatResponse) ProtoReflect() protoreflect.Message

func (*SourceStatResponse) Reset

func (x *SourceStatResponse) Reset()

func (*SourceStatResponse) String

func (x *SourceStatResponse) String() string

type SourceView added in v0.1.50

type SourceView struct {
	ExternalId   string `protobuf:"bytes,1,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"`
	Integration  string `protobuf:"bytes,2,opt,name=integration,proto3" json:"integration,omitempty"`                       // "gmail", "gdrive", etc.
	Path         string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`                                     // Full path: "/sources/gmail/unread-emails"
	Name         string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`                                     // Folder/file name
	QuerySpec    string `protobuf:"bytes,5,opt,name=query_spec,json=querySpec,proto3" json:"query_spec,omitempty"`          // JSON query params from LLM
	Guidance     string `protobuf:"bytes,6,opt,name=guidance,proto3" json:"guidance,omitempty"`                             // User-provided context for inference
	OutputFormat string `protobuf:"bytes,7,opt,name=output_format,json=outputFormat,proto3" json:"output_format,omitempty"` // "folder" or "file"
	FileExt      string `protobuf:"bytes,8,opt,name=file_ext,json=fileExt,proto3" json:"file_ext,omitempty"`                // For files: ".json", ".md"
	CacheTtl     int32  `protobuf:"varint,9,opt,name=cache_ttl,json=cacheTtl,proto3" json:"cache_ttl,omitempty"`            // Seconds, 0 = always live
	CreatedAt    int64  `protobuf:"varint,10,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`        // Unix timestamp
	UpdatedAt    int64  `protobuf:"varint,11,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	Mode         string `protobuf:"bytes,12,opt,name=mode,proto3" json:"mode,omitempty"`                                      // "smart" or "query"
	Filter       string `protobuf:"bytes,13,opt,name=filter,proto3" json:"filter,omitempty"`                                  // JSON structured filter (for query mode, enables round-trip editing)
	LastExecuted int64  `protobuf:"varint,14,opt,name=last_executed,json=lastExecuted,proto3" json:"last_executed,omitempty"` // Unix timestamp of last query execution (0 = never)
	// contains filtered or unexported fields
}

SourceView represents a stored view that materializes as filesystem content. A view can be created via LLM inference (smart mode) or structured filters (query mode).

func (*SourceView) Descriptor deprecated added in v0.1.50

func (*SourceView) Descriptor() ([]byte, []int)

Deprecated: Use SourceView.ProtoReflect.Descriptor instead.

func (*SourceView) GetCacheTtl added in v0.1.50

func (x *SourceView) GetCacheTtl() int32

func (*SourceView) GetCreatedAt added in v0.1.50

func (x *SourceView) GetCreatedAt() int64

func (*SourceView) GetExternalId added in v0.1.50

func (x *SourceView) GetExternalId() string

func (*SourceView) GetFileExt added in v0.1.50

func (x *SourceView) GetFileExt() string

func (*SourceView) GetFilter added in v0.1.50

func (x *SourceView) GetFilter() string

func (*SourceView) GetGuidance added in v0.1.50

func (x *SourceView) GetGuidance() string

func (*SourceView) GetIntegration added in v0.1.50

func (x *SourceView) GetIntegration() string

func (*SourceView) GetLastExecuted added in v0.1.51

func (x *SourceView) GetLastExecuted() int64

func (*SourceView) GetMode added in v0.1.50

func (x *SourceView) GetMode() string

func (*SourceView) GetName added in v0.1.50

func (x *SourceView) GetName() string

func (*SourceView) GetOutputFormat added in v0.1.50

func (x *SourceView) GetOutputFormat() string

func (*SourceView) GetPath added in v0.1.50

func (x *SourceView) GetPath() string

func (*SourceView) GetQuerySpec added in v0.1.50

func (x *SourceView) GetQuerySpec() string

func (*SourceView) GetUpdatedAt added in v0.1.50

func (x *SourceView) GetUpdatedAt() int64

func (*SourceView) ProtoMessage added in v0.1.50

func (*SourceView) ProtoMessage()

func (*SourceView) ProtoReflect added in v0.1.50

func (x *SourceView) ProtoReflect() protoreflect.Message

func (*SourceView) Reset added in v0.1.50

func (x *SourceView) Reset()

func (*SourceView) String added in v0.1.50

func (x *SourceView) String() string

type SourceWatchRequest added in v0.1.110

type SourceWatchRequest struct {
	Integration        string   `protobuf:"bytes,1,opt,name=integration,proto3" json:"integration,omitempty"`
	Reason             string   `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	Query              string   `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	FilenameFormat     string   `protobuf:"bytes,4,opt,name=filename_format,json=filenameFormat,proto3" json:"filename_format,omitempty"`
	EventTypes         []string `protobuf:"bytes,5,rep,name=event_types,json=eventTypes,proto3" json:"event_types,omitempty"`
	EntityKey          string   `protobuf:"bytes,6,opt,name=entity_key,json=entityKey,proto3" json:"entity_key,omitempty"`
	EntityLabel        string   `protobuf:"bytes,7,opt,name=entity_label,json=entityLabel,proto3" json:"entity_label,omitempty"`
	SourceOutputId     string   `protobuf:"bytes,8,opt,name=source_output_id,json=sourceOutputId,proto3" json:"source_output_id,omitempty"`
	ThreadId           string   `protobuf:"bytes,9,opt,name=thread_id,json=threadId,proto3" json:"thread_id,omitempty"`
	MessageId          string   `protobuf:"bytes,10,opt,name=message_id,json=messageId,proto3" json:"message_id,omitempty"`
	IncludeAttachments bool     `protobuf:"varint,11,opt,name=include_attachments,json=includeAttachments,proto3" json:"include_attachments,omitempty"`
	IncludeInline      bool     `protobuf:"varint,12,opt,name=include_inline,json=includeInline,proto3" json:"include_inline,omitempty"`
	IncludeMessageBody bool     `protobuf:"varint,13,opt,name=include_message_body,json=includeMessageBody,proto3" json:"include_message_body,omitempty"`
	// contains filtered or unexported fields
}

func (*SourceWatchRequest) Descriptor deprecated added in v0.1.110

func (*SourceWatchRequest) Descriptor() ([]byte, []int)

Deprecated: Use SourceWatchRequest.ProtoReflect.Descriptor instead.

func (*SourceWatchRequest) GetEntityKey added in v0.1.110

func (x *SourceWatchRequest) GetEntityKey() string

func (*SourceWatchRequest) GetEntityLabel added in v0.1.110

func (x *SourceWatchRequest) GetEntityLabel() string

func (*SourceWatchRequest) GetEventTypes added in v0.1.110

func (x *SourceWatchRequest) GetEventTypes() []string

func (*SourceWatchRequest) GetFilenameFormat added in v0.1.110

func (x *SourceWatchRequest) GetFilenameFormat() string

func (*SourceWatchRequest) GetIncludeAttachments added in v0.1.110

func (x *SourceWatchRequest) GetIncludeAttachments() bool

func (*SourceWatchRequest) GetIncludeInline added in v0.1.110

func (x *SourceWatchRequest) GetIncludeInline() bool

func (*SourceWatchRequest) GetIncludeMessageBody added in v0.1.110

func (x *SourceWatchRequest) GetIncludeMessageBody() bool

func (*SourceWatchRequest) GetIntegration added in v0.1.110

func (x *SourceWatchRequest) GetIntegration() string

func (*SourceWatchRequest) GetMessageId added in v0.1.110

func (x *SourceWatchRequest) GetMessageId() string

func (*SourceWatchRequest) GetQuery added in v0.1.110

func (x *SourceWatchRequest) GetQuery() string

func (*SourceWatchRequest) GetReason added in v0.1.110

func (x *SourceWatchRequest) GetReason() string

func (*SourceWatchRequest) GetSourceOutputId added in v0.1.110

func (x *SourceWatchRequest) GetSourceOutputId() string

func (*SourceWatchRequest) GetThreadId added in v0.1.110

func (x *SourceWatchRequest) GetThreadId() string

func (*SourceWatchRequest) ProtoMessage added in v0.1.110

func (*SourceWatchRequest) ProtoMessage()

func (*SourceWatchRequest) ProtoReflect added in v0.1.110

func (x *SourceWatchRequest) ProtoReflect() protoreflect.Message

func (*SourceWatchRequest) Reset added in v0.1.110

func (x *SourceWatchRequest) Reset()

func (*SourceWatchRequest) String added in v0.1.110

func (x *SourceWatchRequest) String() string

type StatRequest

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

Stat

func (*StatRequest) Descriptor deprecated

func (*StatRequest) Descriptor() ([]byte, []int)

Deprecated: Use StatRequest.ProtoReflect.Descriptor instead.

func (*StatRequest) GetPath

func (x *StatRequest) GetPath() string

func (*StatRequest) ProtoMessage

func (*StatRequest) ProtoMessage()

func (*StatRequest) ProtoReflect

func (x *StatRequest) ProtoReflect() protoreflect.Message

func (*StatRequest) Reset

func (x *StatRequest) Reset()

func (*StatRequest) String

func (x *StatRequest) String() string

type StatResponse

type StatResponse struct {
	Ok    bool      `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string    `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Info  *FileStat `protobuf:"bytes,3,opt,name=info,proto3" json:"info,omitempty"`
	// contains filtered or unexported fields
}

func (*StatResponse) Descriptor deprecated

func (*StatResponse) Descriptor() ([]byte, []int)

Deprecated: Use StatResponse.ProtoReflect.Descriptor instead.

func (*StatResponse) GetError

func (x *StatResponse) GetError() string

func (*StatResponse) GetInfo

func (x *StatResponse) GetInfo() *FileStat

func (*StatResponse) GetOk

func (x *StatResponse) GetOk() bool

func (*StatResponse) ProtoMessage

func (*StatResponse) ProtoMessage()

func (*StatResponse) ProtoReflect

func (x *StatResponse) ProtoReflect() protoreflect.Message

func (*StatResponse) Reset

func (x *StatResponse) Reset()

func (*StatResponse) String

func (x *StatResponse) String() string

type SubtaskRequest added in v0.1.110

type SubtaskRequest struct {
	SourceOutputId   string `protobuf:"bytes,1,opt,name=source_output_id,json=sourceOutputId,proto3" json:"source_output_id,omitempty"`
	EntityLabel      string `protobuf:"bytes,2,opt,name=entity_label,json=entityLabel,proto3" json:"entity_label,omitempty"`
	Prompt           string `protobuf:"bytes,3,opt,name=prompt,proto3" json:"prompt,omitempty"`
	WakeDelayMinutes int32  `protobuf:"varint,4,opt,name=wake_delay_minutes,json=wakeDelayMinutes,proto3" json:"wake_delay_minutes,omitempty"`
	// contains filtered or unexported fields
}

func (*SubtaskRequest) Descriptor deprecated added in v0.1.110

func (*SubtaskRequest) Descriptor() ([]byte, []int)

Deprecated: Use SubtaskRequest.ProtoReflect.Descriptor instead.

func (*SubtaskRequest) GetEntityLabel added in v0.1.110

func (x *SubtaskRequest) GetEntityLabel() string

func (*SubtaskRequest) GetPrompt added in v0.1.110

func (x *SubtaskRequest) GetPrompt() string

func (*SubtaskRequest) GetSourceOutputId added in v0.1.110

func (x *SubtaskRequest) GetSourceOutputId() string

func (*SubtaskRequest) GetWakeDelayMinutes added in v0.1.110

func (x *SubtaskRequest) GetWakeDelayMinutes() int32

func (*SubtaskRequest) ProtoMessage added in v0.1.110

func (*SubtaskRequest) ProtoMessage()

func (*SubtaskRequest) ProtoReflect added in v0.1.110

func (x *SubtaskRequest) ProtoReflect() protoreflect.Message

func (*SubtaskRequest) Reset added in v0.1.110

func (x *SubtaskRequest) Reset()

func (*SubtaskRequest) String added in v0.1.110

func (x *SubtaskRequest) String() string

type SyncViewRequest added in v0.1.50

type SyncViewRequest struct {
	ExternalId string `protobuf:"bytes,1,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"` // Stable view ID
	// contains filtered or unexported fields
}

SyncView - re-executes a view's query, refreshing cached metadata

func (*SyncViewRequest) Descriptor deprecated added in v0.1.50

func (*SyncViewRequest) Descriptor() ([]byte, []int)

Deprecated: Use SyncViewRequest.ProtoReflect.Descriptor instead.

func (*SyncViewRequest) GetExternalId added in v0.1.50

func (x *SyncViewRequest) GetExternalId() string

func (*SyncViewRequest) ProtoMessage added in v0.1.50

func (*SyncViewRequest) ProtoMessage()

func (*SyncViewRequest) ProtoReflect added in v0.1.50

func (x *SyncViewRequest) ProtoReflect() protoreflect.Message

func (*SyncViewRequest) Reset added in v0.1.50

func (x *SyncViewRequest) Reset()

func (*SyncViewRequest) String added in v0.1.50

func (x *SyncViewRequest) String() string

type SyncViewResponse added in v0.1.50

type SyncViewResponse struct {
	Ok           bool        `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error        string      `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	View         *SourceView `protobuf:"bytes,3,opt,name=view,proto3" json:"view,omitempty"`
	ResultsCount int32       `protobuf:"varint,4,opt,name=results_count,json=resultsCount,proto3" json:"results_count,omitempty"` // Total number of results after sync
	NewResults   int32       `protobuf:"varint,5,opt,name=new_results,json=newResults,proto3" json:"new_results,omitempty"`       // Number of newly detected results
	// contains filtered or unexported fields
}

func (*SyncViewResponse) Descriptor deprecated added in v0.1.50

func (*SyncViewResponse) Descriptor() ([]byte, []int)

Deprecated: Use SyncViewResponse.ProtoReflect.Descriptor instead.

func (*SyncViewResponse) GetError added in v0.1.50

func (x *SyncViewResponse) GetError() string

func (*SyncViewResponse) GetNewResults added in v0.1.50

func (x *SyncViewResponse) GetNewResults() int32

func (*SyncViewResponse) GetOk added in v0.1.50

func (x *SyncViewResponse) GetOk() bool

func (*SyncViewResponse) GetResultsCount added in v0.1.50

func (x *SyncViewResponse) GetResultsCount() int32

func (*SyncViewResponse) GetView added in v0.1.50

func (x *SyncViewResponse) GetView() *SourceView

func (*SyncViewResponse) ProtoMessage added in v0.1.50

func (*SyncViewResponse) ProtoMessage()

func (*SyncViewResponse) ProtoReflect added in v0.1.50

func (x *SyncViewResponse) ProtoReflect() protoreflect.Message

func (*SyncViewResponse) Reset added in v0.1.50

func (x *SyncViewResponse) Reset()

func (*SyncViewResponse) String added in v0.1.50

func (x *SyncViewResponse) String() string

type TaskLogEntry

type TaskLogEntry struct {
	TaskId    string `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	Timestamp int64  `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Stream    string `protobuf:"bytes,3,opt,name=stream,proto3" json:"stream,omitempty"`
	Data      string `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskLogEntry) Descriptor deprecated

func (*TaskLogEntry) Descriptor() ([]byte, []int)

Deprecated: Use TaskLogEntry.ProtoReflect.Descriptor instead.

func (*TaskLogEntry) GetData

func (x *TaskLogEntry) GetData() string

func (*TaskLogEntry) GetStream

func (x *TaskLogEntry) GetStream() string

func (*TaskLogEntry) GetTaskId

func (x *TaskLogEntry) GetTaskId() string

func (*TaskLogEntry) GetTimestamp

func (x *TaskLogEntry) GetTimestamp() int64

func (*TaskLogEntry) ProtoMessage

func (*TaskLogEntry) ProtoMessage()

func (*TaskLogEntry) ProtoReflect

func (x *TaskLogEntry) ProtoReflect() protoreflect.Message

func (*TaskLogEntry) Reset

func (x *TaskLogEntry) Reset()

func (*TaskLogEntry) String

func (x *TaskLogEntry) String() string

type Token

type Token struct {
	Id         string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name       string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	TokenType  string `protobuf:"bytes,3,opt,name=token_type,json=tokenType,proto3" json:"token_type,omitempty"` // "workspace_member" or "worker"
	MemberId   string `protobuf:"bytes,4,opt,name=member_id,json=memberId,proto3" json:"member_id,omitempty"`    // Set for workspace_member tokens
	PoolName   string `protobuf:"bytes,5,opt,name=pool_name,json=poolName,proto3" json:"pool_name,omitempty"`    // Set for worker tokens (optional)
	ExpiresAt  string `protobuf:"bytes,6,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
	CreatedAt  string `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	LastUsedAt string `protobuf:"bytes,8,opt,name=last_used_at,json=lastUsedAt,proto3" json:"last_used_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Token) Descriptor deprecated

func (*Token) Descriptor() ([]byte, []int)

Deprecated: Use Token.ProtoReflect.Descriptor instead.

func (*Token) GetCreatedAt

func (x *Token) GetCreatedAt() string

func (*Token) GetExpiresAt

func (x *Token) GetExpiresAt() string

func (*Token) GetId

func (x *Token) GetId() string

func (*Token) GetLastUsedAt

func (x *Token) GetLastUsedAt() string

func (*Token) GetMemberId

func (x *Token) GetMemberId() string

func (*Token) GetName

func (x *Token) GetName() string

func (*Token) GetPoolName

func (x *Token) GetPoolName() string

func (*Token) GetTokenType

func (x *Token) GetTokenType() string

func (*Token) ProtoMessage

func (*Token) ProtoMessage()

func (*Token) ProtoReflect

func (x *Token) ProtoReflect() protoreflect.Message

func (*Token) Reset

func (x *Token) Reset()

func (*Token) String

func (x *Token) String() string

type ToolInfo

type ToolInfo struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Help string `protobuf:"bytes,2,opt,name=help,proto3" json:"help,omitempty"`
	// If set, the tool runs locally inside the sandbox via this CLI command
	// rather than proxying through the gateway's ExecuteTool RPC.
	LocalCommand string `protobuf:"bytes,3,opt,name=local_command,json=localCommand,proto3" json:"local_command,omitempty"`
	// contains filtered or unexported fields
}

func (*ToolInfo) Descriptor deprecated

func (*ToolInfo) Descriptor() ([]byte, []int)

Deprecated: Use ToolInfo.ProtoReflect.Descriptor instead.

func (*ToolInfo) GetHelp

func (x *ToolInfo) GetHelp() string

func (*ToolInfo) GetLocalCommand added in v0.1.60

func (x *ToolInfo) GetLocalCommand() string

func (*ToolInfo) GetName

func (x *ToolInfo) GetName() string

func (*ToolInfo) ProtoMessage

func (*ToolInfo) ProtoMessage()

func (*ToolInfo) ProtoReflect

func (x *ToolInfo) ProtoReflect() protoreflect.Message

func (*ToolInfo) Reset

func (x *ToolInfo) Reset()

func (*ToolInfo) String

func (x *ToolInfo) String() string

type ToolServiceClient

type ToolServiceClient interface {
	// ListTools returns all registered tools
	ListTools(ctx context.Context, in *ListToolsRequest, opts ...grpc.CallOption) (*ListToolsResponse, error)
	// GetToolHelp returns help/usage information for a tool
	GetToolHelp(ctx context.Context, in *GetToolHelpRequest, opts ...grpc.CallOption) (*GetToolHelpResponse, error)
	// ExecuteTool runs a tool and streams output back
	ExecuteTool(ctx context.Context, in *ExecuteToolRequest, opts ...grpc.CallOption) (ToolService_ExecuteToolClient, error)
}

ToolServiceClient is the client API for ToolService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type ToolServiceServer

type ToolServiceServer interface {
	// ListTools returns all registered tools
	ListTools(context.Context, *ListToolsRequest) (*ListToolsResponse, error)
	// GetToolHelp returns help/usage information for a tool
	GetToolHelp(context.Context, *GetToolHelpRequest) (*GetToolHelpResponse, error)
	// ExecuteTool runs a tool and streams output back
	ExecuteTool(*ExecuteToolRequest, ToolService_ExecuteToolServer) error
	// contains filtered or unexported methods
}

ToolServiceServer is the server API for ToolService service. All implementations must embed UnimplementedToolServiceServer for forward compatibility

type ToolService_ExecuteToolClient

type ToolService_ExecuteToolClient interface {
	Recv() (*ExecuteToolResponse, error)
	grpc.ClientStream
}

type ToolService_ExecuteToolServer

type ToolService_ExecuteToolServer interface {
	Send(*ExecuteToolResponse) error
	grpc.ServerStream
}

type TreeEntry

type TreeEntry struct {
	Path  string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	Size  int64  `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"`
	Mtime int64  `protobuf:"varint,3,opt,name=mtime,proto3" json:"mtime,omitempty"`
	Mode  uint32 `protobuf:"varint,4,opt,name=mode,proto3" json:"mode,omitempty"`
	Etag  string `protobuf:"bytes,5,opt,name=etag,proto3" json:"etag,omitempty"`
	// contains filtered or unexported fields
}

func (*TreeEntry) Descriptor deprecated

func (*TreeEntry) Descriptor() ([]byte, []int)

Deprecated: Use TreeEntry.ProtoReflect.Descriptor instead.

func (*TreeEntry) GetEtag

func (x *TreeEntry) GetEtag() string

func (*TreeEntry) GetMode

func (x *TreeEntry) GetMode() uint32

func (*TreeEntry) GetMtime

func (x *TreeEntry) GetMtime() int64

func (*TreeEntry) GetPath

func (x *TreeEntry) GetPath() string

func (*TreeEntry) GetSize

func (x *TreeEntry) GetSize() int64

func (*TreeEntry) ProtoMessage

func (*TreeEntry) ProtoMessage()

func (*TreeEntry) ProtoReflect

func (x *TreeEntry) ProtoReflect() protoreflect.Message

func (*TreeEntry) Reset

func (x *TreeEntry) Reset()

func (*TreeEntry) String

func (x *TreeEntry) String() string

type UnimplementedAccessLogServiceServer added in v0.1.47

type UnimplementedAccessLogServiceServer struct {
}

UnimplementedAccessLogServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAccessLogServiceServer) IngestAccessEvents added in v0.1.47

type UnimplementedAgentServiceServer added in v0.1.60

type UnimplementedAgentServiceServer struct {
}

UnimplementedAgentServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAgentServiceServer) CancelAgentRun added in v0.1.60

func (UnimplementedAgentServiceServer) CreateAgentProfile added in v0.1.60

func (UnimplementedAgentServiceServer) CreateTask added in v0.1.60

func (UnimplementedAgentServiceServer) DeleteTask added in v0.1.60

func (UnimplementedAgentServiceServer) EnqueueRunInput added in v0.1.60

func (UnimplementedAgentServiceServer) GetAgentProfile added in v0.1.60

func (UnimplementedAgentServiceServer) GetAgentRun added in v0.1.60

func (UnimplementedAgentServiceServer) GetTask added in v0.1.60

func (UnimplementedAgentServiceServer) GetTaskLogs added in v0.1.60

func (UnimplementedAgentServiceServer) ListAgentProfiles added in v0.1.60

func (UnimplementedAgentServiceServer) ListAgentRunEvents added in v0.1.60

func (UnimplementedAgentServiceServer) ListAgentRunSnapshots added in v0.1.60

func (UnimplementedAgentServiceServer) ListAgentRuns added in v0.1.60

func (UnimplementedAgentServiceServer) ListTasks added in v0.1.60

type UnimplementedContextServiceServer

type UnimplementedContextServiceServer struct {
}

UnimplementedContextServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedContextServiceServer) Create

func (UnimplementedContextServiceServer) Delete

func (UnimplementedContextServiceServer) ListTree

func (UnimplementedContextServiceServer) Mkdir

func (UnimplementedContextServiceServer) Read

func (UnimplementedContextServiceServer) ReadDir

func (UnimplementedContextServiceServer) Rename

func (UnimplementedContextServiceServer) Stat

func (UnimplementedContextServiceServer) Truncate

func (UnimplementedContextServiceServer) Write

type UnimplementedFilesystemServiceServer

type UnimplementedFilesystemServiceServer struct {
}

UnimplementedFilesystemServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFilesystemServiceServer) Chmod

func (UnimplementedFilesystemServiceServer) Create

func (UnimplementedFilesystemServiceServer) Mkdir

func (UnimplementedFilesystemServiceServer) ReadDir

func (UnimplementedFilesystemServiceServer) Remove

func (UnimplementedFilesystemServiceServer) Rename

func (UnimplementedFilesystemServiceServer) Stat

type UnimplementedGatewayServiceServer

type UnimplementedGatewayServiceServer struct {
}

UnimplementedGatewayServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedGatewayServiceServer) AddConnection

func (UnimplementedGatewayServiceServer) AddMember

func (UnimplementedGatewayServiceServer) CreateHook added in v0.1.28

func (UnimplementedGatewayServiceServer) CreateToken

func (UnimplementedGatewayServiceServer) CreateWorkerToken

func (UnimplementedGatewayServiceServer) CreateWorkspace

func (UnimplementedGatewayServiceServer) DeleteHook added in v0.1.28

func (UnimplementedGatewayServiceServer) DeleteWorkspace

func (UnimplementedGatewayServiceServer) GetHook added in v0.1.28

func (UnimplementedGatewayServiceServer) GetWorkspace

func (UnimplementedGatewayServiceServer) ListConnections

func (UnimplementedGatewayServiceServer) ListHookRuns added in v0.1.28

func (UnimplementedGatewayServiceServer) ListHooks added in v0.1.28

func (UnimplementedGatewayServiceServer) ListMembers

func (UnimplementedGatewayServiceServer) ListTokens

func (UnimplementedGatewayServiceServer) ListWorkerTokens

func (UnimplementedGatewayServiceServer) ListWorkspaces

func (UnimplementedGatewayServiceServer) RemoveConnection

func (UnimplementedGatewayServiceServer) RemoveMember

func (UnimplementedGatewayServiceServer) RevokeToken

func (UnimplementedGatewayServiceServer) UpdateHook added in v0.1.28

type UnimplementedSourceServiceServer

type UnimplementedSourceServiceServer struct {
}

UnimplementedSourceServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSourceServiceServer) CreateView added in v0.1.50

func (UnimplementedSourceServiceServer) DeleteView added in v0.1.50

func (UnimplementedSourceServiceServer) ExecuteView added in v0.1.50

func (UnimplementedSourceServiceServer) GetView added in v0.1.50

func (UnimplementedSourceServiceServer) ListResources added in v0.1.50

func (UnimplementedSourceServiceServer) ListViews added in v0.1.50

func (UnimplementedSourceServiceServer) Read

func (UnimplementedSourceServiceServer) ReadDir

func (UnimplementedSourceServiceServer) Stat

func (UnimplementedSourceServiceServer) SyncView added in v0.1.50

func (UnimplementedSourceServiceServer) UpdateView added in v0.1.50

type UnimplementedToolServiceServer

type UnimplementedToolServiceServer struct {
}

UnimplementedToolServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedToolServiceServer) ExecuteTool

func (UnimplementedToolServiceServer) GetToolHelp

func (UnimplementedToolServiceServer) ListTools

type UnimplementedWorkerServiceServer

type UnimplementedWorkerServiceServer struct {
}

UnimplementedWorkerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedWorkerServiceServer) AckTaskInput added in v0.1.98

func (UnimplementedWorkerServiceServer) AllocateIP added in v0.1.23

func (UnimplementedWorkerServiceServer) AppendTaskOutputRows added in v0.1.96

func (UnimplementedWorkerServiceServer) ClaimTaskInput added in v0.1.98

func (UnimplementedWorkerServiceServer) CreateTaskOutput added in v0.1.96

func (UnimplementedWorkerServiceServer) Deregister

func (UnimplementedWorkerServiceServer) FinalizeTaskOutput added in v0.1.96

func (UnimplementedWorkerServiceServer) GetWorker

func (UnimplementedWorkerServiceServer) Heartbeat

func (UnimplementedWorkerServiceServer) ListWorkers added in v0.1.23

func (UnimplementedWorkerServiceServer) RegisterWorker

func (UnimplementedWorkerServiceServer) ReleaseIP added in v0.1.23

func (UnimplementedWorkerServiceServer) SetTaskResult

func (UnimplementedWorkerServiceServer) SetTaskStarted added in v0.1.28

func (UnimplementedWorkerServiceServer) UpdateStatus

func (UnimplementedWorkerServiceServer) UpdateTaskOutputStatus added in v0.1.106

func (UnimplementedWorkerServiceServer) UpdateTaskState added in v0.1.96

type UnsafeAccessLogServiceServer added in v0.1.47

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

UnsafeAccessLogServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AccessLogServiceServer will result in compilation errors.

type UnsafeAgentServiceServer added in v0.1.60

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

UnsafeAgentServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AgentServiceServer will result in compilation errors.

type UnsafeContextServiceServer

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

UnsafeContextServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ContextServiceServer will result in compilation errors.

type UnsafeFilesystemServiceServer

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

UnsafeFilesystemServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FilesystemServiceServer will result in compilation errors.

type UnsafeGatewayServiceServer

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

UnsafeGatewayServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to GatewayServiceServer will result in compilation errors.

type UnsafeSourceServiceServer

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

UnsafeSourceServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SourceServiceServer will result in compilation errors.

type UnsafeToolServiceServer

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

UnsafeToolServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ToolServiceServer will result in compilation errors.

type UnsafeWorkerServiceServer

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

UnsafeWorkerServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to WorkerServiceServer will result in compilation errors.

type UpdateHookRequest added in v0.1.28

type UpdateHookRequest struct {
	Id           string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Prompt       string `protobuf:"bytes,2,opt,name=prompt,proto3" json:"prompt,omitempty"`
	Active       bool   `protobuf:"varint,3,opt,name=active,proto3" json:"active,omitempty"`
	HasActive    bool   `protobuf:"varint,4,opt,name=has_active,json=hasActive,proto3" json:"has_active,omitempty"`
	SkillPath    string `protobuf:"bytes,5,opt,name=skill_path,json=skillPath,proto3" json:"skill_path,omitempty"`
	HasSkillPath bool   `protobuf:"varint,6,opt,name=has_skill_path,json=hasSkillPath,proto3" json:"has_skill_path,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateHookRequest) Descriptor deprecated added in v0.1.28

func (*UpdateHookRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateHookRequest.ProtoReflect.Descriptor instead.

func (*UpdateHookRequest) GetActive added in v0.1.28

func (x *UpdateHookRequest) GetActive() bool

func (*UpdateHookRequest) GetHasActive added in v0.1.28

func (x *UpdateHookRequest) GetHasActive() bool

func (*UpdateHookRequest) GetHasSkillPath added in v0.1.32

func (x *UpdateHookRequest) GetHasSkillPath() bool

func (*UpdateHookRequest) GetId added in v0.1.28

func (x *UpdateHookRequest) GetId() string

func (*UpdateHookRequest) GetPrompt added in v0.1.28

func (x *UpdateHookRequest) GetPrompt() string

func (*UpdateHookRequest) GetSkillPath added in v0.1.32

func (x *UpdateHookRequest) GetSkillPath() string

func (*UpdateHookRequest) ProtoMessage added in v0.1.28

func (*UpdateHookRequest) ProtoMessage()

func (*UpdateHookRequest) ProtoReflect added in v0.1.28

func (x *UpdateHookRequest) ProtoReflect() protoreflect.Message

func (*UpdateHookRequest) Reset added in v0.1.28

func (x *UpdateHookRequest) Reset()

func (*UpdateHookRequest) String added in v0.1.28

func (x *UpdateHookRequest) String() string

type UpdateStatusRequest

type UpdateStatusRequest struct {
	WorkerId string `protobuf:"bytes,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Status   string `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

Status update

func (*UpdateStatusRequest) Descriptor deprecated

func (*UpdateStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateStatusRequest.ProtoReflect.Descriptor instead.

func (*UpdateStatusRequest) GetStatus

func (x *UpdateStatusRequest) GetStatus() string

func (*UpdateStatusRequest) GetWorkerId

func (x *UpdateStatusRequest) GetWorkerId() string

func (*UpdateStatusRequest) ProtoMessage

func (*UpdateStatusRequest) ProtoMessage()

func (*UpdateStatusRequest) ProtoReflect

func (x *UpdateStatusRequest) ProtoReflect() protoreflect.Message

func (*UpdateStatusRequest) Reset

func (x *UpdateStatusRequest) Reset()

func (*UpdateStatusRequest) String

func (x *UpdateStatusRequest) String() string

type UpdateStatusResponse

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

func (*UpdateStatusResponse) Descriptor deprecated

func (*UpdateStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateStatusResponse.ProtoReflect.Descriptor instead.

func (*UpdateStatusResponse) ProtoMessage

func (*UpdateStatusResponse) ProtoMessage()

func (*UpdateStatusResponse) ProtoReflect

func (x *UpdateStatusResponse) ProtoReflect() protoreflect.Message

func (*UpdateStatusResponse) Reset

func (x *UpdateStatusResponse) Reset()

func (*UpdateStatusResponse) String

func (x *UpdateStatusResponse) String() string

type UpdateTaskOutputStatusRequest added in v0.1.106

type UpdateTaskOutputStatusRequest struct {
	WorkspaceId uint32 `protobuf:"varint,1,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	OutputId    string `protobuf:"bytes,2,opt,name=output_id,json=outputId,proto3" json:"output_id,omitempty"`
	Status      string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTaskOutputStatusRequest) Descriptor deprecated added in v0.1.106

func (*UpdateTaskOutputStatusRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateTaskOutputStatusRequest.ProtoReflect.Descriptor instead.

func (*UpdateTaskOutputStatusRequest) GetOutputId added in v0.1.106

func (x *UpdateTaskOutputStatusRequest) GetOutputId() string

func (*UpdateTaskOutputStatusRequest) GetStatus added in v0.1.106

func (x *UpdateTaskOutputStatusRequest) GetStatus() string

func (*UpdateTaskOutputStatusRequest) GetWorkspaceId added in v0.1.106

func (x *UpdateTaskOutputStatusRequest) GetWorkspaceId() uint32

func (*UpdateTaskOutputStatusRequest) ProtoMessage added in v0.1.106

func (*UpdateTaskOutputStatusRequest) ProtoMessage()

func (*UpdateTaskOutputStatusRequest) ProtoReflect added in v0.1.106

func (*UpdateTaskOutputStatusRequest) Reset added in v0.1.106

func (x *UpdateTaskOutputStatusRequest) Reset()

func (*UpdateTaskOutputStatusRequest) String added in v0.1.106

type UpdateTaskOutputStatusResponse added in v0.1.106

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

func (*UpdateTaskOutputStatusResponse) Descriptor deprecated added in v0.1.106

func (*UpdateTaskOutputStatusResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateTaskOutputStatusResponse.ProtoReflect.Descriptor instead.

func (*UpdateTaskOutputStatusResponse) ProtoMessage added in v0.1.106

func (*UpdateTaskOutputStatusResponse) ProtoMessage()

func (*UpdateTaskOutputStatusResponse) ProtoReflect added in v0.1.106

func (*UpdateTaskOutputStatusResponse) Reset added in v0.1.106

func (x *UpdateTaskOutputStatusResponse) Reset()

func (*UpdateTaskOutputStatusResponse) String added in v0.1.106

type UpdateTaskStateRequest added in v0.1.96

type UpdateTaskStateRequest struct {
	TaskId             string   `protobuf:"bytes,1,opt,name=task_id,json=taskId,proto3" json:"task_id,omitempty"`
	State              string   `protobuf:"bytes,2,opt,name=state,proto3" json:"state,omitempty"`
	RunId              string   `protobuf:"bytes,3,opt,name=run_id,json=runId,proto3" json:"run_id,omitempty"`
	InputKind          string   `protobuf:"bytes,4,opt,name=input_kind,json=inputKind,proto3" json:"input_kind,omitempty"`
	WaitingSummary     string   `protobuf:"bytes,5,opt,name=waiting_summary,json=waitingSummary,proto3" json:"waiting_summary,omitempty"`
	BlockerKind        string   `protobuf:"bytes,6,opt,name=blocker_kind,json=blockerKind,proto3" json:"blocker_kind,omitempty"`
	BlockerWaitGroupId string   `protobuf:"bytes,7,opt,name=blocker_wait_group_id,json=blockerWaitGroupId,proto3" json:"blocker_wait_group_id,omitempty"`
	BlockerPayloadJson string   `protobuf:"bytes,8,opt,name=blocker_payload_json,json=blockerPayloadJson,proto3" json:"blocker_payload_json,omitempty"`
	BlockerOutputIds   []string `protobuf:"bytes,9,rep,name=blocker_output_ids,json=blockerOutputIds,proto3" json:"blocker_output_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateTaskStateRequest) Descriptor deprecated added in v0.1.96

func (*UpdateTaskStateRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateTaskStateRequest.ProtoReflect.Descriptor instead.

func (*UpdateTaskStateRequest) GetBlockerKind added in v0.1.110

func (x *UpdateTaskStateRequest) GetBlockerKind() string

func (*UpdateTaskStateRequest) GetBlockerOutputIds added in v0.1.110

func (x *UpdateTaskStateRequest) GetBlockerOutputIds() []string

func (*UpdateTaskStateRequest) GetBlockerPayloadJson added in v0.1.110

func (x *UpdateTaskStateRequest) GetBlockerPayloadJson() string

func (*UpdateTaskStateRequest) GetBlockerWaitGroupId added in v0.1.110

func (x *UpdateTaskStateRequest) GetBlockerWaitGroupId() string

func (*UpdateTaskStateRequest) GetInputKind added in v0.1.98

func (x *UpdateTaskStateRequest) GetInputKind() string

func (*UpdateTaskStateRequest) GetRunId added in v0.1.96

func (x *UpdateTaskStateRequest) GetRunId() string

func (*UpdateTaskStateRequest) GetState added in v0.1.96

func (x *UpdateTaskStateRequest) GetState() string

func (*UpdateTaskStateRequest) GetTaskId added in v0.1.96

func (x *UpdateTaskStateRequest) GetTaskId() string

func (*UpdateTaskStateRequest) GetWaitingSummary added in v0.1.100

func (x *UpdateTaskStateRequest) GetWaitingSummary() string

func (*UpdateTaskStateRequest) ProtoMessage added in v0.1.96

func (*UpdateTaskStateRequest) ProtoMessage()

func (*UpdateTaskStateRequest) ProtoReflect added in v0.1.96

func (x *UpdateTaskStateRequest) ProtoReflect() protoreflect.Message

func (*UpdateTaskStateRequest) Reset added in v0.1.96

func (x *UpdateTaskStateRequest) Reset()

func (*UpdateTaskStateRequest) String added in v0.1.96

func (x *UpdateTaskStateRequest) String() string

type UpdateTaskStateResponse added in v0.1.96

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

func (*UpdateTaskStateResponse) Descriptor deprecated added in v0.1.96

func (*UpdateTaskStateResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateTaskStateResponse.ProtoReflect.Descriptor instead.

func (*UpdateTaskStateResponse) ProtoMessage added in v0.1.96

func (*UpdateTaskStateResponse) ProtoMessage()

func (*UpdateTaskStateResponse) ProtoReflect added in v0.1.96

func (x *UpdateTaskStateResponse) ProtoReflect() protoreflect.Message

func (*UpdateTaskStateResponse) Reset added in v0.1.96

func (x *UpdateTaskStateResponse) Reset()

func (*UpdateTaskStateResponse) String added in v0.1.96

func (x *UpdateTaskStateResponse) String() string

type UpdateViewRequest added in v0.1.50

type UpdateViewRequest struct {
	ExternalId string `protobuf:"bytes,1,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"` // Stable view ID (from SourceView.external_id)
	Name       string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`                               // New name (optional, triggers rename + path update)
	Guidance   string `protobuf:"bytes,3,opt,name=guidance,proto3" json:"guidance,omitempty"`                       // New guidance (triggers re-inference of query_spec)
	Filter     string `protobuf:"bytes,4,opt,name=filter,proto3" json:"filter,omitempty"`                           // New structured filter JSON (query mode)
	Mode       string `protobuf:"bytes,5,opt,name=mode,proto3" json:"mode,omitempty"`                               // Explicit mode: "smart" or "query" (triggers mode switch)
	// contains filtered or unexported fields
}

UpdateView - updates an existing view's name and/or guidance

func (*UpdateViewRequest) Descriptor deprecated added in v0.1.50

func (*UpdateViewRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateViewRequest.ProtoReflect.Descriptor instead.

func (*UpdateViewRequest) GetExternalId added in v0.1.50

func (x *UpdateViewRequest) GetExternalId() string

func (*UpdateViewRequest) GetFilter added in v0.1.50

func (x *UpdateViewRequest) GetFilter() string

func (*UpdateViewRequest) GetGuidance added in v0.1.50

func (x *UpdateViewRequest) GetGuidance() string

func (*UpdateViewRequest) GetMode added in v0.1.54

func (x *UpdateViewRequest) GetMode() string

func (*UpdateViewRequest) GetName added in v0.1.50

func (x *UpdateViewRequest) GetName() string

func (*UpdateViewRequest) ProtoMessage added in v0.1.50

func (*UpdateViewRequest) ProtoMessage()

func (*UpdateViewRequest) ProtoReflect added in v0.1.50

func (x *UpdateViewRequest) ProtoReflect() protoreflect.Message

func (*UpdateViewRequest) Reset added in v0.1.50

func (x *UpdateViewRequest) Reset()

func (*UpdateViewRequest) String added in v0.1.50

func (x *UpdateViewRequest) String() string

type UpdateViewResponse added in v0.1.50

type UpdateViewResponse struct {
	Ok    bool        `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error string      `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	View  *SourceView `protobuf:"bytes,3,opt,name=view,proto3" json:"view,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateViewResponse) Descriptor deprecated added in v0.1.50

func (*UpdateViewResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateViewResponse.ProtoReflect.Descriptor instead.

func (*UpdateViewResponse) GetError added in v0.1.50

func (x *UpdateViewResponse) GetError() string

func (*UpdateViewResponse) GetOk added in v0.1.50

func (x *UpdateViewResponse) GetOk() bool

func (*UpdateViewResponse) GetView added in v0.1.50

func (x *UpdateViewResponse) GetView() *SourceView

func (*UpdateViewResponse) ProtoMessage added in v0.1.50

func (*UpdateViewResponse) ProtoMessage()

func (*UpdateViewResponse) ProtoReflect added in v0.1.50

func (x *UpdateViewResponse) ProtoReflect() protoreflect.Message

func (*UpdateViewResponse) Reset added in v0.1.50

func (x *UpdateViewResponse) Reset()

func (*UpdateViewResponse) String added in v0.1.50

func (x *UpdateViewResponse) String() string

type WakeAgendaItem added in v0.1.103

type WakeAgendaItem struct {
	Type   string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Title  string `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
	Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*WakeAgendaItem) Descriptor deprecated added in v0.1.103

func (*WakeAgendaItem) Descriptor() ([]byte, []int)

Deprecated: Use WakeAgendaItem.ProtoReflect.Descriptor instead.

func (*WakeAgendaItem) GetReason added in v0.1.103

func (x *WakeAgendaItem) GetReason() string

func (*WakeAgendaItem) GetTitle added in v0.1.103

func (x *WakeAgendaItem) GetTitle() string

func (*WakeAgendaItem) GetType added in v0.1.103

func (x *WakeAgendaItem) GetType() string

func (*WakeAgendaItem) ProtoMessage added in v0.1.103

func (*WakeAgendaItem) ProtoMessage()

func (*WakeAgendaItem) ProtoReflect added in v0.1.103

func (x *WakeAgendaItem) ProtoReflect() protoreflect.Message

func (*WakeAgendaItem) Reset added in v0.1.103

func (x *WakeAgendaItem) Reset()

func (*WakeAgendaItem) String added in v0.1.103

func (x *WakeAgendaItem) String() string

type WakeSignal added in v0.1.96

type WakeSignal struct {
	DelayMinutes   int32             `protobuf:"varint,1,opt,name=delay_minutes,json=delayMinutes,proto3" json:"delay_minutes,omitempty"`
	Reason         string            `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	FollowUpPrompt string            `protobuf:"bytes,3,opt,name=follow_up_prompt,json=followUpPrompt,proto3" json:"follow_up_prompt,omitempty"`
	WakeAgenda     []*WakeAgendaItem `protobuf:"bytes,4,rep,name=wake_agenda,json=wakeAgenda,proto3" json:"wake_agenda,omitempty"`
	// contains filtered or unexported fields
}

func (*WakeSignal) Descriptor deprecated added in v0.1.96

func (*WakeSignal) Descriptor() ([]byte, []int)

Deprecated: Use WakeSignal.ProtoReflect.Descriptor instead.

func (*WakeSignal) GetDelayMinutes added in v0.1.96

func (x *WakeSignal) GetDelayMinutes() int32

func (*WakeSignal) GetFollowUpPrompt added in v0.1.96

func (x *WakeSignal) GetFollowUpPrompt() string

func (*WakeSignal) GetReason added in v0.1.96

func (x *WakeSignal) GetReason() string

func (*WakeSignal) GetWakeAgenda added in v0.1.103

func (x *WakeSignal) GetWakeAgenda() []*WakeAgendaItem

func (*WakeSignal) ProtoMessage added in v0.1.96

func (*WakeSignal) ProtoMessage()

func (*WakeSignal) ProtoReflect added in v0.1.96

func (x *WakeSignal) ProtoReflect() protoreflect.Message

func (*WakeSignal) Reset added in v0.1.96

func (x *WakeSignal) Reset()

func (*WakeSignal) String added in v0.1.96

func (x *WakeSignal) String() string

type WorkerServiceClient

type WorkerServiceClient interface {
	// Worker lifecycle
	RegisterWorker(ctx context.Context, in *RegisterWorkerRequest, opts ...grpc.CallOption) (*RegisterWorkerResponse, error)
	Heartbeat(ctx context.Context, in *HeartbeatRequest, opts ...grpc.CallOption) (*HeartbeatResponse, error)
	UpdateStatus(ctx context.Context, in *UpdateStatusRequest, opts ...grpc.CallOption) (*UpdateStatusResponse, error)
	Deregister(ctx context.Context, in *DeregisterRequest, opts ...grpc.CallOption) (*DeregisterResponse, error)
	GetWorker(ctx context.Context, in *GetWorkerRequest, opts ...grpc.CallOption) (*GetWorkerResponse, error)
	ListWorkers(ctx context.Context, in *ListWorkersRequest, opts ...grpc.CallOption) (*ListWorkersResponse, error)
	// Task lifecycle
	SetTaskStarted(ctx context.Context, in *SetTaskStartedRequest, opts ...grpc.CallOption) (*SetTaskStartedResponse, error)
	SetTaskResult(ctx context.Context, in *SetTaskResultRequest, opts ...grpc.CallOption) (*SetTaskResultResponse, error)
	UpdateTaskState(ctx context.Context, in *UpdateTaskStateRequest, opts ...grpc.CallOption) (*UpdateTaskStateResponse, error)
	// Network/IP management for sandboxes
	AllocateIP(ctx context.Context, in *AllocateIPRequest, opts ...grpc.CallOption) (*AllocateIPResponse, error)
	ReleaseIP(ctx context.Context, in *ReleaseIPRequest, opts ...grpc.CallOption) (*ReleaseIPResponse, error)
	// Task input inbox (durable follow-up claims)
	ClaimTaskInput(ctx context.Context, in *ClaimTaskInputRequest, opts ...grpc.CallOption) (*ClaimTaskInputResponse, error)
	AckTaskInput(ctx context.Context, in *AckTaskInputRequest, opts ...grpc.CallOption) (*AckTaskInputResponse, error)
	// Task outputs
	CreateTaskOutput(ctx context.Context, in *CreateTaskOutputRequest, opts ...grpc.CallOption) (*CreateTaskOutputResponse, error)
	AppendTaskOutputRows(ctx context.Context, in *AppendTaskOutputRowsRequest, opts ...grpc.CallOption) (*AppendTaskOutputRowsResponse, error)
	FinalizeTaskOutput(ctx context.Context, in *FinalizeTaskOutputRequest, opts ...grpc.CallOption) (*FinalizeTaskOutputResponse, error)
	UpdateTaskOutputStatus(ctx context.Context, in *UpdateTaskOutputStatusRequest, opts ...grpc.CallOption) (*UpdateTaskOutputStatusResponse, error)
}

WorkerServiceClient is the client API for WorkerService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type WorkerServiceServer

type WorkerServiceServer interface {
	// Worker lifecycle
	RegisterWorker(context.Context, *RegisterWorkerRequest) (*RegisterWorkerResponse, error)
	Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)
	UpdateStatus(context.Context, *UpdateStatusRequest) (*UpdateStatusResponse, error)
	Deregister(context.Context, *DeregisterRequest) (*DeregisterResponse, error)
	GetWorker(context.Context, *GetWorkerRequest) (*GetWorkerResponse, error)
	ListWorkers(context.Context, *ListWorkersRequest) (*ListWorkersResponse, error)
	// Task lifecycle
	SetTaskStarted(context.Context, *SetTaskStartedRequest) (*SetTaskStartedResponse, error)
	SetTaskResult(context.Context, *SetTaskResultRequest) (*SetTaskResultResponse, error)
	UpdateTaskState(context.Context, *UpdateTaskStateRequest) (*UpdateTaskStateResponse, error)
	// Network/IP management for sandboxes
	AllocateIP(context.Context, *AllocateIPRequest) (*AllocateIPResponse, error)
	ReleaseIP(context.Context, *ReleaseIPRequest) (*ReleaseIPResponse, error)
	// Task input inbox (durable follow-up claims)
	ClaimTaskInput(context.Context, *ClaimTaskInputRequest) (*ClaimTaskInputResponse, error)
	AckTaskInput(context.Context, *AckTaskInputRequest) (*AckTaskInputResponse, error)
	// Task outputs
	CreateTaskOutput(context.Context, *CreateTaskOutputRequest) (*CreateTaskOutputResponse, error)
	AppendTaskOutputRows(context.Context, *AppendTaskOutputRowsRequest) (*AppendTaskOutputRowsResponse, error)
	FinalizeTaskOutput(context.Context, *FinalizeTaskOutputRequest) (*FinalizeTaskOutputResponse, error)
	UpdateTaskOutputStatus(context.Context, *UpdateTaskOutputStatusRequest) (*UpdateTaskOutputStatusResponse, error)
	// contains filtered or unexported methods
}

WorkerServiceServer is the server API for WorkerService service. All implementations must embed UnimplementedWorkerServiceServer for forward compatibility

type Workspace

type Workspace struct {
	Id        string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	CreatedAt string `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	UpdatedAt string `protobuf:"bytes,4,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Workspace) Descriptor deprecated

func (*Workspace) Descriptor() ([]byte, []int)

Deprecated: Use Workspace.ProtoReflect.Descriptor instead.

func (*Workspace) GetCreatedAt

func (x *Workspace) GetCreatedAt() string

func (*Workspace) GetId

func (x *Workspace) GetId() string

func (*Workspace) GetName

func (x *Workspace) GetName() string

func (*Workspace) GetUpdatedAt

func (x *Workspace) GetUpdatedAt() string

func (*Workspace) ProtoMessage

func (*Workspace) ProtoMessage()

func (*Workspace) ProtoReflect

func (x *Workspace) ProtoReflect() protoreflect.Message

func (*Workspace) Reset

func (x *Workspace) Reset()

func (*Workspace) String

func (x *Workspace) String() string

type WorkspaceResponse

type WorkspaceResponse struct {
	Ok        bool       `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	Error     string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Workspace *Workspace `protobuf:"bytes,3,opt,name=workspace,proto3" json:"workspace,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkspaceResponse) Descriptor deprecated

func (*WorkspaceResponse) Descriptor() ([]byte, []int)

Deprecated: Use WorkspaceResponse.ProtoReflect.Descriptor instead.

func (*WorkspaceResponse) GetError

func (x *WorkspaceResponse) GetError() string

func (*WorkspaceResponse) GetOk

func (x *WorkspaceResponse) GetOk() bool

func (*WorkspaceResponse) GetWorkspace

func (x *WorkspaceResponse) GetWorkspace() *Workspace

func (*WorkspaceResponse) ProtoMessage

func (*WorkspaceResponse) ProtoMessage()

func (*WorkspaceResponse) ProtoReflect

func (x *WorkspaceResponse) ProtoReflect() protoreflect.Message

func (*WorkspaceResponse) Reset

func (x *WorkspaceResponse) Reset()

func (*WorkspaceResponse) String

func (x *WorkspaceResponse) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL