protos

package
v0.1.5 Latest Latest
Warning

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

Go to latest
Published: Jun 15, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.

View Source
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.

View Source
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)

View Source
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 (*ListManifestFilesResponse) ProtoMessage added in v0.1.2

func (*ListManifestFilesResponse) ProtoMessage()

func (*ListManifestFilesResponse) ProtoReflect added in v0.1.2

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 (*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 (*ListManifestFilesResponse_FileUpload) GetTargetPath added in v0.1.2

func (x *ListManifestFilesResponse_FileUpload) GetTargetPath() string

func (*ListManifestFilesResponse_FileUpload) GetUploadId added in v0.1.2

func (*ListManifestFilesResponse_FileUpload) ProtoMessage added in v0.1.2

func (*ListManifestFilesResponse_FileUpload) ProtoMessage()

func (*ListManifestFilesResponse_FileUpload) ProtoReflect added in v0.1.2

func (*ListManifestFilesResponse_FileUpload) Reset added in v0.1.2

func (*ListManifestFilesResponse_FileUpload) String added in v0.1.2

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) Enum added in v0.1.2

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 (ListManifestFilesResponse_StatusType) String added in v0.1.2

func (ListManifestFilesResponse_StatusType) Type added in v0.1.2

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 (*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 (*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 (*ListManifestsResponse_Manifest) Reset added in v0.1.2

func (x *ListManifestsResponse_Manifest) Reset()

func (*ListManifestsResponse_Manifest) String added in v0.1.2

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 (*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 (*SubsrcribeResponse) GetMessageData

func (m *SubsrcribeResponse) GetMessageData() isSubsrcribeResponse_MessageData

func (*SubsrcribeResponse) GetType

func (*SubsrcribeResponse) GetUploadStatus

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 (*SubsrcribeResponse_EventResponse) Reset

func (*SubsrcribeResponse_EventResponse) 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) Enum added in v0.1.2

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 (SubsrcribeResponse_MessageType) String added in v0.1.2

func (SubsrcribeResponse_MessageType) Type added in v0.1.2

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 (*SubsrcribeResponse_UploadResponse) GetTotal

func (*SubsrcribeResponse_UploadResponse) GetWorkerId

func (x *SubsrcribeResponse_UploadResponse) GetWorkerId() int32

func (*SubsrcribeResponse_UploadResponse) ProtoMessage

func (*SubsrcribeResponse_UploadResponse) ProtoMessage()

func (*SubsrcribeResponse_UploadResponse) ProtoReflect

func (*SubsrcribeResponse_UploadResponse) Reset

func (*SubsrcribeResponse_UploadResponse) 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) CancelUpload

func (UnimplementedAgentServer) CreateManifest

func (UnimplementedAgentServer) DeleteManifest

func (UnimplementedAgentServer) GetUser added in v0.1.2

func (UnimplementedAgentServer) ListManifestFiles added in v0.1.2

func (UnimplementedAgentServer) ListManifests added in v0.1.2

func (UnimplementedAgentServer) ReAuthenticate added in v0.1.2

func (UnimplementedAgentServer) RemoveFromManifest

func (UnimplementedAgentServer) Subscribe

func (UnimplementedAgentServer) SwitchProfile added in v0.1.2

func (UnimplementedAgentServer) SyncManifest added in v0.1.2

func (UnimplementedAgentServer) Unsubscribe

func (UnimplementedAgentServer) UploadManifest

func (UnimplementedAgentServer) UseDataset added in v0.1.2

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

Jump to

Keyboard shortcuts

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