files

package
v0.0.0-...-456eabd Latest Latest
Warning

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

 Go to latest Published: Nov 5, 2011 License: BSD-3-Clause Imports: 2 Imported by: 0

Documentation

Index

Constants

View Source 
const Default_CloseRequest_Finalize 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",
	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,
	"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{
	0: "CSV_INPUT",
	1: "RECORDS_KEY_VALUE_PROTO_INPUT",
}
View Source 
var ShuffleEnums_InputFormat_value = map[string]int32{
	"CSV_INPUT":                     0,
	"RECORDS_KEY_VALUE_PROTO_INPUT": 1,
}
View Source 
var ShuffleEnums_OutputFormat_name = map[int32]string{
	0: "CSV_OUTPUT",
	1: "RECORDS_KEY_MULTI_VALUE_PROTO_OUTPUT",
}
View Source 
var ShuffleEnums_OutputFormat_value = map[string]int32{
	"CSV_OUTPUT":                           0,
	"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:",omitempty"`
}

func (*AppendRequest) Reset 

func (this *AppendRequest) Reset()

func (*AppendRequest) String 

func (this *AppendRequest) String() string

type AppendResponse 

type AppendResponse struct {
	XXX_unrecognized []byte `json:",omitempty"`
}

func (*AppendResponse) Reset 

func (this *AppendResponse) Reset()

func (*AppendResponse) String 

func (this *AppendResponse) String() string

type BoolProto 

type BoolProto struct {
	Value            *bool  `protobuf:"varint,1,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte `json:",omitempty"`
}

func (*BoolProto) Reset 

func (this *BoolProto) Reset()

func (*BoolProto) String 

func (this *BoolProto) String() string

type BytesProto 

type BytesProto struct {
	Value            []byte `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte `json:",omitempty"`
}

func (*BytesProto) Reset 

func (this *BytesProto) Reset()

func (*BytesProto) String 

func (this *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:",omitempty"`
}

func (*CloseRequest) Reset 

func (this *CloseRequest) Reset()

func (*CloseRequest) String 

func (this *CloseRequest) String() string

type CloseResponse 

type CloseResponse struct {
	XXX_unrecognized []byte `json:",omitempty"`
}

func (*CloseResponse) Reset 

func (this *CloseResponse) Reset()

func (*CloseResponse) String 

func (this *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" 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:",omitempty"`
}

func (*CreateRequest) Reset 

func (this *CreateRequest) Reset()

func (*CreateRequest) String 

func (this *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:",omitempty"`
}

func (*CreateRequest_Parameter) Reset 

func (this *CreateRequest_Parameter) Reset()

func (*CreateRequest_Parameter) String 

func (this *CreateRequest_Parameter) String() string

type CreateResponse 

type CreateResponse struct {
	Filename         *string `protobuf:"bytes,1,req,name=filename" json:"filename,omitempty"`
	XXX_unrecognized []byte  `json:",omitempty"`
}

func (*CreateResponse) Reset 

func (this *CreateResponse) Reset()

func (*CreateResponse) String 

func (this *CreateResponse) String() string

type DeleteRequest 

type DeleteRequest struct {
	Filename         *string `protobuf:"bytes,1,req,name=filename" json:"filename,omitempty"`
	XXX_unrecognized []byte  `json:",omitempty"`
}

func (*DeleteRequest) Reset 

func (this *DeleteRequest) Reset()

func (*DeleteRequest) String 

func (this *DeleteRequest) String() string

type DeleteResponse 

type DeleteResponse struct {
	XXX_unrecognized []byte `json:",omitempty"`
}

func (*DeleteResponse) Reset 

func (this *DeleteResponse) Reset()

func (*DeleteResponse) String 

func (this *DeleteResponse) String() string

type DoubleProto 

type DoubleProto struct {
	Value            *float64 `protobuf:"fixed64,1,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte   `json:",omitempty"`
}

func (*DoubleProto) Reset 

func (this *DoubleProto) Reset()

func (*DoubleProto) String 

func (this *DoubleProto) String() string

type FileContentType 

type FileContentType struct {
	XXX_unrecognized []byte `json:",omitempty"`
}

func (*FileContentType) Reset 

func (this *FileContentType) Reset()

func (*FileContentType) String 

func (this *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 NewFileContentType_ContentType 

func NewFileContentType_ContentType(x FileContentType_ContentType) *FileContentType_ContentType

func (FileContentType_ContentType) String 

func (x FileContentType_ContentType) String() string

type FileServiceErrors 

type FileServiceErrors struct {
	XXX_unrecognized []byte `json:",omitempty"`
}

func (*FileServiceErrors) Reset 

func (this *FileServiceErrors) Reset()

func (*FileServiceErrors) String 

func (this *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_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 NewFileServiceErrors_ErrorCode 

func NewFileServiceErrors_ErrorCode(x FileServiceErrors_ErrorCode) *FileServiceErrors_ErrorCode

func (FileServiceErrors_ErrorCode) String 

func (x FileServiceErrors_ErrorCode) String() string

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:",omitempty"`
}

func (*FileStat) Reset 

func (this *FileStat) Reset()

func (*FileStat) String 

func (this *FileStat) String() string

type GetCapabilitiesRequest 

type GetCapabilitiesRequest struct {
	XXX_unrecognized []byte `json:",omitempty"`
}

func (*GetCapabilitiesRequest) Reset 

func (this *GetCapabilitiesRequest) Reset()

func (*GetCapabilitiesRequest) String 

func (this *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:",omitempty"`
}

func (*GetCapabilitiesResponse) Reset 

func (this *GetCapabilitiesResponse) Reset()

func (*GetCapabilitiesResponse) String 

func (this *GetCapabilitiesResponse) String() string

type GetShuffleStatusRequest 

type GetShuffleStatusRequest struct {
	ShuffleName      *string `protobuf:"bytes,1,req,name=shuffle_name" json:"shuffle_name,omitempty"`
	XXX_unrecognized []byte  `json:",omitempty"`
}

func (*GetShuffleStatusRequest) Reset 

func (this *GetShuffleStatusRequest) Reset()

func (*GetShuffleStatusRequest) String 

func (this *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:",omitempty"`
}

func (*GetShuffleStatusResponse) Reset 

func (this *GetShuffleStatusResponse) Reset()

func (*GetShuffleStatusResponse) String 

func (this *GetShuffleStatusResponse) String() string

type Integer32Proto 

type Integer32Proto struct {
	Value            *int32 `protobuf:"varint,1,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte `json:",omitempty"`
}

func (*Integer32Proto) Reset 

func (this *Integer32Proto) Reset()

func (*Integer32Proto) String 

func (this *Integer32Proto) String() string

type Integer64Proto 

type Integer64Proto struct {
	Value            *int64 `protobuf:"varint,1,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte `json:",omitempty"`
}

func (*Integer64Proto) Reset 

func (this *Integer64Proto) Reset()

func (*Integer64Proto) String 

func (this *Integer64Proto) String() string

type KeyValue 

type KeyValue struct {
	Key              *string `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Value            *string `protobuf:"bytes,2,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:",omitempty"`
}

func (*KeyValue) Reset 

func (this *KeyValue) Reset()

func (*KeyValue) String 

func (this *KeyValue) String() string

type KeyValues 

type KeyValues struct {
	Key              *string  `protobuf:"bytes,1,req,name=key" json:"key,omitempty"`
	Value            []string `protobuf:"bytes,2,rep,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte   `json:",omitempty"`
}

func (*KeyValues) Reset 

func (this *KeyValues) Reset()

func (*KeyValues) String 

func (this *KeyValues) 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:",omitempty"`
}

func (*OpenRequest) Reset 

func (this *OpenRequest) Reset()

func (*OpenRequest) String 

func (this *OpenRequest) String() string

type OpenRequest_OpenMode 

type OpenRequest_OpenMode int32
const (
	OpenRequest_APPEND OpenRequest_OpenMode = 1
	OpenRequest_READ   OpenRequest_OpenMode = 2
)

func NewOpenRequest_OpenMode 

func NewOpenRequest_OpenMode(x OpenRequest_OpenMode) *OpenRequest_OpenMode

func (OpenRequest_OpenMode) String 

func (x OpenRequest_OpenMode) String() string

type OpenResponse 

type OpenResponse struct {
	XXX_unrecognized []byte `json:",omitempty"`
}

func (*OpenResponse) Reset 

func (this *OpenResponse) Reset()

func (*OpenResponse) String 

func (this *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:",omitempty"`
}

func (*ReadKeyValueRequest) Reset 

func (this *ReadKeyValueRequest) Reset()

func (*ReadKeyValueRequest) String 

func (this *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:",omitempty"`
}

func (*ReadKeyValueResponse) Reset 

func (this *ReadKeyValueResponse) Reset()

func (*ReadKeyValueResponse) String 

func (this *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:",omitempty"`
}

func (*ReadKeyValueResponse_KeyValue) Reset 

func (this *ReadKeyValueResponse_KeyValue) Reset()

func (*ReadKeyValueResponse_KeyValue) String 

func (this *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:",omitempty"`
}

func (*ReadRequest) Reset 

func (this *ReadRequest) Reset()

func (*ReadRequest) String 

func (this *ReadRequest) String() string

type ReadResponse 

type ReadResponse struct {
	Data             []byte `protobuf:"bytes,1,req,name=data" json:"data,omitempty"`
	XXX_unrecognized []byte `json:",omitempty"`
}

func (*ReadResponse) Reset 

func (this *ReadResponse) Reset()

func (*ReadResponse) String 

func (this *ReadResponse) String() string

type ShuffleEnums 

type ShuffleEnums struct {
	XXX_unrecognized []byte `json:",omitempty"`
}

func (*ShuffleEnums) Reset 

func (this *ShuffleEnums) Reset()

func (*ShuffleEnums) String 

func (this *ShuffleEnums) String() string

type ShuffleEnums_InputFormat 

type ShuffleEnums_InputFormat int32
const (
	ShuffleEnums_CSV_INPUT                     ShuffleEnums_InputFormat = 0
	ShuffleEnums_RECORDS_KEY_VALUE_PROTO_INPUT ShuffleEnums_InputFormat = 1
)
const Default_ShuffleInputSpecification_Format ShuffleEnums_InputFormat = ShuffleEnums_CSV_INPUT

func NewShuffleEnums_InputFormat 

func NewShuffleEnums_InputFormat(x ShuffleEnums_InputFormat) *ShuffleEnums_InputFormat

func (ShuffleEnums_InputFormat) String 

func (x ShuffleEnums_InputFormat) String() string

type ShuffleEnums_OutputFormat 

type ShuffleEnums_OutputFormat int32
const (
	ShuffleEnums_CSV_OUTPUT                           ShuffleEnums_OutputFormat = 0
	ShuffleEnums_RECORDS_KEY_MULTI_VALUE_PROTO_OUTPUT ShuffleEnums_OutputFormat = 1
)
const Default_ShuffleOutputSpecification_Format ShuffleEnums_OutputFormat = ShuffleEnums_CSV_OUTPUT

func NewShuffleEnums_OutputFormat 

func NewShuffleEnums_OutputFormat(x ShuffleEnums_OutputFormat) *ShuffleEnums_OutputFormat

func (ShuffleEnums_OutputFormat) String 

func (x ShuffleEnums_OutputFormat) String() string

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 NewShuffleEnums_Status 

func NewShuffleEnums_Status(x ShuffleEnums_Status) *ShuffleEnums_Status

func (ShuffleEnums_Status) String 

func (x ShuffleEnums_Status) String() string

type ShuffleInputSpecification 

type ShuffleInputSpecification struct {
	Format           *ShuffleEnums_InputFormat `protobuf:"varint,1,opt,name=format,enum=files.ShuffleEnums_InputFormat,def=0" json:"format,omitempty"`
	Path             *string                   `protobuf:"bytes,2,req,name=path" json:"path,omitempty"`
	XXX_unrecognized []byte                    `json:",omitempty"`
}

func (*ShuffleInputSpecification) Reset 

func (this *ShuffleInputSpecification) Reset()

func (*ShuffleInputSpecification) String 

func (this *ShuffleInputSpecification) String() string

type ShuffleOutputSpecification 

type ShuffleOutputSpecification struct {
	Format           *ShuffleEnums_OutputFormat `protobuf:"varint,1,opt,name=format,enum=files.ShuffleEnums_OutputFormat,def=0" json:"format,omitempty"`
	Path             []string                   `protobuf:"bytes,2,rep,name=path" json:"path,omitempty"`
	XXX_unrecognized []byte                     `json:",omitempty"`
}

func (*ShuffleOutputSpecification) Reset 

func (this *ShuffleOutputSpecification) Reset()

func (*ShuffleOutputSpecification) String 

func (this *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:",omitempty"`
}

func (*ShuffleRequest) Reset 

func (this *ShuffleRequest) Reset()

func (*ShuffleRequest) String 

func (this *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:",omitempty"`
}

func (*ShuffleRequest_Callback) Reset 

func (this *ShuffleRequest_Callback) Reset()

func (*ShuffleRequest_Callback) String 

func (this *ShuffleRequest_Callback) String() string

type ShuffleResponse 

type ShuffleResponse struct {
	XXX_unrecognized []byte `json:",omitempty"`
}

func (*ShuffleResponse) Reset 

func (this *ShuffleResponse) Reset()

func (*ShuffleResponse) String 

func (this *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:",omitempty"`
}

func (*StatRequest) Reset 

func (this *StatRequest) Reset()

func (*StatRequest) String 

func (this *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:",omitempty"`
}

func (*StatResponse) Reset 

func (this *StatResponse) Reset()

func (*StatResponse) String 

func (this *StatResponse) String() string

type StringProto 

type StringProto struct {
	Value            *string `protobuf:"bytes,1,req,name=value" json:"value,omitempty"`
	XXX_unrecognized []byte  `json:",omitempty"`
}

func (*StringProto) Reset 

func (this *StringProto) Reset()

func (*StringProto) String 

func (this *StringProto) String() string

type VoidProto 

type VoidProto struct {
	XXX_unrecognized []byte `json:",omitempty"`
}

func (*VoidProto) Reset 

func (this *VoidProto) Reset()

func (*VoidProto) String 

func (this *VoidProto) 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.