Documentation ¶
Overview ¶
Package files is a generated protocol buffer package.
It is generated from these files:
appengine_internal/files
It has these top-level messages:
StringProto Integer32Proto Integer64Proto BoolProto DoubleProto BytesProto VoidProto FileServiceErrors KeyValue KeyValues FileContentType CreateRequest CreateResponse OpenRequest OpenResponse CloseRequest CloseResponse FileStat StatRequest StatResponse AppendRequest AppendResponse DeleteRequest DeleteResponse ReadRequest ReadResponse ReadKeyValueRequest ReadKeyValueResponse ShuffleEnums ShuffleInputSpecification ShuffleOutputSpecification ShuffleRequest ShuffleResponse GetShuffleStatusRequest GetShuffleStatusResponse GetCapabilitiesRequest GetCapabilitiesResponse FinalizeRequest FinalizeResponse GetDefaultGsBucketNameRequest GetDefaultGsBucketNameResponse ListDirRequest ListDirResponse
Index ¶
- Constants
- Variables
- type AppendRequest
- type AppendResponse
- type BoolProto
- type BytesProto
- type CloseRequest
- type CloseResponse
- type CreateRequest
- func (m *CreateRequest) GetContentType() FileContentType_ContentType
- func (m *CreateRequest) GetExpirationTimeSeconds() int64
- func (m *CreateRequest) GetFilename() string
- func (m *CreateRequest) GetFilesystem() string
- func (m *CreateRequest) GetParameters() []*CreateRequest_Parameter
- func (*CreateRequest) ProtoMessage()
- func (m *CreateRequest) Reset()
- func (m *CreateRequest) String() string
- type CreateRequest_Parameter
- type CreateResponse
- type DeleteRequest
- type DeleteResponse
- type DoubleProto
- type FileContentType
- type FileContentType_ContentType
- type FileServiceErrors
- type FileServiceErrors_ErrorCode
- type FileStat
- func (m *FileStat) GetContentType() FileContentType_ContentType
- func (m *FileStat) GetCtime() int64
- func (m *FileStat) GetFilename() string
- func (m *FileStat) GetFinalized() bool
- func (m *FileStat) GetLength() int64
- func (m *FileStat) GetMtime() int64
- func (*FileStat) ProtoMessage()
- func (m *FileStat) Reset()
- func (m *FileStat) String() string
- type FinalizeRequest
- type FinalizeResponse
- type GetCapabilitiesRequest
- type GetCapabilitiesResponse
- type GetDefaultGsBucketNameRequest
- type GetDefaultGsBucketNameResponse
- type GetShuffleStatusRequest
- type GetShuffleStatusResponse
- type Integer32Proto
- type Integer64Proto
- type KeyValue
- type KeyValues
- type ListDirRequest
- type ListDirResponse
- type OpenRequest
- func (m *OpenRequest) GetBufferedOutput() bool
- func (m *OpenRequest) GetContentType() FileContentType_ContentType
- func (m *OpenRequest) GetExclusiveLock() bool
- func (m *OpenRequest) GetFilename() string
- func (m *OpenRequest) GetOpenLeaseTimeSeconds() int32
- func (m *OpenRequest) GetOpenMode() OpenRequest_OpenMode
- func (*OpenRequest) ProtoMessage()
- func (m *OpenRequest) Reset()
- func (m *OpenRequest) String() string
- type OpenRequest_OpenMode
- type OpenResponse
- type ReadKeyValueRequest
- func (m *ReadKeyValueRequest) GetFilename() string
- func (m *ReadKeyValueRequest) GetMaxBytes() int64
- func (m *ReadKeyValueRequest) GetStartKey() []byte
- func (m *ReadKeyValueRequest) GetValuePos() int64
- func (*ReadKeyValueRequest) ProtoMessage()
- func (m *ReadKeyValueRequest) Reset()
- func (m *ReadKeyValueRequest) String() string
- type ReadKeyValueResponse
- func (m *ReadKeyValueResponse) GetData() []*ReadKeyValueResponse_KeyValue
- func (m *ReadKeyValueResponse) GetNextKey() []byte
- func (m *ReadKeyValueResponse) GetTruncatedValue() bool
- func (*ReadKeyValueResponse) ProtoMessage()
- func (m *ReadKeyValueResponse) Reset()
- func (m *ReadKeyValueResponse) String() string
- type ReadKeyValueResponse_KeyValue
- type ReadRequest
- type ReadResponse
- type ShuffleEnums
- type ShuffleEnums_InputFormat
- type ShuffleEnums_OutputFormat
- type ShuffleEnums_Status
- type ShuffleInputSpecification
- type ShuffleOutputSpecification
- type ShuffleRequest
- func (m *ShuffleRequest) GetCallback() *ShuffleRequest_Callback
- func (m *ShuffleRequest) GetInput() []*ShuffleInputSpecification
- func (m *ShuffleRequest) GetOutput() *ShuffleOutputSpecification
- func (m *ShuffleRequest) GetShuffleName() string
- func (m *ShuffleRequest) GetShuffleSizeBytes() int64
- func (*ShuffleRequest) ProtoMessage()
- func (m *ShuffleRequest) Reset()
- func (m *ShuffleRequest) String() string
- type ShuffleRequest_Callback
- func (m *ShuffleRequest_Callback) GetAppVersionId() string
- func (m *ShuffleRequest_Callback) GetMethod() string
- func (m *ShuffleRequest_Callback) GetQueue() string
- func (m *ShuffleRequest_Callback) GetUrl() string
- func (*ShuffleRequest_Callback) ProtoMessage()
- func (m *ShuffleRequest_Callback) Reset()
- func (m *ShuffleRequest_Callback) String() string
- type ShuffleResponse
- type StatRequest
- type StatResponse
- type StringProto
- type VoidProto
Constants ¶
View Source
const Default_CloseRequest_Finalize bool = false
View Source
const Default_KeyValues_Partial bool = false
View Source
const Default_OpenRequest_BufferedOutput bool = false
View Source
const Default_OpenRequest_ExclusiveLock bool = false
View Source
const Default_OpenRequest_OpenLeaseTimeSeconds int32 = 30
View Source
const Default_ShuffleRequest_Callback_Method string = "POST"
View Source
const Default_ShuffleRequest_Callback_Queue string = "default"
View Source
const Default_StatResponse_MoreFilesFound bool = false
Variables ¶
View Source
var FileContentType_ContentType_name = map[int32]string{
0: "RAW",
2: "DEPRECATED_1",
127: "INVALID_TYPE",
}
View Source
var FileContentType_ContentType_value = map[string]int32{
"RAW": 0,
"DEPRECATED_1": 2,
"INVALID_TYPE": 127,
}
View Source
var FileServiceErrors_ErrorCode_name = map[int32]string{
0: "OK",
1: "API_TEMPORARILY_UNAVAILABLE",
3: "REQUEST_TOO_LARGE",
4: "RESPONSE_TOO_LARGE",
5: "INVALID_FILE_NAME",
6: "OPERATION_NOT_SUPPORTED",
7: "IO_ERROR",
8: "PERMISSION_DENIED",
9: "WRONG_CONTENT_TYPE",
10: "FILE_NOT_OPENED",
11: "WRONG_OPEN_MODE",
12: "EXCLUSIVE_LOCK_REQUIRED",
13: "FILE_TEMPORARILY_UNAVAILABLE",
100: "EXISTENCE_ERROR",
101: "FINALIZATION_ERROR",
102: "UNSUPPORTED_CONTENT_TYPE",
103: "READ_ONLY",
104: "EXCLUSIVE_LOCK_FAILED",
105: "EXISTENCE_ERROR_METADATA_NOT_FOUND",
106: "EXISTENCE_ERROR_METADATA_FOUND",
107: "EXISTENCE_ERROR_SHARDING_MISMATCH",
108: "FINALIZATION_IN_PROGRESS",
109: "EXISTENCE_ERROR_OBJECT_NOT_FOUND",
110: "EXISTENCE_ERROR_BUCKET_NOT_FOUND",
300: "SEQUENCE_KEY_OUT_OF_ORDER",
500: "OUT_OF_BOUNDS",
600: "GLOBS_NOT_SUPPORTED",
701: "FILE_NAME_NOT_SPECIFIED",
702: "FILE_NAME_SPECIFIED",
703: "FILE_ALREADY_EXISTS",
704: "UNSUPPORTED_FILE_SYSTEM",
705: "INVALID_PARAMETER",
800: "SHUFFLER_INTERNAL_ERROR",
801: "SHUFFLE_REQUEST_TOO_LARGE",
802: "DUPLICATE_SHUFFLE_NAME",
803: "SHUFFLE_NOT_AVAILABLE",
900: "SHUFFLER_TEMPORARILY_UNAVAILABLE",
9999: "MAX_ERROR_CODE",
}
View Source
var FileServiceErrors_ErrorCode_value = map[string]int32{
"OK": 0,
"API_TEMPORARILY_UNAVAILABLE": 1,
"REQUEST_TOO_LARGE": 3,
"RESPONSE_TOO_LARGE": 4,
"INVALID_FILE_NAME": 5,
"OPERATION_NOT_SUPPORTED": 6,
"IO_ERROR": 7,
"PERMISSION_DENIED": 8,
"WRONG_CONTENT_TYPE": 9,
"FILE_NOT_OPENED": 10,
"WRONG_OPEN_MODE": 11,
"EXCLUSIVE_LOCK_REQUIRED": 12,
"FILE_TEMPORARILY_UNAVAILABLE": 13,
"EXISTENCE_ERROR": 100,
"FINALIZATION_ERROR": 101,
"UNSUPPORTED_CONTENT_TYPE": 102,
"READ_ONLY": 103,
"EXCLUSIVE_LOCK_FAILED": 104,
"EXISTENCE_ERROR_METADATA_NOT_FOUND": 105,
"EXISTENCE_ERROR_METADATA_FOUND": 106,
"EXISTENCE_ERROR_SHARDING_MISMATCH": 107,
"FINALIZATION_IN_PROGRESS": 108,
"EXISTENCE_ERROR_OBJECT_NOT_FOUND": 109,
"EXISTENCE_ERROR_BUCKET_NOT_FOUND": 110,
"SEQUENCE_KEY_OUT_OF_ORDER": 300,
"OUT_OF_BOUNDS": 500,
"GLOBS_NOT_SUPPORTED": 600,
"FILE_NAME_NOT_SPECIFIED": 701,
"FILE_NAME_SPECIFIED": 702,
"FILE_ALREADY_EXISTS": 703,
"UNSUPPORTED_FILE_SYSTEM": 704,
"INVALID_PARAMETER": 705,
"SHUFFLER_INTERNAL_ERROR": 800,
"SHUFFLE_REQUEST_TOO_LARGE": 801,
"DUPLICATE_SHUFFLE_NAME": 802,
"SHUFFLE_NOT_AVAILABLE": 803,
"SHUFFLER_TEMPORARILY_UNAVAILABLE": 900,
"MAX_ERROR_CODE": 9999,
}
View Source
var OpenRequest_OpenMode_name = map[int32]string{
1: "APPEND",
2: "READ",
}
View Source
var OpenRequest_OpenMode_value = map[string]int32{
"APPEND": 1,
"READ": 2,
}
View Source
var ShuffleEnums_InputFormat_name = map[int32]string{
1: "RECORDS_KEY_VALUE_PROTO_INPUT",
}
View Source
var ShuffleEnums_InputFormat_value = map[string]int32{
"RECORDS_KEY_VALUE_PROTO_INPUT": 1,
}
View Source
var ShuffleEnums_OutputFormat_name = map[int32]string{
1: "RECORDS_KEY_MULTI_VALUE_PROTO_OUTPUT",
}
View Source
var ShuffleEnums_OutputFormat_value = map[string]int32{
"RECORDS_KEY_MULTI_VALUE_PROTO_OUTPUT": 1,
}
View Source
var ShuffleEnums_Status_name = map[int32]string{
1: "UNKNOWN",
2: "RUNNING",
3: "SUCCESS",
4: "FAILURE",
5: "INVALID_INPUT",
6: "OUTPUT_ALREADY_EXISTS",
7: "INCORRECT_SHUFFLE_SIZE_BYTES",
}
View Source
var ShuffleEnums_Status_value = map[string]int32{
"UNKNOWN": 1,
"RUNNING": 2,
"SUCCESS": 3,
"FAILURE": 4,
"INVALID_INPUT": 5,
"OUTPUT_ALREADY_EXISTS": 6,
"INCORRECT_SHUFFLE_SIZE_BYTES": 7,
}
Functions ¶
This section is empty.
Types ¶
type AppendRequest ¶
type AppendRequest struct { Filename *string `protobuf:"bytes,1,req,name=filename" json:"filename,omitempty"` Data []byte `protobuf:"bytes,2,req,name=data" json:"data,omitempty"` SequenceKey *string `protobuf:"bytes,3,opt,name=sequence_key" json:"sequence_key,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*AppendRequest) GetData ¶
func (m *AppendRequest) GetData() []byte
func (*AppendRequest) GetFilename ¶
func (m *AppendRequest) GetFilename() string
func (*AppendRequest) GetSequenceKey ¶
func (m *AppendRequest) GetSequenceKey() string
func (*AppendRequest) ProtoMessage ¶
func (*AppendRequest) ProtoMessage()
func (*AppendRequest) Reset ¶
func (m *AppendRequest) Reset()
func (*AppendRequest) String ¶
func (m *AppendRequest) String() string
type AppendResponse ¶
type AppendResponse struct {
XXX_unrecognized []byte `json:"-"`
}
func (*AppendResponse) ProtoMessage ¶
func (*AppendResponse) ProtoMessage()
func (*AppendResponse) Reset ¶
func (m *AppendResponse) Reset()
func (*AppendResponse) String ¶
func (m *AppendResponse) String() string
type BoolProto ¶
type BoolProto struct { Value *bool `protobuf:"varint,1,req,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*BoolProto) ProtoMessage ¶
func (*BoolProto) ProtoMessage()
type BytesProto ¶
type BytesProto struct { Value []byte `protobuf:"bytes,1,req,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*BytesProto) GetValue ¶
func (m *BytesProto) GetValue() []byte
func (*BytesProto) ProtoMessage ¶
func (*BytesProto) ProtoMessage()
func (*BytesProto) Reset ¶
func (m *BytesProto) Reset()
func (*BytesProto) String ¶
func (m *BytesProto) String() string
type CloseRequest ¶
type CloseRequest struct { Filename *string `protobuf:"bytes,1,req,name=filename" json:"filename,omitempty"` Finalize *bool `protobuf:"varint,2,opt,name=finalize,def=0" json:"finalize,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CloseRequest) GetFilename ¶
func (m *CloseRequest) GetFilename() string
func (*CloseRequest) GetFinalize ¶
func (m *CloseRequest) GetFinalize() bool
func (*CloseRequest) ProtoMessage ¶
func (*CloseRequest) ProtoMessage()
func (*CloseRequest) Reset ¶
func (m *CloseRequest) Reset()
func (*CloseRequest) String ¶
func (m *CloseRequest) String() string
type CloseResponse ¶
type CloseResponse struct {
XXX_unrecognized []byte `json:"-"`
}
func (*CloseResponse) ProtoMessage ¶
func (*CloseResponse) ProtoMessage()
func (*CloseResponse) Reset ¶
func (m *CloseResponse) Reset()
func (*CloseResponse) String ¶
func (m *CloseResponse) String() string
type CreateRequest ¶
type CreateRequest struct { Filesystem *string `protobuf:"bytes,1,req,name=filesystem" json:"filesystem,omitempty"` ContentType *FileContentType_ContentType `protobuf:"varint,2,req,name=content_type,enum=files.FileContentType_ContentType" json:"content_type,omitempty"` Filename *string `protobuf:"bytes,3,opt,name=filename,def=" json:"filename,omitempty"` Parameters []*CreateRequest_Parameter `protobuf:"bytes,4,rep,name=parameters" json:"parameters,omitempty"` ExpirationTimeSeconds *int64 `protobuf:"varint,5,opt,name=expiration_time_seconds" json:"expiration_time_seconds,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CreateRequest) GetContentType ¶
func (m *CreateRequest) GetContentType() FileContentType_ContentType
func (*CreateRequest) GetExpirationTimeSeconds ¶
func (m *CreateRequest) GetExpirationTimeSeconds() int64
func (*CreateRequest) GetFilename ¶
func (m *CreateRequest) GetFilename() string
func (*CreateRequest) GetFilesystem ¶
func (m *CreateRequest) GetFilesystem() string
func (*CreateRequest) GetParameters ¶
func (m *CreateRequest) GetParameters() []*CreateRequest_Parameter
func (*CreateRequest) ProtoMessage ¶
func (*CreateRequest) ProtoMessage()
func (*CreateRequest) Reset ¶
func (m *CreateRequest) Reset()
func (*CreateRequest) String ¶
func (m *CreateRequest) String() string
type CreateRequest_Parameter ¶
type CreateRequest_Parameter struct { Name *string `protobuf:"bytes,1,req,name=name" json:"name,omitempty"` Value *string `protobuf:"bytes,2,req,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CreateRequest_Parameter) GetName ¶
func (m *CreateRequest_Parameter) GetName() string
func (*CreateRequest_Parameter) GetValue ¶
func (m *CreateRequest_Parameter) GetValue() string
func (*CreateRequest_Parameter) ProtoMessage ¶
func (*CreateRequest_Parameter) ProtoMessage()
func (*CreateRequest_Parameter) Reset ¶
func (m *CreateRequest_Parameter) Reset()
func (*CreateRequest_Parameter) String ¶
func (m *CreateRequest_Parameter) String() string
type CreateResponse ¶
type CreateResponse struct { Filename *string `protobuf:"bytes,1,req,name=filename" json:"filename,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*CreateResponse) GetFilename ¶
func (m *CreateResponse) GetFilename() string
func (*CreateResponse) ProtoMessage ¶
func (*CreateResponse) ProtoMessage()
func (*CreateResponse) Reset ¶
func (m *CreateResponse) Reset()
func (*CreateResponse) String ¶
func (m *CreateResponse) String() string
type DeleteRequest ¶
type DeleteRequest struct { Filename *string `protobuf:"bytes,1,req,name=filename" json:"filename,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*DeleteRequest) GetFilename ¶
func (m *DeleteRequest) GetFilename() string
func (*DeleteRequest) ProtoMessage ¶
func (*DeleteRequest) ProtoMessage()
func (*DeleteRequest) Reset ¶
func (m *DeleteRequest) Reset()
func (*DeleteRequest) String ¶
func (m *DeleteRequest) String() string
type DeleteResponse ¶
type DeleteResponse struct {
XXX_unrecognized []byte `json:"-"`
}
func (*DeleteResponse) ProtoMessage ¶
func (*DeleteResponse) ProtoMessage()
func (*DeleteResponse) Reset ¶
func (m *DeleteResponse) Reset()
func (*DeleteResponse) String ¶
func (m *DeleteResponse) String() string
type DoubleProto ¶
type DoubleProto struct { Value *float64 `protobuf:"fixed64,1,req,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*DoubleProto) GetValue ¶
func (m *DoubleProto) GetValue() float64
func (*DoubleProto) ProtoMessage ¶
func (*DoubleProto) ProtoMessage()
func (*DoubleProto) Reset ¶
func (m *DoubleProto) Reset()
func (*DoubleProto) String ¶
func (m *DoubleProto) String() string
type FileContentType ¶
type FileContentType struct {
XXX_unrecognized []byte `json:"-"`
}
func (*FileContentType) ProtoMessage ¶
func (*FileContentType) ProtoMessage()
func (*FileContentType) Reset ¶
func (m *FileContentType) Reset()
func (*FileContentType) String ¶
func (m *FileContentType) String() string
type FileContentType_ContentType ¶
type FileContentType_ContentType int32
const ( FileContentType_RAW FileContentType_ContentType = 0 FileContentType_DEPRECATED_1 FileContentType_ContentType = 2 FileContentType_INVALID_TYPE FileContentType_ContentType = 127 )
func (FileContentType_ContentType) Enum ¶
func (x FileContentType_ContentType) Enum() *FileContentType_ContentType
func (FileContentType_ContentType) String ¶
func (x FileContentType_ContentType) String() string
func (*FileContentType_ContentType) UnmarshalJSON ¶
func (x *FileContentType_ContentType) UnmarshalJSON(data []byte) error
type FileServiceErrors ¶
type FileServiceErrors struct {
XXX_unrecognized []byte `json:"-"`
}
func (*FileServiceErrors) ProtoMessage ¶
func (*FileServiceErrors) ProtoMessage()
func (*FileServiceErrors) Reset ¶
func (m *FileServiceErrors) Reset()
func (*FileServiceErrors) String ¶
func (m *FileServiceErrors) String() string
type FileServiceErrors_ErrorCode ¶
type FileServiceErrors_ErrorCode int32
const ( FileServiceErrors_OK FileServiceErrors_ErrorCode = 0 FileServiceErrors_API_TEMPORARILY_UNAVAILABLE FileServiceErrors_ErrorCode = 1 FileServiceErrors_REQUEST_TOO_LARGE FileServiceErrors_ErrorCode = 3 FileServiceErrors_RESPONSE_TOO_LARGE FileServiceErrors_ErrorCode = 4 FileServiceErrors_INVALID_FILE_NAME FileServiceErrors_ErrorCode = 5 FileServiceErrors_OPERATION_NOT_SUPPORTED FileServiceErrors_ErrorCode = 6 FileServiceErrors_IO_ERROR FileServiceErrors_ErrorCode = 7 FileServiceErrors_PERMISSION_DENIED FileServiceErrors_ErrorCode = 8 FileServiceErrors_WRONG_CONTENT_TYPE FileServiceErrors_ErrorCode = 9 FileServiceErrors_FILE_NOT_OPENED FileServiceErrors_ErrorCode = 10 FileServiceErrors_WRONG_OPEN_MODE FileServiceErrors_ErrorCode = 11 FileServiceErrors_EXCLUSIVE_LOCK_REQUIRED FileServiceErrors_ErrorCode = 12 FileServiceErrors_FILE_TEMPORARILY_UNAVAILABLE FileServiceErrors_ErrorCode = 13 FileServiceErrors_EXISTENCE_ERROR FileServiceErrors_ErrorCode = 100 FileServiceErrors_FINALIZATION_ERROR FileServiceErrors_ErrorCode = 101 FileServiceErrors_UNSUPPORTED_CONTENT_TYPE FileServiceErrors_ErrorCode = 102 FileServiceErrors_READ_ONLY FileServiceErrors_ErrorCode = 103 FileServiceErrors_EXCLUSIVE_LOCK_FAILED FileServiceErrors_ErrorCode = 104 FileServiceErrors_EXISTENCE_ERROR_METADATA_NOT_FOUND FileServiceErrors_ErrorCode = 105 FileServiceErrors_EXISTENCE_ERROR_METADATA_FOUND FileServiceErrors_ErrorCode = 106 FileServiceErrors_EXISTENCE_ERROR_SHARDING_MISMATCH FileServiceErrors_ErrorCode = 107 FileServiceErrors_FINALIZATION_IN_PROGRESS FileServiceErrors_ErrorCode = 108 FileServiceErrors_EXISTENCE_ERROR_OBJECT_NOT_FOUND FileServiceErrors_ErrorCode = 109 FileServiceErrors_EXISTENCE_ERROR_BUCKET_NOT_FOUND FileServiceErrors_ErrorCode = 110 FileServiceErrors_SEQUENCE_KEY_OUT_OF_ORDER FileServiceErrors_ErrorCode = 300 FileServiceErrors_OUT_OF_BOUNDS FileServiceErrors_ErrorCode = 500 FileServiceErrors_GLOBS_NOT_SUPPORTED FileServiceErrors_ErrorCode = 600 FileServiceErrors_FILE_NAME_NOT_SPECIFIED FileServiceErrors_ErrorCode = 701 FileServiceErrors_FILE_NAME_SPECIFIED FileServiceErrors_ErrorCode = 702 FileServiceErrors_FILE_ALREADY_EXISTS FileServiceErrors_ErrorCode = 703 FileServiceErrors_UNSUPPORTED_FILE_SYSTEM FileServiceErrors_ErrorCode = 704 FileServiceErrors_INVALID_PARAMETER FileServiceErrors_ErrorCode = 705 FileServiceErrors_SHUFFLER_INTERNAL_ERROR FileServiceErrors_ErrorCode = 800 FileServiceErrors_SHUFFLE_REQUEST_TOO_LARGE FileServiceErrors_ErrorCode = 801 FileServiceErrors_DUPLICATE_SHUFFLE_NAME FileServiceErrors_ErrorCode = 802 FileServiceErrors_SHUFFLE_NOT_AVAILABLE FileServiceErrors_ErrorCode = 803 FileServiceErrors_SHUFFLER_TEMPORARILY_UNAVAILABLE FileServiceErrors_ErrorCode = 900 FileServiceErrors_MAX_ERROR_CODE FileServiceErrors_ErrorCode = 9999 )
func (FileServiceErrors_ErrorCode) Enum ¶
func (x FileServiceErrors_ErrorCode) Enum() *FileServiceErrors_ErrorCode
func (FileServiceErrors_ErrorCode) String ¶
func (x FileServiceErrors_ErrorCode) String() string
func (*FileServiceErrors_ErrorCode) UnmarshalJSON ¶
func (x *FileServiceErrors_ErrorCode) UnmarshalJSON(data []byte) error
type FileStat ¶
type FileStat struct { Filename *string `protobuf:"bytes,1,req,name=filename" json:"filename,omitempty"` ContentType *FileContentType_ContentType `protobuf:"varint,2,req,name=content_type,enum=files.FileContentType_ContentType" json:"content_type,omitempty"` Finalized *bool `protobuf:"varint,3,req,name=finalized" json:"finalized,omitempty"` Length *int64 `protobuf:"varint,4,opt,name=length" json:"length,omitempty"` Ctime *int64 `protobuf:"varint,5,opt,name=ctime" json:"ctime,omitempty"` Mtime *int64 `protobuf:"varint,6,opt,name=mtime" json:"mtime,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*FileStat) GetContentType ¶
func (m *FileStat) GetContentType() FileContentType_ContentType
func (*FileStat) GetFilename ¶
func (*FileStat) GetFinalized ¶
func (*FileStat) ProtoMessage ¶
func (*FileStat) ProtoMessage()
type FinalizeRequest ¶
type FinalizeRequest struct { Filename *string `protobuf:"bytes,1,req,name=filename" json:"filename,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*FinalizeRequest) GetFilename ¶
func (m *FinalizeRequest) GetFilename() string
func (*FinalizeRequest) ProtoMessage ¶
func (*FinalizeRequest) ProtoMessage()
func (*FinalizeRequest) Reset ¶
func (m *FinalizeRequest) Reset()
func (*FinalizeRequest) String ¶
func (m *FinalizeRequest) String() string
type FinalizeResponse ¶
type FinalizeResponse struct {
XXX_unrecognized []byte `json:"-"`
}
func (*FinalizeResponse) ProtoMessage ¶
func (*FinalizeResponse) ProtoMessage()
func (*FinalizeResponse) Reset ¶
func (m *FinalizeResponse) Reset()
func (*FinalizeResponse) String ¶
func (m *FinalizeResponse) String() string
type GetCapabilitiesRequest ¶
type GetCapabilitiesRequest struct {
XXX_unrecognized []byte `json:"-"`
}
func (*GetCapabilitiesRequest) ProtoMessage ¶
func (*GetCapabilitiesRequest) ProtoMessage()
func (*GetCapabilitiesRequest) Reset ¶
func (m *GetCapabilitiesRequest) Reset()
func (*GetCapabilitiesRequest) String ¶
func (m *GetCapabilitiesRequest) String() string
type GetCapabilitiesResponse ¶
type GetCapabilitiesResponse struct { Filesystem []string `protobuf:"bytes,1,rep,name=filesystem" json:"filesystem,omitempty"` ShuffleAvailable *bool `protobuf:"varint,2,req,name=shuffle_available" json:"shuffle_available,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*GetCapabilitiesResponse) GetFilesystem ¶
func (m *GetCapabilitiesResponse) GetFilesystem() []string
func (*GetCapabilitiesResponse) GetShuffleAvailable ¶
func (m *GetCapabilitiesResponse) GetShuffleAvailable() bool
func (*GetCapabilitiesResponse) ProtoMessage ¶
func (*GetCapabilitiesResponse) ProtoMessage()
func (*GetCapabilitiesResponse) Reset ¶
func (m *GetCapabilitiesResponse) Reset()
func (*GetCapabilitiesResponse) String ¶
func (m *GetCapabilitiesResponse) String() string
type GetDefaultGsBucketNameRequest ¶
type GetDefaultGsBucketNameRequest struct {
XXX_unrecognized []byte `json:"-"`
}
func (*GetDefaultGsBucketNameRequest) ProtoMessage ¶
func (*GetDefaultGsBucketNameRequest) ProtoMessage()
func (*GetDefaultGsBucketNameRequest) Reset ¶
func (m *GetDefaultGsBucketNameRequest) Reset()
func (*GetDefaultGsBucketNameRequest) String ¶
func (m *GetDefaultGsBucketNameRequest) String() string
type GetDefaultGsBucketNameResponse ¶
type GetDefaultGsBucketNameResponse struct { DefaultGsBucketName *string `protobuf:"bytes,1,opt,name=default_gs_bucket_name" json:"default_gs_bucket_name,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*GetDefaultGsBucketNameResponse) GetDefaultGsBucketName ¶
func (m *GetDefaultGsBucketNameResponse) GetDefaultGsBucketName() string
func (*GetDefaultGsBucketNameResponse) ProtoMessage ¶
func (*GetDefaultGsBucketNameResponse) ProtoMessage()
func (*GetDefaultGsBucketNameResponse) Reset ¶
func (m *GetDefaultGsBucketNameResponse) Reset()
func (*GetDefaultGsBucketNameResponse) String ¶
func (m *GetDefaultGsBucketNameResponse) String() string
type GetShuffleStatusRequest ¶
type GetShuffleStatusRequest struct { ShuffleName *string `protobuf:"bytes,1,req,name=shuffle_name" json:"shuffle_name,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*GetShuffleStatusRequest) GetShuffleName ¶
func (m *GetShuffleStatusRequest) GetShuffleName() string
func (*GetShuffleStatusRequest) ProtoMessage ¶
func (*GetShuffleStatusRequest) ProtoMessage()
func (*GetShuffleStatusRequest) Reset ¶
func (m *GetShuffleStatusRequest) Reset()
func (*GetShuffleStatusRequest) String ¶
func (m *GetShuffleStatusRequest) String() string
type GetShuffleStatusResponse ¶
type GetShuffleStatusResponse struct { Status *ShuffleEnums_Status `protobuf:"varint,1,req,name=status,enum=files.ShuffleEnums_Status" json:"status,omitempty"` Description *string `protobuf:"bytes,2,opt,name=description" json:"description,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*GetShuffleStatusResponse) GetDescription ¶
func (m *GetShuffleStatusResponse) GetDescription() string
func (*GetShuffleStatusResponse) GetStatus ¶
func (m *GetShuffleStatusResponse) GetStatus() ShuffleEnums_Status
func (*GetShuffleStatusResponse) ProtoMessage ¶
func (*GetShuffleStatusResponse) ProtoMessage()
func (*GetShuffleStatusResponse) Reset ¶
func (m *GetShuffleStatusResponse) Reset()
func (*GetShuffleStatusResponse) String ¶
func (m *GetShuffleStatusResponse) String() string
type Integer32Proto ¶
type Integer32Proto struct { Value *int32 `protobuf:"varint,1,req,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Integer32Proto) GetValue ¶
func (m *Integer32Proto) GetValue() int32
func (*Integer32Proto) ProtoMessage ¶
func (*Integer32Proto) ProtoMessage()
func (*Integer32Proto) Reset ¶
func (m *Integer32Proto) Reset()
func (*Integer32Proto) String ¶
func (m *Integer32Proto) String() string
type Integer64Proto ¶
type Integer64Proto struct { Value *int64 `protobuf:"varint,1,req,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*Integer64Proto) GetValue ¶
func (m *Integer64Proto) GetValue() int64
func (*Integer64Proto) ProtoMessage ¶
func (*Integer64Proto) ProtoMessage()
func (*Integer64Proto) Reset ¶
func (m *Integer64Proto) Reset()
func (*Integer64Proto) String ¶
func (m *Integer64Proto) String() string
type KeyValue ¶
type KeyValue struct { Key []byte `protobuf:"bytes,1,req,name=key" json:"key,omitempty"` Value []byte `protobuf:"bytes,2,req,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*KeyValue) ProtoMessage ¶
func (*KeyValue) ProtoMessage()
type KeyValues ¶
type KeyValues struct { Key []byte `protobuf:"bytes,1,req,name=key" json:"key,omitempty"` Value [][]byte `protobuf:"bytes,2,rep,name=value" json:"value,omitempty"` Partial *bool `protobuf:"varint,3,opt,name=partial,def=0" json:"partial,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*KeyValues) GetPartial ¶
func (*KeyValues) ProtoMessage ¶
func (*KeyValues) ProtoMessage()
type ListDirRequest ¶
type ListDirRequest struct { Path *string `protobuf:"bytes,1,req,name=path" json:"path,omitempty"` Marker *string `protobuf:"bytes,2,opt,name=marker" json:"marker,omitempty"` MaxKeys *int64 `protobuf:"varint,3,opt,name=max_keys" json:"max_keys,omitempty"` Prefix *string `protobuf:"bytes,4,opt,name=prefix" json:"prefix,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ListDirRequest) GetMarker ¶
func (m *ListDirRequest) GetMarker() string
func (*ListDirRequest) GetMaxKeys ¶
func (m *ListDirRequest) GetMaxKeys() int64
func (*ListDirRequest) GetPath ¶
func (m *ListDirRequest) GetPath() string
func (*ListDirRequest) GetPrefix ¶
func (m *ListDirRequest) GetPrefix() string
func (*ListDirRequest) ProtoMessage ¶
func (*ListDirRequest) ProtoMessage()
func (*ListDirRequest) Reset ¶
func (m *ListDirRequest) Reset()
func (*ListDirRequest) String ¶
func (m *ListDirRequest) String() string
type ListDirResponse ¶
type ListDirResponse struct { Filenames []string `protobuf:"bytes,1,rep,name=filenames" json:"filenames,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ListDirResponse) GetFilenames ¶
func (m *ListDirResponse) GetFilenames() []string
func (*ListDirResponse) ProtoMessage ¶
func (*ListDirResponse) ProtoMessage()
func (*ListDirResponse) Reset ¶
func (m *ListDirResponse) Reset()
func (*ListDirResponse) String ¶
func (m *ListDirResponse) String() string
type OpenRequest ¶
type OpenRequest struct { Filename *string `protobuf:"bytes,1,req,name=filename" json:"filename,omitempty"` ContentType *FileContentType_ContentType `protobuf:"varint,2,req,name=content_type,enum=files.FileContentType_ContentType" json:"content_type,omitempty"` OpenMode *OpenRequest_OpenMode `protobuf:"varint,3,req,name=open_mode,enum=files.OpenRequest_OpenMode" json:"open_mode,omitempty"` ExclusiveLock *bool `protobuf:"varint,4,opt,name=exclusive_lock,def=0" json:"exclusive_lock,omitempty"` BufferedOutput *bool `protobuf:"varint,5,opt,name=buffered_output,def=0" json:"buffered_output,omitempty"` OpenLeaseTimeSeconds *int32 `protobuf:"varint,6,opt,name=open_lease_time_seconds,def=30" json:"open_lease_time_seconds,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*OpenRequest) GetBufferedOutput ¶
func (m *OpenRequest) GetBufferedOutput() bool
func (*OpenRequest) GetContentType ¶
func (m *OpenRequest) GetContentType() FileContentType_ContentType
func (*OpenRequest) GetExclusiveLock ¶
func (m *OpenRequest) GetExclusiveLock() bool
func (*OpenRequest) GetFilename ¶
func (m *OpenRequest) GetFilename() string
func (*OpenRequest) GetOpenLeaseTimeSeconds ¶
func (m *OpenRequest) GetOpenLeaseTimeSeconds() int32
func (*OpenRequest) GetOpenMode ¶
func (m *OpenRequest) GetOpenMode() OpenRequest_OpenMode
func (*OpenRequest) ProtoMessage ¶
func (*OpenRequest) ProtoMessage()
func (*OpenRequest) Reset ¶
func (m *OpenRequest) Reset()
func (*OpenRequest) String ¶
func (m *OpenRequest) String() string
type OpenRequest_OpenMode ¶
type OpenRequest_OpenMode int32
const ( OpenRequest_APPEND OpenRequest_OpenMode = 1 OpenRequest_READ OpenRequest_OpenMode = 2 )
func (OpenRequest_OpenMode) Enum ¶
func (x OpenRequest_OpenMode) Enum() *OpenRequest_OpenMode
func (OpenRequest_OpenMode) String ¶
func (x OpenRequest_OpenMode) String() string
func (*OpenRequest_OpenMode) UnmarshalJSON ¶
func (x *OpenRequest_OpenMode) UnmarshalJSON(data []byte) error
type OpenResponse ¶
type OpenResponse struct {
XXX_unrecognized []byte `json:"-"`
}
func (*OpenResponse) ProtoMessage ¶
func (*OpenResponse) ProtoMessage()
func (*OpenResponse) Reset ¶
func (m *OpenResponse) Reset()
func (*OpenResponse) String ¶
func (m *OpenResponse) String() string
type ReadKeyValueRequest ¶
type ReadKeyValueRequest struct { Filename *string `protobuf:"bytes,1,req,name=filename" json:"filename,omitempty"` StartKey []byte `protobuf:"bytes,2,req,name=start_key" json:"start_key,omitempty"` MaxBytes *int64 `protobuf:"varint,3,req,name=max_bytes" json:"max_bytes,omitempty"` ValuePos *int64 `protobuf:"varint,4,opt,name=value_pos" json:"value_pos,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ReadKeyValueRequest) GetFilename ¶
func (m *ReadKeyValueRequest) GetFilename() string
func (*ReadKeyValueRequest) GetMaxBytes ¶
func (m *ReadKeyValueRequest) GetMaxBytes() int64
func (*ReadKeyValueRequest) GetStartKey ¶
func (m *ReadKeyValueRequest) GetStartKey() []byte
func (*ReadKeyValueRequest) GetValuePos ¶
func (m *ReadKeyValueRequest) GetValuePos() int64
func (*ReadKeyValueRequest) ProtoMessage ¶
func (*ReadKeyValueRequest) ProtoMessage()
func (*ReadKeyValueRequest) Reset ¶
func (m *ReadKeyValueRequest) Reset()
func (*ReadKeyValueRequest) String ¶
func (m *ReadKeyValueRequest) String() string
type ReadKeyValueResponse ¶
type ReadKeyValueResponse struct { Data []*ReadKeyValueResponse_KeyValue `protobuf:"bytes,1,rep,name=data" json:"data,omitempty"` NextKey []byte `protobuf:"bytes,2,opt,name=next_key" json:"next_key,omitempty"` TruncatedValue *bool `protobuf:"varint,3,opt,name=truncated_value" json:"truncated_value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ReadKeyValueResponse) GetData ¶
func (m *ReadKeyValueResponse) GetData() []*ReadKeyValueResponse_KeyValue
func (*ReadKeyValueResponse) GetNextKey ¶
func (m *ReadKeyValueResponse) GetNextKey() []byte
func (*ReadKeyValueResponse) GetTruncatedValue ¶
func (m *ReadKeyValueResponse) GetTruncatedValue() bool
func (*ReadKeyValueResponse) ProtoMessage ¶
func (*ReadKeyValueResponse) ProtoMessage()
func (*ReadKeyValueResponse) Reset ¶
func (m *ReadKeyValueResponse) Reset()
func (*ReadKeyValueResponse) String ¶
func (m *ReadKeyValueResponse) String() string
type ReadKeyValueResponse_KeyValue ¶
type ReadKeyValueResponse_KeyValue struct { Key []byte `protobuf:"bytes,1,req,name=key" json:"key,omitempty"` Value []byte `protobuf:"bytes,2,req,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ReadKeyValueResponse_KeyValue) GetKey ¶
func (m *ReadKeyValueResponse_KeyValue) GetKey() []byte
func (*ReadKeyValueResponse_KeyValue) GetValue ¶
func (m *ReadKeyValueResponse_KeyValue) GetValue() []byte
func (*ReadKeyValueResponse_KeyValue) ProtoMessage ¶
func (*ReadKeyValueResponse_KeyValue) ProtoMessage()
func (*ReadKeyValueResponse_KeyValue) Reset ¶
func (m *ReadKeyValueResponse_KeyValue) Reset()
func (*ReadKeyValueResponse_KeyValue) String ¶
func (m *ReadKeyValueResponse_KeyValue) String() string
type ReadRequest ¶
type ReadRequest struct { Filename *string `protobuf:"bytes,1,req,name=filename" json:"filename,omitempty"` Pos *int64 `protobuf:"varint,2,req,name=pos" json:"pos,omitempty"` MaxBytes *int64 `protobuf:"varint,3,req,name=max_bytes" json:"max_bytes,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ReadRequest) GetFilename ¶
func (m *ReadRequest) GetFilename() string
func (*ReadRequest) GetMaxBytes ¶
func (m *ReadRequest) GetMaxBytes() int64
func (*ReadRequest) GetPos ¶
func (m *ReadRequest) GetPos() int64
func (*ReadRequest) ProtoMessage ¶
func (*ReadRequest) ProtoMessage()
func (*ReadRequest) Reset ¶
func (m *ReadRequest) Reset()
func (*ReadRequest) String ¶
func (m *ReadRequest) String() string
type ReadResponse ¶
type ReadResponse struct { Data []byte `protobuf:"bytes,1,req,name=data" json:"data,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ReadResponse) GetData ¶
func (m *ReadResponse) GetData() []byte
func (*ReadResponse) ProtoMessage ¶
func (*ReadResponse) ProtoMessage()
func (*ReadResponse) Reset ¶
func (m *ReadResponse) Reset()
func (*ReadResponse) String ¶
func (m *ReadResponse) String() string
type ShuffleEnums ¶
type ShuffleEnums struct {
XXX_unrecognized []byte `json:"-"`
}
func (*ShuffleEnums) ProtoMessage ¶
func (*ShuffleEnums) ProtoMessage()
func (*ShuffleEnums) Reset ¶
func (m *ShuffleEnums) Reset()
func (*ShuffleEnums) String ¶
func (m *ShuffleEnums) String() string
type ShuffleEnums_InputFormat ¶
type ShuffleEnums_InputFormat int32
const Default_ShuffleInputSpecification_Format ShuffleEnums_InputFormat = ShuffleEnums_RECORDS_KEY_VALUE_PROTO_INPUT
const (
ShuffleEnums_RECORDS_KEY_VALUE_PROTO_INPUT ShuffleEnums_InputFormat = 1
)
func (ShuffleEnums_InputFormat) Enum ¶
func (x ShuffleEnums_InputFormat) Enum() *ShuffleEnums_InputFormat
func (ShuffleEnums_InputFormat) String ¶
func (x ShuffleEnums_InputFormat) String() string
func (*ShuffleEnums_InputFormat) UnmarshalJSON ¶
func (x *ShuffleEnums_InputFormat) UnmarshalJSON(data []byte) error
type ShuffleEnums_OutputFormat ¶
type ShuffleEnums_OutputFormat int32
const Default_ShuffleOutputSpecification_Format ShuffleEnums_OutputFormat = ShuffleEnums_RECORDS_KEY_MULTI_VALUE_PROTO_OUTPUT
const (
ShuffleEnums_RECORDS_KEY_MULTI_VALUE_PROTO_OUTPUT ShuffleEnums_OutputFormat = 1
)
func (ShuffleEnums_OutputFormat) Enum ¶
func (x ShuffleEnums_OutputFormat) Enum() *ShuffleEnums_OutputFormat
func (ShuffleEnums_OutputFormat) String ¶
func (x ShuffleEnums_OutputFormat) String() string
func (*ShuffleEnums_OutputFormat) UnmarshalJSON ¶
func (x *ShuffleEnums_OutputFormat) UnmarshalJSON(data []byte) error
type ShuffleEnums_Status ¶
type ShuffleEnums_Status int32
const ( ShuffleEnums_UNKNOWN ShuffleEnums_Status = 1 ShuffleEnums_RUNNING ShuffleEnums_Status = 2 ShuffleEnums_SUCCESS ShuffleEnums_Status = 3 ShuffleEnums_FAILURE ShuffleEnums_Status = 4 ShuffleEnums_INVALID_INPUT ShuffleEnums_Status = 5 ShuffleEnums_OUTPUT_ALREADY_EXISTS ShuffleEnums_Status = 6 ShuffleEnums_INCORRECT_SHUFFLE_SIZE_BYTES ShuffleEnums_Status = 7 )
func (ShuffleEnums_Status) Enum ¶
func (x ShuffleEnums_Status) Enum() *ShuffleEnums_Status
func (ShuffleEnums_Status) String ¶
func (x ShuffleEnums_Status) String() string
func (*ShuffleEnums_Status) UnmarshalJSON ¶
func (x *ShuffleEnums_Status) UnmarshalJSON(data []byte) error
type ShuffleInputSpecification ¶
type ShuffleInputSpecification struct { Format *ShuffleEnums_InputFormat `protobuf:"varint,1,opt,name=format,enum=files.ShuffleEnums_InputFormat,def=1" json:"format,omitempty"` Path *string `protobuf:"bytes,2,req,name=path" json:"path,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ShuffleInputSpecification) GetFormat ¶
func (m *ShuffleInputSpecification) GetFormat() ShuffleEnums_InputFormat
func (*ShuffleInputSpecification) GetPath ¶
func (m *ShuffleInputSpecification) GetPath() string
func (*ShuffleInputSpecification) ProtoMessage ¶
func (*ShuffleInputSpecification) ProtoMessage()
func (*ShuffleInputSpecification) Reset ¶
func (m *ShuffleInputSpecification) Reset()
func (*ShuffleInputSpecification) String ¶
func (m *ShuffleInputSpecification) String() string
type ShuffleOutputSpecification ¶
type ShuffleOutputSpecification struct { Format *ShuffleEnums_OutputFormat `protobuf:"varint,1,opt,name=format,enum=files.ShuffleEnums_OutputFormat,def=1" json:"format,omitempty"` Path []string `protobuf:"bytes,2,rep,name=path" json:"path,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ShuffleOutputSpecification) GetFormat ¶
func (m *ShuffleOutputSpecification) GetFormat() ShuffleEnums_OutputFormat
func (*ShuffleOutputSpecification) GetPath ¶
func (m *ShuffleOutputSpecification) GetPath() []string
func (*ShuffleOutputSpecification) ProtoMessage ¶
func (*ShuffleOutputSpecification) ProtoMessage()
func (*ShuffleOutputSpecification) Reset ¶
func (m *ShuffleOutputSpecification) Reset()
func (*ShuffleOutputSpecification) String ¶
func (m *ShuffleOutputSpecification) String() string
type ShuffleRequest ¶
type ShuffleRequest struct { ShuffleName *string `protobuf:"bytes,1,req,name=shuffle_name" json:"shuffle_name,omitempty"` Input []*ShuffleInputSpecification `protobuf:"bytes,2,rep,name=input" json:"input,omitempty"` Output *ShuffleOutputSpecification `protobuf:"bytes,3,req,name=output" json:"output,omitempty"` ShuffleSizeBytes *int64 `protobuf:"varint,4,req,name=shuffle_size_bytes" json:"shuffle_size_bytes,omitempty"` Callback *ShuffleRequest_Callback `protobuf:"bytes,5,req,name=callback" json:"callback,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ShuffleRequest) GetCallback ¶
func (m *ShuffleRequest) GetCallback() *ShuffleRequest_Callback
func (*ShuffleRequest) GetInput ¶
func (m *ShuffleRequest) GetInput() []*ShuffleInputSpecification
func (*ShuffleRequest) GetOutput ¶
func (m *ShuffleRequest) GetOutput() *ShuffleOutputSpecification
func (*ShuffleRequest) GetShuffleName ¶
func (m *ShuffleRequest) GetShuffleName() string
func (*ShuffleRequest) GetShuffleSizeBytes ¶
func (m *ShuffleRequest) GetShuffleSizeBytes() int64
func (*ShuffleRequest) ProtoMessage ¶
func (*ShuffleRequest) ProtoMessage()
func (*ShuffleRequest) Reset ¶
func (m *ShuffleRequest) Reset()
func (*ShuffleRequest) String ¶
func (m *ShuffleRequest) String() string
type ShuffleRequest_Callback ¶
type ShuffleRequest_Callback struct { Url *string `protobuf:"bytes,1,req,name=url" json:"url,omitempty"` AppVersionId *string `protobuf:"bytes,2,opt,name=app_version_id" json:"app_version_id,omitempty"` Method *string `protobuf:"bytes,3,opt,name=method,def=POST" json:"method,omitempty"` Queue *string `protobuf:"bytes,4,opt,name=queue,def=default" json:"queue,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*ShuffleRequest_Callback) GetAppVersionId ¶
func (m *ShuffleRequest_Callback) GetAppVersionId() string
func (*ShuffleRequest_Callback) GetMethod ¶
func (m *ShuffleRequest_Callback) GetMethod() string
func (*ShuffleRequest_Callback) GetQueue ¶
func (m *ShuffleRequest_Callback) GetQueue() string
func (*ShuffleRequest_Callback) GetUrl ¶
func (m *ShuffleRequest_Callback) GetUrl() string
func (*ShuffleRequest_Callback) ProtoMessage ¶
func (*ShuffleRequest_Callback) ProtoMessage()
func (*ShuffleRequest_Callback) Reset ¶
func (m *ShuffleRequest_Callback) Reset()
func (*ShuffleRequest_Callback) String ¶
func (m *ShuffleRequest_Callback) String() string
type ShuffleResponse ¶
type ShuffleResponse struct {
XXX_unrecognized []byte `json:"-"`
}
func (*ShuffleResponse) ProtoMessage ¶
func (*ShuffleResponse) ProtoMessage()
func (*ShuffleResponse) Reset ¶
func (m *ShuffleResponse) Reset()
func (*ShuffleResponse) String ¶
func (m *ShuffleResponse) String() string
type StatRequest ¶
type StatRequest struct { Filename *string `protobuf:"bytes,1,opt,name=filename" json:"filename,omitempty"` FileGlob *string `protobuf:"bytes,2,opt,name=file_glob" json:"file_glob,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*StatRequest) GetFileGlob ¶
func (m *StatRequest) GetFileGlob() string
func (*StatRequest) GetFilename ¶
func (m *StatRequest) GetFilename() string
func (*StatRequest) ProtoMessage ¶
func (*StatRequest) ProtoMessage()
func (*StatRequest) Reset ¶
func (m *StatRequest) Reset()
func (*StatRequest) String ¶
func (m *StatRequest) String() string
type StatResponse ¶
type StatResponse struct { Stat []*FileStat `protobuf:"bytes,1,rep,name=stat" json:"stat,omitempty"` MoreFilesFound *bool `protobuf:"varint,2,req,name=more_files_found,def=0" json:"more_files_found,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*StatResponse) GetMoreFilesFound ¶
func (m *StatResponse) GetMoreFilesFound() bool
func (*StatResponse) GetStat ¶
func (m *StatResponse) GetStat() []*FileStat
func (*StatResponse) ProtoMessage ¶
func (*StatResponse) ProtoMessage()
func (*StatResponse) Reset ¶
func (m *StatResponse) Reset()
func (*StatResponse) String ¶
func (m *StatResponse) String() string
type StringProto ¶
type StringProto struct { Value *string `protobuf:"bytes,1,req,name=value" json:"value,omitempty"` XXX_unrecognized []byte `json:"-"` }
func (*StringProto) GetValue ¶
func (m *StringProto) GetValue() string
func (*StringProto) ProtoMessage ¶
func (*StringProto) ProtoMessage()
func (*StringProto) Reset ¶
func (m *StringProto) Reset()
func (*StringProto) String ¶
func (m *StringProto) String() string
Click to show internal directories.
Click to hide internal directories.