Documentation
¶
Index ¶
- Variables
- func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer)
- type AddToManifestRequest
- func (*AddToManifestRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AddToManifestRequest) GetBasePath() string
- func (x *AddToManifestRequest) GetManifestId() int32
- func (x *AddToManifestRequest) GetRecursive() bool
- func (x *AddToManifestRequest) GetTargetBasePath() string
- func (*AddToManifestRequest) ProtoMessage()
- func (x *AddToManifestRequest) ProtoReflect() protoreflect.Message
- func (x *AddToManifestRequest) Reset()
- func (x *AddToManifestRequest) String() string
- type AgentClient
- type AgentServer
- type Agent_SubscribeClient
- type Agent_SubscribeServer
- type CancelUploadRequest
- func (*CancelUploadRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CancelUploadRequest) GetCancelAll() bool
- func (x *CancelUploadRequest) GetManifestId() string
- func (*CancelUploadRequest) ProtoMessage()
- func (x *CancelUploadRequest) ProtoReflect() protoreflect.Message
- func (x *CancelUploadRequest) Reset()
- func (x *CancelUploadRequest) String() string
- type CreateManifestRequest
- func (*CreateManifestRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateManifestRequest) GetBasePath() string
- func (x *CreateManifestRequest) GetRecursive() bool
- func (x *CreateManifestRequest) GetTargetBasePath() string
- func (*CreateManifestRequest) ProtoMessage()
- func (x *CreateManifestRequest) ProtoReflect() protoreflect.Message
- func (x *CreateManifestRequest) Reset()
- func (x *CreateManifestRequest) String() string
- type DeleteManifestRequest
- func (*DeleteManifestRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteManifestRequest) GetManifestId() int32
- func (*DeleteManifestRequest) ProtoMessage()
- func (x *DeleteManifestRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteManifestRequest) Reset()
- func (x *DeleteManifestRequest) String() string
- type GetUserRequest
- type ListManifestFilesRequest
- func (*ListManifestFilesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListManifestFilesRequest) GetLimit() int32
- func (x *ListManifestFilesRequest) GetManifestId() int32
- func (x *ListManifestFilesRequest) GetOffset() int32
- func (*ListManifestFilesRequest) ProtoMessage()
- func (x *ListManifestFilesRequest) ProtoReflect() protoreflect.Message
- func (x *ListManifestFilesRequest) Reset()
- func (x *ListManifestFilesRequest) String() string
- type ListManifestFilesResponse
- func (*ListManifestFilesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListManifestFilesResponse) GetFile() []*ListManifestFilesResponse_FileUpload
- func (*ListManifestFilesResponse) ProtoMessage()
- func (x *ListManifestFilesResponse) ProtoReflect() protoreflect.Message
- func (x *ListManifestFilesResponse) Reset()
- func (x *ListManifestFilesResponse) String() string
- type ListManifestFilesResponse_FileUpload
- func (*ListManifestFilesResponse_FileUpload) Descriptor() ([]byte, []int)deprecated
- 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 (*ListManifestFilesResponse_FileUpload) ProtoMessage()
- func (x *ListManifestFilesResponse_FileUpload) ProtoReflect() protoreflect.Message
- func (x *ListManifestFilesResponse_FileUpload) Reset()
- func (x *ListManifestFilesResponse_FileUpload) String() string
- type ListManifestFilesResponse_StatusType
- func (ListManifestFilesResponse_StatusType) Descriptor() protoreflect.EnumDescriptor
- func (x ListManifestFilesResponse_StatusType) Enum() *ListManifestFilesResponse_StatusType
- func (ListManifestFilesResponse_StatusType) EnumDescriptor() ([]byte, []int)deprecated
- func (x ListManifestFilesResponse_StatusType) Number() protoreflect.EnumNumber
- func (x ListManifestFilesResponse_StatusType) String() string
- func (ListManifestFilesResponse_StatusType) Type() protoreflect.EnumType
- type ListManifestsRequest
- type ListManifestsResponse
- func (*ListManifestsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListManifestsResponse) GetManifests() []*ListManifestsResponse_Manifest
- func (*ListManifestsResponse) ProtoMessage()
- func (x *ListManifestsResponse) ProtoReflect() protoreflect.Message
- func (x *ListManifestsResponse) Reset()
- func (x *ListManifestsResponse) String() string
- type ListManifestsResponse_Manifest
- func (*ListManifestsResponse_Manifest) Descriptor() ([]byte, []int)deprecated
- 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 (*ListManifestsResponse_Manifest) ProtoMessage()
- func (x *ListManifestsResponse_Manifest) ProtoReflect() protoreflect.Message
- func (x *ListManifestsResponse_Manifest) Reset()
- func (x *ListManifestsResponse_Manifest) String() string
- type ReAuthenticateRequest
- type RemoveFromManifestRequest
- func (*RemoveFromManifestRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveFromManifestRequest) GetFileId() []int32
- func (x *RemoveFromManifestRequest) GetManifestId() string
- func (*RemoveFromManifestRequest) ProtoMessage()
- func (x *RemoveFromManifestRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveFromManifestRequest) Reset()
- func (x *RemoveFromManifestRequest) String() string
- type ResetManifestRequest
- func (*ResetManifestRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ResetManifestRequest) GetManifestId() int32
- func (*ResetManifestRequest) ProtoMessage()
- func (x *ResetManifestRequest) ProtoReflect() protoreflect.Message
- func (x *ResetManifestRequest) Reset()
- func (x *ResetManifestRequest) String() string
- type SimpleStatusResponse
- func (*SimpleStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SimpleStatusResponse) GetStatus() string
- func (*SimpleStatusResponse) ProtoMessage()
- func (x *SimpleStatusResponse) ProtoReflect() protoreflect.Message
- func (x *SimpleStatusResponse) Reset()
- func (x *SimpleStatusResponse) String() string
- type SubscribeRequest
- type SubsrcribeResponse
- func (*SubsrcribeResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SubsrcribeResponse) GetEventInfo() *SubsrcribeResponse_EventResponse
- func (m *SubsrcribeResponse) GetMessageData() isSubsrcribeResponse_MessageData
- func (x *SubsrcribeResponse) GetType() SubsrcribeResponse_MessageType
- func (x *SubsrcribeResponse) GetUploadStatus() *SubsrcribeResponse_UploadResponse
- func (*SubsrcribeResponse) ProtoMessage()
- func (x *SubsrcribeResponse) ProtoReflect() protoreflect.Message
- func (x *SubsrcribeResponse) Reset()
- func (x *SubsrcribeResponse) String() string
- type SubsrcribeResponse_EventInfo
- type SubsrcribeResponse_EventResponse
- func (*SubsrcribeResponse_EventResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SubsrcribeResponse_EventResponse) GetDetails() string
- func (*SubsrcribeResponse_EventResponse) ProtoMessage()
- func (x *SubsrcribeResponse_EventResponse) ProtoReflect() protoreflect.Message
- func (x *SubsrcribeResponse_EventResponse) Reset()
- func (x *SubsrcribeResponse_EventResponse) String() string
- type SubsrcribeResponse_MessageType
- func (SubsrcribeResponse_MessageType) Descriptor() protoreflect.EnumDescriptor
- func (x SubsrcribeResponse_MessageType) Enum() *SubsrcribeResponse_MessageType
- func (SubsrcribeResponse_MessageType) EnumDescriptor() ([]byte, []int)deprecated
- func (x SubsrcribeResponse_MessageType) Number() protoreflect.EnumNumber
- func (x SubsrcribeResponse_MessageType) String() string
- func (SubsrcribeResponse_MessageType) Type() protoreflect.EnumType
- type SubsrcribeResponse_UploadResponse
- func (*SubsrcribeResponse_UploadResponse) Descriptor() ([]byte, []int)deprecated
- 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 (*SubsrcribeResponse_UploadResponse) ProtoMessage()
- func (x *SubsrcribeResponse_UploadResponse) ProtoReflect() protoreflect.Message
- func (x *SubsrcribeResponse_UploadResponse) Reset()
- func (x *SubsrcribeResponse_UploadResponse) String() string
- type SubsrcribeResponse_UploadStatus
- type SwitchProfileRequest
- func (*SwitchProfileRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SwitchProfileRequest) GetProfile() string
- func (*SwitchProfileRequest) ProtoMessage()
- func (x *SwitchProfileRequest) ProtoReflect() protoreflect.Message
- func (x *SwitchProfileRequest) Reset()
- func (x *SwitchProfileRequest) String() string
- type SyncManifestRequest
- func (*SyncManifestRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SyncManifestRequest) GetManifestId() int32
- func (*SyncManifestRequest) ProtoMessage()
- func (x *SyncManifestRequest) ProtoReflect() protoreflect.Message
- func (x *SyncManifestRequest) Reset()
- func (x *SyncManifestRequest) String() string
- type SyncManifestResponse
- func (*SyncManifestResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SyncManifestResponse) GetManifestNodeId() string
- func (x *SyncManifestResponse) GetNrFilesAdded() int32
- func (x *SyncManifestResponse) GetNrFilesRemoved() int32
- func (*SyncManifestResponse) ProtoMessage()
- func (x *SyncManifestResponse) ProtoReflect() protoreflect.Message
- func (x *SyncManifestResponse) Reset()
- func (x *SyncManifestResponse) String() string
- type UnimplementedAgentServer
- func (UnimplementedAgentServer) AddToManifest(context.Context, *AddToManifestRequest) (*SimpleStatusResponse, error)
- func (UnimplementedAgentServer) CancelUpload(context.Context, *CancelUploadRequest) (*SimpleStatusResponse, error)
- func (UnimplementedAgentServer) CreateManifest(context.Context, *CreateManifestRequest) (*SimpleStatusResponse, error)
- func (UnimplementedAgentServer) DeleteManifest(context.Context, *DeleteManifestRequest) (*SimpleStatusResponse, error)
- 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) RemoveFromManifest(context.Context, *RemoveFromManifestRequest) (*SimpleStatusResponse, error)
- func (UnimplementedAgentServer) Subscribe(*SubscribeRequest, Agent_SubscribeServer) error
- func (UnimplementedAgentServer) SwitchProfile(context.Context, *SwitchProfileRequest) (*UserResponse, error)
- func (UnimplementedAgentServer) SyncManifest(context.Context, *SyncManifestRequest) (*SyncManifestResponse, error)
- func (UnimplementedAgentServer) Unsubscribe(context.Context, *SubscribeRequest) (*SubsrcribeResponse, error)
- func (UnimplementedAgentServer) UploadManifest(context.Context, *UploadManifestRequest) (*SimpleStatusResponse, error)
- func (UnimplementedAgentServer) UseDataset(context.Context, *UseDatasetRequest) (*UseDatasetResponse, error)
- type UnsafeAgentServer
- type UploadManifestRequest
- func (*UploadManifestRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UploadManifestRequest) GetManifestId() string
- func (*UploadManifestRequest) ProtoMessage()
- func (x *UploadManifestRequest) ProtoReflect() protoreflect.Message
- func (x *UploadManifestRequest) Reset()
- func (x *UploadManifestRequest) String() string
- type UseDatasetRequest
- type UseDatasetResponse
- func (*UseDatasetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UseDatasetResponse) GetDatasetId() string
- func (*UseDatasetResponse) ProtoMessage()
- func (x *UseDatasetResponse) ProtoReflect() protoreflect.Message
- func (x *UseDatasetResponse) Reset()
- func (x *UseDatasetResponse) String() string
- type UserResponse
- func (*UserResponse) Descriptor() ([]byte, []int)deprecated
- 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 (*UserResponse) ProtoMessage()
- func (x *UserResponse) ProtoReflect() protoreflect.Message
- func (x *UserResponse) Reset()
- func (x *UserResponse) String() string
Constants ¶
This section is empty.
Variables ¶
var ( SubsrcribeResponse_MessageType_name = map[int32]string{ 0: "EVENT", 1: "UPLOAD_STATUS", 2: "UPLOAD_CANCEL", } SubsrcribeResponse_MessageType_value = map[string]int32{ "EVENT": 0, "UPLOAD_STATUS": 1, "UPLOAD_CANCEL": 2, } )
Enum value maps for SubsrcribeResponse_MessageType.
var ( ListManifestFilesResponse_StatusType_name = map[int32]string{ 0: "INDEXED", 1: "SYNCED", 3: "UPLOADING", 4: "COMPLETED", 5: "VERIFIED", 6: "CANCELLED", } ListManifestFilesResponse_StatusType_value = map[string]int32{ "INDEXED": 0, "SYNCED": 1, "UPLOADING": 3, "COMPLETED": 4, "VERIFIED": 5, "CANCELLED": 6, } )
Enum value maps for ListManifestFilesResponse_StatusType.
var Agent_ServiceDesc = grpc.ServiceDesc{ ServiceName: "protos.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: "SyncManifest", Handler: _Agent_SyncManifest_Handler, }, { MethodName: "UploadManifest", Handler: _Agent_UploadManifest_Handler, }, { MethodName: "CancelUpload", Handler: _Agent_CancelUpload_Handler, }, { MethodName: "Unsubscribe", Handler: _Agent_Unsubscribe_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, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Subscribe", Handler: _Agent_Subscribe_Handler, ServerStreams: true, }, }, Metadata: "protos/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)
var File_protos_agent_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAgentServer ¶
func RegisterAgentServer(s grpc.ServiceRegistrar, srv AgentServer)
Types ¶
type AddToManifestRequest ¶ added in v0.1.2
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"` // contains filtered or unexported fields }
func (*AddToManifestRequest) Descriptor
deprecated
added in
v0.1.2
func (*AddToManifestRequest) Descriptor() ([]byte, []int)
Deprecated: Use AddToManifestRequest.ProtoReflect.Descriptor instead.
func (*AddToManifestRequest) GetBasePath ¶ added in v0.1.2
func (x *AddToManifestRequest) GetBasePath() string
func (*AddToManifestRequest) GetManifestId ¶ added in v0.1.2
func (x *AddToManifestRequest) GetManifestId() int32
func (*AddToManifestRequest) GetRecursive ¶ added in v0.1.2
func (x *AddToManifestRequest) GetRecursive() bool
func (*AddToManifestRequest) GetTargetBasePath ¶ added in v0.1.2
func (x *AddToManifestRequest) GetTargetBasePath() string
func (*AddToManifestRequest) ProtoMessage ¶ added in v0.1.2
func (*AddToManifestRequest) ProtoMessage()
func (*AddToManifestRequest) ProtoReflect ¶ added in v0.1.2
func (x *AddToManifestRequest) ProtoReflect() protoreflect.Message
func (*AddToManifestRequest) Reset ¶ added in v0.1.2
func (x *AddToManifestRequest) Reset()
func (*AddToManifestRequest) String ¶ added in v0.1.2
func (x *AddToManifestRequest) String() string
type AgentClient ¶
type AgentClient interface { // Manifest Endpoints CreateManifest(ctx context.Context, in *CreateManifestRequest, opts ...grpc.CallOption) (*SimpleStatusResponse, 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) // rpc ResetManifest(ResetManifestRequest) returns (SimpleStatusResponse) {} ListManifests(ctx context.Context, in *ListManifestsRequest, opts ...grpc.CallOption) (*ListManifestsResponse, error) ListManifestFiles(ctx context.Context, in *ListManifestFilesRequest, opts ...grpc.CallOption) (*ListManifestFilesResponse, error) SyncManifest(ctx context.Context, in *SyncManifestRequest, opts ...grpc.CallOption) (*SyncManifestResponse, 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 Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Agent_SubscribeClient, error) Unsubscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (*SubsrcribeResponse, 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) }
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) (*SimpleStatusResponse, error) AddToManifest(context.Context, *AddToManifestRequest) (*SimpleStatusResponse, error) RemoveFromManifest(context.Context, *RemoveFromManifestRequest) (*SimpleStatusResponse, error) DeleteManifest(context.Context, *DeleteManifestRequest) (*SimpleStatusResponse, error) // rpc ResetManifest(ResetManifestRequest) returns (SimpleStatusResponse) {} ListManifests(context.Context, *ListManifestsRequest) (*ListManifestsResponse, error) ListManifestFiles(context.Context, *ListManifestFilesRequest) (*ListManifestFilesResponse, error) SyncManifest(context.Context, *SyncManifestRequest) (*SyncManifestResponse, error) // Upload Endpoints UploadManifest(context.Context, *UploadManifestRequest) (*SimpleStatusResponse, error) CancelUpload(context.Context, *CancelUploadRequest) (*SimpleStatusResponse, error) // Server Endpoints Subscribe(*SubscribeRequest, Agent_SubscribeServer) error Unsubscribe(context.Context, *SubscribeRequest) (*SubsrcribeResponse, 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) // 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() (*SubsrcribeResponse, error) grpc.ClientStream }
type Agent_SubscribeServer ¶
type Agent_SubscribeServer interface { Send(*SubsrcribeResponse) error grpc.ServerStream }
type CancelUploadRequest ¶ added in v0.1.2
type CancelUploadRequest struct { ManifestId string `protobuf:"bytes,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
added in
v0.1.2
func (*CancelUploadRequest) Descriptor() ([]byte, []int)
Deprecated: Use CancelUploadRequest.ProtoReflect.Descriptor instead.
func (*CancelUploadRequest) GetCancelAll ¶ added in v0.1.2
func (x *CancelUploadRequest) GetCancelAll() bool
func (*CancelUploadRequest) GetManifestId ¶ added in v0.1.2
func (x *CancelUploadRequest) GetManifestId() string
func (*CancelUploadRequest) ProtoMessage ¶ added in v0.1.2
func (*CancelUploadRequest) ProtoMessage()
func (*CancelUploadRequest) ProtoReflect ¶ added in v0.1.2
func (x *CancelUploadRequest) ProtoReflect() protoreflect.Message
func (*CancelUploadRequest) Reset ¶ added in v0.1.2
func (x *CancelUploadRequest) Reset()
func (*CancelUploadRequest) String ¶ added in v0.1.2
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"` // 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) 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 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 ¶ added in v0.1.2
type GetUserRequest struct {
// contains filtered or unexported fields
}
func (*GetUserRequest) Descriptor
deprecated
added in
v0.1.2
func (*GetUserRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetUserRequest.ProtoReflect.Descriptor instead.
func (*GetUserRequest) ProtoMessage ¶ added in v0.1.2
func (*GetUserRequest) ProtoMessage()
func (*GetUserRequest) ProtoReflect ¶ added in v0.1.2
func (x *GetUserRequest) ProtoReflect() protoreflect.Message
func (*GetUserRequest) Reset ¶ added in v0.1.2
func (x *GetUserRequest) Reset()
func (*GetUserRequest) String ¶ added in v0.1.2
func (x *GetUserRequest) String() string
type ListManifestFilesRequest ¶ added in v0.1.2
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
added in
v0.1.2
func (*ListManifestFilesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListManifestFilesRequest.ProtoReflect.Descriptor instead.
func (*ListManifestFilesRequest) GetLimit ¶ added in v0.1.2
func (x *ListManifestFilesRequest) GetLimit() int32
func (*ListManifestFilesRequest) GetManifestId ¶ added in v0.1.2
func (x *ListManifestFilesRequest) GetManifestId() int32
func (*ListManifestFilesRequest) GetOffset ¶ added in v0.1.2
func (x *ListManifestFilesRequest) GetOffset() int32
func (*ListManifestFilesRequest) ProtoMessage ¶ added in v0.1.2
func (*ListManifestFilesRequest) ProtoMessage()
func (*ListManifestFilesRequest) ProtoReflect ¶ added in v0.1.2
func (x *ListManifestFilesRequest) ProtoReflect() protoreflect.Message
func (*ListManifestFilesRequest) Reset ¶ added in v0.1.2
func (x *ListManifestFilesRequest) Reset()
func (*ListManifestFilesRequest) String ¶ added in v0.1.2
func (x *ListManifestFilesRequest) String() string
type ListManifestFilesResponse ¶ added in v0.1.2
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
added in
v0.1.2
func (*ListManifestFilesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListManifestFilesResponse.ProtoReflect.Descriptor instead.
func (*ListManifestFilesResponse) GetFile ¶ added in v0.1.2
func (x *ListManifestFilesResponse) GetFile() []*ListManifestFilesResponse_FileUpload
func (*ListManifestFilesResponse) ProtoMessage ¶ added in v0.1.2
func (*ListManifestFilesResponse) ProtoMessage()
func (*ListManifestFilesResponse) ProtoReflect ¶ added in v0.1.2
func (x *ListManifestFilesResponse) ProtoReflect() protoreflect.Message
func (*ListManifestFilesResponse) Reset ¶ added in v0.1.2
func (x *ListManifestFilesResponse) Reset()
func (*ListManifestFilesResponse) String ¶ added in v0.1.2
func (x *ListManifestFilesResponse) String() string
type ListManifestFilesResponse_FileUpload ¶ added in v0.1.2
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=protos.ListManifestFilesResponse_StatusType" json:"status,omitempty"` // contains filtered or unexported fields }
func (*ListManifestFilesResponse_FileUpload) Descriptor
deprecated
added in
v0.1.2
func (*ListManifestFilesResponse_FileUpload) Descriptor() ([]byte, []int)
Deprecated: Use ListManifestFilesResponse_FileUpload.ProtoReflect.Descriptor instead.
func (*ListManifestFilesResponse_FileUpload) GetId ¶ added in v0.1.2
func (x *ListManifestFilesResponse_FileUpload) GetId() int32
func (*ListManifestFilesResponse_FileUpload) GetManifestId ¶ added in v0.1.2
func (x *ListManifestFilesResponse_FileUpload) GetManifestId() int32
func (*ListManifestFilesResponse_FileUpload) GetSourcePath ¶ added in v0.1.2
func (x *ListManifestFilesResponse_FileUpload) GetSourcePath() string
func (*ListManifestFilesResponse_FileUpload) GetStatus ¶ added in v0.1.2
func (x *ListManifestFilesResponse_FileUpload) GetStatus() ListManifestFilesResponse_StatusType
func (*ListManifestFilesResponse_FileUpload) GetTargetPath ¶ added in v0.1.2
func (x *ListManifestFilesResponse_FileUpload) GetTargetPath() string
func (*ListManifestFilesResponse_FileUpload) GetUploadId ¶ added in v0.1.2
func (x *ListManifestFilesResponse_FileUpload) GetUploadId() string
func (*ListManifestFilesResponse_FileUpload) ProtoMessage ¶ added in v0.1.2
func (*ListManifestFilesResponse_FileUpload) ProtoMessage()
func (*ListManifestFilesResponse_FileUpload) ProtoReflect ¶ added in v0.1.2
func (x *ListManifestFilesResponse_FileUpload) ProtoReflect() protoreflect.Message
func (*ListManifestFilesResponse_FileUpload) Reset ¶ added in v0.1.2
func (x *ListManifestFilesResponse_FileUpload) Reset()
func (*ListManifestFilesResponse_FileUpload) String ¶ added in v0.1.2
func (x *ListManifestFilesResponse_FileUpload) String() string
type ListManifestFilesResponse_StatusType ¶ added in v0.1.2
type ListManifestFilesResponse_StatusType int32
const ( ListManifestFilesResponse_INDEXED ListManifestFilesResponse_StatusType = 0 // File indexed locally ListManifestFilesResponse_SYNCED ListManifestFilesResponse_StatusType = 1 // File manifest synchronized with Cloud ListManifestFilesResponse_UPLOADING ListManifestFilesResponse_StatusType = 3 // File being uploaded ListManifestFilesResponse_COMPLETED ListManifestFilesResponse_StatusType = 4 // File completed uploading ListManifestFilesResponse_VERIFIED ListManifestFilesResponse_StatusType = 5 // File imported in cloud ListManifestFilesResponse_CANCELLED ListManifestFilesResponse_StatusType = 6 // File Upload canceled (manually, or failed) )
func (ListManifestFilesResponse_StatusType) Descriptor ¶ added in v0.1.2
func (ListManifestFilesResponse_StatusType) Descriptor() protoreflect.EnumDescriptor
func (ListManifestFilesResponse_StatusType) Enum ¶ added in v0.1.2
func (x ListManifestFilesResponse_StatusType) Enum() *ListManifestFilesResponse_StatusType
func (ListManifestFilesResponse_StatusType) EnumDescriptor
deprecated
added in
v0.1.2
func (ListManifestFilesResponse_StatusType) EnumDescriptor() ([]byte, []int)
Deprecated: Use ListManifestFilesResponse_StatusType.Descriptor instead.
func (ListManifestFilesResponse_StatusType) Number ¶ added in v0.1.2
func (x ListManifestFilesResponse_StatusType) Number() protoreflect.EnumNumber
func (ListManifestFilesResponse_StatusType) String ¶ added in v0.1.2
func (x ListManifestFilesResponse_StatusType) String() string
func (ListManifestFilesResponse_StatusType) Type ¶ added in v0.1.2
func (ListManifestFilesResponse_StatusType) Type() protoreflect.EnumType
type ListManifestsRequest ¶ added in v0.1.2
type ListManifestsRequest struct {
// contains filtered or unexported fields
}
func (*ListManifestsRequest) Descriptor
deprecated
added in
v0.1.2
func (*ListManifestsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListManifestsRequest.ProtoReflect.Descriptor instead.
func (*ListManifestsRequest) ProtoMessage ¶ added in v0.1.2
func (*ListManifestsRequest) ProtoMessage()
func (*ListManifestsRequest) ProtoReflect ¶ added in v0.1.2
func (x *ListManifestsRequest) ProtoReflect() protoreflect.Message
func (*ListManifestsRequest) Reset ¶ added in v0.1.2
func (x *ListManifestsRequest) Reset()
func (*ListManifestsRequest) String ¶ added in v0.1.2
func (x *ListManifestsRequest) String() string
type ListManifestsResponse ¶ added in v0.1.2
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
added in
v0.1.2
func (*ListManifestsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListManifestsResponse.ProtoReflect.Descriptor instead.
func (*ListManifestsResponse) GetManifests ¶ added in v0.1.2
func (x *ListManifestsResponse) GetManifests() []*ListManifestsResponse_Manifest
func (*ListManifestsResponse) ProtoMessage ¶ added in v0.1.2
func (*ListManifestsResponse) ProtoMessage()
func (*ListManifestsResponse) ProtoReflect ¶ added in v0.1.2
func (x *ListManifestsResponse) ProtoReflect() protoreflect.Message
func (*ListManifestsResponse) Reset ¶ added in v0.1.2
func (x *ListManifestsResponse) Reset()
func (*ListManifestsResponse) String ¶ added in v0.1.2
func (x *ListManifestsResponse) String() string
type ListManifestsResponse_Manifest ¶ added in v0.1.2
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
added in
v0.1.2
func (*ListManifestsResponse_Manifest) Descriptor() ([]byte, []int)
Deprecated: Use ListManifestsResponse_Manifest.ProtoReflect.Descriptor instead.
func (*ListManifestsResponse_Manifest) GetDatasetId ¶ added in v0.1.2
func (x *ListManifestsResponse_Manifest) GetDatasetId() string
func (*ListManifestsResponse_Manifest) GetDatasetName ¶ added in v0.1.2
func (x *ListManifestsResponse_Manifest) GetDatasetName() string
func (*ListManifestsResponse_Manifest) GetId ¶ added in v0.1.2
func (x *ListManifestsResponse_Manifest) GetId() int32
func (*ListManifestsResponse_Manifest) GetNodeId ¶ added in v0.1.2
func (x *ListManifestsResponse_Manifest) GetNodeId() string
func (*ListManifestsResponse_Manifest) GetOrganizationId ¶ added in v0.1.2
func (x *ListManifestsResponse_Manifest) GetOrganizationId() string
func (*ListManifestsResponse_Manifest) GetOrganizationName ¶ added in v0.1.2
func (x *ListManifestsResponse_Manifest) GetOrganizationName() string
func (*ListManifestsResponse_Manifest) GetStatus ¶ added in v0.1.2
func (x *ListManifestsResponse_Manifest) GetStatus() string
func (*ListManifestsResponse_Manifest) GetUserId ¶ added in v0.1.2
func (x *ListManifestsResponse_Manifest) GetUserId() string
func (*ListManifestsResponse_Manifest) GetUserName ¶ added in v0.1.2
func (x *ListManifestsResponse_Manifest) GetUserName() string
func (*ListManifestsResponse_Manifest) ProtoMessage ¶ added in v0.1.2
func (*ListManifestsResponse_Manifest) ProtoMessage()
func (*ListManifestsResponse_Manifest) ProtoReflect ¶ added in v0.1.2
func (x *ListManifestsResponse_Manifest) ProtoReflect() protoreflect.Message
func (*ListManifestsResponse_Manifest) Reset ¶ added in v0.1.2
func (x *ListManifestsResponse_Manifest) Reset()
func (*ListManifestsResponse_Manifest) String ¶ added in v0.1.2
func (x *ListManifestsResponse_Manifest) String() string
type ReAuthenticateRequest ¶ added in v0.1.2
type ReAuthenticateRequest struct {
// contains filtered or unexported fields
}
func (*ReAuthenticateRequest) Descriptor
deprecated
added in
v0.1.2
func (*ReAuthenticateRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReAuthenticateRequest.ProtoReflect.Descriptor instead.
func (*ReAuthenticateRequest) ProtoMessage ¶ added in v0.1.2
func (*ReAuthenticateRequest) ProtoMessage()
func (*ReAuthenticateRequest) ProtoReflect ¶ added in v0.1.2
func (x *ReAuthenticateRequest) ProtoReflect() protoreflect.Message
func (*ReAuthenticateRequest) Reset ¶ added in v0.1.2
func (x *ReAuthenticateRequest) Reset()
func (*ReAuthenticateRequest) String ¶ added in v0.1.2
func (x *ReAuthenticateRequest) String() string
type RemoveFromManifestRequest ¶
type RemoveFromManifestRequest struct { ManifestId string `protobuf:"bytes,1,opt,name=manifest_id,json=manifestId,proto3" json:"manifest_id,omitempty"` FileId []int32 `protobuf:"varint,2,rep,packed,name=file_id,json=fileId,proto3" json:"file_id,omitempty"` // contains filtered or unexported fields }
func (*RemoveFromManifestRequest) Descriptor
deprecated
func (*RemoveFromManifestRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveFromManifestRequest.ProtoReflect.Descriptor instead.
func (*RemoveFromManifestRequest) GetFileId ¶
func (x *RemoveFromManifestRequest) GetFileId() []int32
func (*RemoveFromManifestRequest) GetManifestId ¶
func (x *RemoveFromManifestRequest) GetManifestId() 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 ¶ added in v0.1.2
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
added in
v0.1.2
func (*ResetManifestRequest) Descriptor() ([]byte, []int)
Deprecated: Use ResetManifestRequest.ProtoReflect.Descriptor instead.
func (*ResetManifestRequest) GetManifestId ¶ added in v0.1.2
func (x *ResetManifestRequest) GetManifestId() int32
func (*ResetManifestRequest) ProtoMessage ¶ added in v0.1.2
func (*ResetManifestRequest) ProtoMessage()
func (*ResetManifestRequest) ProtoReflect ¶ added in v0.1.2
func (x *ResetManifestRequest) ProtoReflect() protoreflect.Message
func (*ResetManifestRequest) Reset ¶ added in v0.1.2
func (x *ResetManifestRequest) Reset()
func (*ResetManifestRequest) String ¶ added in v0.1.2
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 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 SubsrcribeResponse ¶
type SubsrcribeResponse struct { Type SubsrcribeResponse_MessageType `protobuf:"varint,8,opt,name=type,proto3,enum=protos.SubsrcribeResponse_MessageType" json:"type,omitempty"` // Types that are assignable to MessageData: // *SubsrcribeResponse_UploadStatus // *SubsrcribeResponse_EventInfo MessageData isSubsrcribeResponse_MessageData `protobuf_oneof:"message_data"` // contains filtered or unexported fields }
func (*SubsrcribeResponse) Descriptor
deprecated
func (*SubsrcribeResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubsrcribeResponse.ProtoReflect.Descriptor instead.
func (*SubsrcribeResponse) GetEventInfo ¶
func (x *SubsrcribeResponse) GetEventInfo() *SubsrcribeResponse_EventResponse
func (*SubsrcribeResponse) GetMessageData ¶
func (m *SubsrcribeResponse) GetMessageData() isSubsrcribeResponse_MessageData
func (*SubsrcribeResponse) GetType ¶
func (x *SubsrcribeResponse) GetType() SubsrcribeResponse_MessageType
func (*SubsrcribeResponse) GetUploadStatus ¶
func (x *SubsrcribeResponse) GetUploadStatus() *SubsrcribeResponse_UploadResponse
func (*SubsrcribeResponse) ProtoMessage ¶
func (*SubsrcribeResponse) ProtoMessage()
func (*SubsrcribeResponse) ProtoReflect ¶
func (x *SubsrcribeResponse) ProtoReflect() protoreflect.Message
func (*SubsrcribeResponse) Reset ¶
func (x *SubsrcribeResponse) Reset()
func (*SubsrcribeResponse) String ¶
func (x *SubsrcribeResponse) String() string
type SubsrcribeResponse_EventInfo ¶
type SubsrcribeResponse_EventInfo struct {
EventInfo *SubsrcribeResponse_EventResponse `protobuf:"bytes,10,opt,name=event_info,json=eventInfo,proto3,oneof"`
}
type SubsrcribeResponse_EventResponse ¶
type SubsrcribeResponse_EventResponse struct { Details string `protobuf:"bytes,1,opt,name=details,proto3" json:"details,omitempty"` // contains filtered or unexported fields }
func (*SubsrcribeResponse_EventResponse) Descriptor
deprecated
func (*SubsrcribeResponse_EventResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubsrcribeResponse_EventResponse.ProtoReflect.Descriptor instead.
func (*SubsrcribeResponse_EventResponse) GetDetails ¶
func (x *SubsrcribeResponse_EventResponse) GetDetails() string
func (*SubsrcribeResponse_EventResponse) ProtoMessage ¶
func (*SubsrcribeResponse_EventResponse) ProtoMessage()
func (*SubsrcribeResponse_EventResponse) ProtoReflect ¶
func (x *SubsrcribeResponse_EventResponse) ProtoReflect() protoreflect.Message
func (*SubsrcribeResponse_EventResponse) Reset ¶
func (x *SubsrcribeResponse_EventResponse) Reset()
func (*SubsrcribeResponse_EventResponse) String ¶
func (x *SubsrcribeResponse_EventResponse) String() string
type SubsrcribeResponse_MessageType ¶ added in v0.1.2
type SubsrcribeResponse_MessageType int32
const ( SubsrcribeResponse_EVENT SubsrcribeResponse_MessageType = 0 // Server log message SubsrcribeResponse_UPLOAD_STATUS SubsrcribeResponse_MessageType = 1 // Upload Status Message SubsrcribeResponse_UPLOAD_CANCEL SubsrcribeResponse_MessageType = 2 // Upload was cancelled )
func (SubsrcribeResponse_MessageType) Descriptor ¶ added in v0.1.2
func (SubsrcribeResponse_MessageType) Descriptor() protoreflect.EnumDescriptor
func (SubsrcribeResponse_MessageType) Enum ¶ added in v0.1.2
func (x SubsrcribeResponse_MessageType) Enum() *SubsrcribeResponse_MessageType
func (SubsrcribeResponse_MessageType) EnumDescriptor
deprecated
added in
v0.1.2
func (SubsrcribeResponse_MessageType) EnumDescriptor() ([]byte, []int)
Deprecated: Use SubsrcribeResponse_MessageType.Descriptor instead.
func (SubsrcribeResponse_MessageType) Number ¶ added in v0.1.2
func (x SubsrcribeResponse_MessageType) Number() protoreflect.EnumNumber
func (SubsrcribeResponse_MessageType) String ¶ added in v0.1.2
func (x SubsrcribeResponse_MessageType) String() string
func (SubsrcribeResponse_MessageType) Type ¶ added in v0.1.2
func (SubsrcribeResponse_MessageType) Type() protoreflect.EnumType
type SubsrcribeResponse_UploadResponse ¶
type SubsrcribeResponse_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"` // contains filtered or unexported fields }
func (*SubsrcribeResponse_UploadResponse) Descriptor
deprecated
func (*SubsrcribeResponse_UploadResponse) Descriptor() ([]byte, []int)
Deprecated: Use SubsrcribeResponse_UploadResponse.ProtoReflect.Descriptor instead.
func (*SubsrcribeResponse_UploadResponse) GetCurrent ¶
func (x *SubsrcribeResponse_UploadResponse) GetCurrent() int64
func (*SubsrcribeResponse_UploadResponse) GetFileId ¶
func (x *SubsrcribeResponse_UploadResponse) GetFileId() string
func (*SubsrcribeResponse_UploadResponse) GetTotal ¶
func (x *SubsrcribeResponse_UploadResponse) GetTotal() int64
func (*SubsrcribeResponse_UploadResponse) GetWorkerId ¶
func (x *SubsrcribeResponse_UploadResponse) GetWorkerId() int32
func (*SubsrcribeResponse_UploadResponse) ProtoMessage ¶
func (*SubsrcribeResponse_UploadResponse) ProtoMessage()
func (*SubsrcribeResponse_UploadResponse) ProtoReflect ¶
func (x *SubsrcribeResponse_UploadResponse) ProtoReflect() protoreflect.Message
func (*SubsrcribeResponse_UploadResponse) Reset ¶
func (x *SubsrcribeResponse_UploadResponse) Reset()
func (*SubsrcribeResponse_UploadResponse) String ¶
func (x *SubsrcribeResponse_UploadResponse) String() string
type SubsrcribeResponse_UploadStatus ¶
type SubsrcribeResponse_UploadStatus struct {
UploadStatus *SubsrcribeResponse_UploadResponse `protobuf:"bytes,9,opt,name=upload_status,json=uploadStatus,proto3,oneof"`
}
type SwitchProfileRequest ¶ added in v0.1.2
type SwitchProfileRequest struct { Profile string `protobuf:"bytes,1,opt,name=profile,proto3" json:"profile,omitempty"` // contains filtered or unexported fields }
func (*SwitchProfileRequest) Descriptor
deprecated
added in
v0.1.2
func (*SwitchProfileRequest) Descriptor() ([]byte, []int)
Deprecated: Use SwitchProfileRequest.ProtoReflect.Descriptor instead.
func (*SwitchProfileRequest) GetProfile ¶ added in v0.1.2
func (x *SwitchProfileRequest) GetProfile() string
func (*SwitchProfileRequest) ProtoMessage ¶ added in v0.1.2
func (*SwitchProfileRequest) ProtoMessage()
func (*SwitchProfileRequest) ProtoReflect ¶ added in v0.1.2
func (x *SwitchProfileRequest) ProtoReflect() protoreflect.Message
func (*SwitchProfileRequest) Reset ¶ added in v0.1.2
func (x *SwitchProfileRequest) Reset()
func (*SwitchProfileRequest) String ¶ added in v0.1.2
func (x *SwitchProfileRequest) String() string
type SyncManifestRequest ¶ added in v0.1.2
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
added in
v0.1.2
func (*SyncManifestRequest) Descriptor() ([]byte, []int)
Deprecated: Use SyncManifestRequest.ProtoReflect.Descriptor instead.
func (*SyncManifestRequest) GetManifestId ¶ added in v0.1.2
func (x *SyncManifestRequest) GetManifestId() int32
func (*SyncManifestRequest) ProtoMessage ¶ added in v0.1.2
func (*SyncManifestRequest) ProtoMessage()
func (*SyncManifestRequest) ProtoReflect ¶ added in v0.1.2
func (x *SyncManifestRequest) ProtoReflect() protoreflect.Message
func (*SyncManifestRequest) Reset ¶ added in v0.1.2
func (x *SyncManifestRequest) Reset()
func (*SyncManifestRequest) String ¶ added in v0.1.2
func (x *SyncManifestRequest) String() string
type SyncManifestResponse ¶ added in v0.1.2
type SyncManifestResponse struct { ManifestNodeId string `protobuf:"bytes,1,opt,name=manifest_node_id,json=manifestNodeId,proto3" json:"manifest_node_id,omitempty"` NrFilesAdded int32 `protobuf:"varint,2,opt,name=nr_files_added,json=nrFilesAdded,proto3" json:"nr_files_added,omitempty"` NrFilesRemoved int32 `protobuf:"varint,3,opt,name=nr_files_removed,json=nrFilesRemoved,proto3" json:"nr_files_removed,omitempty"` // contains filtered or unexported fields }
func (*SyncManifestResponse) Descriptor
deprecated
added in
v0.1.2
func (*SyncManifestResponse) Descriptor() ([]byte, []int)
Deprecated: Use SyncManifestResponse.ProtoReflect.Descriptor instead.
func (*SyncManifestResponse) GetManifestNodeId ¶ added in v0.1.2
func (x *SyncManifestResponse) GetManifestNodeId() string
func (*SyncManifestResponse) GetNrFilesAdded ¶ added in v0.1.2
func (x *SyncManifestResponse) GetNrFilesAdded() int32
func (*SyncManifestResponse) GetNrFilesRemoved ¶ added in v0.1.2
func (x *SyncManifestResponse) GetNrFilesRemoved() int32
func (*SyncManifestResponse) ProtoMessage ¶ added in v0.1.2
func (*SyncManifestResponse) ProtoMessage()
func (*SyncManifestResponse) ProtoReflect ¶ added in v0.1.2
func (x *SyncManifestResponse) ProtoReflect() protoreflect.Message
func (*SyncManifestResponse) Reset ¶ added in v0.1.2
func (x *SyncManifestResponse) Reset()
func (*SyncManifestResponse) String ¶ added in v0.1.2
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) (*SimpleStatusResponse, error)
func (UnimplementedAgentServer) DeleteManifest ¶
func (UnimplementedAgentServer) DeleteManifest(context.Context, *DeleteManifestRequest) (*SimpleStatusResponse, error)
func (UnimplementedAgentServer) GetUser ¶ added in v0.1.2
func (UnimplementedAgentServer) GetUser(context.Context, *GetUserRequest) (*UserResponse, error)
func (UnimplementedAgentServer) ListManifestFiles ¶ added in v0.1.2
func (UnimplementedAgentServer) ListManifestFiles(context.Context, *ListManifestFilesRequest) (*ListManifestFilesResponse, error)
func (UnimplementedAgentServer) ListManifests ¶ added in v0.1.2
func (UnimplementedAgentServer) ListManifests(context.Context, *ListManifestsRequest) (*ListManifestsResponse, error)
func (UnimplementedAgentServer) ReAuthenticate ¶ added in v0.1.2
func (UnimplementedAgentServer) ReAuthenticate(context.Context, *ReAuthenticateRequest) (*UserResponse, error)
func (UnimplementedAgentServer) RemoveFromManifest ¶
func (UnimplementedAgentServer) RemoveFromManifest(context.Context, *RemoveFromManifestRequest) (*SimpleStatusResponse, error)
func (UnimplementedAgentServer) Subscribe ¶
func (UnimplementedAgentServer) Subscribe(*SubscribeRequest, Agent_SubscribeServer) error
func (UnimplementedAgentServer) SwitchProfile ¶ added in v0.1.2
func (UnimplementedAgentServer) SwitchProfile(context.Context, *SwitchProfileRequest) (*UserResponse, error)
func (UnimplementedAgentServer) SyncManifest ¶ added in v0.1.2
func (UnimplementedAgentServer) SyncManifest(context.Context, *SyncManifestRequest) (*SyncManifestResponse, error)
func (UnimplementedAgentServer) Unsubscribe ¶
func (UnimplementedAgentServer) Unsubscribe(context.Context, *SubscribeRequest) (*SubsrcribeResponse, error)
func (UnimplementedAgentServer) UploadManifest ¶
func (UnimplementedAgentServer) UploadManifest(context.Context, *UploadManifestRequest) (*SimpleStatusResponse, error)
func (UnimplementedAgentServer) UseDataset ¶ added in v0.1.2
func (UnimplementedAgentServer) UseDataset(context.Context, *UseDatasetRequest) (*UseDatasetResponse, 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 string `protobuf:"bytes,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() string
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 ¶ added in v0.1.2
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
added in
v0.1.2
func (*UseDatasetRequest) Descriptor() ([]byte, []int)
Deprecated: Use UseDatasetRequest.ProtoReflect.Descriptor instead.
func (*UseDatasetRequest) GetDatasetId ¶ added in v0.1.2
func (x *UseDatasetRequest) GetDatasetId() string
func (*UseDatasetRequest) ProtoMessage ¶ added in v0.1.2
func (*UseDatasetRequest) ProtoMessage()
func (*UseDatasetRequest) ProtoReflect ¶ added in v0.1.2
func (x *UseDatasetRequest) ProtoReflect() protoreflect.Message
func (*UseDatasetRequest) Reset ¶ added in v0.1.2
func (x *UseDatasetRequest) Reset()
func (*UseDatasetRequest) String ¶ added in v0.1.2
func (x *UseDatasetRequest) String() string
type UseDatasetResponse ¶ added in v0.1.2
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
added in
v0.1.2
func (*UseDatasetResponse) Descriptor() ([]byte, []int)
Deprecated: Use UseDatasetResponse.ProtoReflect.Descriptor instead.
func (*UseDatasetResponse) GetDatasetId ¶ added in v0.1.2
func (x *UseDatasetResponse) GetDatasetId() string
func (*UseDatasetResponse) ProtoMessage ¶ added in v0.1.2
func (*UseDatasetResponse) ProtoMessage()
func (*UseDatasetResponse) ProtoReflect ¶ added in v0.1.2
func (x *UseDatasetResponse) ProtoReflect() protoreflect.Message
func (*UseDatasetResponse) Reset ¶ added in v0.1.2
func (x *UseDatasetResponse) Reset()
func (*UseDatasetResponse) String ¶ added in v0.1.2
func (x *UseDatasetResponse) String() string
type UserResponse ¶ added in v0.1.2
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"` // contains filtered or unexported fields }
func (*UserResponse) Descriptor
deprecated
added in
v0.1.2
func (*UserResponse) Descriptor() ([]byte, []int)
Deprecated: Use UserResponse.ProtoReflect.Descriptor instead.
func (*UserResponse) GetEnvironment ¶ added in v0.1.2
func (x *UserResponse) GetEnvironment() string
func (*UserResponse) GetId ¶ added in v0.1.2
func (x *UserResponse) GetId() string
func (*UserResponse) GetName ¶ added in v0.1.2
func (x *UserResponse) GetName() string
func (*UserResponse) GetOrganizationId ¶ added in v0.1.2
func (x *UserResponse) GetOrganizationId() string
func (*UserResponse) GetOrganizationName ¶ added in v0.1.2
func (x *UserResponse) GetOrganizationName() string
func (*UserResponse) GetProfile ¶ added in v0.1.2
func (x *UserResponse) GetProfile() string
func (*UserResponse) GetSessionToken ¶ added in v0.1.2
func (x *UserResponse) GetSessionToken() string
func (*UserResponse) GetTokenExpire ¶ added in v0.1.2
func (x *UserResponse) GetTokenExpire() int64
func (*UserResponse) ProtoMessage ¶ added in v0.1.2
func (*UserResponse) ProtoMessage()
func (*UserResponse) ProtoReflect ¶ added in v0.1.2
func (x *UserResponse) ProtoReflect() protoreflect.Message
func (*UserResponse) Reset ¶ added in v0.1.2
func (x *UserResponse) Reset()
func (*UserResponse) String ¶ added in v0.1.2
func (x *UserResponse) String() string