Documentation ¶
Overview ¶
Package storage is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Index ¶
- Constants
- Variables
- func RegisterFilesetHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterFilesetHandlerClient(ctx context.Context, mux *runtime.ServeMux, client FilesetClient) error
- func RegisterFilesetHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterFilesetHandlerServer(ctx context.Context, mux *runtime.ServeMux, server FilesetServer) error
- func RegisterFilesetServer(s grpc.ServiceRegistrar, srv FilesetServer)
- type AppendFile
- func (*AppendFile) Descriptor() ([]byte, []int)deprecated
- func (x *AppendFile) GetData() *wrapperspb.BytesValue
- func (x *AppendFile) GetPath() string
- func (x *AppendFile) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*AppendFile) ProtoMessage()
- func (x *AppendFile) ProtoReflect() protoreflect.Message
- func (x *AppendFile) Reset()
- func (x *AppendFile) String() string
- func (m *AppendFile) Validate() error
- func (m *AppendFile) ValidateAll() error
- type AppendFileMultiError
- type AppendFileValidationError
- type ComposeFilesetRequest
- func (*ComposeFilesetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ComposeFilesetRequest) GetFilesetIds() []string
- func (x *ComposeFilesetRequest) GetTtlSeconds() int64
- func (x *ComposeFilesetRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*ComposeFilesetRequest) ProtoMessage()
- func (x *ComposeFilesetRequest) ProtoReflect() protoreflect.Message
- func (x *ComposeFilesetRequest) Reset()
- func (x *ComposeFilesetRequest) String() string
- func (m *ComposeFilesetRequest) Validate() error
- func (m *ComposeFilesetRequest) ValidateAll() error
- type ComposeFilesetRequestMultiError
- type ComposeFilesetRequestValidationError
- func (e ComposeFilesetRequestValidationError) Cause() error
- func (e ComposeFilesetRequestValidationError) Error() string
- func (e ComposeFilesetRequestValidationError) ErrorName() string
- func (e ComposeFilesetRequestValidationError) Field() string
- func (e ComposeFilesetRequestValidationError) Key() bool
- func (e ComposeFilesetRequestValidationError) Reason() string
- type ComposeFilesetResponse
- func (*ComposeFilesetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ComposeFilesetResponse) GetFilesetId() string
- func (x *ComposeFilesetResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*ComposeFilesetResponse) ProtoMessage()
- func (x *ComposeFilesetResponse) ProtoReflect() protoreflect.Message
- func (x *ComposeFilesetResponse) Reset()
- func (x *ComposeFilesetResponse) String() string
- func (m *ComposeFilesetResponse) Validate() error
- func (m *ComposeFilesetResponse) ValidateAll() error
- type ComposeFilesetResponseMultiError
- type ComposeFilesetResponseValidationError
- func (e ComposeFilesetResponseValidationError) Cause() error
- func (e ComposeFilesetResponseValidationError) Error() string
- func (e ComposeFilesetResponseValidationError) ErrorName() string
- func (e ComposeFilesetResponseValidationError) Field() string
- func (e ComposeFilesetResponseValidationError) Key() bool
- func (e ComposeFilesetResponseValidationError) Reason() string
- type CreateFilesetRequest
- func (*CreateFilesetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateFilesetRequest) GetAppendFile() *AppendFile
- func (x *CreateFilesetRequest) GetDeleteFile() *DeleteFile
- func (m *CreateFilesetRequest) GetModification() isCreateFilesetRequest_Modification
- func (x *CreateFilesetRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*CreateFilesetRequest) ProtoMessage()
- func (x *CreateFilesetRequest) ProtoReflect() protoreflect.Message
- func (x *CreateFilesetRequest) Reset()
- func (x *CreateFilesetRequest) String() string
- func (m *CreateFilesetRequest) Validate() error
- func (m *CreateFilesetRequest) ValidateAll() error
- type CreateFilesetRequestMultiError
- type CreateFilesetRequestValidationError
- func (e CreateFilesetRequestValidationError) Cause() error
- func (e CreateFilesetRequestValidationError) Error() string
- func (e CreateFilesetRequestValidationError) ErrorName() string
- func (e CreateFilesetRequestValidationError) Field() string
- func (e CreateFilesetRequestValidationError) Key() bool
- func (e CreateFilesetRequestValidationError) Reason() string
- type CreateFilesetRequest_AppendFile
- type CreateFilesetRequest_DeleteFile
- type CreateFilesetResponse
- func (*CreateFilesetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateFilesetResponse) GetFilesetId() string
- func (x *CreateFilesetResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*CreateFilesetResponse) ProtoMessage()
- func (x *CreateFilesetResponse) ProtoReflect() protoreflect.Message
- func (x *CreateFilesetResponse) Reset()
- func (x *CreateFilesetResponse) String() string
- func (m *CreateFilesetResponse) Validate() error
- func (m *CreateFilesetResponse) ValidateAll() error
- type CreateFilesetResponseMultiError
- type CreateFilesetResponseValidationError
- func (e CreateFilesetResponseValidationError) Cause() error
- func (e CreateFilesetResponseValidationError) Error() string
- func (e CreateFilesetResponseValidationError) ErrorName() string
- func (e CreateFilesetResponseValidationError) Field() string
- func (e CreateFilesetResponseValidationError) Key() bool
- func (e CreateFilesetResponseValidationError) Reason() string
- type DeleteFile
- func (*DeleteFile) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteFile) GetPath() string
- func (x *DeleteFile) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*DeleteFile) ProtoMessage()
- func (x *DeleteFile) ProtoReflect() protoreflect.Message
- func (x *DeleteFile) Reset()
- func (x *DeleteFile) String() string
- func (m *DeleteFile) Validate() error
- func (m *DeleteFile) ValidateAll() error
- type DeleteFileMultiError
- type DeleteFileValidationError
- type FileFilter
- func (*FileFilter) Descriptor() ([]byte, []int)deprecated
- func (m *FileFilter) GetFilter() isFileFilter_Filter
- func (x *FileFilter) GetPathRange() *PathRange
- func (x *FileFilter) GetPathRegex() string
- func (x *FileFilter) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*FileFilter) ProtoMessage()
- func (x *FileFilter) ProtoReflect() protoreflect.Message
- func (x *FileFilter) Reset()
- func (x *FileFilter) String() string
- func (m *FileFilter) Validate() error
- func (m *FileFilter) ValidateAll() error
- type FileFilterMultiError
- type FileFilterValidationError
- type FileFilter_PathRange
- type FileFilter_PathRegex
- type FilesetClient
- type FilesetServer
- type Fileset_CreateFilesetClient
- type Fileset_CreateFilesetServer
- type Fileset_ReadFilesetClient
- type Fileset_ReadFilesetServer
- type PathRange
- func (*PathRange) Descriptor() ([]byte, []int)deprecated
- func (x *PathRange) GetLower() string
- func (x *PathRange) GetUpper() string
- func (x *PathRange) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*PathRange) ProtoMessage()
- func (x *PathRange) ProtoReflect() protoreflect.Message
- func (x *PathRange) Reset()
- func (x *PathRange) String() string
- func (m *PathRange) Validate() error
- func (m *PathRange) ValidateAll() error
- type PathRangeMultiError
- type PathRangeValidationError
- type ReadFilesetRequest
- func (*ReadFilesetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ReadFilesetRequest) GetEmptyFiles() bool
- func (x *ReadFilesetRequest) GetFilesetId() string
- func (x *ReadFilesetRequest) GetFilters() []*FileFilter
- func (x *ReadFilesetRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*ReadFilesetRequest) ProtoMessage()
- func (x *ReadFilesetRequest) ProtoReflect() protoreflect.Message
- func (x *ReadFilesetRequest) Reset()
- func (x *ReadFilesetRequest) String() string
- func (m *ReadFilesetRequest) Validate() error
- func (m *ReadFilesetRequest) ValidateAll() error
- type ReadFilesetRequestMultiError
- type ReadFilesetRequestValidationError
- func (e ReadFilesetRequestValidationError) Cause() error
- func (e ReadFilesetRequestValidationError) Error() string
- func (e ReadFilesetRequestValidationError) ErrorName() string
- func (e ReadFilesetRequestValidationError) Field() string
- func (e ReadFilesetRequestValidationError) Key() bool
- func (e ReadFilesetRequestValidationError) Reason() string
- type ReadFilesetResponse
- func (*ReadFilesetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ReadFilesetResponse) GetData() *wrapperspb.BytesValue
- func (x *ReadFilesetResponse) GetPath() string
- func (x *ReadFilesetResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*ReadFilesetResponse) ProtoMessage()
- func (x *ReadFilesetResponse) ProtoReflect() protoreflect.Message
- func (x *ReadFilesetResponse) Reset()
- func (x *ReadFilesetResponse) String() string
- func (m *ReadFilesetResponse) Validate() error
- func (m *ReadFilesetResponse) ValidateAll() error
- type ReadFilesetResponseMultiError
- type ReadFilesetResponseValidationError
- func (e ReadFilesetResponseValidationError) Cause() error
- func (e ReadFilesetResponseValidationError) Error() string
- func (e ReadFilesetResponseValidationError) ErrorName() string
- func (e ReadFilesetResponseValidationError) Field() string
- func (e ReadFilesetResponseValidationError) Key() bool
- func (e ReadFilesetResponseValidationError) Reason() string
- type RenewFilesetRequest
- func (*RenewFilesetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RenewFilesetRequest) GetFilesetId() string
- func (x *RenewFilesetRequest) GetTtlSeconds() int64
- func (x *RenewFilesetRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*RenewFilesetRequest) ProtoMessage()
- func (x *RenewFilesetRequest) ProtoReflect() protoreflect.Message
- func (x *RenewFilesetRequest) Reset()
- func (x *RenewFilesetRequest) String() string
- func (m *RenewFilesetRequest) Validate() error
- func (m *RenewFilesetRequest) ValidateAll() error
- type RenewFilesetRequestMultiError
- type RenewFilesetRequestValidationError
- func (e RenewFilesetRequestValidationError) Cause() error
- func (e RenewFilesetRequestValidationError) Error() string
- func (e RenewFilesetRequestValidationError) ErrorName() string
- func (e RenewFilesetRequestValidationError) Field() string
- func (e RenewFilesetRequestValidationError) Key() bool
- func (e RenewFilesetRequestValidationError) Reason() string
- type ShardFilesetRequest
- func (*ShardFilesetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ShardFilesetRequest) GetFilesetId() string
- func (x *ShardFilesetRequest) GetNumFiles() int64
- func (x *ShardFilesetRequest) GetSizeBytes() int64
- func (x *ShardFilesetRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*ShardFilesetRequest) ProtoMessage()
- func (x *ShardFilesetRequest) ProtoReflect() protoreflect.Message
- func (x *ShardFilesetRequest) Reset()
- func (x *ShardFilesetRequest) String() string
- func (m *ShardFilesetRequest) Validate() error
- func (m *ShardFilesetRequest) ValidateAll() error
- type ShardFilesetRequestMultiError
- type ShardFilesetRequestValidationError
- func (e ShardFilesetRequestValidationError) Cause() error
- func (e ShardFilesetRequestValidationError) Error() string
- func (e ShardFilesetRequestValidationError) ErrorName() string
- func (e ShardFilesetRequestValidationError) Field() string
- func (e ShardFilesetRequestValidationError) Key() bool
- func (e ShardFilesetRequestValidationError) Reason() string
- type ShardFilesetResponse
- func (*ShardFilesetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ShardFilesetResponse) GetShards() []*PathRange
- func (x *ShardFilesetResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
- func (*ShardFilesetResponse) ProtoMessage()
- func (x *ShardFilesetResponse) ProtoReflect() protoreflect.Message
- func (x *ShardFilesetResponse) Reset()
- func (x *ShardFilesetResponse) String() string
- func (m *ShardFilesetResponse) Validate() error
- func (m *ShardFilesetResponse) ValidateAll() error
- type ShardFilesetResponseMultiError
- type ShardFilesetResponseValidationError
- func (e ShardFilesetResponseValidationError) Cause() error
- func (e ShardFilesetResponseValidationError) Error() string
- func (e ShardFilesetResponseValidationError) ErrorName() string
- func (e ShardFilesetResponseValidationError) Field() string
- func (e ShardFilesetResponseValidationError) Key() bool
- func (e ShardFilesetResponseValidationError) Reason() string
- type UnimplementedFilesetServer
- func (UnimplementedFilesetServer) ComposeFileset(context.Context, *ComposeFilesetRequest) (*ComposeFilesetResponse, error)
- func (UnimplementedFilesetServer) CreateFileset(Fileset_CreateFilesetServer) error
- func (UnimplementedFilesetServer) ReadFileset(*ReadFilesetRequest, Fileset_ReadFilesetServer) error
- func (UnimplementedFilesetServer) RenewFileset(context.Context, *RenewFilesetRequest) (*emptypb.Empty, error)
- func (UnimplementedFilesetServer) ShardFileset(context.Context, *ShardFilesetRequest) (*ShardFilesetResponse, error)
- type UnsafeFilesetServer
Constants ¶
const ( Fileset_CreateFileset_FullMethodName = "/storage.Fileset/CreateFileset" Fileset_ReadFileset_FullMethodName = "/storage.Fileset/ReadFileset" Fileset_RenewFileset_FullMethodName = "/storage.Fileset/RenewFileset" Fileset_ComposeFileset_FullMethodName = "/storage.Fileset/ComposeFileset" Fileset_ShardFileset_FullMethodName = "/storage.Fileset/ShardFileset" )
Variables ¶
var File_storage_fileset_proto protoreflect.FileDescriptor
var Fileset_ServiceDesc = grpc.ServiceDesc{ ServiceName: "storage.Fileset", HandlerType: (*FilesetServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "RenewFileset", Handler: _Fileset_RenewFileset_Handler, }, { MethodName: "ComposeFileset", Handler: _Fileset_ComposeFileset_Handler, }, { MethodName: "ShardFileset", Handler: _Fileset_ShardFileset_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "CreateFileset", Handler: _Fileset_CreateFileset_Handler, ClientStreams: true, }, { StreamName: "ReadFileset", Handler: _Fileset_ReadFileset_Handler, ServerStreams: true, }, }, Metadata: "storage/fileset.proto", }
Fileset_ServiceDesc is the grpc.ServiceDesc for Fileset service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterFilesetHandler ¶
func RegisterFilesetHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterFilesetHandler registers the http handlers for service Fileset to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterFilesetHandlerClient ¶
func RegisterFilesetHandlerClient(ctx context.Context, mux *runtime.ServeMux, client FilesetClient) error
RegisterFilesetHandlerClient registers the http handlers for service Fileset to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "FilesetClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "FilesetClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "FilesetClient" to call the correct interceptors.
func RegisterFilesetHandlerFromEndpoint ¶
func RegisterFilesetHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterFilesetHandlerFromEndpoint is same as RegisterFilesetHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterFilesetHandlerServer ¶
func RegisterFilesetHandlerServer(ctx context.Context, mux *runtime.ServeMux, server FilesetServer) error
RegisterFilesetHandlerServer registers the http handlers for service Fileset to "mux". UnaryRPC :call FilesetServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterFilesetHandlerFromEndpoint instead.
func RegisterFilesetServer ¶
func RegisterFilesetServer(s grpc.ServiceRegistrar, srv FilesetServer)
Types ¶
type AppendFile ¶
type AppendFile struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` Data *wrapperspb.BytesValue `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
AppendFile will append the provided data to the file with the specified path. If a file with the specified path doesn't exist, it will be created.
func (*AppendFile) Descriptor
deprecated
func (*AppendFile) Descriptor() ([]byte, []int)
Deprecated: Use AppendFile.ProtoReflect.Descriptor instead.
func (*AppendFile) GetData ¶
func (x *AppendFile) GetData() *wrapperspb.BytesValue
func (*AppendFile) GetPath ¶
func (x *AppendFile) GetPath() string
func (*AppendFile) MarshalLogObject ¶
func (x *AppendFile) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*AppendFile) ProtoMessage ¶
func (*AppendFile) ProtoMessage()
func (*AppendFile) ProtoReflect ¶
func (x *AppendFile) ProtoReflect() protoreflect.Message
func (*AppendFile) Reset ¶
func (x *AppendFile) Reset()
func (*AppendFile) String ¶
func (x *AppendFile) String() string
func (*AppendFile) Validate ¶
func (m *AppendFile) Validate() error
Validate checks the field values on AppendFile with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*AppendFile) ValidateAll ¶
func (m *AppendFile) ValidateAll() error
ValidateAll checks the field values on AppendFile with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in AppendFileMultiError, or nil if none found.
type AppendFileMultiError ¶
type AppendFileMultiError []error
AppendFileMultiError is an error wrapping multiple validation errors returned by AppendFile.ValidateAll() if the designated constraints aren't met.
func (AppendFileMultiError) AllErrors ¶
func (m AppendFileMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (AppendFileMultiError) Error ¶
func (m AppendFileMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type AppendFileValidationError ¶
type AppendFileValidationError struct {
// contains filtered or unexported fields
}
AppendFileValidationError is the validation error returned by AppendFile.Validate if the designated constraints aren't met.
func (AppendFileValidationError) Cause ¶
func (e AppendFileValidationError) Cause() error
Cause function returns cause value.
func (AppendFileValidationError) Error ¶
func (e AppendFileValidationError) Error() string
Error satisfies the builtin error interface
func (AppendFileValidationError) ErrorName ¶
func (e AppendFileValidationError) ErrorName() string
ErrorName returns error name.
func (AppendFileValidationError) Field ¶
func (e AppendFileValidationError) Field() string
Field function returns field value.
func (AppendFileValidationError) Key ¶
func (e AppendFileValidationError) Key() bool
Key function returns key value.
func (AppendFileValidationError) Reason ¶
func (e AppendFileValidationError) Reason() string
Reason function returns reason value.
type ComposeFilesetRequest ¶
type ComposeFilesetRequest struct { FilesetIds []string `protobuf:"bytes,1,rep,name=fileset_ids,json=filesetIds,proto3" json:"fileset_ids,omitempty"` // The TTL, in seconds, for the composite fileset that is created. TtlSeconds int64 `protobuf:"varint,2,opt,name=ttl_seconds,json=ttlSeconds,proto3" json:"ttl_seconds,omitempty"` // contains filtered or unexported fields }
func (*ComposeFilesetRequest) Descriptor
deprecated
func (*ComposeFilesetRequest) Descriptor() ([]byte, []int)
Deprecated: Use ComposeFilesetRequest.ProtoReflect.Descriptor instead.
func (*ComposeFilesetRequest) GetFilesetIds ¶
func (x *ComposeFilesetRequest) GetFilesetIds() []string
func (*ComposeFilesetRequest) GetTtlSeconds ¶
func (x *ComposeFilesetRequest) GetTtlSeconds() int64
func (*ComposeFilesetRequest) MarshalLogObject ¶
func (x *ComposeFilesetRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*ComposeFilesetRequest) ProtoMessage ¶
func (*ComposeFilesetRequest) ProtoMessage()
func (*ComposeFilesetRequest) ProtoReflect ¶
func (x *ComposeFilesetRequest) ProtoReflect() protoreflect.Message
func (*ComposeFilesetRequest) Reset ¶
func (x *ComposeFilesetRequest) Reset()
func (*ComposeFilesetRequest) String ¶
func (x *ComposeFilesetRequest) String() string
func (*ComposeFilesetRequest) Validate ¶
func (m *ComposeFilesetRequest) Validate() error
Validate checks the field values on ComposeFilesetRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ComposeFilesetRequest) ValidateAll ¶
func (m *ComposeFilesetRequest) ValidateAll() error
ValidateAll checks the field values on ComposeFilesetRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ComposeFilesetRequestMultiError, or nil if none found.
type ComposeFilesetRequestMultiError ¶
type ComposeFilesetRequestMultiError []error
ComposeFilesetRequestMultiError is an error wrapping multiple validation errors returned by ComposeFilesetRequest.ValidateAll() if the designated constraints aren't met.
func (ComposeFilesetRequestMultiError) AllErrors ¶
func (m ComposeFilesetRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ComposeFilesetRequestMultiError) Error ¶
func (m ComposeFilesetRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ComposeFilesetRequestValidationError ¶
type ComposeFilesetRequestValidationError struct {
// contains filtered or unexported fields
}
ComposeFilesetRequestValidationError is the validation error returned by ComposeFilesetRequest.Validate if the designated constraints aren't met.
func (ComposeFilesetRequestValidationError) Cause ¶
func (e ComposeFilesetRequestValidationError) Cause() error
Cause function returns cause value.
func (ComposeFilesetRequestValidationError) Error ¶
func (e ComposeFilesetRequestValidationError) Error() string
Error satisfies the builtin error interface
func (ComposeFilesetRequestValidationError) ErrorName ¶
func (e ComposeFilesetRequestValidationError) ErrorName() string
ErrorName returns error name.
func (ComposeFilesetRequestValidationError) Field ¶
func (e ComposeFilesetRequestValidationError) Field() string
Field function returns field value.
func (ComposeFilesetRequestValidationError) Key ¶
func (e ComposeFilesetRequestValidationError) Key() bool
Key function returns key value.
func (ComposeFilesetRequestValidationError) Reason ¶
func (e ComposeFilesetRequestValidationError) Reason() string
Reason function returns reason value.
type ComposeFilesetResponse ¶
type ComposeFilesetResponse struct { FilesetId string `protobuf:"bytes,1,opt,name=fileset_id,json=filesetId,proto3" json:"fileset_id,omitempty"` // contains filtered or unexported fields }
func (*ComposeFilesetResponse) Descriptor
deprecated
func (*ComposeFilesetResponse) Descriptor() ([]byte, []int)
Deprecated: Use ComposeFilesetResponse.ProtoReflect.Descriptor instead.
func (*ComposeFilesetResponse) GetFilesetId ¶
func (x *ComposeFilesetResponse) GetFilesetId() string
func (*ComposeFilesetResponse) MarshalLogObject ¶
func (x *ComposeFilesetResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*ComposeFilesetResponse) ProtoMessage ¶
func (*ComposeFilesetResponse) ProtoMessage()
func (*ComposeFilesetResponse) ProtoReflect ¶
func (x *ComposeFilesetResponse) ProtoReflect() protoreflect.Message
func (*ComposeFilesetResponse) Reset ¶
func (x *ComposeFilesetResponse) Reset()
func (*ComposeFilesetResponse) String ¶
func (x *ComposeFilesetResponse) String() string
func (*ComposeFilesetResponse) Validate ¶
func (m *ComposeFilesetResponse) Validate() error
Validate checks the field values on ComposeFilesetResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ComposeFilesetResponse) ValidateAll ¶
func (m *ComposeFilesetResponse) ValidateAll() error
ValidateAll checks the field values on ComposeFilesetResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ComposeFilesetResponseMultiError, or nil if none found.
type ComposeFilesetResponseMultiError ¶
type ComposeFilesetResponseMultiError []error
ComposeFilesetResponseMultiError is an error wrapping multiple validation errors returned by ComposeFilesetResponse.ValidateAll() if the designated constraints aren't met.
func (ComposeFilesetResponseMultiError) AllErrors ¶
func (m ComposeFilesetResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ComposeFilesetResponseMultiError) Error ¶
func (m ComposeFilesetResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ComposeFilesetResponseValidationError ¶
type ComposeFilesetResponseValidationError struct {
// contains filtered or unexported fields
}
ComposeFilesetResponseValidationError is the validation error returned by ComposeFilesetResponse.Validate if the designated constraints aren't met.
func (ComposeFilesetResponseValidationError) Cause ¶
func (e ComposeFilesetResponseValidationError) Cause() error
Cause function returns cause value.
func (ComposeFilesetResponseValidationError) Error ¶
func (e ComposeFilesetResponseValidationError) Error() string
Error satisfies the builtin error interface
func (ComposeFilesetResponseValidationError) ErrorName ¶
func (e ComposeFilesetResponseValidationError) ErrorName() string
ErrorName returns error name.
func (ComposeFilesetResponseValidationError) Field ¶
func (e ComposeFilesetResponseValidationError) Field() string
Field function returns field value.
func (ComposeFilesetResponseValidationError) Key ¶
func (e ComposeFilesetResponseValidationError) Key() bool
Key function returns key value.
func (ComposeFilesetResponseValidationError) Reason ¶
func (e ComposeFilesetResponseValidationError) Reason() string
Reason function returns reason value.
type CreateFilesetRequest ¶
type CreateFilesetRequest struct { // Types that are assignable to Modification: // // *CreateFilesetRequest_AppendFile // *CreateFilesetRequest_DeleteFile Modification isCreateFilesetRequest_Modification `protobuf_oneof:"modification"` // contains filtered or unexported fields }
A CreateFilesetRequest corresponds to a single file modification. Supported file modifications are append and delete. A put / overwrite file modification can be performed by a delete followed by an append.
TODO: Decide how to handle datums.
func (*CreateFilesetRequest) Descriptor
deprecated
func (*CreateFilesetRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateFilesetRequest.ProtoReflect.Descriptor instead.
func (*CreateFilesetRequest) GetAppendFile ¶
func (x *CreateFilesetRequest) GetAppendFile() *AppendFile
func (*CreateFilesetRequest) GetDeleteFile ¶
func (x *CreateFilesetRequest) GetDeleteFile() *DeleteFile
func (*CreateFilesetRequest) GetModification ¶
func (m *CreateFilesetRequest) GetModification() isCreateFilesetRequest_Modification
func (*CreateFilesetRequest) MarshalLogObject ¶
func (x *CreateFilesetRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*CreateFilesetRequest) ProtoMessage ¶
func (*CreateFilesetRequest) ProtoMessage()
func (*CreateFilesetRequest) ProtoReflect ¶
func (x *CreateFilesetRequest) ProtoReflect() protoreflect.Message
func (*CreateFilesetRequest) Reset ¶
func (x *CreateFilesetRequest) Reset()
func (*CreateFilesetRequest) String ¶
func (x *CreateFilesetRequest) String() string
func (*CreateFilesetRequest) Validate ¶
func (m *CreateFilesetRequest) Validate() error
Validate checks the field values on CreateFilesetRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*CreateFilesetRequest) ValidateAll ¶
func (m *CreateFilesetRequest) ValidateAll() error
ValidateAll checks the field values on CreateFilesetRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CreateFilesetRequestMultiError, or nil if none found.
type CreateFilesetRequestMultiError ¶
type CreateFilesetRequestMultiError []error
CreateFilesetRequestMultiError is an error wrapping multiple validation errors returned by CreateFilesetRequest.ValidateAll() if the designated constraints aren't met.
func (CreateFilesetRequestMultiError) AllErrors ¶
func (m CreateFilesetRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (CreateFilesetRequestMultiError) Error ¶
func (m CreateFilesetRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type CreateFilesetRequestValidationError ¶
type CreateFilesetRequestValidationError struct {
// contains filtered or unexported fields
}
CreateFilesetRequestValidationError is the validation error returned by CreateFilesetRequest.Validate if the designated constraints aren't met.
func (CreateFilesetRequestValidationError) Cause ¶
func (e CreateFilesetRequestValidationError) Cause() error
Cause function returns cause value.
func (CreateFilesetRequestValidationError) Error ¶
func (e CreateFilesetRequestValidationError) Error() string
Error satisfies the builtin error interface
func (CreateFilesetRequestValidationError) ErrorName ¶
func (e CreateFilesetRequestValidationError) ErrorName() string
ErrorName returns error name.
func (CreateFilesetRequestValidationError) Field ¶
func (e CreateFilesetRequestValidationError) Field() string
Field function returns field value.
func (CreateFilesetRequestValidationError) Key ¶
func (e CreateFilesetRequestValidationError) Key() bool
Key function returns key value.
func (CreateFilesetRequestValidationError) Reason ¶
func (e CreateFilesetRequestValidationError) Reason() string
Reason function returns reason value.
type CreateFilesetRequest_AppendFile ¶
type CreateFilesetRequest_AppendFile struct {
AppendFile *AppendFile `protobuf:"bytes,1,opt,name=append_file,json=appendFile,proto3,oneof"`
}
type CreateFilesetRequest_DeleteFile ¶
type CreateFilesetRequest_DeleteFile struct {
DeleteFile *DeleteFile `protobuf:"bytes,2,opt,name=delete_file,json=deleteFile,proto3,oneof"`
}
type CreateFilesetResponse ¶
type CreateFilesetResponse struct { FilesetId string `protobuf:"bytes,1,opt,name=fileset_id,json=filesetId,proto3" json:"fileset_id,omitempty"` // contains filtered or unexported fields }
func (*CreateFilesetResponse) Descriptor
deprecated
func (*CreateFilesetResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateFilesetResponse.ProtoReflect.Descriptor instead.
func (*CreateFilesetResponse) GetFilesetId ¶
func (x *CreateFilesetResponse) GetFilesetId() string
func (*CreateFilesetResponse) MarshalLogObject ¶
func (x *CreateFilesetResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*CreateFilesetResponse) ProtoMessage ¶
func (*CreateFilesetResponse) ProtoMessage()
func (*CreateFilesetResponse) ProtoReflect ¶
func (x *CreateFilesetResponse) ProtoReflect() protoreflect.Message
func (*CreateFilesetResponse) Reset ¶
func (x *CreateFilesetResponse) Reset()
func (*CreateFilesetResponse) String ¶
func (x *CreateFilesetResponse) String() string
func (*CreateFilesetResponse) Validate ¶
func (m *CreateFilesetResponse) Validate() error
Validate checks the field values on CreateFilesetResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*CreateFilesetResponse) ValidateAll ¶
func (m *CreateFilesetResponse) ValidateAll() error
ValidateAll checks the field values on CreateFilesetResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in CreateFilesetResponseMultiError, or nil if none found.
type CreateFilesetResponseMultiError ¶
type CreateFilesetResponseMultiError []error
CreateFilesetResponseMultiError is an error wrapping multiple validation errors returned by CreateFilesetResponse.ValidateAll() if the designated constraints aren't met.
func (CreateFilesetResponseMultiError) AllErrors ¶
func (m CreateFilesetResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (CreateFilesetResponseMultiError) Error ¶
func (m CreateFilesetResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type CreateFilesetResponseValidationError ¶
type CreateFilesetResponseValidationError struct {
// contains filtered or unexported fields
}
CreateFilesetResponseValidationError is the validation error returned by CreateFilesetResponse.Validate if the designated constraints aren't met.
func (CreateFilesetResponseValidationError) Cause ¶
func (e CreateFilesetResponseValidationError) Cause() error
Cause function returns cause value.
func (CreateFilesetResponseValidationError) Error ¶
func (e CreateFilesetResponseValidationError) Error() string
Error satisfies the builtin error interface
func (CreateFilesetResponseValidationError) ErrorName ¶
func (e CreateFilesetResponseValidationError) ErrorName() string
ErrorName returns error name.
func (CreateFilesetResponseValidationError) Field ¶
func (e CreateFilesetResponseValidationError) Field() string
Field function returns field value.
func (CreateFilesetResponseValidationError) Key ¶
func (e CreateFilesetResponseValidationError) Key() bool
Key function returns key value.
func (CreateFilesetResponseValidationError) Reason ¶
func (e CreateFilesetResponseValidationError) Reason() string
Reason function returns reason value.
type DeleteFile ¶
type DeleteFile struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
DeleteFile will delete the file with the specified path. If a file with the specified path doesn't exist, the delete will be a no-op.
func (*DeleteFile) Descriptor
deprecated
func (*DeleteFile) Descriptor() ([]byte, []int)
Deprecated: Use DeleteFile.ProtoReflect.Descriptor instead.
func (*DeleteFile) GetPath ¶
func (x *DeleteFile) GetPath() string
func (*DeleteFile) MarshalLogObject ¶
func (x *DeleteFile) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*DeleteFile) ProtoMessage ¶
func (*DeleteFile) ProtoMessage()
func (*DeleteFile) ProtoReflect ¶
func (x *DeleteFile) ProtoReflect() protoreflect.Message
func (*DeleteFile) Reset ¶
func (x *DeleteFile) Reset()
func (*DeleteFile) String ¶
func (x *DeleteFile) String() string
func (*DeleteFile) Validate ¶
func (m *DeleteFile) Validate() error
Validate checks the field values on DeleteFile with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*DeleteFile) ValidateAll ¶
func (m *DeleteFile) ValidateAll() error
ValidateAll checks the field values on DeleteFile with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in DeleteFileMultiError, or nil if none found.
type DeleteFileMultiError ¶
type DeleteFileMultiError []error
DeleteFileMultiError is an error wrapping multiple validation errors returned by DeleteFile.ValidateAll() if the designated constraints aren't met.
func (DeleteFileMultiError) AllErrors ¶
func (m DeleteFileMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (DeleteFileMultiError) Error ¶
func (m DeleteFileMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type DeleteFileValidationError ¶
type DeleteFileValidationError struct {
// contains filtered or unexported fields
}
DeleteFileValidationError is the validation error returned by DeleteFile.Validate if the designated constraints aren't met.
func (DeleteFileValidationError) Cause ¶
func (e DeleteFileValidationError) Cause() error
Cause function returns cause value.
func (DeleteFileValidationError) Error ¶
func (e DeleteFileValidationError) Error() string
Error satisfies the builtin error interface
func (DeleteFileValidationError) ErrorName ¶
func (e DeleteFileValidationError) ErrorName() string
ErrorName returns error name.
func (DeleteFileValidationError) Field ¶
func (e DeleteFileValidationError) Field() string
Field function returns field value.
func (DeleteFileValidationError) Key ¶
func (e DeleteFileValidationError) Key() bool
Key function returns key value.
func (DeleteFileValidationError) Reason ¶
func (e DeleteFileValidationError) Reason() string
Reason function returns reason value.
type FileFilter ¶
type FileFilter struct { // Types that are assignable to Filter: // // *FileFilter_PathRange // *FileFilter_PathRegex Filter isFileFilter_Filter `protobuf_oneof:"filter"` // contains filtered or unexported fields }
func (*FileFilter) Descriptor
deprecated
func (*FileFilter) Descriptor() ([]byte, []int)
Deprecated: Use FileFilter.ProtoReflect.Descriptor instead.
func (*FileFilter) GetFilter ¶
func (m *FileFilter) GetFilter() isFileFilter_Filter
func (*FileFilter) GetPathRange ¶
func (x *FileFilter) GetPathRange() *PathRange
func (*FileFilter) GetPathRegex ¶
func (x *FileFilter) GetPathRegex() string
func (*FileFilter) MarshalLogObject ¶
func (x *FileFilter) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*FileFilter) ProtoMessage ¶
func (*FileFilter) ProtoMessage()
func (*FileFilter) ProtoReflect ¶
func (x *FileFilter) ProtoReflect() protoreflect.Message
func (*FileFilter) Reset ¶
func (x *FileFilter) Reset()
func (*FileFilter) String ¶
func (x *FileFilter) String() string
func (*FileFilter) Validate ¶
func (m *FileFilter) Validate() error
Validate checks the field values on FileFilter with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*FileFilter) ValidateAll ¶
func (m *FileFilter) ValidateAll() error
ValidateAll checks the field values on FileFilter with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in FileFilterMultiError, or nil if none found.
type FileFilterMultiError ¶
type FileFilterMultiError []error
FileFilterMultiError is an error wrapping multiple validation errors returned by FileFilter.ValidateAll() if the designated constraints aren't met.
func (FileFilterMultiError) AllErrors ¶
func (m FileFilterMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (FileFilterMultiError) Error ¶
func (m FileFilterMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type FileFilterValidationError ¶
type FileFilterValidationError struct {
// contains filtered or unexported fields
}
FileFilterValidationError is the validation error returned by FileFilter.Validate if the designated constraints aren't met.
func (FileFilterValidationError) Cause ¶
func (e FileFilterValidationError) Cause() error
Cause function returns cause value.
func (FileFilterValidationError) Error ¶
func (e FileFilterValidationError) Error() string
Error satisfies the builtin error interface
func (FileFilterValidationError) ErrorName ¶
func (e FileFilterValidationError) ErrorName() string
ErrorName returns error name.
func (FileFilterValidationError) Field ¶
func (e FileFilterValidationError) Field() string
Field function returns field value.
func (FileFilterValidationError) Key ¶
func (e FileFilterValidationError) Key() bool
Key function returns key value.
func (FileFilterValidationError) Reason ¶
func (e FileFilterValidationError) Reason() string
Reason function returns reason value.
type FileFilter_PathRange ¶
type FileFilter_PathRange struct { // Only emit files with paths in the provided path range. PathRange *PathRange `protobuf:"bytes,1,opt,name=path_range,json=pathRange,proto3,oneof"` }
type FileFilter_PathRegex ¶
type FileFilter_PathRegex struct { // Only emit files with paths that match the provided regular expression. PathRegex string `protobuf:"bytes,2,opt,name=path_regex,json=pathRegex,proto3,oneof"` }
type FilesetClient ¶
type FilesetClient interface { // CreateFileset creates a fileset based on a stream of file modifications. // A string identifier for the created fileset will be returned that can be used for subsequent fileset operations. // Filesets have a fixed time-to-live (ttl), which is currently 10 minutes. // Filesets needed longer than the ttl will need to be renewed. CreateFileset(ctx context.Context, opts ...grpc.CallOption) (Fileset_CreateFilesetClient, error) // ReadFileset reads a fileset. ReadFileset(ctx context.Context, in *ReadFilesetRequest, opts ...grpc.CallOption) (Fileset_ReadFilesetClient, error) // RenewFileset renews a fileset. RenewFileset(ctx context.Context, in *RenewFilesetRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // ComposeFileset composes a fileset. // Composing a fileset involves combining one or more filesets into a single fileset. // TODO: Explain how the filesets are layered and what that means for the order of file modifications. ComposeFileset(ctx context.Context, in *ComposeFilesetRequest, opts ...grpc.CallOption) (*ComposeFilesetResponse, error) // ShardFileset shards a fileset. // The shards of a fileset are returned as a list of path ranges that are disjoint // and account for the full set of paths in the fileset. ShardFileset(ctx context.Context, in *ShardFilesetRequest, opts ...grpc.CallOption) (*ShardFilesetResponse, error) }
FilesetClient is the client API for Fileset 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 NewFilesetClient ¶
func NewFilesetClient(cc grpc.ClientConnInterface) FilesetClient
type FilesetServer ¶
type FilesetServer interface { // CreateFileset creates a fileset based on a stream of file modifications. // A string identifier for the created fileset will be returned that can be used for subsequent fileset operations. // Filesets have a fixed time-to-live (ttl), which is currently 10 minutes. // Filesets needed longer than the ttl will need to be renewed. CreateFileset(Fileset_CreateFilesetServer) error // ReadFileset reads a fileset. ReadFileset(*ReadFilesetRequest, Fileset_ReadFilesetServer) error // RenewFileset renews a fileset. RenewFileset(context.Context, *RenewFilesetRequest) (*emptypb.Empty, error) // ComposeFileset composes a fileset. // Composing a fileset involves combining one or more filesets into a single fileset. // TODO: Explain how the filesets are layered and what that means for the order of file modifications. ComposeFileset(context.Context, *ComposeFilesetRequest) (*ComposeFilesetResponse, error) // ShardFileset shards a fileset. // The shards of a fileset are returned as a list of path ranges that are disjoint // and account for the full set of paths in the fileset. ShardFileset(context.Context, *ShardFilesetRequest) (*ShardFilesetResponse, error) // contains filtered or unexported methods }
FilesetServer is the server API for Fileset service. All implementations must embed UnimplementedFilesetServer for forward compatibility
type Fileset_CreateFilesetClient ¶
type Fileset_CreateFilesetClient interface { Send(*CreateFilesetRequest) error CloseAndRecv() (*CreateFilesetResponse, error) grpc.ClientStream }
type Fileset_CreateFilesetServer ¶
type Fileset_CreateFilesetServer interface { SendAndClose(*CreateFilesetResponse) error Recv() (*CreateFilesetRequest, error) grpc.ServerStream }
type Fileset_ReadFilesetClient ¶
type Fileset_ReadFilesetClient interface { Recv() (*ReadFilesetResponse, error) grpc.ClientStream }
type Fileset_ReadFilesetServer ¶
type Fileset_ReadFilesetServer interface { Send(*ReadFilesetResponse) error grpc.ServerStream }
type PathRange ¶
type PathRange struct { Lower string `protobuf:"bytes,1,opt,name=lower,proto3" json:"lower,omitempty"` Upper string `protobuf:"bytes,2,opt,name=upper,proto3" json:"upper,omitempty"` // contains filtered or unexported fields }
PathRange is a range of paths. The range is inclusive, exclusive: [Lower, Upper).
func (*PathRange) Descriptor
deprecated
func (*PathRange) MarshalLogObject ¶
func (x *PathRange) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*PathRange) ProtoMessage ¶
func (*PathRange) ProtoMessage()
func (*PathRange) ProtoReflect ¶
func (x *PathRange) ProtoReflect() protoreflect.Message
func (*PathRange) Validate ¶
Validate checks the field values on PathRange with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*PathRange) ValidateAll ¶
ValidateAll checks the field values on PathRange with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in PathRangeMultiError, or nil if none found.
type PathRangeMultiError ¶
type PathRangeMultiError []error
PathRangeMultiError is an error wrapping multiple validation errors returned by PathRange.ValidateAll() if the designated constraints aren't met.
func (PathRangeMultiError) AllErrors ¶
func (m PathRangeMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (PathRangeMultiError) Error ¶
func (m PathRangeMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type PathRangeValidationError ¶
type PathRangeValidationError struct {
// contains filtered or unexported fields
}
PathRangeValidationError is the validation error returned by PathRange.Validate if the designated constraints aren't met.
func (PathRangeValidationError) Cause ¶
func (e PathRangeValidationError) Cause() error
Cause function returns cause value.
func (PathRangeValidationError) Error ¶
func (e PathRangeValidationError) Error() string
Error satisfies the builtin error interface
func (PathRangeValidationError) ErrorName ¶
func (e PathRangeValidationError) ErrorName() string
ErrorName returns error name.
func (PathRangeValidationError) Field ¶
func (e PathRangeValidationError) Field() string
Field function returns field value.
func (PathRangeValidationError) Key ¶
func (e PathRangeValidationError) Key() bool
Key function returns key value.
func (PathRangeValidationError) Reason ¶
func (e PathRangeValidationError) Reason() string
Reason function returns reason value.
type ReadFilesetRequest ¶
type ReadFilesetRequest struct { FilesetId string `protobuf:"bytes,1,opt,name=fileset_id,json=filesetId,proto3" json:"fileset_id,omitempty"` // Filters constrain which files are emitted. // A file is only emitted if it makes it through all of the filters sequentially. Filters []*FileFilter `protobuf:"bytes,2,rep,name=filters,proto3" json:"filters,omitempty"` // If true, then the file data will be omitted from the stream. EmptyFiles bool `protobuf:"varint,3,opt,name=empty_files,json=emptyFiles,proto3" json:"empty_files,omitempty"` // contains filtered or unexported fields }
func (*ReadFilesetRequest) Descriptor
deprecated
func (*ReadFilesetRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadFilesetRequest.ProtoReflect.Descriptor instead.
func (*ReadFilesetRequest) GetEmptyFiles ¶
func (x *ReadFilesetRequest) GetEmptyFiles() bool
func (*ReadFilesetRequest) GetFilesetId ¶
func (x *ReadFilesetRequest) GetFilesetId() string
func (*ReadFilesetRequest) GetFilters ¶
func (x *ReadFilesetRequest) GetFilters() []*FileFilter
func (*ReadFilesetRequest) MarshalLogObject ¶
func (x *ReadFilesetRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*ReadFilesetRequest) ProtoMessage ¶
func (*ReadFilesetRequest) ProtoMessage()
func (*ReadFilesetRequest) ProtoReflect ¶
func (x *ReadFilesetRequest) ProtoReflect() protoreflect.Message
func (*ReadFilesetRequest) Reset ¶
func (x *ReadFilesetRequest) Reset()
func (*ReadFilesetRequest) String ¶
func (x *ReadFilesetRequest) String() string
func (*ReadFilesetRequest) Validate ¶
func (m *ReadFilesetRequest) Validate() error
Validate checks the field values on ReadFilesetRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ReadFilesetRequest) ValidateAll ¶
func (m *ReadFilesetRequest) ValidateAll() error
ValidateAll checks the field values on ReadFilesetRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ReadFilesetRequestMultiError, or nil if none found.
type ReadFilesetRequestMultiError ¶
type ReadFilesetRequestMultiError []error
ReadFilesetRequestMultiError is an error wrapping multiple validation errors returned by ReadFilesetRequest.ValidateAll() if the designated constraints aren't met.
func (ReadFilesetRequestMultiError) AllErrors ¶
func (m ReadFilesetRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ReadFilesetRequestMultiError) Error ¶
func (m ReadFilesetRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ReadFilesetRequestValidationError ¶
type ReadFilesetRequestValidationError struct {
// contains filtered or unexported fields
}
ReadFilesetRequestValidationError is the validation error returned by ReadFilesetRequest.Validate if the designated constraints aren't met.
func (ReadFilesetRequestValidationError) Cause ¶
func (e ReadFilesetRequestValidationError) Cause() error
Cause function returns cause value.
func (ReadFilesetRequestValidationError) Error ¶
func (e ReadFilesetRequestValidationError) Error() string
Error satisfies the builtin error interface
func (ReadFilesetRequestValidationError) ErrorName ¶
func (e ReadFilesetRequestValidationError) ErrorName() string
ErrorName returns error name.
func (ReadFilesetRequestValidationError) Field ¶
func (e ReadFilesetRequestValidationError) Field() string
Field function returns field value.
func (ReadFilesetRequestValidationError) Key ¶
func (e ReadFilesetRequestValidationError) Key() bool
Key function returns key value.
func (ReadFilesetRequestValidationError) Reason ¶
func (e ReadFilesetRequestValidationError) Reason() string
Reason function returns reason value.
type ReadFilesetResponse ¶
type ReadFilesetResponse struct { Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` Data *wrapperspb.BytesValue `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` // contains filtered or unexported fields }
A ReadFilesetResponse corresponds to a single chunk of data in a file. Small or empty files will be contained within a single message, while large files may be spread across multiple messages. For files spread across multiple messages, each message will have the same path and the content will be returned in append order.
func (*ReadFilesetResponse) Descriptor
deprecated
func (*ReadFilesetResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadFilesetResponse.ProtoReflect.Descriptor instead.
func (*ReadFilesetResponse) GetData ¶
func (x *ReadFilesetResponse) GetData() *wrapperspb.BytesValue
func (*ReadFilesetResponse) GetPath ¶
func (x *ReadFilesetResponse) GetPath() string
func (*ReadFilesetResponse) MarshalLogObject ¶
func (x *ReadFilesetResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*ReadFilesetResponse) ProtoMessage ¶
func (*ReadFilesetResponse) ProtoMessage()
func (*ReadFilesetResponse) ProtoReflect ¶
func (x *ReadFilesetResponse) ProtoReflect() protoreflect.Message
func (*ReadFilesetResponse) Reset ¶
func (x *ReadFilesetResponse) Reset()
func (*ReadFilesetResponse) String ¶
func (x *ReadFilesetResponse) String() string
func (*ReadFilesetResponse) Validate ¶
func (m *ReadFilesetResponse) Validate() error
Validate checks the field values on ReadFilesetResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ReadFilesetResponse) ValidateAll ¶
func (m *ReadFilesetResponse) ValidateAll() error
ValidateAll checks the field values on ReadFilesetResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ReadFilesetResponseMultiError, or nil if none found.
type ReadFilesetResponseMultiError ¶
type ReadFilesetResponseMultiError []error
ReadFilesetResponseMultiError is an error wrapping multiple validation errors returned by ReadFilesetResponse.ValidateAll() if the designated constraints aren't met.
func (ReadFilesetResponseMultiError) AllErrors ¶
func (m ReadFilesetResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ReadFilesetResponseMultiError) Error ¶
func (m ReadFilesetResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ReadFilesetResponseValidationError ¶
type ReadFilesetResponseValidationError struct {
// contains filtered or unexported fields
}
ReadFilesetResponseValidationError is the validation error returned by ReadFilesetResponse.Validate if the designated constraints aren't met.
func (ReadFilesetResponseValidationError) Cause ¶
func (e ReadFilesetResponseValidationError) Cause() error
Cause function returns cause value.
func (ReadFilesetResponseValidationError) Error ¶
func (e ReadFilesetResponseValidationError) Error() string
Error satisfies the builtin error interface
func (ReadFilesetResponseValidationError) ErrorName ¶
func (e ReadFilesetResponseValidationError) ErrorName() string
ErrorName returns error name.
func (ReadFilesetResponseValidationError) Field ¶
func (e ReadFilesetResponseValidationError) Field() string
Field function returns field value.
func (ReadFilesetResponseValidationError) Key ¶
func (e ReadFilesetResponseValidationError) Key() bool
Key function returns key value.
func (ReadFilesetResponseValidationError) Reason ¶
func (e ReadFilesetResponseValidationError) Reason() string
Reason function returns reason value.
type RenewFilesetRequest ¶
type RenewFilesetRequest struct { FilesetId string `protobuf:"bytes,1,opt,name=fileset_id,json=filesetId,proto3" json:"fileset_id,omitempty"` // The TTL, in seconds, for the fileset after renewal. TtlSeconds int64 `protobuf:"varint,2,opt,name=ttl_seconds,json=ttlSeconds,proto3" json:"ttl_seconds,omitempty"` // contains filtered or unexported fields }
func (*RenewFilesetRequest) Descriptor
deprecated
func (*RenewFilesetRequest) Descriptor() ([]byte, []int)
Deprecated: Use RenewFilesetRequest.ProtoReflect.Descriptor instead.
func (*RenewFilesetRequest) GetFilesetId ¶
func (x *RenewFilesetRequest) GetFilesetId() string
func (*RenewFilesetRequest) GetTtlSeconds ¶
func (x *RenewFilesetRequest) GetTtlSeconds() int64
func (*RenewFilesetRequest) MarshalLogObject ¶
func (x *RenewFilesetRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*RenewFilesetRequest) ProtoMessage ¶
func (*RenewFilesetRequest) ProtoMessage()
func (*RenewFilesetRequest) ProtoReflect ¶
func (x *RenewFilesetRequest) ProtoReflect() protoreflect.Message
func (*RenewFilesetRequest) Reset ¶
func (x *RenewFilesetRequest) Reset()
func (*RenewFilesetRequest) String ¶
func (x *RenewFilesetRequest) String() string
func (*RenewFilesetRequest) Validate ¶
func (m *RenewFilesetRequest) Validate() error
Validate checks the field values on RenewFilesetRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*RenewFilesetRequest) ValidateAll ¶
func (m *RenewFilesetRequest) ValidateAll() error
ValidateAll checks the field values on RenewFilesetRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in RenewFilesetRequestMultiError, or nil if none found.
type RenewFilesetRequestMultiError ¶
type RenewFilesetRequestMultiError []error
RenewFilesetRequestMultiError is an error wrapping multiple validation errors returned by RenewFilesetRequest.ValidateAll() if the designated constraints aren't met.
func (RenewFilesetRequestMultiError) AllErrors ¶
func (m RenewFilesetRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (RenewFilesetRequestMultiError) Error ¶
func (m RenewFilesetRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type RenewFilesetRequestValidationError ¶
type RenewFilesetRequestValidationError struct {
// contains filtered or unexported fields
}
RenewFilesetRequestValidationError is the validation error returned by RenewFilesetRequest.Validate if the designated constraints aren't met.
func (RenewFilesetRequestValidationError) Cause ¶
func (e RenewFilesetRequestValidationError) Cause() error
Cause function returns cause value.
func (RenewFilesetRequestValidationError) Error ¶
func (e RenewFilesetRequestValidationError) Error() string
Error satisfies the builtin error interface
func (RenewFilesetRequestValidationError) ErrorName ¶
func (e RenewFilesetRequestValidationError) ErrorName() string
ErrorName returns error name.
func (RenewFilesetRequestValidationError) Field ¶
func (e RenewFilesetRequestValidationError) Field() string
Field function returns field value.
func (RenewFilesetRequestValidationError) Key ¶
func (e RenewFilesetRequestValidationError) Key() bool
Key function returns key value.
func (RenewFilesetRequestValidationError) Reason ¶
func (e RenewFilesetRequestValidationError) Reason() string
Reason function returns reason value.
type ShardFilesetRequest ¶
type ShardFilesetRequest struct { FilesetId string `protobuf:"bytes,1,opt,name=fileset_id,json=filesetId,proto3" json:"fileset_id,omitempty"` // Number of files targeted in each shard. NumFiles int64 `protobuf:"varint,2,opt,name=num_files,json=numFiles,proto3" json:"num_files,omitempty"` // Size (in bytes) targeted for each shard. SizeBytes int64 `protobuf:"varint,3,opt,name=size_bytes,json=sizeBytes,proto3" json:"size_bytes,omitempty"` // contains filtered or unexported fields }
If both num_files and size_bytes are set, shards are created based on whichever threshold is surpassed first. If a shard configuration field (num_files, size_bytes) is unset, the storage's default value is used.
func (*ShardFilesetRequest) Descriptor
deprecated
func (*ShardFilesetRequest) Descriptor() ([]byte, []int)
Deprecated: Use ShardFilesetRequest.ProtoReflect.Descriptor instead.
func (*ShardFilesetRequest) GetFilesetId ¶
func (x *ShardFilesetRequest) GetFilesetId() string
func (*ShardFilesetRequest) GetNumFiles ¶
func (x *ShardFilesetRequest) GetNumFiles() int64
func (*ShardFilesetRequest) GetSizeBytes ¶
func (x *ShardFilesetRequest) GetSizeBytes() int64
func (*ShardFilesetRequest) MarshalLogObject ¶
func (x *ShardFilesetRequest) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*ShardFilesetRequest) ProtoMessage ¶
func (*ShardFilesetRequest) ProtoMessage()
func (*ShardFilesetRequest) ProtoReflect ¶
func (x *ShardFilesetRequest) ProtoReflect() protoreflect.Message
func (*ShardFilesetRequest) Reset ¶
func (x *ShardFilesetRequest) Reset()
func (*ShardFilesetRequest) String ¶
func (x *ShardFilesetRequest) String() string
func (*ShardFilesetRequest) Validate ¶
func (m *ShardFilesetRequest) Validate() error
Validate checks the field values on ShardFilesetRequest with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ShardFilesetRequest) ValidateAll ¶
func (m *ShardFilesetRequest) ValidateAll() error
ValidateAll checks the field values on ShardFilesetRequest with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ShardFilesetRequestMultiError, or nil if none found.
type ShardFilesetRequestMultiError ¶
type ShardFilesetRequestMultiError []error
ShardFilesetRequestMultiError is an error wrapping multiple validation errors returned by ShardFilesetRequest.ValidateAll() if the designated constraints aren't met.
func (ShardFilesetRequestMultiError) AllErrors ¶
func (m ShardFilesetRequestMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ShardFilesetRequestMultiError) Error ¶
func (m ShardFilesetRequestMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ShardFilesetRequestValidationError ¶
type ShardFilesetRequestValidationError struct {
// contains filtered or unexported fields
}
ShardFilesetRequestValidationError is the validation error returned by ShardFilesetRequest.Validate if the designated constraints aren't met.
func (ShardFilesetRequestValidationError) Cause ¶
func (e ShardFilesetRequestValidationError) Cause() error
Cause function returns cause value.
func (ShardFilesetRequestValidationError) Error ¶
func (e ShardFilesetRequestValidationError) Error() string
Error satisfies the builtin error interface
func (ShardFilesetRequestValidationError) ErrorName ¶
func (e ShardFilesetRequestValidationError) ErrorName() string
ErrorName returns error name.
func (ShardFilesetRequestValidationError) Field ¶
func (e ShardFilesetRequestValidationError) Field() string
Field function returns field value.
func (ShardFilesetRequestValidationError) Key ¶
func (e ShardFilesetRequestValidationError) Key() bool
Key function returns key value.
func (ShardFilesetRequestValidationError) Reason ¶
func (e ShardFilesetRequestValidationError) Reason() string
Reason function returns reason value.
type ShardFilesetResponse ¶
type ShardFilesetResponse struct { Shards []*PathRange `protobuf:"bytes,1,rep,name=shards,proto3" json:"shards,omitempty"` // contains filtered or unexported fields }
func (*ShardFilesetResponse) Descriptor
deprecated
func (*ShardFilesetResponse) Descriptor() ([]byte, []int)
Deprecated: Use ShardFilesetResponse.ProtoReflect.Descriptor instead.
func (*ShardFilesetResponse) GetShards ¶
func (x *ShardFilesetResponse) GetShards() []*PathRange
func (*ShardFilesetResponse) MarshalLogObject ¶
func (x *ShardFilesetResponse) MarshalLogObject(enc zapcore.ObjectEncoder) error
func (*ShardFilesetResponse) ProtoMessage ¶
func (*ShardFilesetResponse) ProtoMessage()
func (*ShardFilesetResponse) ProtoReflect ¶
func (x *ShardFilesetResponse) ProtoReflect() protoreflect.Message
func (*ShardFilesetResponse) Reset ¶
func (x *ShardFilesetResponse) Reset()
func (*ShardFilesetResponse) String ¶
func (x *ShardFilesetResponse) String() string
func (*ShardFilesetResponse) Validate ¶
func (m *ShardFilesetResponse) Validate() error
Validate checks the field values on ShardFilesetResponse with the rules defined in the proto definition for this message. If any rules are violated, the first error encountered is returned, or nil if there are no violations.
func (*ShardFilesetResponse) ValidateAll ¶
func (m *ShardFilesetResponse) ValidateAll() error
ValidateAll checks the field values on ShardFilesetResponse with the rules defined in the proto definition for this message. If any rules are violated, the result is a list of violation errors wrapped in ShardFilesetResponseMultiError, or nil if none found.
type ShardFilesetResponseMultiError ¶
type ShardFilesetResponseMultiError []error
ShardFilesetResponseMultiError is an error wrapping multiple validation errors returned by ShardFilesetResponse.ValidateAll() if the designated constraints aren't met.
func (ShardFilesetResponseMultiError) AllErrors ¶
func (m ShardFilesetResponseMultiError) AllErrors() []error
AllErrors returns a list of validation violation errors.
func (ShardFilesetResponseMultiError) Error ¶
func (m ShardFilesetResponseMultiError) Error() string
Error returns a concatenation of all the error messages it wraps.
type ShardFilesetResponseValidationError ¶
type ShardFilesetResponseValidationError struct {
// contains filtered or unexported fields
}
ShardFilesetResponseValidationError is the validation error returned by ShardFilesetResponse.Validate if the designated constraints aren't met.
func (ShardFilesetResponseValidationError) Cause ¶
func (e ShardFilesetResponseValidationError) Cause() error
Cause function returns cause value.
func (ShardFilesetResponseValidationError) Error ¶
func (e ShardFilesetResponseValidationError) Error() string
Error satisfies the builtin error interface
func (ShardFilesetResponseValidationError) ErrorName ¶
func (e ShardFilesetResponseValidationError) ErrorName() string
ErrorName returns error name.
func (ShardFilesetResponseValidationError) Field ¶
func (e ShardFilesetResponseValidationError) Field() string
Field function returns field value.
func (ShardFilesetResponseValidationError) Key ¶
func (e ShardFilesetResponseValidationError) Key() bool
Key function returns key value.
func (ShardFilesetResponseValidationError) Reason ¶
func (e ShardFilesetResponseValidationError) Reason() string
Reason function returns reason value.
type UnimplementedFilesetServer ¶
type UnimplementedFilesetServer struct { }
UnimplementedFilesetServer must be embedded to have forward compatible implementations.
func (UnimplementedFilesetServer) ComposeFileset ¶
func (UnimplementedFilesetServer) ComposeFileset(context.Context, *ComposeFilesetRequest) (*ComposeFilesetResponse, error)
func (UnimplementedFilesetServer) CreateFileset ¶
func (UnimplementedFilesetServer) CreateFileset(Fileset_CreateFilesetServer) error
func (UnimplementedFilesetServer) ReadFileset ¶
func (UnimplementedFilesetServer) ReadFileset(*ReadFilesetRequest, Fileset_ReadFilesetServer) error
func (UnimplementedFilesetServer) RenewFileset ¶
func (UnimplementedFilesetServer) RenewFileset(context.Context, *RenewFilesetRequest) (*emptypb.Empty, error)
func (UnimplementedFilesetServer) ShardFileset ¶
func (UnimplementedFilesetServer) ShardFileset(context.Context, *ShardFilesetRequest) (*ShardFilesetResponse, error)
type UnsafeFilesetServer ¶
type UnsafeFilesetServer interface {
// contains filtered or unexported methods
}
UnsafeFilesetServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FilesetServer will result in compilation errors.