protos

Aug 18, 2022

Changes in this version

type ListManifestFilesResponse_StatusType

+ const ListManifestFilesResponse_CHANGES

+ const ListManifestFilesResponse_LOCAL

+ const ListManifestFilesResponse_REGISTERED

+ const ListManifestFilesResponse_UPLOADED

Aug 16, 2022

Changes in this version

type AddToManifestRequest

+ Files []string

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

type CreateManifestRequest

+ Files []string

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

Jul 7, 2022

Changes in this version

type AgentClient

+ RelocateManifestFiles func(ctx context.Context, in *RelocateManifestFilesRequest, opts ...grpc.CallOption) (*SimpleStatusResponse, error)

+ ResetManifest func(ctx context.Context, in *ResetManifestRequest, opts ...grpc.CallOption) (*SimpleStatusResponse, error)

type AgentServer

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

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

+ type CreateManifestResponse struct

+ ManifestId int32

+ Message string

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

+ func (*CreateManifestResponse) ProtoMessage()

+ func (x *CreateManifestResponse) GetManifestId() int32

+ func (x *CreateManifestResponse) GetMessage() string

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

+ func (x *CreateManifestResponse) Reset()

+ func (x *CreateManifestResponse) String() string

type ListManifestFilesResponse_StatusType

+ const ListManifestFilesResponse_FAILED

+ const ListManifestFilesResponse_FINALIZED

+ const ListManifestFilesResponse_IMPORTED

+ const ListManifestFilesResponse_INITIATED

+ const ListManifestFilesResponse_REMOVED

+ const ListManifestFilesResponse_UNKNOWN

+ type RelocateManifestFilesRequest struct

+ ManifestId int32

+ Path string

+ UpdatedPath string

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

+ func (*RelocateManifestFilesRequest) ProtoMessage()

+ func (x *RelocateManifestFilesRequest) GetManifestId() int32

+ func (x *RelocateManifestFilesRequest) GetPath() string

+ func (x *RelocateManifestFilesRequest) GetUpdatedPath() string

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

+ func (x *RelocateManifestFilesRequest) Reset()

+ func (x *RelocateManifestFilesRequest) String() string

type RemoveFromManifestRequest

+ RemovePath string

+ func (x *RemoveFromManifestRequest) GetRemovePath() string

type SyncManifestResponse

+ NrFilesFailed int32

+ NrFilesUpdated int32

+ func (x *SyncManifestResponse) GetNrFilesFailed() int32

+ func (x *SyncManifestResponse) GetNrFilesUpdated() int32

type UnimplementedAgentServer

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

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

Jun 15, 2022

Changes in this version

+ var ListManifestFilesResponse_StatusType_name = map[int32]string

+ var ListManifestFilesResponse_StatusType_value = map[string]int32

+ var SubsrcribeResponse_MessageType_name = map[int32]string

+ var SubsrcribeResponse_MessageType_value = map[string]int32

+ type AddToManifestRequest struct

+ BasePath string

+ ManifestId int32

+ Recursive bool

+ TargetBasePath string

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

+ func (*AddToManifestRequest) ProtoMessage()

+ func (x *AddToManifestRequest) GetBasePath() string

+ func (x *AddToManifestRequest) GetManifestId() int32

+ func (x *AddToManifestRequest) GetRecursive() bool

+ func (x *AddToManifestRequest) GetTargetBasePath() string

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

+ func (x *AddToManifestRequest) Reset()

+ func (x *AddToManifestRequest) String() string

type AgentClient

+ GetUser func(ctx context.Context, in *GetUserRequest, opts ...grpc.CallOption) (*UserResponse, error)

+ ListManifestFiles func(ctx context.Context, in *ListManifestFilesRequest, opts ...grpc.CallOption) (*ListManifestFilesResponse, error)

+ ListManifests func(ctx context.Context, in *ListManifestsRequest, opts ...grpc.CallOption) (*ListManifestsResponse, error)

+ ReAuthenticate func(ctx context.Context, in *ReAuthenticateRequest, opts ...grpc.CallOption) (*UserResponse, error)

+ SwitchProfile func(ctx context.Context, in *SwitchProfileRequest, opts ...grpc.CallOption) (*UserResponse, error)

+ SyncManifest func(ctx context.Context, in *SyncManifestRequest, opts ...grpc.CallOption) (*SyncManifestResponse, error)

+ UseDataset func(ctx context.Context, in *UseDatasetRequest, opts ...grpc.CallOption) (*UseDatasetResponse, error)

type AgentServer

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

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

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

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

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

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

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

+ type CancelUploadRequest struct

+ CancelAll bool

+ ManifestId string

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

+ func (*CancelUploadRequest) ProtoMessage()

+ func (x *CancelUploadRequest) GetCancelAll() bool

+ func (x *CancelUploadRequest) GetManifestId() string

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

+ func (x *CancelUploadRequest) Reset()

+ func (x *CancelUploadRequest) String() string

+ type GetUserRequest struct

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

+ func (*GetUserRequest) ProtoMessage()

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

+ func (x *GetUserRequest) Reset()

+ func (x *GetUserRequest) String() string

+ type ListManifestFilesRequest struct

+ Limit int32

+ ManifestId int32

+ Offset int32

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

+ func (*ListManifestFilesRequest) ProtoMessage()

+ func (x *ListManifestFilesRequest) GetLimit() int32

+ func (x *ListManifestFilesRequest) GetManifestId() int32

+ func (x *ListManifestFilesRequest) GetOffset() int32

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

+ func (x *ListManifestFilesRequest) Reset()

+ func (x *ListManifestFilesRequest) String() string

+ type ListManifestFilesResponse struct

+ File []*ListManifestFilesResponse_FileUpload

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

+ func (*ListManifestFilesResponse) ProtoMessage()

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

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

+ func (x *ListManifestFilesResponse) Reset()

+ func (x *ListManifestFilesResponse) String() string

+ type ListManifestFilesResponse_FileUpload struct

+ Id int32

+ ManifestId int32

+ SourcePath string

+ Status ListManifestFilesResponse_StatusType

+ TargetPath string

+ UploadId string

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

+ func (*ListManifestFilesResponse_FileUpload) ProtoMessage()

+ func (x *ListManifestFilesResponse_FileUpload) GetId() int32

+ func (x *ListManifestFilesResponse_FileUpload) GetManifestId() int32

+ func (x *ListManifestFilesResponse_FileUpload) GetSourcePath() string

+ func (x *ListManifestFilesResponse_FileUpload) GetStatus() ListManifestFilesResponse_StatusType

+ func (x *ListManifestFilesResponse_FileUpload) GetTargetPath() string

+ func (x *ListManifestFilesResponse_FileUpload) GetUploadId() string

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

+ func (x *ListManifestFilesResponse_FileUpload) Reset()

+ func (x *ListManifestFilesResponse_FileUpload) String() string

+ type ListManifestFilesResponse_StatusType int32

+ const ListManifestFilesResponse_CANCELLED

+ const ListManifestFilesResponse_COMPLETED

+ const ListManifestFilesResponse_INDEXED

+ const ListManifestFilesResponse_SYNCED

+ const ListManifestFilesResponse_UPLOADING

+ const ListManifestFilesResponse_VERIFIED

+ func (ListManifestFilesResponse_StatusType) Descriptor() protoreflect.EnumDescriptor

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

+ func (ListManifestFilesResponse_StatusType) Type() protoreflect.EnumType

+ func (x ListManifestFilesResponse_StatusType) Enum() *ListManifestFilesResponse_StatusType

+ func (x ListManifestFilesResponse_StatusType) Number() protoreflect.EnumNumber

+ func (x ListManifestFilesResponse_StatusType) String() string

+ type ListManifestsRequest struct

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

+ func (*ListManifestsRequest) ProtoMessage()

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

+ func (x *ListManifestsRequest) Reset()

+ func (x *ListManifestsRequest) String() string

+ type ListManifestsResponse struct

+ Manifests []*ListManifestsResponse_Manifest

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

+ func (*ListManifestsResponse) ProtoMessage()

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

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

+ func (x *ListManifestsResponse) Reset()

+ func (x *ListManifestsResponse) String() string

+ type ListManifestsResponse_Manifest struct

+ DatasetId string

+ DatasetName string

+ Id int32

+ NodeId string

+ OrganizationId string

+ OrganizationName string

+ Status string

+ UserId string

+ UserName string

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

+ func (*ListManifestsResponse_Manifest) ProtoMessage()

+ func (x *ListManifestsResponse_Manifest) GetDatasetId() string

+ func (x *ListManifestsResponse_Manifest) GetDatasetName() string

+ func (x *ListManifestsResponse_Manifest) GetId() int32

+ func (x *ListManifestsResponse_Manifest) GetNodeId() string

+ func (x *ListManifestsResponse_Manifest) GetOrganizationId() string

+ func (x *ListManifestsResponse_Manifest) GetOrganizationName() string

+ func (x *ListManifestsResponse_Manifest) GetStatus() string

+ func (x *ListManifestsResponse_Manifest) GetUserId() string

+ func (x *ListManifestsResponse_Manifest) GetUserName() string

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

+ func (x *ListManifestsResponse_Manifest) Reset()

+ func (x *ListManifestsResponse_Manifest) String() string

+ type ReAuthenticateRequest struct

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

+ func (*ReAuthenticateRequest) ProtoMessage()

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

+ func (x *ReAuthenticateRequest) Reset()

+ func (x *ReAuthenticateRequest) String() string

+ type ResetManifestRequest struct

+ ManifestId int32

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

+ func (*ResetManifestRequest) ProtoMessage()

+ func (x *ResetManifestRequest) GetManifestId() int32

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

+ func (x *ResetManifestRequest) Reset()

+ func (x *ResetManifestRequest) String() string

+ type SubsrcribeResponse_MessageType int32

+ func (SubsrcribeResponse_MessageType) Descriptor() protoreflect.EnumDescriptor

+ func (SubsrcribeResponse_MessageType) EnumDescriptor() ([]byte, []int)

+ func (SubsrcribeResponse_MessageType) Type() protoreflect.EnumType

+ func (x SubsrcribeResponse_MessageType) Enum() *SubsrcribeResponse_MessageType

+ func (x SubsrcribeResponse_MessageType) Number() protoreflect.EnumNumber

+ func (x SubsrcribeResponse_MessageType) String() string

+ type SwitchProfileRequest struct

+ Profile string

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

+ func (*SwitchProfileRequest) ProtoMessage()

+ func (x *SwitchProfileRequest) GetProfile() string

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

+ func (x *SwitchProfileRequest) Reset()

+ func (x *SwitchProfileRequest) String() string

+ type SyncManifestRequest struct

+ ManifestId int32

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

+ func (*SyncManifestRequest) ProtoMessage()

+ func (x *SyncManifestRequest) GetManifestId() int32

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

+ func (x *SyncManifestRequest) Reset()

+ func (x *SyncManifestRequest) String() string

+ type SyncManifestResponse struct

+ ManifestNodeId string

+ NrFilesAdded int32

+ NrFilesRemoved int32

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

+ func (*SyncManifestResponse) ProtoMessage()

+ func (x *SyncManifestResponse) GetManifestNodeId() string

+ func (x *SyncManifestResponse) GetNrFilesAdded() int32

+ func (x *SyncManifestResponse) GetNrFilesRemoved() int32

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

+ func (x *SyncManifestResponse) Reset()

+ func (x *SyncManifestResponse) String() string

type UnimplementedAgentServer

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

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

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

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

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

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

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

+ type UseDatasetRequest struct

+ DatasetId string

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

+ func (*UseDatasetRequest) ProtoMessage()

+ func (x *UseDatasetRequest) GetDatasetId() string

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

+ func (x *UseDatasetRequest) Reset()

+ func (x *UseDatasetRequest) String() string

+ type UseDatasetResponse struct

+ DatasetId string

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

+ func (*UseDatasetResponse) ProtoMessage()

+ func (x *UseDatasetResponse) GetDatasetId() string

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

+ func (x *UseDatasetResponse) Reset()

+ func (x *UseDatasetResponse) String() string

+ type UserResponse struct

+ Environment string

+ Id string

+ Name string

+ OrganizationId string

+ OrganizationName string

+ Profile string

+ SessionToken string

+ TokenExpire int64

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

+ func (*UserResponse) ProtoMessage()

+ func (x *UserResponse) GetEnvironment() string

+ func (x *UserResponse) GetId() string

+ func (x *UserResponse) GetName() string

+ func (x *UserResponse) GetOrganizationId() string

+ func (x *UserResponse) GetOrganizationName() string

+ func (x *UserResponse) GetProfile() string

+ func (x *UserResponse) GetSessionToken() string

+ func (x *UserResponse) GetTokenExpire() int64

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

+ func (x *UserResponse) Reset()

+ func (x *UserResponse) String() string

May 10, 2022

Changes in this version

+ var Agent_ServiceDesc = grpc.ServiceDesc

+ var File_protos_agent_proto protoreflect.FileDescriptor

+ var ListFilesResponse_STATUS_TYPE_name = map[int32]string

+ var ListFilesResponse_STATUS_TYPE_value = map[string]int32

+ var SubsrcribeResponse_MESSAGE_TYPE_name = map[int32]string

+ var SubsrcribeResponse_MESSAGE_TYPE_value = map[string]int32

+ func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer)

+ type AddManifestRequest struct

+ BasePath string

+ ManifestId string

+ Recursive bool

+ TargetBasePath string

+ func (*AddManifestRequest) Descriptor() ([]byte, []int)

+ func (*AddManifestRequest) ProtoMessage()

+ func (x *AddManifestRequest) GetBasePath() string

+ func (x *AddManifestRequest) GetManifestId() string

+ func (x *AddManifestRequest) GetRecursive() bool

+ func (x *AddManifestRequest) GetTargetBasePath() string

+ func (x *AddManifestRequest) ProtoReflect() protoreflect.Message

+ func (x *AddManifestRequest) Reset()

+ func (x *AddManifestRequest) String() string

+ type AgentClient interface

+ AddToManifest func(ctx context.Context, in *AddManifestRequest, opts ...grpc.CallOption) (*SimpleStatusResponse, error)

+ CancelUpload func(ctx context.Context, in *CancelRequest, opts ...grpc.CallOption) (*SimpleStatusResponse, error)

+ CreateManifest func(ctx context.Context, in *CreateManifestRequest, opts ...grpc.CallOption) (*SimpleStatusResponse, error)

+ DeleteManifest func(ctx context.Context, in *DeleteManifestRequest, opts ...grpc.CallOption) (*SimpleStatusResponse, error)

+ ListFilesForManifest func(ctx context.Context, in *ListFilesRequest, opts ...grpc.CallOption) (*ListFilesResponse, error)

+ ManifestStatus func(ctx context.Context, in *ManifestStatusRequest, opts ...grpc.CallOption) (*ManifestStatusResponse, error)

+ RemoveFromManifest func(ctx context.Context, in *RemoveFromManifestRequest, opts ...grpc.CallOption) (*SimpleStatusResponse, error)

+ Subscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Agent_SubscribeClient, error)

+ Unsubscribe func(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*SubsrcribeResponse, error)

+ UploadManifest func(ctx context.Context, in *UploadManifestRequest, opts ...grpc.CallOption) (*SimpleStatusResponse, error)

+ func NewAgentClient(cc grpc.ClientConnInterface) AgentClient

+ type AgentServer interface

+ AddToManifest func(context.Context, *AddManifestRequest) (*SimpleStatusResponse, error)

+ CancelUpload func(context.Context, *CancelRequest) (*SimpleStatusResponse, error)

+ CreateManifest func(context.Context, *CreateManifestRequest) (*SimpleStatusResponse, error)

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

+ ListFilesForManifest func(context.Context, *ListFilesRequest) (*ListFilesResponse, error)

+ ManifestStatus func(context.Context, *ManifestStatusRequest) (*ManifestStatusResponse, error)

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

+ Subscribe func(*SubscribeRequest, Agent_SubscribeServer) error

+ Unsubscribe func(context.Context, *SubscribeRequest) (*SubsrcribeResponse, error)

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

+ type Agent_SubscribeClient interface

+ Recv func() (*SubsrcribeResponse, error)

+ type Agent_SubscribeServer interface

+ Send func(*SubsrcribeResponse) error

+ type CancelRequest struct

+ CancelAll bool

+ ManifestId string

+ func (*CancelRequest) Descriptor() ([]byte, []int)

+ func (*CancelRequest) ProtoMessage()

+ func (x *CancelRequest) GetCancelAll() bool

+ func (x *CancelRequest) GetManifestId() string

+ func (x *CancelRequest) ProtoReflect() protoreflect.Message

+ func (x *CancelRequest) Reset()

+ func (x *CancelRequest) String() string

+ type CreateManifestRequest struct

+ BasePath string

+ Recursive bool

+ TargetBasePath string

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

+ func (*CreateManifestRequest) ProtoMessage()

+ func (x *CreateManifestRequest) GetBasePath() string

+ func (x *CreateManifestRequest) GetRecursive() bool

+ func (x *CreateManifestRequest) GetTargetBasePath() string

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

+ func (x *CreateManifestRequest) Reset()

+ func (x *CreateManifestRequest) String() string

+ type DeleteManifestRequest struct

+ ManifestId string

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

+ func (*DeleteManifestRequest) ProtoMessage()

+ func (x *DeleteManifestRequest) GetManifestId() string

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

+ func (x *DeleteManifestRequest) Reset()

+ func (x *DeleteManifestRequest) String() string

+ type ListFilesRequest struct

+ Limit int32

+ ManifestId string

+ Offset int32

+ func (*ListFilesRequest) Descriptor() ([]byte, []int)

+ func (*ListFilesRequest) ProtoMessage()

+ func (x *ListFilesRequest) GetLimit() int32

+ func (x *ListFilesRequest) GetManifestId() string

+ func (x *ListFilesRequest) GetOffset() int32

+ func (x *ListFilesRequest) ProtoReflect() protoreflect.Message

+ func (x *ListFilesRequest) Reset()

+ func (x *ListFilesRequest) String() string

+ type ListFilesResponse struct

+ File []*ListFilesResponse_FileUpload

+ func (*ListFilesResponse) Descriptor() ([]byte, []int)

+ func (*ListFilesResponse) ProtoMessage()

+ func (x *ListFilesResponse) GetFile() []*ListFilesResponse_FileUpload

+ func (x *ListFilesResponse) ProtoReflect() protoreflect.Message

+ func (x *ListFilesResponse) Reset()

+ func (x *ListFilesResponse) String() string

+ type ListFilesResponse_FileUpload struct

+ Id int32

+ S3Key string

+ SessionId string

+ SourcePath string

+ Status ListFilesResponse_STATUS_TYPE

+ TargetPath string

+ func (*ListFilesResponse_FileUpload) Descriptor() ([]byte, []int)

+ func (*ListFilesResponse_FileUpload) ProtoMessage()

+ func (x *ListFilesResponse_FileUpload) GetId() int32

+ func (x *ListFilesResponse_FileUpload) GetS3Key() string

+ func (x *ListFilesResponse_FileUpload) GetSessionId() string

+ func (x *ListFilesResponse_FileUpload) GetSourcePath() string

+ func (x *ListFilesResponse_FileUpload) GetStatus() ListFilesResponse_STATUS_TYPE

+ func (x *ListFilesResponse_FileUpload) GetTargetPath() string

+ func (x *ListFilesResponse_FileUpload) ProtoReflect() protoreflect.Message

+ func (x *ListFilesResponse_FileUpload) Reset()

+ func (x *ListFilesResponse_FileUpload) String() string

+ type ListFilesResponse_STATUS_TYPE int32

+ const ListFilesResponse_CANCELED

+ const ListFilesResponse_COMPLETED

+ const ListFilesResponse_INDEXED

+ const ListFilesResponse_SYNCED

+ const ListFilesResponse_UPLOADING

+ func (ListFilesResponse_STATUS_TYPE) Descriptor() protoreflect.EnumDescriptor

+ func (ListFilesResponse_STATUS_TYPE) EnumDescriptor() ([]byte, []int)

+ func (ListFilesResponse_STATUS_TYPE) Type() protoreflect.EnumType

+ func (x ListFilesResponse_STATUS_TYPE) Enum() *ListFilesResponse_STATUS_TYPE

+ func (x ListFilesResponse_STATUS_TYPE) Number() protoreflect.EnumNumber

+ func (x ListFilesResponse_STATUS_TYPE) String() string

+ type ManifestStatusRequest struct

+ func (*ManifestStatusRequest) Descriptor() ([]byte, []int)

+ func (*ManifestStatusRequest) ProtoMessage()

+ func (x *ManifestStatusRequest) ProtoReflect() protoreflect.Message

+ func (x *ManifestStatusRequest) Reset()

+ func (x *ManifestStatusRequest) String() string

+ type ManifestStatusResponse struct

+ Manifests []*ManifestStatusResponse_Manifest

+ func (*ManifestStatusResponse) Descriptor() ([]byte, []int)

+ func (*ManifestStatusResponse) ProtoMessage()

+ func (x *ManifestStatusResponse) GetManifests() []*ManifestStatusResponse_Manifest

+ func (x *ManifestStatusResponse) ProtoReflect() protoreflect.Message

+ func (x *ManifestStatusResponse) Reset()

+ func (x *ManifestStatusResponse) String() string

+ type ManifestStatusResponse_Manifest struct

+ DatasetId string

+ DatasetName string

+ Id string

+ OrganizationId string

+ OrganizationName string

+ Status string

+ UserId string

+ UserName string

+ func (*ManifestStatusResponse_Manifest) Descriptor() ([]byte, []int)

+ func (*ManifestStatusResponse_Manifest) ProtoMessage()

+ func (x *ManifestStatusResponse_Manifest) GetDatasetId() string

+ func (x *ManifestStatusResponse_Manifest) GetDatasetName() string

+ func (x *ManifestStatusResponse_Manifest) GetId() string

+ func (x *ManifestStatusResponse_Manifest) GetOrganizationId() string

+ func (x *ManifestStatusResponse_Manifest) GetOrganizationName() string

+ func (x *ManifestStatusResponse_Manifest) GetStatus() string

+ func (x *ManifestStatusResponse_Manifest) GetUserId() string

+ func (x *ManifestStatusResponse_Manifest) GetUserName() string

+ func (x *ManifestStatusResponse_Manifest) ProtoReflect() protoreflect.Message

+ func (x *ManifestStatusResponse_Manifest) Reset()

+ func (x *ManifestStatusResponse_Manifest) String() string

+ type RemoveFromManifestRequest struct

+ FileId []int32

+ ManifestId string

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

+ func (*RemoveFromManifestRequest) ProtoMessage()

+ func (x *RemoveFromManifestRequest) GetFileId() []int32

+ func (x *RemoveFromManifestRequest) GetManifestId() string

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

+ func (x *RemoveFromManifestRequest) Reset()

+ func (x *RemoveFromManifestRequest) String() string

+ type SimpleStatusResponse struct

+ Status string

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

+ func (*SimpleStatusResponse) ProtoMessage()

+ func (x *SimpleStatusResponse) GetStatus() string

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

+ func (x *SimpleStatusResponse) Reset()

+ func (x *SimpleStatusResponse) String() string

+ type SubscribeRequest struct

+ Id int32

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

+ func (*SubscribeRequest) ProtoMessage()

+ func (x *SubscribeRequest) GetId() int32

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

+ func (x *SubscribeRequest) Reset()

+ func (x *SubscribeRequest) String() string

+ type SubsrcribeResponse struct

+ MessageData isSubsrcribeResponse_MessageData

+ Type SubsrcribeResponse_MESSAGE_TYPE

+ func (*SubsrcribeResponse) Descriptor() ([]byte, []int)

+ func (*SubsrcribeResponse) ProtoMessage()

+ func (m *SubsrcribeResponse) GetMessageData() isSubsrcribeResponse_MessageData

+ func (x *SubsrcribeResponse) GetEventInfo() *SubsrcribeResponse_EventResponse

+ func (x *SubsrcribeResponse) GetType() SubsrcribeResponse_MESSAGE_TYPE

+ func (x *SubsrcribeResponse) GetUploadStatus() *SubsrcribeResponse_UploadResponse

+ func (x *SubsrcribeResponse) ProtoReflect() protoreflect.Message

+ func (x *SubsrcribeResponse) Reset()

+ func (x *SubsrcribeResponse) String() string

+ type SubsrcribeResponse_EventInfo struct

+ EventInfo *SubsrcribeResponse_EventResponse

+ type SubsrcribeResponse_EventResponse struct

+ Details string

+ func (*SubsrcribeResponse_EventResponse) Descriptor() ([]byte, []int)

+ func (*SubsrcribeResponse_EventResponse) ProtoMessage()

+ func (x *SubsrcribeResponse_EventResponse) GetDetails() string

+ func (x *SubsrcribeResponse_EventResponse) ProtoReflect() protoreflect.Message

+ func (x *SubsrcribeResponse_EventResponse) Reset()

+ func (x *SubsrcribeResponse_EventResponse) String() string

+ type SubsrcribeResponse_MESSAGE_TYPE int32

+ const SubsrcribeResponse_EVENT

+ const SubsrcribeResponse_UPLOAD_CANCEL

+ const SubsrcribeResponse_UPLOAD_STATUS

+ func (SubsrcribeResponse_MESSAGE_TYPE) Descriptor() protoreflect.EnumDescriptor

+ func (SubsrcribeResponse_MESSAGE_TYPE) EnumDescriptor() ([]byte, []int)

+ func (SubsrcribeResponse_MESSAGE_TYPE) Type() protoreflect.EnumType

+ func (x SubsrcribeResponse_MESSAGE_TYPE) Enum() *SubsrcribeResponse_MESSAGE_TYPE

+ func (x SubsrcribeResponse_MESSAGE_TYPE) Number() protoreflect.EnumNumber

+ func (x SubsrcribeResponse_MESSAGE_TYPE) String() string

+ type SubsrcribeResponse_UploadResponse struct

+ Current int64

+ FileId string

+ Total int64

+ WorkerId int32

+ func (*SubsrcribeResponse_UploadResponse) Descriptor() ([]byte, []int)

+ func (*SubsrcribeResponse_UploadResponse) ProtoMessage()

+ func (x *SubsrcribeResponse_UploadResponse) GetCurrent() int64

+ func (x *SubsrcribeResponse_UploadResponse) GetFileId() string

+ func (x *SubsrcribeResponse_UploadResponse) GetTotal() int64

+ func (x *SubsrcribeResponse_UploadResponse) GetWorkerId() int32

+ func (x *SubsrcribeResponse_UploadResponse) ProtoReflect() protoreflect.Message

+ func (x *SubsrcribeResponse_UploadResponse) Reset()

+ func (x *SubsrcribeResponse_UploadResponse) String() string

+ type SubsrcribeResponse_UploadStatus struct

+ UploadStatus *SubsrcribeResponse_UploadResponse

+ type UnimplementedAgentServer struct

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

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

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

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

+ func (UnimplementedAgentServer) ListFilesForManifest(context.Context, *ListFilesRequest) (*ListFilesResponse, error)

+ func (UnimplementedAgentServer) ManifestStatus(context.Context, *ManifestStatusRequest) (*ManifestStatusResponse, error)

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

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

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

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

+ type UnsafeAgentServer interface

+ type UploadManifestRequest struct

+ ManifestId string

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

+ func (*UploadManifestRequest) ProtoMessage()

+ func (x *UploadManifestRequest) GetManifestId() string

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

+ func (x *UploadManifestRequest) Reset()

+ func (x *UploadManifestRequest) String() string