proto

package
v0.1.36 Latest Latest
Warning

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

 Go to latest Published: Feb 11, 2026 License: AGPL-3.0, AGPL-3.0-or-later Imports: 8 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_CreateTask_FullMethodName        = "/gateway.GatewayService/CreateTask"
	GatewayService_ListTasks_FullMethodName         = "/gateway.GatewayService/ListTasks"
	GatewayService_GetTask_FullMethodName           = "/gateway.GatewayService/GetTask"
	GatewayService_DeleteTask_FullMethodName        = "/gateway.GatewayService/DeleteTask"
	GatewayService_GetTaskLogs_FullMethodName       = "/gateway.GatewayService/GetTaskLogs"
	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 (
	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_CreateSmartQuery_FullMethodName  = "/sources.SourceService/CreateSmartQuery"
	SourceService_GetSmartQuery_FullMethodName     = "/sources.SourceService/GetSmartQuery"
	SourceService_ListSmartQueries_FullMethodName  = "/sources.SourceService/ListSmartQueries"
	SourceService_DeleteSmartQuery_FullMethodName  = "/sources.SourceService/DeleteSmartQuery"
	SourceService_UpdateSmartQuery_FullMethodName  = "/sources.SourceService/UpdateSmartQuery"
	SourceService_ExecuteSmartQuery_FullMethodName = "/sources.SourceService/ExecuteSmartQuery"
)
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_AllocateIP_FullMethodName     = "/worker.WorkerService/AllocateIP"
	WorkerService_ReleaseIP_FullMethodName      = "/worker.WorkerService/ReleaseIP"
)

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 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: "CreateTask",
			Handler:    _GatewayService_CreateTask_Handler,
		},
		{
			MethodName: "ListTasks",
			Handler:    _GatewayService_ListTasks_Handler,
		},
		{
			MethodName: "GetTask",
			Handler:    _GatewayService_GetTask_Handler,
		},
		{
			MethodName: "DeleteTask",
			Handler:    _GatewayService_DeleteTask_Handler,
		},
		{
			MethodName: "GetTaskLogs",
			Handler:    _GatewayService_GetTaskLogs_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: "CreateSmartQuery",
			Handler:    _SourceService_CreateSmartQuery_Handler,
		},
		{
			MethodName: "GetSmartQuery",
			Handler:    _SourceService_GetSmartQuery_Handler,
		},
		{
			MethodName: "ListSmartQueries",
			Handler:    _SourceService_ListSmartQueries_Handler,
		},
		{
			MethodName: "DeleteSmartQuery",
			Handler:    _SourceService_DeleteSmartQuery_Handler,
		},
		{
			MethodName: "UpdateSmartQuery",
			Handler:    _SourceService_UpdateSmartQuery_Handler,
		},
		{
			MethodName: "ExecuteSmartQuery",
			Handler:    _SourceService_ExecuteSmartQuery_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: "AllocateIP",
			Handler:    _WorkerService_AllocateIP_Handler,
		},
		{
			MethodName: "ReleaseIP",
			Handler:    _WorkerService_ReleaseIP_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 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 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 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"`
	// 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) GetIp added in v0.1.23 

func (x *AllocateIPResponse) GetIp() string

func (*AllocateIPResponse) GetPrefixLen added in v0.1.23 

func (x *AllocateIPResponse) GetPrefixLen() 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 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 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.

func NewContextServiceClient 

func NewContextServiceClient(cc grpc.ClientConnInterface) ContextServiceClient

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 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 CreateSmartQueryRequest 

type CreateSmartQueryRequest 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
	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"
	// contains filtered or unexported fields
}

CreateSmartQuery - creates a query from a folder/file name via LLM inference

func (*CreateSmartQueryRequest) Descriptor deprecated 

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

Deprecated: Use CreateSmartQueryRequest.ProtoReflect.Descriptor instead.

func (*CreateSmartQueryRequest) GetFileExt 

func (x *CreateSmartQueryRequest) GetFileExt() string

func (*CreateSmartQueryRequest) GetGuidance 

func (x *CreateSmartQueryRequest) GetGuidance() string

func (*CreateSmartQueryRequest) GetIntegration 

func (x *CreateSmartQueryRequest) GetIntegration() string

func (*CreateSmartQueryRequest) GetName 

func (x *CreateSmartQueryRequest) GetName() string

func (*CreateSmartQueryRequest) GetOutputFormat 

func (x *CreateSmartQueryRequest) GetOutputFormat() string

func (*CreateSmartQueryRequest) ProtoMessage 

func (*CreateSmartQueryRequest) ProtoMessage()

func (*CreateSmartQueryRequest) ProtoReflect 

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

func (*CreateSmartQueryRequest) Reset 

func (x *CreateSmartQueryRequest) Reset()

func (*CreateSmartQueryRequest) String 

func (x *CreateSmartQueryRequest) String() string

type CreateSmartQueryResponse 

type CreateSmartQueryResponse 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"`
	Query *SmartQuery `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSmartQueryResponse) Descriptor deprecated 

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

Deprecated: Use CreateSmartQueryResponse.ProtoReflect.Descriptor instead.

func (*CreateSmartQueryResponse) GetError 

func (x *CreateSmartQueryResponse) GetError() string

func (*CreateSmartQueryResponse) GetOk 

func (x *CreateSmartQueryResponse) GetOk() bool

func (*CreateSmartQueryResponse) GetQuery 

func (x *CreateSmartQueryResponse) GetQuery() *SmartQuery

func (*CreateSmartQueryResponse) ProtoMessage 

func (*CreateSmartQueryResponse) ProtoMessage()

func (*CreateSmartQueryResponse) ProtoReflect 

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

func (*CreateSmartQueryResponse) Reset 

func (x *CreateSmartQueryResponse) Reset()

func (*CreateSmartQueryResponse) String 

func (x *CreateSmartQueryResponse) String() string

type CreateTaskRequest added in v0.1.31 

type CreateTaskRequest struct {
	Prompt     string            `protobuf:"bytes,1,opt,name=prompt,proto3" json:"prompt,omitempty"`
	Image      string            `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	Entrypoint []string          `protobuf:"bytes,3,rep,name=entrypoint,proto3" json:"entrypoint,omitempty"`
	Env        map[string]string `` /* 147-byte string literal not displayed */
	// 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) GetEntrypoint added in v0.1.31 

func (x *CreateTaskRequest) GetEntrypoint() []string

func (*CreateTaskRequest) GetEnv added in v0.1.31 

func (x *CreateTaskRequest) GetEnv() map[string]string

func (*CreateTaskRequest) GetImage added in v0.1.31 

func (x *CreateTaskRequest) GetImage() string

func (*CreateTaskRequest) GetPrompt added in v0.1.31 

func (x *CreateTaskRequest) GetPrompt() string

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 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 DeleteSmartQueryRequest 

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

DeleteSmartQuery - removes a query by external_id

func (*DeleteSmartQueryRequest) Descriptor deprecated 

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

Deprecated: Use DeleteSmartQueryRequest.ProtoReflect.Descriptor instead.

func (*DeleteSmartQueryRequest) GetExternalId 

func (x *DeleteSmartQueryRequest) GetExternalId() string

func (*DeleteSmartQueryRequest) ProtoMessage 

func (*DeleteSmartQueryRequest) ProtoMessage()

func (*DeleteSmartQueryRequest) ProtoReflect 

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

func (*DeleteSmartQueryRequest) Reset 

func (x *DeleteSmartQueryRequest) Reset()

func (*DeleteSmartQueryRequest) String 

func (x *DeleteSmartQueryRequest) String() string

type DeleteSmartQueryResponse 

type DeleteSmartQueryResponse 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 (*DeleteSmartQueryResponse) Descriptor deprecated 

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

Deprecated: Use DeleteSmartQueryResponse.ProtoReflect.Descriptor instead.

func (*DeleteSmartQueryResponse) GetError 

func (x *DeleteSmartQueryResponse) GetError() string

func (*DeleteSmartQueryResponse) GetOk 

func (x *DeleteSmartQueryResponse) GetOk() bool

func (*DeleteSmartQueryResponse) ProtoMessage 

func (*DeleteSmartQueryResponse) ProtoMessage()

func (*DeleteSmartQueryResponse) ProtoReflect 

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

func (*DeleteSmartQueryResponse) Reset 

func (x *DeleteSmartQueryResponse) Reset()

func (*DeleteSmartQueryResponse) String 

func (x *DeleteSmartQueryResponse) 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 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 ExecuteSmartQueryRequest 

type ExecuteSmartQueryRequest struct {
	Path     string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`                         // Query 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
}

ExecuteSmartQuery - runs a query and returns results

func (*ExecuteSmartQueryRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteSmartQueryRequest.ProtoReflect.Descriptor instead.

func (*ExecuteSmartQueryRequest) GetFilename 

func (x *ExecuteSmartQueryRequest) GetFilename() string

func (*ExecuteSmartQueryRequest) GetPath 

func (x *ExecuteSmartQueryRequest) GetPath() string

func (*ExecuteSmartQueryRequest) GetResultId 

func (x *ExecuteSmartQueryRequest) GetResultId() string

func (*ExecuteSmartQueryRequest) ProtoMessage 

func (*ExecuteSmartQueryRequest) ProtoMessage()

func (*ExecuteSmartQueryRequest) ProtoReflect 

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

func (*ExecuteSmartQueryRequest) Reset 

func (x *ExecuteSmartQueryRequest) Reset()

func (*ExecuteSmartQueryRequest) String 

func (x *ExecuteSmartQueryRequest) String() string

type ExecuteSmartQueryResponse 

type ExecuteSmartQueryResponse 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 (*ExecuteSmartQueryResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteSmartQueryResponse.ProtoReflect.Descriptor instead.

func (*ExecuteSmartQueryResponse) GetEntries 

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

func (*ExecuteSmartQueryResponse) GetError 

func (x *ExecuteSmartQueryResponse) GetError() string

func (*ExecuteSmartQueryResponse) GetFileData 

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

func (*ExecuteSmartQueryResponse) GetOk 

func (x *ExecuteSmartQueryResponse) GetOk() bool

func (*ExecuteSmartQueryResponse) ProtoMessage 

func (*ExecuteSmartQueryResponse) ProtoMessage()

func (*ExecuteSmartQueryResponse) ProtoReflect 

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

func (*ExecuteSmartQueryResponse) Reset 

func (x *ExecuteSmartQueryResponse) Reset()

func (*ExecuteSmartQueryResponse) String 

func (x *ExecuteSmartQueryResponse) 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 (x *ExecuteToolResponse) GetStream() ExecuteToolResponse_StreamType

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) Descriptor() protoreflect.EnumDescriptor

func (ExecuteToolResponse_StreamType) Enum 

func (x ExecuteToolResponse_StreamType) Enum() *ExecuteToolResponse_StreamType

func (ExecuteToolResponse_StreamType) EnumDescriptor deprecated 

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

Deprecated: Use ExecuteToolResponse_StreamType.Descriptor instead.

func (ExecuteToolResponse_StreamType) Number 

func (x ExecuteToolResponse_StreamType) Number() protoreflect.EnumNumber

func (ExecuteToolResponse_StreamType) String 

func (x ExecuteToolResponse_StreamType) String() string

func (ExecuteToolResponse_StreamType) Type 

func (ExecuteToolResponse_StreamType) Type() protoreflect.EnumType

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.

func NewFilesystemServiceClient 

func NewFilesystemServiceClient(cc grpc.ClientConnInterface) FilesystemServiceClient

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 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)
	// Tasks
	CreateTask(ctx context.Context, in *CreateTaskRequest, opts ...grpc.CallOption) (*TaskResponse, error)
	ListTasks(ctx context.Context, in *ListTasksRequest, opts ...grpc.CallOption) (*ListTasksResponse, error)
	GetTask(ctx context.Context, in *GetTaskRequest, opts ...grpc.CallOption) (*TaskResponse, error)
	DeleteTask(ctx context.Context, in *DeleteTaskRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	GetTaskLogs(ctx context.Context, in *GetTaskLogsRequest, opts ...grpc.CallOption) (*GetTaskLogsResponse, 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.

func NewGatewayServiceClient 

func NewGatewayServiceClient(cc grpc.ClientConnInterface) GatewayServiceClient

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)
	// Tasks
	CreateTask(context.Context, *CreateTaskRequest) (*TaskResponse, error)
	ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)
	GetTask(context.Context, *GetTaskRequest) (*TaskResponse, error)
	DeleteTask(context.Context, *DeleteTaskRequest) (*DeleteResponse, error)
	GetTaskLogs(context.Context, *GetTaskLogsRequest) (*GetTaskLogsResponse, 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 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 GetSmartQueryRequest 

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

GetSmartQuery - retrieves a query by path

func (*GetSmartQueryRequest) Descriptor deprecated 

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

Deprecated: Use GetSmartQueryRequest.ProtoReflect.Descriptor instead.

func (*GetSmartQueryRequest) GetPath 

func (x *GetSmartQueryRequest) GetPath() string

func (*GetSmartQueryRequest) ProtoMessage 

func (*GetSmartQueryRequest) ProtoMessage()

func (*GetSmartQueryRequest) ProtoReflect 

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

func (*GetSmartQueryRequest) Reset 

func (x *GetSmartQueryRequest) Reset()

func (*GetSmartQueryRequest) String 

func (x *GetSmartQueryRequest) String() string

type GetSmartQueryResponse 

type GetSmartQueryResponse 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"`
	Query *SmartQuery `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"` // nil if not found
	// contains filtered or unexported fields
}

func (*GetSmartQueryResponse) Descriptor deprecated 

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

Deprecated: Use GetSmartQueryResponse.ProtoReflect.Descriptor instead.

func (*GetSmartQueryResponse) GetError 

func (x *GetSmartQueryResponse) GetError() string

func (*GetSmartQueryResponse) GetOk 

func (x *GetSmartQueryResponse) GetOk() bool

func (*GetSmartQueryResponse) GetQuery 

func (x *GetSmartQueryResponse) GetQuery() *SmartQuery

func (*GetSmartQueryResponse) ProtoMessage 

func (*GetSmartQueryResponse) ProtoMessage()

func (*GetSmartQueryResponse) ProtoReflect 

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

func (*GetSmartQueryResponse) Reset 

func (x *GetSmartQueryResponse) Reset()

func (*GetSmartQueryResponse) String 

func (x *GetSmartQueryResponse) 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 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 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 ListSmartQueriesRequest 

type ListSmartQueriesRequest 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
}

ListSmartQueries - lists queries under a parent path

func (*ListSmartQueriesRequest) Descriptor deprecated 

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

Deprecated: Use ListSmartQueriesRequest.ProtoReflect.Descriptor instead.

func (*ListSmartQueriesRequest) GetParentPath 

func (x *ListSmartQueriesRequest) GetParentPath() string

func (*ListSmartQueriesRequest) ProtoMessage 

func (*ListSmartQueriesRequest) ProtoMessage()

func (*ListSmartQueriesRequest) ProtoReflect 

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

func (*ListSmartQueriesRequest) Reset 

func (x *ListSmartQueriesRequest) Reset()

func (*ListSmartQueriesRequest) String 

func (x *ListSmartQueriesRequest) String() string

type ListSmartQueriesResponse 

type ListSmartQueriesResponse 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"`
	Queries []*SmartQuery `protobuf:"bytes,3,rep,name=queries,proto3" json:"queries,omitempty"`
	// contains filtered or unexported fields
}

func (*ListSmartQueriesResponse) Descriptor deprecated 

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

Deprecated: Use ListSmartQueriesResponse.ProtoReflect.Descriptor instead.

func (*ListSmartQueriesResponse) GetError 

func (x *ListSmartQueriesResponse) GetError() string

func (*ListSmartQueriesResponse) GetOk 

func (x *ListSmartQueriesResponse) GetOk() bool

func (*ListSmartQueriesResponse) GetQueries 

func (x *ListSmartQueriesResponse) GetQueries() []*SmartQuery

func (*ListSmartQueriesResponse) ProtoMessage 

func (*ListSmartQueriesResponse) ProtoMessage()

func (*ListSmartQueriesResponse) ProtoReflect 

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

func (*ListSmartQueriesResponse) Reset 

func (x *ListSmartQueriesResponse) Reset()

func (*ListSmartQueriesResponse) String 

func (x *ListSmartQueriesResponse) 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 []*Task `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() []*Task

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 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"`
	// contains filtered or unexported fields
}

func (*SetTaskResultRequest) Descriptor deprecated 

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

Deprecated: Use SetTaskResultRequest.ProtoReflect.Descriptor instead.

func (*SetTaskResultRequest) GetError 

func (x *SetTaskResultRequest) GetError() string

func (*SetTaskResultRequest) GetExitCode 

func (x *SetTaskResultRequest) GetExitCode() int32

func (*SetTaskResultRequest) GetTaskId 

func (x *SetTaskResultRequest) GetTaskId() string

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"`
	// 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) 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 SmartQuery 

type SmartQuery 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"`
	// contains filtered or unexported fields
}

SmartQuery represents a stored query that materializes as filesystem content

func (*SmartQuery) Descriptor deprecated 

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

Deprecated: Use SmartQuery.ProtoReflect.Descriptor instead.

func (*SmartQuery) GetCacheTtl 

func (x *SmartQuery) GetCacheTtl() int32

func (*SmartQuery) GetCreatedAt 

func (x *SmartQuery) GetCreatedAt() int64

func (*SmartQuery) GetExternalId 

func (x *SmartQuery) GetExternalId() string

func (*SmartQuery) GetFileExt 

func (x *SmartQuery) GetFileExt() string

func (*SmartQuery) GetGuidance 

func (x *SmartQuery) GetGuidance() string

func (*SmartQuery) GetIntegration 

func (x *SmartQuery) GetIntegration() string

func (*SmartQuery) GetName 

func (x *SmartQuery) GetName() string

func (*SmartQuery) GetOutputFormat 

func (x *SmartQuery) GetOutputFormat() string

func (*SmartQuery) GetPath 

func (x *SmartQuery) GetPath() string

func (*SmartQuery) GetQuerySpec 

func (x *SmartQuery) GetQuerySpec() string

func (*SmartQuery) GetUpdatedAt 

func (x *SmartQuery) GetUpdatedAt() int64

func (*SmartQuery) ProtoMessage 

func (*SmartQuery) ProtoMessage()

func (*SmartQuery) ProtoReflect 

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

func (*SmartQuery) Reset 

func (x *SmartQuery) Reset()

func (*SmartQuery) String 

func (x *SmartQuery) 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 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"`
	// contains filtered or unexported fields
}

func (*SourceReadResponse) Descriptor deprecated 

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

Deprecated: Use SourceReadResponse.ProtoReflect.Descriptor instead.

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 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)
	// CreateSmartQuery creates a new smart query (called on mkdir/touch)
	CreateSmartQuery(ctx context.Context, in *CreateSmartQueryRequest, opts ...grpc.CallOption) (*CreateSmartQueryResponse, error)
	// GetSmartQuery retrieves a query by its path
	GetSmartQuery(ctx context.Context, in *GetSmartQueryRequest, opts ...grpc.CallOption) (*GetSmartQueryResponse, error)
	// ListSmartQueries lists queries under a parent path
	ListSmartQueries(ctx context.Context, in *ListSmartQueriesRequest, opts ...grpc.CallOption) (*ListSmartQueriesResponse, error)
	// DeleteSmartQuery removes a query by external_id
	DeleteSmartQuery(ctx context.Context, in *DeleteSmartQueryRequest, opts ...grpc.CallOption) (*DeleteSmartQueryResponse, error)
	// UpdateSmartQuery updates an existing query's name/guidance
	UpdateSmartQuery(ctx context.Context, in *UpdateSmartQueryRequest, opts ...grpc.CallOption) (*UpdateSmartQueryResponse, error)
	// ExecuteSmartQuery runs a query and returns materialized results
	ExecuteSmartQuery(ctx context.Context, in *ExecuteSmartQueryRequest, opts ...grpc.CallOption) (*ExecuteSmartQueryResponse, 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.

func NewSourceServiceClient 

func NewSourceServiceClient(cc grpc.ClientConnInterface) SourceServiceClient

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)
	// CreateSmartQuery creates a new smart query (called on mkdir/touch)
	CreateSmartQuery(context.Context, *CreateSmartQueryRequest) (*CreateSmartQueryResponse, error)
	// GetSmartQuery retrieves a query by its path
	GetSmartQuery(context.Context, *GetSmartQueryRequest) (*GetSmartQueryResponse, error)
	// ListSmartQueries lists queries under a parent path
	ListSmartQueries(context.Context, *ListSmartQueriesRequest) (*ListSmartQueriesResponse, error)
	// DeleteSmartQuery removes a query by external_id
	DeleteSmartQuery(context.Context, *DeleteSmartQueryRequest) (*DeleteSmartQueryResponse, error)
	// UpdateSmartQuery updates an existing query's name/guidance
	UpdateSmartQuery(context.Context, *UpdateSmartQueryRequest) (*UpdateSmartQueryResponse, error)
	// ExecuteSmartQuery runs a query and returns materialized results
	ExecuteSmartQuery(context.Context, *ExecuteSmartQueryRequest) (*ExecuteSmartQueryResponse, 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 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 Task 

type Task 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"`
	Prompt      string `protobuf:"bytes,3,opt,name=prompt,proto3" json:"prompt,omitempty"`
	Image       string `protobuf:"bytes,4,opt,name=image,proto3" json:"image,omitempty"`
	ExitCode    int32  `protobuf:"varint,5,opt,name=exit_code,json=exitCode,proto3" json:"exit_code,omitempty"`
	HasExitCode bool   `protobuf:"varint,6,opt,name=has_exit_code,json=hasExitCode,proto3" json:"has_exit_code,omitempty"`
	Error       string `protobuf:"bytes,7,opt,name=error,proto3" json:"error,omitempty"`
	CreatedAt   string `protobuf:"bytes,8,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	StartedAt   string `protobuf:"bytes,9,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"`
	FinishedAt  string `protobuf:"bytes,10,opt,name=finished_at,json=finishedAt,proto3" json:"finished_at,omitempty"`
	// contains filtered or unexported fields
}

Task messages

func (*Task) Descriptor deprecated 

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

Deprecated: Use Task.ProtoReflect.Descriptor instead.

func (*Task) GetCreatedAt 

func (x *Task) GetCreatedAt() string

func (*Task) GetError 

func (x *Task) GetError() string

func (*Task) GetExitCode 

func (x *Task) GetExitCode() int32

func (*Task) GetFinishedAt 

func (x *Task) GetFinishedAt() string

func (*Task) GetHasExitCode 

func (x *Task) GetHasExitCode() bool

func (*Task) GetId 

func (x *Task) GetId() string

func (*Task) GetImage 

func (x *Task) GetImage() string

func (*Task) GetPrompt 

func (x *Task) GetPrompt() string

func (*Task) GetStartedAt 

func (x *Task) GetStartedAt() string

func (*Task) GetStatus 

func (x *Task) GetStatus() string

func (*Task) ProtoMessage 

func (*Task) ProtoMessage()

func (*Task) ProtoReflect 

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

func (*Task) Reset 

func (x *Task) Reset()

func (*Task) String 

func (x *Task) 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 TaskResponse 

type TaskResponse 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  *Task  `protobuf:"bytes,3,opt,name=task,proto3" json:"task,omitempty"`
	// contains filtered or unexported fields
}

func (*TaskResponse) Descriptor deprecated 

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

Deprecated: Use TaskResponse.ProtoReflect.Descriptor instead.

func (*TaskResponse) GetError 

func (x *TaskResponse) GetError() string

func (*TaskResponse) GetOk 

func (x *TaskResponse) GetOk() bool

func (*TaskResponse) GetTask 

func (x *TaskResponse) GetTask() *Task

func (*TaskResponse) ProtoMessage 

func (*TaskResponse) ProtoMessage()

func (*TaskResponse) ProtoReflect 

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

func (*TaskResponse) Reset 

func (x *TaskResponse) Reset()

func (*TaskResponse) String 

func (x *TaskResponse) 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"`
	// 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) 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.

func NewToolServiceClient 

func NewToolServiceClient(cc grpc.ClientConnInterface) ToolServiceClient

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 UnimplementedContextServiceServer 

type UnimplementedContextServiceServer struct {
}

UnimplementedContextServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedContextServiceServer) Create 

func (UnimplementedContextServiceServer) Create(context.Context, *ContextCreateRequest) (*ContextCreateResponse, error)

func (UnimplementedContextServiceServer) Delete 

func (UnimplementedContextServiceServer) Delete(context.Context, *ContextDeleteRequest) (*ContextDeleteResponse, error)

func (UnimplementedContextServiceServer) ListTree 

func (UnimplementedContextServiceServer) ListTree(context.Context, *ListTreeRequest) (*ListTreeResponse, error)

func (UnimplementedContextServiceServer) Mkdir 

func (UnimplementedContextServiceServer) Mkdir(context.Context, *ContextMkdirRequest) (*ContextMkdirResponse, error)

func (UnimplementedContextServiceServer) Read 

func (UnimplementedContextServiceServer) Read(context.Context, *ContextReadRequest) (*ContextReadResponse, error)

func (UnimplementedContextServiceServer) ReadDir 

func (UnimplementedContextServiceServer) ReadDir(context.Context, *ContextReadDirRequest) (*ContextReadDirResponse, error)
func (UnimplementedContextServiceServer) Readlink(context.Context, *ContextReadlinkRequest) (*ContextReadlinkResponse, error)

func (UnimplementedContextServiceServer) Rename 

func (UnimplementedContextServiceServer) Rename(context.Context, *ContextRenameRequest) (*ContextRenameResponse, error)

func (UnimplementedContextServiceServer) Stat 

func (UnimplementedContextServiceServer) Stat(context.Context, *ContextStatRequest) (*ContextStatResponse, error)
func (UnimplementedContextServiceServer) Symlink(context.Context, *ContextSymlinkRequest) (*ContextSymlinkResponse, error)

func (UnimplementedContextServiceServer) Truncate 

func (UnimplementedContextServiceServer) Truncate(context.Context, *ContextTruncateRequest) (*ContextTruncateResponse, error)

func (UnimplementedContextServiceServer) Write 

func (UnimplementedContextServiceServer) Write(context.Context, *ContextWriteRequest) (*ContextWriteResponse, error)

type UnimplementedFilesystemServiceServer 

type UnimplementedFilesystemServiceServer struct {
}

UnimplementedFilesystemServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedFilesystemServiceServer) Chmod 

func (UnimplementedFilesystemServiceServer) Chmod(context.Context, *ChmodRequest) (*ChmodResponse, error)

func (UnimplementedFilesystemServiceServer) Create 

func (UnimplementedFilesystemServiceServer) Create(context.Context, *CreateRequest) (*CreateResponse, error)

func (UnimplementedFilesystemServiceServer) Mkdir 

func (UnimplementedFilesystemServiceServer) Mkdir(context.Context, *MkdirRequest) (*MkdirResponse, error)

func (UnimplementedFilesystemServiceServer) ReadDir 

func (UnimplementedFilesystemServiceServer) ReadDir(context.Context, *ReadDirRequest) (*ReadDirResponse, error)

func (UnimplementedFilesystemServiceServer) Remove 

func (UnimplementedFilesystemServiceServer) Remove(context.Context, *RemoveRequest) (*RemoveResponse, error)

func (UnimplementedFilesystemServiceServer) Rename 

func (UnimplementedFilesystemServiceServer) Rename(context.Context, *RenameRequest) (*RenameResponse, error)

func (UnimplementedFilesystemServiceServer) Stat 

func (UnimplementedFilesystemServiceServer) Stat(context.Context, *StatRequest) (*StatResponse, error)

type UnimplementedGatewayServiceServer 

type UnimplementedGatewayServiceServer struct {
}

UnimplementedGatewayServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedGatewayServiceServer) AddConnection 

func (UnimplementedGatewayServiceServer) AddConnection(context.Context, *AddConnectionRequest) (*ConnectionResponse, error)

func (UnimplementedGatewayServiceServer) AddMember 

func (UnimplementedGatewayServiceServer) AddMember(context.Context, *AddMemberRequest) (*MemberResponse, error)

func (UnimplementedGatewayServiceServer) CreateHook added in v0.1.28 

func (UnimplementedGatewayServiceServer) CreateHook(context.Context, *CreateHookRequest) (*HookResponse, error)

func (UnimplementedGatewayServiceServer) CreateTask added in v0.1.31 

func (UnimplementedGatewayServiceServer) CreateTask(context.Context, *CreateTaskRequest) (*TaskResponse, error)

func (UnimplementedGatewayServiceServer) CreateToken 

func (UnimplementedGatewayServiceServer) CreateToken(context.Context, *CreateTokenRequest) (*CreateTokenResponse, error)

func (UnimplementedGatewayServiceServer) CreateWorkerToken 

func (UnimplementedGatewayServiceServer) CreateWorkerToken(context.Context, *CreateWorkerTokenRequest) (*CreateTokenResponse, error)

func (UnimplementedGatewayServiceServer) CreateWorkspace 

func (UnimplementedGatewayServiceServer) CreateWorkspace(context.Context, *CreateWorkspaceRequest) (*WorkspaceResponse, error)

func (UnimplementedGatewayServiceServer) DeleteHook added in v0.1.28 

func (UnimplementedGatewayServiceServer) DeleteHook(context.Context, *DeleteHookRequest) (*DeleteResponse, error)

func (UnimplementedGatewayServiceServer) DeleteTask added in v0.1.31 

func (UnimplementedGatewayServiceServer) DeleteTask(context.Context, *DeleteTaskRequest) (*DeleteResponse, error)

func (UnimplementedGatewayServiceServer) DeleteWorkspace 

func (UnimplementedGatewayServiceServer) DeleteWorkspace(context.Context, *DeleteWorkspaceRequest) (*DeleteResponse, error)

func (UnimplementedGatewayServiceServer) GetHook added in v0.1.28 

func (UnimplementedGatewayServiceServer) GetHook(context.Context, *GetHookRequest) (*HookResponse, error)

func (UnimplementedGatewayServiceServer) GetTask 

func (UnimplementedGatewayServiceServer) GetTask(context.Context, *GetTaskRequest) (*TaskResponse, error)

func (UnimplementedGatewayServiceServer) GetTaskLogs 

func (UnimplementedGatewayServiceServer) GetTaskLogs(context.Context, *GetTaskLogsRequest) (*GetTaskLogsResponse, error)

func (UnimplementedGatewayServiceServer) GetWorkspace 

func (UnimplementedGatewayServiceServer) GetWorkspace(context.Context, *GetWorkspaceRequest) (*WorkspaceResponse, error)

func (UnimplementedGatewayServiceServer) ListConnections 

func (UnimplementedGatewayServiceServer) ListConnections(context.Context, *ListConnectionsRequest) (*ListConnectionsResponse, error)

func (UnimplementedGatewayServiceServer) ListHookRuns added in v0.1.28 

func (UnimplementedGatewayServiceServer) ListHookRuns(context.Context, *ListHookRunsRequest) (*ListHookRunsResponse, error)

func (UnimplementedGatewayServiceServer) ListHooks added in v0.1.28 

func (UnimplementedGatewayServiceServer) ListHooks(context.Context, *ListHooksRequest) (*ListHooksResponse, error)

func (UnimplementedGatewayServiceServer) ListMembers 

func (UnimplementedGatewayServiceServer) ListMembers(context.Context, *ListMembersRequest) (*ListMembersResponse, error)

func (UnimplementedGatewayServiceServer) ListTasks 

func (UnimplementedGatewayServiceServer) ListTasks(context.Context, *ListTasksRequest) (*ListTasksResponse, error)

func (UnimplementedGatewayServiceServer) ListTokens 

func (UnimplementedGatewayServiceServer) ListTokens(context.Context, *ListTokensRequest) (*ListTokensResponse, error)

func (UnimplementedGatewayServiceServer) ListWorkerTokens 

func (UnimplementedGatewayServiceServer) ListWorkerTokens(context.Context, *ListWorkerTokensRequest) (*ListTokensResponse, error)

func (UnimplementedGatewayServiceServer) ListWorkspaces 

func (UnimplementedGatewayServiceServer) ListWorkspaces(context.Context, *ListWorkspacesRequest) (*ListWorkspacesResponse, error)

func (UnimplementedGatewayServiceServer) RemoveConnection 

func (UnimplementedGatewayServiceServer) RemoveConnection(context.Context, *RemoveConnectionRequest) (*DeleteResponse, error)

func (UnimplementedGatewayServiceServer) RemoveMember 

func (UnimplementedGatewayServiceServer) RemoveMember(context.Context, *RemoveMemberRequest) (*DeleteResponse, error)

func (UnimplementedGatewayServiceServer) RevokeToken 

func (UnimplementedGatewayServiceServer) RevokeToken(context.Context, *RevokeTokenRequest) (*DeleteResponse, error)

func (UnimplementedGatewayServiceServer) UpdateHook added in v0.1.28 

func (UnimplementedGatewayServiceServer) UpdateHook(context.Context, *UpdateHookRequest) (*HookResponse, error)

type UnimplementedSourceServiceServer 

type UnimplementedSourceServiceServer struct {
}

UnimplementedSourceServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSourceServiceServer) CreateSmartQuery 

func (UnimplementedSourceServiceServer) CreateSmartQuery(context.Context, *CreateSmartQueryRequest) (*CreateSmartQueryResponse, error)

func (UnimplementedSourceServiceServer) DeleteSmartQuery 

func (UnimplementedSourceServiceServer) DeleteSmartQuery(context.Context, *DeleteSmartQueryRequest) (*DeleteSmartQueryResponse, error)

func (UnimplementedSourceServiceServer) ExecuteSmartQuery 

func (UnimplementedSourceServiceServer) ExecuteSmartQuery(context.Context, *ExecuteSmartQueryRequest) (*ExecuteSmartQueryResponse, error)

func (UnimplementedSourceServiceServer) GetSmartQuery 

func (UnimplementedSourceServiceServer) GetSmartQuery(context.Context, *GetSmartQueryRequest) (*GetSmartQueryResponse, error)

func (UnimplementedSourceServiceServer) ListSmartQueries 

func (UnimplementedSourceServiceServer) ListSmartQueries(context.Context, *ListSmartQueriesRequest) (*ListSmartQueriesResponse, error)

func (UnimplementedSourceServiceServer) Read 

func (UnimplementedSourceServiceServer) Read(context.Context, *SourceReadRequest) (*SourceReadResponse, error)

func (UnimplementedSourceServiceServer) ReadDir 

func (UnimplementedSourceServiceServer) ReadDir(context.Context, *SourceReadDirRequest) (*SourceReadDirResponse, error)
func (UnimplementedSourceServiceServer) Readlink(context.Context, *SourceReadlinkRequest) (*SourceReadlinkResponse, error)

func (UnimplementedSourceServiceServer) Stat 

func (UnimplementedSourceServiceServer) Stat(context.Context, *SourceStatRequest) (*SourceStatResponse, error)

func (UnimplementedSourceServiceServer) UpdateSmartQuery 

func (UnimplementedSourceServiceServer) UpdateSmartQuery(context.Context, *UpdateSmartQueryRequest) (*UpdateSmartQueryResponse, error)

type UnimplementedToolServiceServer 

type UnimplementedToolServiceServer struct {
}

UnimplementedToolServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedToolServiceServer) ExecuteTool 

func (UnimplementedToolServiceServer) ExecuteTool(*ExecuteToolRequest, ToolService_ExecuteToolServer) error

func (UnimplementedToolServiceServer) GetToolHelp 

func (UnimplementedToolServiceServer) GetToolHelp(context.Context, *GetToolHelpRequest) (*GetToolHelpResponse, error)

func (UnimplementedToolServiceServer) ListTools 

func (UnimplementedToolServiceServer) ListTools(context.Context, *ListToolsRequest) (*ListToolsResponse, error)

type UnimplementedWorkerServiceServer 

type UnimplementedWorkerServiceServer struct {
}

UnimplementedWorkerServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedWorkerServiceServer) AllocateIP added in v0.1.23 

func (UnimplementedWorkerServiceServer) AllocateIP(context.Context, *AllocateIPRequest) (*AllocateIPResponse, error)

func (UnimplementedWorkerServiceServer) Deregister 

func (UnimplementedWorkerServiceServer) Deregister(context.Context, *DeregisterRequest) (*DeregisterResponse, error)

func (UnimplementedWorkerServiceServer) GetWorker 

func (UnimplementedWorkerServiceServer) GetWorker(context.Context, *GetWorkerRequest) (*GetWorkerResponse, error)

func (UnimplementedWorkerServiceServer) Heartbeat 

func (UnimplementedWorkerServiceServer) Heartbeat(context.Context, *HeartbeatRequest) (*HeartbeatResponse, error)

func (UnimplementedWorkerServiceServer) ListWorkers added in v0.1.23 

func (UnimplementedWorkerServiceServer) ListWorkers(context.Context, *ListWorkersRequest) (*ListWorkersResponse, error)

func (UnimplementedWorkerServiceServer) RegisterWorker 

func (UnimplementedWorkerServiceServer) RegisterWorker(context.Context, *RegisterWorkerRequest) (*RegisterWorkerResponse, error)

func (UnimplementedWorkerServiceServer) ReleaseIP added in v0.1.23 

func (UnimplementedWorkerServiceServer) ReleaseIP(context.Context, *ReleaseIPRequest) (*ReleaseIPResponse, error)

func (UnimplementedWorkerServiceServer) SetTaskResult 

func (UnimplementedWorkerServiceServer) SetTaskResult(context.Context, *SetTaskResultRequest) (*SetTaskResultResponse, error)

func (UnimplementedWorkerServiceServer) SetTaskStarted added in v0.1.28 

func (UnimplementedWorkerServiceServer) SetTaskStarted(context.Context, *SetTaskStartedRequest) (*SetTaskStartedResponse, error)

func (UnimplementedWorkerServiceServer) UpdateStatus 

func (UnimplementedWorkerServiceServer) UpdateStatus(context.Context, *UpdateStatusRequest) (*UpdateStatusResponse, error)

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 UpdateSmartQueryRequest 

type UpdateSmartQueryRequest struct {
	ExternalId string `protobuf:"bytes,1,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"` // Stable query ID (from SmartQuery.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)
	// contains filtered or unexported fields
}

UpdateSmartQuery - updates an existing query's name and/or guidance

func (*UpdateSmartQueryRequest) Descriptor deprecated 

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

Deprecated: Use UpdateSmartQueryRequest.ProtoReflect.Descriptor instead.

func (*UpdateSmartQueryRequest) GetExternalId 

func (x *UpdateSmartQueryRequest) GetExternalId() string

func (*UpdateSmartQueryRequest) GetGuidance 

func (x *UpdateSmartQueryRequest) GetGuidance() string

func (*UpdateSmartQueryRequest) GetName 

func (x *UpdateSmartQueryRequest) GetName() string

func (*UpdateSmartQueryRequest) ProtoMessage 

func (*UpdateSmartQueryRequest) ProtoMessage()

func (*UpdateSmartQueryRequest) ProtoReflect 

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

func (*UpdateSmartQueryRequest) Reset 

func (x *UpdateSmartQueryRequest) Reset()

func (*UpdateSmartQueryRequest) String 

func (x *UpdateSmartQueryRequest) String() string

type UpdateSmartQueryResponse 

type UpdateSmartQueryResponse 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"`
	Query *SmartQuery `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSmartQueryResponse) Descriptor deprecated 

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

Deprecated: Use UpdateSmartQueryResponse.ProtoReflect.Descriptor instead.

func (*UpdateSmartQueryResponse) GetError 

func (x *UpdateSmartQueryResponse) GetError() string

func (*UpdateSmartQueryResponse) GetOk 

func (x *UpdateSmartQueryResponse) GetOk() bool

func (*UpdateSmartQueryResponse) GetQuery 

func (x *UpdateSmartQueryResponse) GetQuery() *SmartQuery

func (*UpdateSmartQueryResponse) ProtoMessage 

func (*UpdateSmartQueryResponse) ProtoMessage()

func (*UpdateSmartQueryResponse) ProtoReflect 

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

func (*UpdateSmartQueryResponse) Reset 

func (x *UpdateSmartQueryResponse) Reset()

func (*UpdateSmartQueryResponse) String 

func (x *UpdateSmartQueryResponse) 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 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)
	// 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)
}

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.

func NewWorkerServiceClient 

func NewWorkerServiceClient(cc grpc.ClientConnInterface) WorkerServiceClient

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)
	// Network/IP management for sandboxes
	AllocateIP(context.Context, *AllocateIPRequest) (*AllocateIPResponse, error)
	ReleaseIP(context.Context, *ReleaseIPRequest) (*ReleaseIPResponse, 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.