v1

package
v1.5.3 Latest Latest
Warning

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

 Go to latest Published: Feb 6, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SubscribeResponse_MessageType_name = map[int32]string{
		0: "EVENT",
		1: "UPLOAD_STATUS",
		2: "UPLOAD_CANCEL",
		3: "SYNC_STATUS",
	}
	SubscribeResponse_MessageType_value = map[string]int32{
		"EVENT":         0,
		"UPLOAD_STATUS": 1,
		"UPLOAD_CANCEL": 2,
		"SYNC_STATUS":   3,
	}
)

Enum value maps for SubscribeResponse_MessageType.

View Source 
var (
	SubscribeResponse_UploadResponse_UploadStatus_name = map[int32]string{
		0: "INIT",
		1: "IN_PROGRESS",
		2: "COMPLETE",
	}
	SubscribeResponse_UploadResponse_UploadStatus_value = map[string]int32{
		"INIT":        0,
		"IN_PROGRESS": 1,
		"COMPLETE":    2,
	}
)

Enum value maps for SubscribeResponse_UploadResponse_UploadStatus.

View Source 
var (
	SubscribeResponse_SyncResponse_SyncStatus_name = map[int32]string{
		0: "INIT",
		1: "IN_PROGRESS",
		2: "COMPLETE",
	}
	SubscribeResponse_SyncResponse_SyncStatus_value = map[string]int32{
		"INIT":        0,
		"IN_PROGRESS": 1,
		"COMPLETE":    2,
	}
)

Enum value maps for SubscribeResponse_SyncResponse_SyncStatus.

View Source 
var (
	ListManifestFilesResponse_StatusType_name = map[int32]string{
		0: "LOCAL",
		1: "REGISTERED",
		2: "IMPORTED",
		3: "FINALIZED",
		4: "VERIFIED",
		5: "FAILED",
		6: "REMOVED",
		7: "UNKNOWN",
		8: "CHANGED",
		9: "UPLOADED",
	}
	ListManifestFilesResponse_StatusType_value = map[string]int32{
		"LOCAL":      0,
		"REGISTERED": 1,
		"IMPORTED":   2,
		"FINALIZED":  3,
		"VERIFIED":   4,
		"FAILED":     5,
		"REMOVED":    6,
		"UNKNOWN":    7,
		"CHANGED":    8,
		"UPLOADED":   9,
	}
)

Enum value maps for ListManifestFilesResponse_StatusType.

View Source 
var (
	WorkflowResponse_WorkflowType_name = map[int32]string{
		0: "PATH",
		1: "NAMED",
	}
	WorkflowResponse_WorkflowType_value = map[string]int32{
		"PATH":  0,
		"NAMED": 1,
	}
)

Enum value maps for WorkflowResponse_WorkflowType.

View Source 
var Agent_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "v1.Agent",
	HandlerType: (*AgentServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateManifest",
			Handler:    _Agent_CreateManifest_Handler,
		},
		{
			MethodName: "AddToManifest",
			Handler:    _Agent_AddToManifest_Handler,
		},
		{
			MethodName: "RemoveFromManifest",
			Handler:    _Agent_RemoveFromManifest_Handler,
		},
		{
			MethodName: "DeleteManifest",
			Handler:    _Agent_DeleteManifest_Handler,
		},
		{
			MethodName: "ListManifests",
			Handler:    _Agent_ListManifests_Handler,
		},
		{
			MethodName: "ListManifestFiles",
			Handler:    _Agent_ListManifestFiles_Handler,
		},
		{
			MethodName: "RelocateManifestFiles",
			Handler:    _Agent_RelocateManifestFiles_Handler,
		},
		{
			MethodName: "SyncManifest",
			Handler:    _Agent_SyncManifest_Handler,
		},
		{
			MethodName: "ResetManifest",
			Handler:    _Agent_ResetManifest_Handler,
		},
		{
			MethodName: "UploadManifest",
			Handler:    _Agent_UploadManifest_Handler,
		},
		{
			MethodName: "CancelUpload",
			Handler:    _Agent_CancelUpload_Handler,
		},
		{
			MethodName: "Version",
			Handler:    _Agent_Version_Handler,
		},
		{
			MethodName: "Unsubscribe",
			Handler:    _Agent_Unsubscribe_Handler,
		},
		{
			MethodName: "Stop",
			Handler:    _Agent_Stop_Handler,
		},
		{
			MethodName: "Ping",
			Handler:    _Agent_Ping_Handler,
		},
		{
			MethodName: "GetUser",
			Handler:    _Agent_GetUser_Handler,
		},
		{
			MethodName: "SwitchProfile",
			Handler:    _Agent_SwitchProfile_Handler,
		},
		{
			MethodName: "ReAuthenticate",
			Handler:    _Agent_ReAuthenticate_Handler,
		},
		{
			MethodName: "UseDataset",
			Handler:    _Agent_UseDataset_Handler,
		},
		{
			MethodName: "StartWorkflow",
			Handler:    _Agent_StartWorkflow_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Subscribe",
			Handler:       _Agent_Subscribe_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "api/v1/agent.proto",
}

Agent_ServiceDesc is the grpc.ServiceDesc for Agent 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_api_v1_agent_proto protoreflect.FileDescriptor

Functions

func RegisterAgentServer 

func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer)

Types

type AddToManifestRequest 

type AddToManifestRequest struct {
	ManifestId     int32    `protobuf:"varint,1,opt,name=manifest_id,json=manifestId,proto3" json:"manifest_id,omitempty"`
	BasePath       string   `protobuf:"bytes,2,opt,name=base_path,json=basePath,proto3" json:"base_path,omitempty"`
	TargetBasePath string   `protobuf:"bytes,3,opt,name=target_base_path,json=targetBasePath,proto3" json:"target_base_path,omitempty"`
	Recursive      bool     `protobuf:"varint,4,opt,name=recursive,proto3" json:"recursive,omitempty"`
	Files          []string `protobuf:"bytes,5,rep,name=files,proto3" json:"files,omitempty"`
	// contains filtered or unexported fields
}

func (*AddToManifestRequest) Descriptor deprecated 

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

Deprecated: Use AddToManifestRequest.ProtoReflect.Descriptor instead.

func (*AddToManifestRequest) GetBasePath 

func (x *AddToManifestRequest) GetBasePath() string

func (*AddToManifestRequest) GetFiles 

func (x *AddToManifestRequest) GetFiles() []string

func (*AddToManifestRequest) GetManifestId 

func (x *AddToManifestRequest) GetManifestId() int32

func (*AddToManifestRequest) GetRecursive 

func (x *AddToManifestRequest) GetRecursive() bool

func (*AddToManifestRequest) GetTargetBasePath 

func (x *AddToManifestRequest) GetTargetBasePath() string

func (*AddToManifestRequest) ProtoMessage 

func (*AddToManifestRequest) ProtoMessage()

func (*AddToManifestRequest) ProtoReflect 

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

func (*AddToManifestRequest) Reset 

func (x *AddToManifestRequest) Reset()

func (*AddToManifestRequest) String 

func (x *AddToManifestRequest) String() string

type AgentClient 

type AgentClient interface {
	// Manifest Endpoints
	CreateManifest(ctx context.Context, in *CreateManifestRequest, opts ...grpc.CallOption) (*CreateManifestResponse, error)
	AddToManifest(ctx context.Context, in *AddToManifestRequest, opts ...grpc.CallOption) (*SimpleStatusResponse, error)
	RemoveFromManifest(ctx context.Context, in *RemoveFromManifestRequest, opts ...grpc.CallOption) (*SimpleStatusResponse, error)
	DeleteManifest(ctx context.Context, in *DeleteManifestRequest, opts ...grpc.CallOption) (*SimpleStatusResponse, error)
	ListManifests(ctx context.Context, in *ListManifestsRequest, opts ...grpc.CallOption) (*ListManifestsResponse, error)
	ListManifestFiles(ctx context.Context, in *ListManifestFilesRequest, opts ...grpc.CallOption) (*ListManifestFilesResponse, error)
	RelocateManifestFiles(ctx context.Context, in *RelocateManifestFilesRequest, opts ...grpc.CallOption) (*SimpleStatusResponse, error)
	SyncManifest(ctx context.Context, in *SyncManifestRequest, opts ...grpc.CallOption) (*SyncManifestResponse, error)
	ResetManifest(ctx context.Context, in *ResetManifestRequest, opts ...grpc.CallOption) (*SimpleStatusResponse, error)
	// Upload Endpoints
	UploadManifest(ctx context.Context, in *UploadManifestRequest, opts ...grpc.CallOption) (*SimpleStatusResponse, error)
	CancelUpload(ctx context.Context, in *CancelUploadRequest, opts ...grpc.CallOption) (*SimpleStatusResponse, error)
	// Server Endpoints
	Version(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionResponse, error)
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Agent_SubscribeClient, error)
	Unsubscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*SubscribeResponse, error)
	Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	// User Endpoints
	GetUser(ctx context.Context, in *GetUserRequest, opts ...grpc.CallOption) (*UserResponse, error)
	SwitchProfile(ctx context.Context, in *SwitchProfileRequest, opts ...grpc.CallOption) (*UserResponse, error)
	ReAuthenticate(ctx context.Context, in *ReAuthenticateRequest, opts ...grpc.CallOption) (*UserResponse, error)
	// Datasets Endpoints
	UseDataset(ctx context.Context, in *UseDatasetRequest, opts ...grpc.CallOption) (*UseDatasetResponse, error)
	// Workflow Endpoints
	StartWorkflow(ctx context.Context, in *StartWorkflowRequest, opts ...grpc.CallOption) (*WorkflowResponse, error)
}

AgentClient is the client API for Agent 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 NewAgentClient 

func NewAgentClient(cc grpc.ClientConnInterface) AgentClient

type AgentServer 

type AgentServer interface {
	// Manifest Endpoints
	CreateManifest(context.Context, *CreateManifestRequest) (*CreateManifestResponse, error)
	AddToManifest(context.Context, *AddToManifestRequest) (*SimpleStatusResponse, error)
	RemoveFromManifest(context.Context, *RemoveFromManifestRequest) (*SimpleStatusResponse, error)
	DeleteManifest(context.Context, *DeleteManifestRequest) (*SimpleStatusResponse, error)
	ListManifests(context.Context, *ListManifestsRequest) (*ListManifestsResponse, error)
	ListManifestFiles(context.Context, *ListManifestFilesRequest) (*ListManifestFilesResponse, error)
	RelocateManifestFiles(context.Context, *RelocateManifestFilesRequest) (*SimpleStatusResponse, error)
	SyncManifest(context.Context, *SyncManifestRequest) (*SyncManifestResponse, error)
	ResetManifest(context.Context, *ResetManifestRequest) (*SimpleStatusResponse, error)
	// Upload Endpoints
	UploadManifest(context.Context, *UploadManifestRequest) (*SimpleStatusResponse, error)
	CancelUpload(context.Context, *CancelUploadRequest) (*SimpleStatusResponse, error)
	// Server Endpoints
	Version(context.Context, *VersionRequest) (*VersionResponse, error)
	Subscribe(*SubscribeRequest, Agent_SubscribeServer) error
	Unsubscribe(context.Context, *SubscribeRequest) (*SubscribeResponse, error)
	Stop(context.Context, *StopRequest) (*StopResponse, error)
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	// User Endpoints
	GetUser(context.Context, *GetUserRequest) (*UserResponse, error)
	SwitchProfile(context.Context, *SwitchProfileRequest) (*UserResponse, error)
	ReAuthenticate(context.Context, *ReAuthenticateRequest) (*UserResponse, error)
	// Datasets Endpoints
	UseDataset(context.Context, *UseDatasetRequest) (*UseDatasetResponse, error)
	// Workflow Endpoints
	StartWorkflow(context.Context, *StartWorkflowRequest) (*WorkflowResponse, error)
	// contains filtered or unexported methods
}

AgentServer is the server API for Agent service. All implementations must embed UnimplementedAgentServer for forward compatibility

type Agent_SubscribeClient 

type Agent_SubscribeClient interface {
	Recv() (*SubscribeResponse, error)
	grpc.ClientStream
}

type Agent_SubscribeServer 

type Agent_SubscribeServer interface {
	Send(*SubscribeResponse) error
	grpc.ServerStream
}

type CancelUploadRequest 

type CancelUploadRequest struct {
	ManifestId int32 `protobuf:"varint,1,opt,name=manifest_id,json=manifestId,proto3" json:"manifest_id,omitempty"`
	CancelAll  bool  `protobuf:"varint,2,opt,name=cancel_all,json=cancelAll,proto3" json:"cancel_all,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelUploadRequest) Descriptor deprecated 

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

Deprecated: Use CancelUploadRequest.ProtoReflect.Descriptor instead.

func (*CancelUploadRequest) GetCancelAll 

func (x *CancelUploadRequest) GetCancelAll() bool

func (*CancelUploadRequest) GetManifestId 

func (x *CancelUploadRequest) GetManifestId() int32

func (*CancelUploadRequest) ProtoMessage 

func (*CancelUploadRequest) ProtoMessage()

func (*CancelUploadRequest) ProtoReflect 

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

func (*CancelUploadRequest) Reset 

func (x *CancelUploadRequest) Reset()

func (*CancelUploadRequest) String 

func (x *CancelUploadRequest) String() string

type CreateManifestRequest 

type CreateManifestRequest struct {
	BasePath       string   `protobuf:"bytes,1,opt,name=base_path,json=basePath,proto3" json:"base_path,omitempty"`
	TargetBasePath string   `protobuf:"bytes,2,opt,name=target_base_path,json=targetBasePath,proto3" json:"target_base_path,omitempty"`
	Recursive      bool     `protobuf:"varint,3,opt,name=recursive,proto3" json:"recursive,omitempty"`
	Files          []string `protobuf:"bytes,4,rep,name=files,proto3" json:"files,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateManifestRequest) Descriptor deprecated 

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

Deprecated: Use CreateManifestRequest.ProtoReflect.Descriptor instead.

func (*CreateManifestRequest) GetBasePath 

func (x *CreateManifestRequest) GetBasePath() string

func (*CreateManifestRequest) GetFiles 

func (x *CreateManifestRequest) GetFiles() []string

func (*CreateManifestRequest) GetRecursive 

func (x *CreateManifestRequest) GetRecursive() bool

func (*CreateManifestRequest) GetTargetBasePath 

func (x *CreateManifestRequest) GetTargetBasePath() string

func (*CreateManifestRequest) ProtoMessage 

func (*CreateManifestRequest) ProtoMessage()

func (*CreateManifestRequest) ProtoReflect 

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

func (*CreateManifestRequest) Reset 

func (x *CreateManifestRequest) Reset()

func (*CreateManifestRequest) String 

func (x *CreateManifestRequest) String() string

type CreateManifestResponse 

type CreateManifestResponse struct {
	ManifestId int32  `protobuf:"varint,1,opt,name=manifest_id,json=manifestId,proto3" json:"manifest_id,omitempty"`
	Message    string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateManifestResponse) Descriptor deprecated 

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

Deprecated: Use CreateManifestResponse.ProtoReflect.Descriptor instead.

func (*CreateManifestResponse) GetManifestId 

func (x *CreateManifestResponse) GetManifestId() int32

func (*CreateManifestResponse) GetMessage 

func (x *CreateManifestResponse) GetMessage() string

func (*CreateManifestResponse) ProtoMessage 

func (*CreateManifestResponse) ProtoMessage()

func (*CreateManifestResponse) ProtoReflect 

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

func (*CreateManifestResponse) Reset 

func (x *CreateManifestResponse) Reset()

func (*CreateManifestResponse) String 

func (x *CreateManifestResponse) String() string

type DeleteManifestRequest 

type DeleteManifestRequest struct {
	ManifestId int32 `protobuf:"varint,1,opt,name=manifest_id,json=manifestId,proto3" json:"manifest_id,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteManifestRequest) Descriptor deprecated 

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

Deprecated: Use DeleteManifestRequest.ProtoReflect.Descriptor instead.

func (*DeleteManifestRequest) GetManifestId 

func (x *DeleteManifestRequest) GetManifestId() int32

func (*DeleteManifestRequest) ProtoMessage 

func (*DeleteManifestRequest) ProtoMessage()

func (*DeleteManifestRequest) ProtoReflect 

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

func (*DeleteManifestRequest) Reset 

func (x *DeleteManifestRequest) Reset()

func (*DeleteManifestRequest) String 

func (x *DeleteManifestRequest) String() string

type GetUserRequest 

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

func (*GetUserRequest) Descriptor deprecated 

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

Deprecated: Use GetUserRequest.ProtoReflect.Descriptor instead.

func (*GetUserRequest) ProtoMessage 

func (*GetUserRequest) ProtoMessage()

func (*GetUserRequest) ProtoReflect 

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

func (*GetUserRequest) Reset 

func (x *GetUserRequest) Reset()

func (*GetUserRequest) String 

func (x *GetUserRequest) String() string

type ListManifestFilesRequest 

type ListManifestFilesRequest struct {
	ManifestId int32 `protobuf:"varint,1,opt,name=manifest_id,json=manifestId,proto3" json:"manifest_id,omitempty"`
	Offset     int32 `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	Limit      int32 `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

func (*ListManifestFilesRequest) Descriptor deprecated 

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

Deprecated: Use ListManifestFilesRequest.ProtoReflect.Descriptor instead.

func (*ListManifestFilesRequest) GetLimit 

func (x *ListManifestFilesRequest) GetLimit() int32

func (*ListManifestFilesRequest) GetManifestId 

func (x *ListManifestFilesRequest) GetManifestId() int32

func (*ListManifestFilesRequest) GetOffset 

func (x *ListManifestFilesRequest) GetOffset() int32

func (*ListManifestFilesRequest) ProtoMessage 

func (*ListManifestFilesRequest) ProtoMessage()

func (*ListManifestFilesRequest) ProtoReflect 

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

func (*ListManifestFilesRequest) Reset 

func (x *ListManifestFilesRequest) Reset()

func (*ListManifestFilesRequest) String 

func (x *ListManifestFilesRequest) String() string

type ListManifestFilesResponse 

type ListManifestFilesResponse struct {
	File []*ListManifestFilesResponse_FileUpload `protobuf:"bytes,1,rep,name=file,proto3" json:"file,omitempty"`
	// contains filtered or unexported fields
}

func (*ListManifestFilesResponse) Descriptor deprecated 

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

Deprecated: Use ListManifestFilesResponse.ProtoReflect.Descriptor instead.

func (*ListManifestFilesResponse) GetFile 

func (x *ListManifestFilesResponse) GetFile() []*ListManifestFilesResponse_FileUpload

func (*ListManifestFilesResponse) ProtoMessage 

func (*ListManifestFilesResponse) ProtoMessage()

func (*ListManifestFilesResponse) ProtoReflect 

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

func (*ListManifestFilesResponse) Reset 

func (x *ListManifestFilesResponse) Reset()

func (*ListManifestFilesResponse) String 

func (x *ListManifestFilesResponse) String() string

type ListManifestFilesResponse_FileUpload 

type ListManifestFilesResponse_FileUpload struct {
	Id         int32                                `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	ManifestId int32                                `protobuf:"varint,2,opt,name=manifest_id,json=manifestId,proto3" json:"manifest_id,omitempty"`
	SourcePath string                               `protobuf:"bytes,3,opt,name=source_path,json=sourcePath,proto3" json:"source_path,omitempty"`
	TargetPath string                               `protobuf:"bytes,4,opt,name=target_path,json=targetPath,proto3" json:"target_path,omitempty"`
	UploadId   string                               `protobuf:"bytes,5,opt,name=upload_id,json=uploadId,proto3" json:"upload_id,omitempty"`
	Status     ListManifestFilesResponse_StatusType `protobuf:"varint,6,opt,name=status,proto3,enum=v1.ListManifestFilesResponse_StatusType" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ListManifestFilesResponse_FileUpload) Descriptor deprecated 

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

Deprecated: Use ListManifestFilesResponse_FileUpload.ProtoReflect.Descriptor instead.

func (*ListManifestFilesResponse_FileUpload) GetId 

func (x *ListManifestFilesResponse_FileUpload) GetId() int32

func (*ListManifestFilesResponse_FileUpload) GetManifestId 

func (x *ListManifestFilesResponse_FileUpload) GetManifestId() int32

func (*ListManifestFilesResponse_FileUpload) GetSourcePath 

func (x *ListManifestFilesResponse_FileUpload) GetSourcePath() string

func (*ListManifestFilesResponse_FileUpload) GetStatus 

func (x *ListManifestFilesResponse_FileUpload) GetStatus() ListManifestFilesResponse_StatusType

func (*ListManifestFilesResponse_FileUpload) GetTargetPath 

func (x *ListManifestFilesResponse_FileUpload) GetTargetPath() string

func (*ListManifestFilesResponse_FileUpload) GetUploadId 

func (x *ListManifestFilesResponse_FileUpload) GetUploadId() string

func (*ListManifestFilesResponse_FileUpload) ProtoMessage 

func (*ListManifestFilesResponse_FileUpload) ProtoMessage()

func (*ListManifestFilesResponse_FileUpload) ProtoReflect 

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

func (*ListManifestFilesResponse_FileUpload) Reset 

func (x *ListManifestFilesResponse_FileUpload) Reset()

func (*ListManifestFilesResponse_FileUpload) String 

func (x *ListManifestFilesResponse_FileUpload) String() string

type ListManifestFilesResponse_StatusType 

type ListManifestFilesResponse_StatusType int32
const (
	ListManifestFilesResponse_LOCAL      ListManifestFilesResponse_StatusType = 0 // File indexed locally
	ListManifestFilesResponse_REGISTERED ListManifestFilesResponse_StatusType = 1 // File manifest synchronized with Cloud
	ListManifestFilesResponse_IMPORTED   ListManifestFilesResponse_StatusType = 2
	ListManifestFilesResponse_FINALIZED  ListManifestFilesResponse_StatusType = 3
	ListManifestFilesResponse_VERIFIED   ListManifestFilesResponse_StatusType = 4
	ListManifestFilesResponse_FAILED     ListManifestFilesResponse_StatusType = 5 // File imported in cloud
	ListManifestFilesResponse_REMOVED    ListManifestFilesResponse_StatusType = 6 // File Upload canceled (manually, or failed)
	ListManifestFilesResponse_UNKNOWN    ListManifestFilesResponse_StatusType = 7
	ListManifestFilesResponse_CHANGED    ListManifestFilesResponse_StatusType = 8
	ListManifestFilesResponse_UPLOADED   ListManifestFilesResponse_StatusType = 9
)

func (ListManifestFilesResponse_StatusType) Descriptor 

func (ListManifestFilesResponse_StatusType) Descriptor() protoreflect.EnumDescriptor

func (ListManifestFilesResponse_StatusType) Enum 

func (x ListManifestFilesResponse_StatusType) Enum() *ListManifestFilesResponse_StatusType

func (ListManifestFilesResponse_StatusType) EnumDescriptor deprecated 

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

Deprecated: Use ListManifestFilesResponse_StatusType.Descriptor instead.

func (ListManifestFilesResponse_StatusType) Number 

func (x ListManifestFilesResponse_StatusType) Number() protoreflect.EnumNumber

func (ListManifestFilesResponse_StatusType) String 

func (x ListManifestFilesResponse_StatusType) String() string

func (ListManifestFilesResponse_StatusType) Type 

func (ListManifestFilesResponse_StatusType) Type() protoreflect.EnumType

type ListManifestsRequest 

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

func (*ListManifestsRequest) Descriptor deprecated 

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

Deprecated: Use ListManifestsRequest.ProtoReflect.Descriptor instead.

func (*ListManifestsRequest) ProtoMessage 

func (*ListManifestsRequest) ProtoMessage()

func (*ListManifestsRequest) ProtoReflect 

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

func (*ListManifestsRequest) Reset 

func (x *ListManifestsRequest) Reset()

func (*ListManifestsRequest) String 

func (x *ListManifestsRequest) String() string

type ListManifestsResponse 

type ListManifestsResponse struct {
	Manifests []*ListManifestsResponse_Manifest `protobuf:"bytes,1,rep,name=manifests,proto3" json:"manifests,omitempty"`
	// contains filtered or unexported fields
}

func (*ListManifestsResponse) Descriptor deprecated 

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

Deprecated: Use ListManifestsResponse.ProtoReflect.Descriptor instead.

func (*ListManifestsResponse) GetManifests 

func (x *ListManifestsResponse) GetManifests() []*ListManifestsResponse_Manifest

func (*ListManifestsResponse) ProtoMessage 

func (*ListManifestsResponse) ProtoMessage()

func (*ListManifestsResponse) ProtoReflect 

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

func (*ListManifestsResponse) Reset 

func (x *ListManifestsResponse) Reset()

func (*ListManifestsResponse) String 

func (x *ListManifestsResponse) String() string

type ListManifestsResponse_Manifest 

type ListManifestsResponse_Manifest struct {
	Id               int32  `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	NodeId           string `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3" json:"node_id,omitempty"`
	UserName         string `protobuf:"bytes,3,opt,name=user_name,json=userName,proto3" json:"user_name,omitempty"`
	UserId           string `protobuf:"bytes,4,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	OrganizationName string `protobuf:"bytes,5,opt,name=organization_name,json=organizationName,proto3" json:"organization_name,omitempty"`
	OrganizationId   string `protobuf:"bytes,6,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	DatasetName      string `protobuf:"bytes,7,opt,name=dataset_name,json=datasetName,proto3" json:"dataset_name,omitempty"`
	DatasetId        string `protobuf:"bytes,8,opt,name=dataset_id,json=datasetId,proto3" json:"dataset_id,omitempty"`
	Status           string `protobuf:"bytes,9,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ListManifestsResponse_Manifest) Descriptor deprecated 

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

Deprecated: Use ListManifestsResponse_Manifest.ProtoReflect.Descriptor instead.

func (*ListManifestsResponse_Manifest) GetDatasetId 

func (x *ListManifestsResponse_Manifest) GetDatasetId() string

func (*ListManifestsResponse_Manifest) GetDatasetName 

func (x *ListManifestsResponse_Manifest) GetDatasetName() string

func (*ListManifestsResponse_Manifest) GetId 

func (x *ListManifestsResponse_Manifest) GetId() int32

func (*ListManifestsResponse_Manifest) GetNodeId 

func (x *ListManifestsResponse_Manifest) GetNodeId() string

func (*ListManifestsResponse_Manifest) GetOrganizationId 

func (x *ListManifestsResponse_Manifest) GetOrganizationId() string

func (*ListManifestsResponse_Manifest) GetOrganizationName 

func (x *ListManifestsResponse_Manifest) GetOrganizationName() string

func (*ListManifestsResponse_Manifest) GetStatus 

func (x *ListManifestsResponse_Manifest) GetStatus() string

func (*ListManifestsResponse_Manifest) GetUserId 

func (x *ListManifestsResponse_Manifest) GetUserId() string

func (*ListManifestsResponse_Manifest) GetUserName 

func (x *ListManifestsResponse_Manifest) GetUserName() string

func (*ListManifestsResponse_Manifest) ProtoMessage 

func (*ListManifestsResponse_Manifest) ProtoMessage()

func (*ListManifestsResponse_Manifest) ProtoReflect 

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

func (*ListManifestsResponse_Manifest) Reset 

func (x *ListManifestsResponse_Manifest) Reset()

func (*ListManifestsResponse_Manifest) String 

func (x *ListManifestsResponse_Manifest) String() string

type PingRequest 

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

func (*PingRequest) Descriptor deprecated 

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

Deprecated: Use PingRequest.ProtoReflect.Descriptor instead.

func (*PingRequest) ProtoMessage 

func (*PingRequest) ProtoMessage()

func (*PingRequest) ProtoReflect 

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

func (*PingRequest) Reset 

func (x *PingRequest) Reset()

func (*PingRequest) String 

func (x *PingRequest) String() string

type PingResponse 

type PingResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*PingResponse) Descriptor deprecated 

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

Deprecated: Use PingResponse.ProtoReflect.Descriptor instead.

func (*PingResponse) GetSuccess 

func (x *PingResponse) GetSuccess() bool

func (*PingResponse) ProtoMessage 

func (*PingResponse) ProtoMessage()

func (*PingResponse) ProtoReflect 

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

func (*PingResponse) Reset 

func (x *PingResponse) Reset()

func (*PingResponse) String 

func (x *PingResponse) String() string

type ReAuthenticateRequest 

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

func (*ReAuthenticateRequest) Descriptor deprecated 

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

Deprecated: Use ReAuthenticateRequest.ProtoReflect.Descriptor instead.

func (*ReAuthenticateRequest) ProtoMessage 

func (*ReAuthenticateRequest) ProtoMessage()

func (*ReAuthenticateRequest) ProtoReflect 

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

func (*ReAuthenticateRequest) Reset 

func (x *ReAuthenticateRequest) Reset()

func (*ReAuthenticateRequest) String 

func (x *ReAuthenticateRequest) String() string

type RelocateManifestFilesRequest 

type RelocateManifestFilesRequest struct {
	ManifestId  int32  `protobuf:"varint,1,opt,name=manifest_id,json=manifestId,proto3" json:"manifest_id,omitempty"`
	Path        string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	UpdatedPath string `protobuf:"bytes,3,opt,name=updated_path,json=updatedPath,proto3" json:"updated_path,omitempty"`
	// contains filtered or unexported fields
}

func (*RelocateManifestFilesRequest) Descriptor deprecated 

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

Deprecated: Use RelocateManifestFilesRequest.ProtoReflect.Descriptor instead.

func (*RelocateManifestFilesRequest) GetManifestId 

func (x *RelocateManifestFilesRequest) GetManifestId() int32

func (*RelocateManifestFilesRequest) GetPath 

func (x *RelocateManifestFilesRequest) GetPath() string

func (*RelocateManifestFilesRequest) GetUpdatedPath 

func (x *RelocateManifestFilesRequest) GetUpdatedPath() string

func (*RelocateManifestFilesRequest) ProtoMessage 

func (*RelocateManifestFilesRequest) ProtoMessage()

func (*RelocateManifestFilesRequest) ProtoReflect 

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

func (*RelocateManifestFilesRequest) Reset 

func (x *RelocateManifestFilesRequest) Reset()

func (*RelocateManifestFilesRequest) String 

func (x *RelocateManifestFilesRequest) String() string

type RemoveFromManifestRequest 

type RemoveFromManifestRequest struct {
	ManifestId int32  `protobuf:"varint,1,opt,name=manifest_id,json=manifestId,proto3" json:"manifest_id,omitempty"`
	RemovePath string `protobuf:"bytes,3,opt,name=remove_path,json=removePath,proto3" json:"remove_path,omitempty"`
	// contains filtered or unexported fields
}

func (*RemoveFromManifestRequest) Descriptor deprecated 

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

Deprecated: Use RemoveFromManifestRequest.ProtoReflect.Descriptor instead.

func (*RemoveFromManifestRequest) GetManifestId 

func (x *RemoveFromManifestRequest) GetManifestId() int32

func (*RemoveFromManifestRequest) GetRemovePath 

func (x *RemoveFromManifestRequest) GetRemovePath() string

func (*RemoveFromManifestRequest) ProtoMessage 

func (*RemoveFromManifestRequest) ProtoMessage()

func (*RemoveFromManifestRequest) ProtoReflect 

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

func (*RemoveFromManifestRequest) Reset 

func (x *RemoveFromManifestRequest) Reset()

func (*RemoveFromManifestRequest) String 

func (x *RemoveFromManifestRequest) String() string

type ResetManifestRequest 

type ResetManifestRequest struct {
	ManifestId int32 `protobuf:"varint,1,opt,name=manifest_id,json=manifestId,proto3" json:"manifest_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ResetManifestRequest) Descriptor deprecated 

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

Deprecated: Use ResetManifestRequest.ProtoReflect.Descriptor instead.

func (*ResetManifestRequest) GetManifestId 

func (x *ResetManifestRequest) GetManifestId() int32

func (*ResetManifestRequest) ProtoMessage 

func (*ResetManifestRequest) ProtoMessage()

func (*ResetManifestRequest) ProtoReflect 

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

func (*ResetManifestRequest) Reset 

func (x *ResetManifestRequest) Reset()

func (*ResetManifestRequest) String 

func (x *ResetManifestRequest) String() string

type SimpleStatusResponse 

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

func (*SimpleStatusResponse) Descriptor deprecated 

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

Deprecated: Use SimpleStatusResponse.ProtoReflect.Descriptor instead.

func (*SimpleStatusResponse) GetStatus 

func (x *SimpleStatusResponse) GetStatus() string

func (*SimpleStatusResponse) ProtoMessage 

func (*SimpleStatusResponse) ProtoMessage()

func (*SimpleStatusResponse) ProtoReflect 

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

func (*SimpleStatusResponse) Reset 

func (x *SimpleStatusResponse) Reset()

func (*SimpleStatusResponse) String 

func (x *SimpleStatusResponse) String() string

type StartWorkflowRequest 

type StartWorkflowRequest struct {
	ManifestId   int32  `protobuf:"varint,1,opt,name=manifest_id,json=manifestId,proto3" json:"manifest_id,omitempty"`
	WorkflowFlag string `protobuf:"bytes,2,opt,name=workflowFlag,proto3" json:"workflowFlag,omitempty"`
	// contains filtered or unexported fields
}

func (*StartWorkflowRequest) Descriptor deprecated 

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

Deprecated: Use StartWorkflowRequest.ProtoReflect.Descriptor instead.

func (*StartWorkflowRequest) GetManifestId 

func (x *StartWorkflowRequest) GetManifestId() int32

func (*StartWorkflowRequest) GetWorkflowFlag 

func (x *StartWorkflowRequest) GetWorkflowFlag() string

func (*StartWorkflowRequest) ProtoMessage 

func (*StartWorkflowRequest) ProtoMessage()

func (*StartWorkflowRequest) ProtoReflect 

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

func (*StartWorkflowRequest) Reset 

func (x *StartWorkflowRequest) Reset()

func (*StartWorkflowRequest) String 

func (x *StartWorkflowRequest) String() string

type StopRequest 

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

func (*StopRequest) Descriptor deprecated 

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

Deprecated: Use StopRequest.ProtoReflect.Descriptor instead.

func (*StopRequest) ProtoMessage 

func (*StopRequest) ProtoMessage()

func (*StopRequest) ProtoReflect 

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

func (*StopRequest) Reset 

func (x *StopRequest) Reset()

func (*StopRequest) String 

func (x *StopRequest) String() string

type StopResponse 

type StopResponse struct {
	Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	// contains filtered or unexported fields
}

func (*StopResponse) Descriptor deprecated 

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

Deprecated: Use StopResponse.ProtoReflect.Descriptor instead.

func (*StopResponse) GetSuccess 

func (x *StopResponse) GetSuccess() bool

func (*StopResponse) ProtoMessage 

func (*StopResponse) ProtoMessage()

func (*StopResponse) ProtoReflect 

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

func (*StopResponse) Reset 

func (x *StopResponse) Reset()

func (*StopResponse) String 

func (x *StopResponse) String() string

type SubscribeRequest 

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

func (*SubscribeRequest) Descriptor deprecated 

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

Deprecated: Use SubscribeRequest.ProtoReflect.Descriptor instead.

func (*SubscribeRequest) GetId 

func (x *SubscribeRequest) GetId() int32

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) ProtoReflect 

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

func (*SubscribeRequest) Reset 

func (x *SubscribeRequest) Reset()

func (*SubscribeRequest) String 

func (x *SubscribeRequest) String() string

type SubscribeResponse 

type SubscribeResponse struct {
	Type SubscribeResponse_MessageType `protobuf:"varint,8,opt,name=type,proto3,enum=v1.SubscribeResponse_MessageType" json:"type,omitempty"`
	// Types that are assignable to MessageData:
	//
	//	*SubscribeResponse_UploadStatus
	//	*SubscribeResponse_EventInfo
	//	*SubscribeResponse_SyncStatus
	MessageData isSubscribeResponse_MessageData `protobuf_oneof:"message_data"`
	// contains filtered or unexported fields
}

func (*SubscribeResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeResponse.ProtoReflect.Descriptor instead.

func (*SubscribeResponse) GetEventInfo 

func (x *SubscribeResponse) GetEventInfo() *SubscribeResponse_EventResponse

func (*SubscribeResponse) GetMessageData 

func (m *SubscribeResponse) GetMessageData() isSubscribeResponse_MessageData

func (*SubscribeResponse) GetSyncStatus 

func (x *SubscribeResponse) GetSyncStatus() *SubscribeResponse_SyncResponse

func (*SubscribeResponse) GetType 

func (x *SubscribeResponse) GetType() SubscribeResponse_MessageType

func (*SubscribeResponse) GetUploadStatus 

func (x *SubscribeResponse) GetUploadStatus() *SubscribeResponse_UploadResponse

func (*SubscribeResponse) ProtoMessage 

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) ProtoReflect 

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

func (*SubscribeResponse) Reset 

func (x *SubscribeResponse) Reset()

func (*SubscribeResponse) String 

func (x *SubscribeResponse) String() string

type SubscribeResponse_EventInfo 

type SubscribeResponse_EventInfo struct {
	EventInfo *SubscribeResponse_EventResponse `protobuf:"bytes,10,opt,name=event_info,json=eventInfo,proto3,oneof"`
}

type SubscribeResponse_EventResponse 

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

func (*SubscribeResponse_EventResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeResponse_EventResponse.ProtoReflect.Descriptor instead.

func (*SubscribeResponse_EventResponse) GetDetails 

func (x *SubscribeResponse_EventResponse) GetDetails() string

func (*SubscribeResponse_EventResponse) ProtoMessage 

func (*SubscribeResponse_EventResponse) ProtoMessage()

func (*SubscribeResponse_EventResponse) ProtoReflect 

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

func (*SubscribeResponse_EventResponse) Reset 

func (x *SubscribeResponse_EventResponse) Reset()

func (*SubscribeResponse_EventResponse) String 

func (x *SubscribeResponse_EventResponse) String() string

type SubscribeResponse_MessageType 

type SubscribeResponse_MessageType int32
const (
	SubscribeResponse_EVENT         SubscribeResponse_MessageType = 0 // Server log message
	SubscribeResponse_UPLOAD_STATUS SubscribeResponse_MessageType = 1 // Upload Status Message
	SubscribeResponse_UPLOAD_CANCEL SubscribeResponse_MessageType = 2 // Upload was cancelled
	SubscribeResponse_SYNC_STATUS   SubscribeResponse_MessageType = 3 // Sync Status message
)

func (SubscribeResponse_MessageType) Descriptor 

func (SubscribeResponse_MessageType) Descriptor() protoreflect.EnumDescriptor

func (SubscribeResponse_MessageType) Enum 

func (x SubscribeResponse_MessageType) Enum() *SubscribeResponse_MessageType

func (SubscribeResponse_MessageType) EnumDescriptor deprecated 

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

Deprecated: Use SubscribeResponse_MessageType.Descriptor instead.

func (SubscribeResponse_MessageType) Number 

func (x SubscribeResponse_MessageType) Number() protoreflect.EnumNumber

func (SubscribeResponse_MessageType) String 

func (x SubscribeResponse_MessageType) String() string

func (SubscribeResponse_MessageType) Type 

func (SubscribeResponse_MessageType) Type() protoreflect.EnumType

type SubscribeResponse_SyncResponse 

type SubscribeResponse_SyncResponse struct {
	Status   SubscribeResponse_SyncResponse_SyncStatus `protobuf:"varint,1,opt,name=status,proto3,enum=v1.SubscribeResponse_SyncResponse_SyncStatus" json:"status,omitempty"`
	Total    int64                                     `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	NrSynced int64                                     `protobuf:"varint,3,opt,name=nr_synced,json=nrSynced,proto3" json:"nr_synced,omitempty"`
	WorkerId int32                                     `protobuf:"varint,4,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeResponse_SyncResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeResponse_SyncResponse.ProtoReflect.Descriptor instead.

func (*SubscribeResponse_SyncResponse) GetNrSynced 

func (x *SubscribeResponse_SyncResponse) GetNrSynced() int64

func (*SubscribeResponse_SyncResponse) GetStatus 

func (x *SubscribeResponse_SyncResponse) GetStatus() SubscribeResponse_SyncResponse_SyncStatus

func (*SubscribeResponse_SyncResponse) GetTotal 

func (x *SubscribeResponse_SyncResponse) GetTotal() int64

func (*SubscribeResponse_SyncResponse) GetWorkerId 

func (x *SubscribeResponse_SyncResponse) GetWorkerId() int32

func (*SubscribeResponse_SyncResponse) ProtoMessage 

func (*SubscribeResponse_SyncResponse) ProtoMessage()

func (*SubscribeResponse_SyncResponse) ProtoReflect 

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

func (*SubscribeResponse_SyncResponse) Reset 

func (x *SubscribeResponse_SyncResponse) Reset()

func (*SubscribeResponse_SyncResponse) String 

func (x *SubscribeResponse_SyncResponse) String() string

type SubscribeResponse_SyncResponse_SyncStatus 

type SubscribeResponse_SyncResponse_SyncStatus int32
const (
	SubscribeResponse_SyncResponse_INIT        SubscribeResponse_SyncResponse_SyncStatus = 0
	SubscribeResponse_SyncResponse_IN_PROGRESS SubscribeResponse_SyncResponse_SyncStatus = 1
	SubscribeResponse_SyncResponse_COMPLETE    SubscribeResponse_SyncResponse_SyncStatus = 2
)

func (SubscribeResponse_SyncResponse_SyncStatus) Descriptor 

func (SubscribeResponse_SyncResponse_SyncStatus) Descriptor() protoreflect.EnumDescriptor

func (SubscribeResponse_SyncResponse_SyncStatus) Enum 

func (x SubscribeResponse_SyncResponse_SyncStatus) Enum() *SubscribeResponse_SyncResponse_SyncStatus

func (SubscribeResponse_SyncResponse_SyncStatus) EnumDescriptor deprecated 

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

Deprecated: Use SubscribeResponse_SyncResponse_SyncStatus.Descriptor instead.

func (SubscribeResponse_SyncResponse_SyncStatus) Number 

func (x SubscribeResponse_SyncResponse_SyncStatus) Number() protoreflect.EnumNumber

func (SubscribeResponse_SyncResponse_SyncStatus) String 

func (x SubscribeResponse_SyncResponse_SyncStatus) String() string

func (SubscribeResponse_SyncResponse_SyncStatus) Type 

func (SubscribeResponse_SyncResponse_SyncStatus) Type() protoreflect.EnumType

type SubscribeResponse_SyncStatus 

type SubscribeResponse_SyncStatus struct {
	SyncStatus *SubscribeResponse_SyncResponse `protobuf:"bytes,11,opt,name=sync_status,json=syncStatus,proto3,oneof"`
}

type SubscribeResponse_UploadResponse 

type SubscribeResponse_UploadResponse struct {
	FileId   string                                        `protobuf:"bytes,1,opt,name=file_id,json=fileId,proto3" json:"file_id,omitempty"`
	Total    int64                                         `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	Current  int64                                         `protobuf:"varint,3,opt,name=current,proto3" json:"current,omitempty"`
	WorkerId int32                                         `protobuf:"varint,4,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	Status   SubscribeResponse_UploadResponse_UploadStatus `protobuf:"varint,5,opt,name=status,proto3,enum=v1.SubscribeResponse_UploadResponse_UploadStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeResponse_UploadResponse) Descriptor deprecated 

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

Deprecated: Use SubscribeResponse_UploadResponse.ProtoReflect.Descriptor instead.

func (*SubscribeResponse_UploadResponse) GetCurrent 

func (x *SubscribeResponse_UploadResponse) GetCurrent() int64

func (*SubscribeResponse_UploadResponse) GetFileId 

func (x *SubscribeResponse_UploadResponse) GetFileId() string

func (*SubscribeResponse_UploadResponse) GetStatus 

func (x *SubscribeResponse_UploadResponse) GetStatus() SubscribeResponse_UploadResponse_UploadStatus

func (*SubscribeResponse_UploadResponse) GetTotal 

func (x *SubscribeResponse_UploadResponse) GetTotal() int64

func (*SubscribeResponse_UploadResponse) GetWorkerId 

func (x *SubscribeResponse_UploadResponse) GetWorkerId() int32

func (*SubscribeResponse_UploadResponse) ProtoMessage 

func (*SubscribeResponse_UploadResponse) ProtoMessage()

func (*SubscribeResponse_UploadResponse) ProtoReflect 

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

func (*SubscribeResponse_UploadResponse) Reset 

func (x *SubscribeResponse_UploadResponse) Reset()

func (*SubscribeResponse_UploadResponse) String 

func (x *SubscribeResponse_UploadResponse) String() string

type SubscribeResponse_UploadResponse_UploadStatus 

type SubscribeResponse_UploadResponse_UploadStatus int32
const (
	SubscribeResponse_UploadResponse_INIT        SubscribeResponse_UploadResponse_UploadStatus = 0
	SubscribeResponse_UploadResponse_IN_PROGRESS SubscribeResponse_UploadResponse_UploadStatus = 1
	SubscribeResponse_UploadResponse_COMPLETE    SubscribeResponse_UploadResponse_UploadStatus = 2
)

func (SubscribeResponse_UploadResponse_UploadStatus) Descriptor 

func (SubscribeResponse_UploadResponse_UploadStatus) Descriptor() protoreflect.EnumDescriptor

func (SubscribeResponse_UploadResponse_UploadStatus) Enum 

func (x SubscribeResponse_UploadResponse_UploadStatus) Enum() *SubscribeResponse_UploadResponse_UploadStatus

func (SubscribeResponse_UploadResponse_UploadStatus) EnumDescriptor deprecated 

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

Deprecated: Use SubscribeResponse_UploadResponse_UploadStatus.Descriptor instead.

func (SubscribeResponse_UploadResponse_UploadStatus) Number 

func (x SubscribeResponse_UploadResponse_UploadStatus) Number() protoreflect.EnumNumber

func (SubscribeResponse_UploadResponse_UploadStatus) String 

func (x SubscribeResponse_UploadResponse_UploadStatus) String() string

func (SubscribeResponse_UploadResponse_UploadStatus) Type 

func (SubscribeResponse_UploadResponse_UploadStatus) Type() protoreflect.EnumType

type SubscribeResponse_UploadStatus 

type SubscribeResponse_UploadStatus struct {
	UploadStatus *SubscribeResponse_UploadResponse `protobuf:"bytes,9,opt,name=upload_status,json=uploadStatus,proto3,oneof"`
}

type SwitchProfileRequest 

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

func (*SwitchProfileRequest) Descriptor deprecated 

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

Deprecated: Use SwitchProfileRequest.ProtoReflect.Descriptor instead.

func (*SwitchProfileRequest) GetProfile 

func (x *SwitchProfileRequest) GetProfile() string

func (*SwitchProfileRequest) ProtoMessage 

func (*SwitchProfileRequest) ProtoMessage()

func (*SwitchProfileRequest) ProtoReflect 

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

func (*SwitchProfileRequest) Reset 

func (x *SwitchProfileRequest) Reset()

func (*SwitchProfileRequest) String 

func (x *SwitchProfileRequest) String() string

type SyncManifestRequest 

type SyncManifestRequest struct {
	ManifestId int32 `protobuf:"varint,1,opt,name=manifest_id,json=manifestId,proto3" json:"manifest_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncManifestRequest) Descriptor deprecated 

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

Deprecated: Use SyncManifestRequest.ProtoReflect.Descriptor instead.

func (*SyncManifestRequest) GetManifestId 

func (x *SyncManifestRequest) GetManifestId() int32

func (*SyncManifestRequest) ProtoMessage 

func (*SyncManifestRequest) ProtoMessage()

func (*SyncManifestRequest) ProtoReflect 

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

func (*SyncManifestRequest) Reset 

func (x *SyncManifestRequest) Reset()

func (*SyncManifestRequest) String 

func (x *SyncManifestRequest) String() string

type SyncManifestResponse 

type SyncManifestResponse struct {
	ManifestNodeId string `protobuf:"bytes,1,opt,name=manifest_node_id,json=manifestNodeId,proto3" json:"manifest_node_id,omitempty"`
	NrFilesUpdated int32  `protobuf:"varint,2,opt,name=nr_files_updated,json=nrFilesUpdated,proto3" json:"nr_files_updated,omitempty"`
	NrFilesRemoved int32  `protobuf:"varint,3,opt,name=nr_files_removed,json=nrFilesRemoved,proto3" json:"nr_files_removed,omitempty"`
	NrFilesFailed  int32  `protobuf:"varint,4,opt,name=nr_files_failed,json=nrFilesFailed,proto3" json:"nr_files_failed,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncManifestResponse) Descriptor deprecated 

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

Deprecated: Use SyncManifestResponse.ProtoReflect.Descriptor instead.

func (*SyncManifestResponse) GetManifestNodeId 

func (x *SyncManifestResponse) GetManifestNodeId() string

func (*SyncManifestResponse) GetNrFilesFailed 

func (x *SyncManifestResponse) GetNrFilesFailed() int32

func (*SyncManifestResponse) GetNrFilesRemoved 

func (x *SyncManifestResponse) GetNrFilesRemoved() int32

func (*SyncManifestResponse) GetNrFilesUpdated 

func (x *SyncManifestResponse) GetNrFilesUpdated() int32

func (*SyncManifestResponse) ProtoMessage 

func (*SyncManifestResponse) ProtoMessage()

func (*SyncManifestResponse) ProtoReflect 

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

func (*SyncManifestResponse) Reset 

func (x *SyncManifestResponse) Reset()

func (*SyncManifestResponse) String 

func (x *SyncManifestResponse) String() string

type UnimplementedAgentServer 

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer must be embedded to have forward compatible implementations.

func (UnimplementedAgentServer) AddToManifest 

func (UnimplementedAgentServer) AddToManifest(context.Context, *AddToManifestRequest) (*SimpleStatusResponse, error)

func (UnimplementedAgentServer) CancelUpload 

func (UnimplementedAgentServer) CancelUpload(context.Context, *CancelUploadRequest) (*SimpleStatusResponse, error)

func (UnimplementedAgentServer) CreateManifest 

func (UnimplementedAgentServer) CreateManifest(context.Context, *CreateManifestRequest) (*CreateManifestResponse, error)

func (UnimplementedAgentServer) DeleteManifest 

func (UnimplementedAgentServer) DeleteManifest(context.Context, *DeleteManifestRequest) (*SimpleStatusResponse, error)

func (UnimplementedAgentServer) GetUser 

func (UnimplementedAgentServer) GetUser(context.Context, *GetUserRequest) (*UserResponse, error)

func (UnimplementedAgentServer) ListManifestFiles 

func (UnimplementedAgentServer) ListManifestFiles(context.Context, *ListManifestFilesRequest) (*ListManifestFilesResponse, error)

func (UnimplementedAgentServer) ListManifests 

func (UnimplementedAgentServer) ListManifests(context.Context, *ListManifestsRequest) (*ListManifestsResponse, error)

func (UnimplementedAgentServer) Ping 

func (UnimplementedAgentServer) Ping(context.Context, *PingRequest) (*PingResponse, error)

func (UnimplementedAgentServer) ReAuthenticate 

func (UnimplementedAgentServer) ReAuthenticate(context.Context, *ReAuthenticateRequest) (*UserResponse, error)

func (UnimplementedAgentServer) RelocateManifestFiles 

func (UnimplementedAgentServer) RelocateManifestFiles(context.Context, *RelocateManifestFilesRequest) (*SimpleStatusResponse, error)

func (UnimplementedAgentServer) RemoveFromManifest 

func (UnimplementedAgentServer) RemoveFromManifest(context.Context, *RemoveFromManifestRequest) (*SimpleStatusResponse, error)

func (UnimplementedAgentServer) ResetManifest 

func (UnimplementedAgentServer) ResetManifest(context.Context, *ResetManifestRequest) (*SimpleStatusResponse, error)

func (UnimplementedAgentServer) StartWorkflow 

func (UnimplementedAgentServer) StartWorkflow(context.Context, *StartWorkflowRequest) (*WorkflowResponse, error)

func (UnimplementedAgentServer) Stop 

func (UnimplementedAgentServer) Stop(context.Context, *StopRequest) (*StopResponse, error)

func (UnimplementedAgentServer) Subscribe 

func (UnimplementedAgentServer) Subscribe(*SubscribeRequest, Agent_SubscribeServer) error

func (UnimplementedAgentServer) SwitchProfile 

func (UnimplementedAgentServer) SwitchProfile(context.Context, *SwitchProfileRequest) (*UserResponse, error)

func (UnimplementedAgentServer) SyncManifest 

func (UnimplementedAgentServer) SyncManifest(context.Context, *SyncManifestRequest) (*SyncManifestResponse, error)

func (UnimplementedAgentServer) Unsubscribe 

func (UnimplementedAgentServer) Unsubscribe(context.Context, *SubscribeRequest) (*SubscribeResponse, error)

func (UnimplementedAgentServer) UploadManifest 

func (UnimplementedAgentServer) UploadManifest(context.Context, *UploadManifestRequest) (*SimpleStatusResponse, error)

func (UnimplementedAgentServer) UseDataset 

func (UnimplementedAgentServer) UseDataset(context.Context, *UseDatasetRequest) (*UseDatasetResponse, error)

func (UnimplementedAgentServer) Version 

func (UnimplementedAgentServer) Version(context.Context, *VersionRequest) (*VersionResponse, error)

type UnsafeAgentServer 

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

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

type UploadManifestRequest 

type UploadManifestRequest struct {
	ManifestId int32 `protobuf:"varint,1,opt,name=manifest_id,json=manifestId,proto3" json:"manifest_id,omitempty"`
	// contains filtered or unexported fields
}

func (*UploadManifestRequest) Descriptor deprecated 

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

Deprecated: Use UploadManifestRequest.ProtoReflect.Descriptor instead.

func (*UploadManifestRequest) GetManifestId 

func (x *UploadManifestRequest) GetManifestId() int32

func (*UploadManifestRequest) ProtoMessage 

func (*UploadManifestRequest) ProtoMessage()

func (*UploadManifestRequest) ProtoReflect 

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

func (*UploadManifestRequest) Reset 

func (x *UploadManifestRequest) Reset()

func (*UploadManifestRequest) String 

func (x *UploadManifestRequest) String() string

type UseDatasetRequest 

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

func (*UseDatasetRequest) Descriptor deprecated 

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

Deprecated: Use UseDatasetRequest.ProtoReflect.Descriptor instead.

func (*UseDatasetRequest) GetDatasetId 

func (x *UseDatasetRequest) GetDatasetId() string

func (*UseDatasetRequest) ProtoMessage 

func (*UseDatasetRequest) ProtoMessage()

func (*UseDatasetRequest) ProtoReflect 

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

func (*UseDatasetRequest) Reset 

func (x *UseDatasetRequest) Reset()

func (*UseDatasetRequest) String 

func (x *UseDatasetRequest) String() string

type UseDatasetResponse 

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

func (*UseDatasetResponse) Descriptor deprecated 

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

Deprecated: Use UseDatasetResponse.ProtoReflect.Descriptor instead.

func (*UseDatasetResponse) GetDatasetId 

func (x *UseDatasetResponse) GetDatasetId() string

func (*UseDatasetResponse) ProtoMessage 

func (*UseDatasetResponse) ProtoMessage()

func (*UseDatasetResponse) ProtoReflect 

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

func (*UseDatasetResponse) Reset 

func (x *UseDatasetResponse) Reset()

func (*UseDatasetResponse) String 

func (x *UseDatasetResponse) String() string

type UserResponse 

type UserResponse struct {
	Id               string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Name             string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	SessionToken     string `protobuf:"bytes,4,opt,name=session_token,json=sessionToken,proto3" json:"session_token,omitempty"`
	TokenExpire      int64  `protobuf:"varint,5,opt,name=token_expire,json=tokenExpire,proto3" json:"token_expire,omitempty"`
	Profile          string `protobuf:"bytes,8,opt,name=profile,proto3" json:"profile,omitempty"`
	Environment      string `protobuf:"bytes,9,opt,name=environment,proto3" json:"environment,omitempty"`
	OrganizationId   string `protobuf:"bytes,10,opt,name=organization_id,json=organizationId,proto3" json:"organization_id,omitempty"`
	OrganizationName string `protobuf:"bytes,11,opt,name=organization_name,json=organizationName,proto3" json:"organization_name,omitempty"`
	ApiHost          string `protobuf:"bytes,12,opt,name=api_host,json=apiHost,proto3" json:"api_host,omitempty"`
	Api2Host         string `protobuf:"bytes,13,opt,name=api2_host,json=api2Host,proto3" json:"api2_host,omitempty"`
	// contains filtered or unexported fields
}

func (*UserResponse) Descriptor deprecated 

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

Deprecated: Use UserResponse.ProtoReflect.Descriptor instead.

func (*UserResponse) GetApi2Host 

func (x *UserResponse) GetApi2Host() string

func (*UserResponse) GetApiHost 

func (x *UserResponse) GetApiHost() string

func (*UserResponse) GetEnvironment 

func (x *UserResponse) GetEnvironment() string

func (*UserResponse) GetId 

func (x *UserResponse) GetId() string

func (*UserResponse) GetName 

func (x *UserResponse) GetName() string

func (*UserResponse) GetOrganizationId 

func (x *UserResponse) GetOrganizationId() string

func (*UserResponse) GetOrganizationName 

func (x *UserResponse) GetOrganizationName() string

func (*UserResponse) GetProfile 

func (x *UserResponse) GetProfile() string

func (*UserResponse) GetSessionToken 

func (x *UserResponse) GetSessionToken() string

func (*UserResponse) GetTokenExpire 

func (x *UserResponse) GetTokenExpire() int64

func (*UserResponse) ProtoMessage 

func (*UserResponse) ProtoMessage()

func (*UserResponse) ProtoReflect 

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

func (*UserResponse) Reset 

func (x *UserResponse) Reset()

func (*UserResponse) String 

func (x *UserResponse) String() string

type VersionRequest 

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

func (*VersionRequest) Descriptor deprecated 

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

Deprecated: Use VersionRequest.ProtoReflect.Descriptor instead.

func (*VersionRequest) ProtoMessage 

func (*VersionRequest) ProtoMessage()

func (*VersionRequest) ProtoReflect 

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

func (*VersionRequest) Reset 

func (x *VersionRequest) Reset()

func (*VersionRequest) String 

func (x *VersionRequest) String() string

type VersionResponse 

type VersionResponse struct {
	Version  string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	LogLevel string `protobuf:"bytes,2,opt,name=log_level,json=logLevel,proto3" json:"log_level,omitempty"`
	// contains filtered or unexported fields
}

func (*VersionResponse) Descriptor deprecated 

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

Deprecated: Use VersionResponse.ProtoReflect.Descriptor instead.

func (*VersionResponse) GetLogLevel 

func (x *VersionResponse) GetLogLevel() string

func (*VersionResponse) GetVersion 

func (x *VersionResponse) GetVersion() string

func (*VersionResponse) ProtoMessage 

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) ProtoReflect 

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

func (*VersionResponse) Reset 

func (x *VersionResponse) Reset()

func (*VersionResponse) String 

func (x *VersionResponse) String() string

type WorkflowResponse 

type WorkflowResponse struct {
	Success      bool                          `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Derivatives  string                        `protobuf:"bytes,2,opt,name=derivatives,proto3" json:"derivatives,omitempty"`
	WorkflowType WorkflowResponse_WorkflowType `protobuf:"varint,3,opt,name=workflowType,proto3,enum=v1.WorkflowResponse_WorkflowType" json:"workflowType,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkflowResponse) Descriptor deprecated 

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

Deprecated: Use WorkflowResponse.ProtoReflect.Descriptor instead.

func (*WorkflowResponse) GetDerivatives 

func (x *WorkflowResponse) GetDerivatives() string

func (*WorkflowResponse) GetSuccess 

func (x *WorkflowResponse) GetSuccess() bool

func (*WorkflowResponse) GetWorkflowType 

func (x *WorkflowResponse) GetWorkflowType() WorkflowResponse_WorkflowType

func (*WorkflowResponse) ProtoMessage 

func (*WorkflowResponse) ProtoMessage()

func (*WorkflowResponse) ProtoReflect 

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

func (*WorkflowResponse) Reset 

func (x *WorkflowResponse) Reset()

func (*WorkflowResponse) String 

func (x *WorkflowResponse) String() string

type WorkflowResponse_WorkflowType 

type WorkflowResponse_WorkflowType int32
const (
	WorkflowResponse_PATH  WorkflowResponse_WorkflowType = 0 // File indexed locally
	WorkflowResponse_NAMED WorkflowResponse_WorkflowType = 1
)

func (WorkflowResponse_WorkflowType) Descriptor 

func (WorkflowResponse_WorkflowType) Descriptor() protoreflect.EnumDescriptor

func (WorkflowResponse_WorkflowType) Enum 

func (x WorkflowResponse_WorkflowType) Enum() *WorkflowResponse_WorkflowType

func (WorkflowResponse_WorkflowType) EnumDescriptor deprecated 

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

Deprecated: Use WorkflowResponse_WorkflowType.Descriptor instead.

func (WorkflowResponse_WorkflowType) Number 

func (x WorkflowResponse_WorkflowType) Number() protoreflect.EnumNumber

func (WorkflowResponse_WorkflowType) String 

func (x WorkflowResponse_WorkflowType) String() string

func (WorkflowResponse_WorkflowType) Type 

func (WorkflowResponse_WorkflowType) Type() protoreflect.EnumType

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.