protos

package
v0.1.0 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SubsrcribeResponse_MESSAGE_TYPE_name = map[int32]string{
		0: "EVENT",
		1: "UPLOAD_STATUS",
		2: "UPLOAD_CANCEL",
	}
	SubsrcribeResponse_MESSAGE_TYPE_value = map[string]int32{
		"EVENT":         0,
		"UPLOAD_STATUS": 1,
		"UPLOAD_CANCEL": 2,
	}
)

Enum value maps for SubsrcribeResponse_MESSAGE_TYPE.

View Source 
var (
	ListFilesResponse_STATUS_TYPE_name = map[int32]string{
		0: "INDEXED",
		1: "SYNCED",
		3: "UPLOADING",
		4: "COMPLETED",
		5: "CANCELED",
	}
	ListFilesResponse_STATUS_TYPE_value = map[string]int32{
		"INDEXED":   0,
		"SYNCED":    1,
		"UPLOADING": 3,
		"COMPLETED": 4,
		"CANCELED":  5,
	}
)

Enum value maps for ListFilesResponse_STATUS_TYPE.

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: "ManifestStatus",
			Handler:    _Agent_ManifestStatus_Handler,
		},
		{
			MethodName: "ListFilesForManifest",
			Handler:    _Agent_ListFilesForManifest_Handler,
		},
		{
			MethodName: "UploadManifest",
			Handler:    _Agent_UploadManifest_Handler,
		},
		{
			MethodName: "CancelUpload",
			Handler:    _Agent_CancelUpload_Handler,
		},
		{
			MethodName: "Unsubscribe",
			Handler:    _Agent_Unsubscribe_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 AddManifestRequest 

type AddManifestRequest struct {
	ManifestId     string `protobuf:"bytes,1,opt,name=manifestId,proto3" json:"manifestId,omitempty"`
	BasePath       string `protobuf:"bytes,2,opt,name=basePath,proto3" json:"basePath,omitempty"`
	TargetBasePath string `protobuf:"bytes,3,opt,name=targetBasePath,proto3" json:"targetBasePath,omitempty"`
	Recursive      bool   `protobuf:"varint,4,opt,name=recursive,proto3" json:"recursive,omitempty"`
	// contains filtered or unexported fields
}

func (*AddManifestRequest) Descriptor deprecated 

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

Deprecated: Use AddManifestRequest.ProtoReflect.Descriptor instead.

func (*AddManifestRequest) GetBasePath 

func (x *AddManifestRequest) GetBasePath() string

func (*AddManifestRequest) GetManifestId 

func (x *AddManifestRequest) GetManifestId() string

func (*AddManifestRequest) GetRecursive 

func (x *AddManifestRequest) GetRecursive() bool

func (*AddManifestRequest) GetTargetBasePath 

func (x *AddManifestRequest) GetTargetBasePath() string

func (*AddManifestRequest) ProtoMessage 

func (*AddManifestRequest) ProtoMessage()

func (*AddManifestRequest) ProtoReflect 

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

func (*AddManifestRequest) Reset 

func (x *AddManifestRequest) Reset()

func (*AddManifestRequest) String 

func (x *AddManifestRequest) 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 *AddManifestRequest, 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)
	ManifestStatus(ctx context.Context, in *ManifestStatusRequest, opts ...grpc.CallOption) (*ManifestStatusResponse, error)
	ListFilesForManifest(ctx context.Context, in *ListFilesRequest, opts ...grpc.CallOption) (*ListFilesResponse, error)
	// Upload Endpoints
	UploadManifest(ctx context.Context, in *UploadManifestRequest, opts ...grpc.CallOption) (*SimpleStatusResponse, error)
	CancelUpload(ctx context.Context, in *CancelRequest, 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)
}

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, *AddManifestRequest) (*SimpleStatusResponse, error)
	RemoveFromManifest(context.Context, *RemoveFromManifestRequest) (*SimpleStatusResponse, error)
	DeleteManifest(context.Context, *DeleteManifestRequest) (*SimpleStatusResponse, error)
	ManifestStatus(context.Context, *ManifestStatusRequest) (*ManifestStatusResponse, error)
	ListFilesForManifest(context.Context, *ListFilesRequest) (*ListFilesResponse, error)
	// Upload Endpoints
	UploadManifest(context.Context, *UploadManifestRequest) (*SimpleStatusResponse, error)
	CancelUpload(context.Context, *CancelRequest) (*SimpleStatusResponse, error)
	// Server Endpoints
	Subscribe(*SubscribeRequest, Agent_SubscribeServer) error
	Unsubscribe(context.Context, *SubscribeRequest) (*SubsrcribeResponse, 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 CancelRequest 

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

func (*CancelRequest) Descriptor deprecated 

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

Deprecated: Use CancelRequest.ProtoReflect.Descriptor instead.

func (*CancelRequest) GetCancelAll 

func (x *CancelRequest) GetCancelAll() bool

func (*CancelRequest) GetManifestId 

func (x *CancelRequest) GetManifestId() string

func (*CancelRequest) ProtoMessage 

func (*CancelRequest) ProtoMessage()

func (*CancelRequest) ProtoReflect 

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

func (*CancelRequest) Reset 

func (x *CancelRequest) Reset()

func (*CancelRequest) String 

func (x *CancelRequest) String() string

type CreateManifestRequest 

type CreateManifestRequest struct {
	BasePath       string `protobuf:"bytes,1,opt,name=basePath,proto3" json:"basePath,omitempty"`
	TargetBasePath string `protobuf:"bytes,2,opt,name=targetBasePath,proto3" json:"targetBasePath,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 string `protobuf:"bytes,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() string

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 ListFilesRequest 

type ListFilesRequest struct {
	ManifestId string `protobuf:"bytes,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 (*ListFilesRequest) Descriptor deprecated 

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

Deprecated: Use ListFilesRequest.ProtoReflect.Descriptor instead.

func (*ListFilesRequest) GetLimit 

func (x *ListFilesRequest) GetLimit() int32

func (*ListFilesRequest) GetManifestId 

func (x *ListFilesRequest) GetManifestId() string

func (*ListFilesRequest) GetOffset 

func (x *ListFilesRequest) GetOffset() int32

func (*ListFilesRequest) ProtoMessage 

func (*ListFilesRequest) ProtoMessage()

func (*ListFilesRequest) ProtoReflect 

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

func (*ListFilesRequest) Reset 

func (x *ListFilesRequest) Reset()

func (*ListFilesRequest) String 

func (x *ListFilesRequest) String() string

type ListFilesResponse 

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

func (*ListFilesResponse) Descriptor deprecated 

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

Deprecated: Use ListFilesResponse.ProtoReflect.Descriptor instead.

func (*ListFilesResponse) GetFile 

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

func (*ListFilesResponse) ProtoMessage 

func (*ListFilesResponse) ProtoMessage()

func (*ListFilesResponse) ProtoReflect 

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

func (*ListFilesResponse) Reset 

func (x *ListFilesResponse) Reset()

func (*ListFilesResponse) String 

func (x *ListFilesResponse) String() string

type ListFilesResponse_FileUpload 

type ListFilesResponse_FileUpload struct {
	Id         int32                         `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	SessionId  string                        `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_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"`
	S3Key      string                        `protobuf:"bytes,5,opt,name=s3_key,json=s3Key,proto3" json:"s3_key,omitempty"`
	Status     ListFilesResponse_STATUS_TYPE `protobuf:"varint,6,opt,name=status,proto3,enum=protos.ListFilesResponse_STATUS_TYPE" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ListFilesResponse_FileUpload) Descriptor deprecated 

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

Deprecated: Use ListFilesResponse_FileUpload.ProtoReflect.Descriptor instead.

func (*ListFilesResponse_FileUpload) GetId 

func (x *ListFilesResponse_FileUpload) GetId() int32

func (*ListFilesResponse_FileUpload) GetS3Key 

func (x *ListFilesResponse_FileUpload) GetS3Key() string

func (*ListFilesResponse_FileUpload) GetSessionId 

func (x *ListFilesResponse_FileUpload) GetSessionId() string

func (*ListFilesResponse_FileUpload) GetSourcePath 

func (x *ListFilesResponse_FileUpload) GetSourcePath() string

func (*ListFilesResponse_FileUpload) GetStatus 

func (x *ListFilesResponse_FileUpload) GetStatus() ListFilesResponse_STATUS_TYPE

func (*ListFilesResponse_FileUpload) GetTargetPath 

func (x *ListFilesResponse_FileUpload) GetTargetPath() string

func (*ListFilesResponse_FileUpload) ProtoMessage 

func (*ListFilesResponse_FileUpload) ProtoMessage()

func (*ListFilesResponse_FileUpload) ProtoReflect 

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

func (*ListFilesResponse_FileUpload) Reset 

func (x *ListFilesResponse_FileUpload) Reset()

func (*ListFilesResponse_FileUpload) String 

func (x *ListFilesResponse_FileUpload) String() string

type ListFilesResponse_STATUS_TYPE 

type ListFilesResponse_STATUS_TYPE int32
const (
	ListFilesResponse_INDEXED   ListFilesResponse_STATUS_TYPE = 0 // File indexed locally
	ListFilesResponse_SYNCED    ListFilesResponse_STATUS_TYPE = 1 // File manifest synchronized with Cloud
	ListFilesResponse_UPLOADING ListFilesResponse_STATUS_TYPE = 3 // File being uploaded
	ListFilesResponse_COMPLETED ListFilesResponse_STATUS_TYPE = 4 // File completed uploading
	ListFilesResponse_CANCELED  ListFilesResponse_STATUS_TYPE = 5 // File Upload canceled (manually, or failed)
)

func (ListFilesResponse_STATUS_TYPE) Descriptor 

func (ListFilesResponse_STATUS_TYPE) Descriptor() protoreflect.EnumDescriptor

func (ListFilesResponse_STATUS_TYPE) Enum 

func (x ListFilesResponse_STATUS_TYPE) Enum() *ListFilesResponse_STATUS_TYPE

func (ListFilesResponse_STATUS_TYPE) EnumDescriptor deprecated 

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

Deprecated: Use ListFilesResponse_STATUS_TYPE.Descriptor instead.

func (ListFilesResponse_STATUS_TYPE) Number 

func (x ListFilesResponse_STATUS_TYPE) Number() protoreflect.EnumNumber

func (ListFilesResponse_STATUS_TYPE) String 

func (x ListFilesResponse_STATUS_TYPE) String() string

func (ListFilesResponse_STATUS_TYPE) Type 

func (ListFilesResponse_STATUS_TYPE) Type() protoreflect.EnumType

type ManifestStatusRequest 

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

func (*ManifestStatusRequest) Descriptor deprecated 

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

Deprecated: Use ManifestStatusRequest.ProtoReflect.Descriptor instead.

func (*ManifestStatusRequest) ProtoMessage 

func (*ManifestStatusRequest) ProtoMessage()

func (*ManifestStatusRequest) ProtoReflect 

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

func (*ManifestStatusRequest) Reset 

func (x *ManifestStatusRequest) Reset()

func (*ManifestStatusRequest) String 

func (x *ManifestStatusRequest) String() string

type ManifestStatusResponse 

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

func (*ManifestStatusResponse) Descriptor deprecated 

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

Deprecated: Use ManifestStatusResponse.ProtoReflect.Descriptor instead.

func (*ManifestStatusResponse) GetManifests 

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

func (*ManifestStatusResponse) ProtoMessage 

func (*ManifestStatusResponse) ProtoMessage()

func (*ManifestStatusResponse) ProtoReflect 

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

func (*ManifestStatusResponse) Reset 

func (x *ManifestStatusResponse) Reset()

func (*ManifestStatusResponse) String 

func (x *ManifestStatusResponse) String() string

type ManifestStatusResponse_Manifest 

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

func (*ManifestStatusResponse_Manifest) Descriptor deprecated 

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

Deprecated: Use ManifestStatusResponse_Manifest.ProtoReflect.Descriptor instead.

func (*ManifestStatusResponse_Manifest) GetDatasetId 

func (x *ManifestStatusResponse_Manifest) GetDatasetId() string

func (*ManifestStatusResponse_Manifest) GetDatasetName 

func (x *ManifestStatusResponse_Manifest) GetDatasetName() string

func (*ManifestStatusResponse_Manifest) GetId 

func (x *ManifestStatusResponse_Manifest) GetId() string

func (*ManifestStatusResponse_Manifest) GetOrganizationId 

func (x *ManifestStatusResponse_Manifest) GetOrganizationId() string

func (*ManifestStatusResponse_Manifest) GetOrganizationName 

func (x *ManifestStatusResponse_Manifest) GetOrganizationName() string

func (*ManifestStatusResponse_Manifest) GetStatus 

func (x *ManifestStatusResponse_Manifest) GetStatus() string

func (*ManifestStatusResponse_Manifest) GetUserId 

func (x *ManifestStatusResponse_Manifest) GetUserId() string

func (*ManifestStatusResponse_Manifest) GetUserName 

func (x *ManifestStatusResponse_Manifest) GetUserName() string

func (*ManifestStatusResponse_Manifest) ProtoMessage 

func (*ManifestStatusResponse_Manifest) ProtoMessage()

func (*ManifestStatusResponse_Manifest) ProtoReflect 

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

func (*ManifestStatusResponse_Manifest) Reset 

func (x *ManifestStatusResponse_Manifest) Reset()

func (*ManifestStatusResponse_Manifest) String 

func (x *ManifestStatusResponse_Manifest) String() string

type RemoveFromManifestRequest 

type RemoveFromManifestRequest struct {
	ManifestId string  `protobuf:"bytes,1,opt,name=manifestId,proto3" json:"manifestId,omitempty"`
	FileId     []int32 `protobuf:"varint,2,rep,packed,name=fileId,proto3" json:"fileId,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 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_MESSAGE_TYPE `protobuf:"varint,8,opt,name=type,proto3,enum=protos.SubsrcribeResponse_MESSAGE_TYPE" 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_MESSAGE_TYPE

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=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_MESSAGE_TYPE 

type SubsrcribeResponse_MESSAGE_TYPE int32
const (
	SubsrcribeResponse_EVENT         SubsrcribeResponse_MESSAGE_TYPE = 0 // Server log message
	SubsrcribeResponse_UPLOAD_STATUS SubsrcribeResponse_MESSAGE_TYPE = 1 // Upload Status Message
	SubsrcribeResponse_UPLOAD_CANCEL SubsrcribeResponse_MESSAGE_TYPE = 2 // Upload was cancelled
)

func (SubsrcribeResponse_MESSAGE_TYPE) Descriptor 

func (SubsrcribeResponse_MESSAGE_TYPE) Descriptor() protoreflect.EnumDescriptor

func (SubsrcribeResponse_MESSAGE_TYPE) Enum 

func (x SubsrcribeResponse_MESSAGE_TYPE) Enum() *SubsrcribeResponse_MESSAGE_TYPE

func (SubsrcribeResponse_MESSAGE_TYPE) EnumDescriptor deprecated 

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

Deprecated: Use SubsrcribeResponse_MESSAGE_TYPE.Descriptor instead.

func (SubsrcribeResponse_MESSAGE_TYPE) Number 

func (x SubsrcribeResponse_MESSAGE_TYPE) Number() protoreflect.EnumNumber

func (SubsrcribeResponse_MESSAGE_TYPE) String 

func (x SubsrcribeResponse_MESSAGE_TYPE) String() string

func (SubsrcribeResponse_MESSAGE_TYPE) Type 

func (SubsrcribeResponse_MESSAGE_TYPE) Type() protoreflect.EnumType

type SubsrcribeResponse_UploadResponse 

type SubsrcribeResponse_UploadResponse struct {
	FileId   string `protobuf:"bytes,1,opt,name=FileId,proto3" json:"FileId,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=workerId,proto3" json:"workerId,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=uploadStatus,proto3,oneof"`
}

type UnimplementedAgentServer 

type UnimplementedAgentServer struct {
}

UnimplementedAgentServer must be embedded to have forward compatible implementations.

func (UnimplementedAgentServer) AddToManifest 

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

func (UnimplementedAgentServer) CancelUpload 

func (UnimplementedAgentServer) CancelUpload(context.Context, *CancelRequest) (*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) ListFilesForManifest 

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

func (UnimplementedAgentServer) ManifestStatus 

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

func (UnimplementedAgentServer) RemoveFromManifest 

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

func (UnimplementedAgentServer) Subscribe 

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

func (UnimplementedAgentServer) Unsubscribe 

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

func (UnimplementedAgentServer) UploadManifest 

func (UnimplementedAgentServer) UploadManifest(context.Context, *UploadManifestRequest) (*SimpleStatusResponse, 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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