Documentation ¶
Overview ¶
Package protos is a generated twirp stub package. This code was generated with github.com/twitchtv/twirp/protoc-gen-twirp v5.10.1.
It is generated from these files:
internal/protos/api.proto
Index ¶
- Constants
- Variables
- func WriteError(resp http.ResponseWriter, err error)
- type ChunkerParams
- func (*ChunkerParams) Descriptor() ([]byte, []int)deprecated
- func (x *ChunkerParams) GetAvgChunkSize() uint64
- func (x *ChunkerParams) GetMaxChunkSize() uint64
- func (x *ChunkerParams) GetMinChunkSize() uint64
- func (x *ChunkerParams) GetNormalization() uint64
- func (*ChunkerParams) ProtoMessage()
- func (x *ChunkerParams) ProtoReflect() protoreflect.Message
- func (x *ChunkerParams) Reset()
- func (x *ChunkerParams) String() string
- type ChunksExistRequest
- func (*ChunksExistRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ChunksExistRequest) GetSums() [][]byte
- func (*ChunksExistRequest) ProtoMessage()
- func (x *ChunksExistRequest) ProtoReflect() protoreflect.Message
- func (x *ChunksExistRequest) Reset()
- func (x *ChunksExistRequest) String() string
- type ChunksExistResponse
- func (*ChunksExistResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ChunksExistResponse) GetExists() []bool
- func (*ChunksExistResponse) ProtoMessage()
- func (x *ChunksExistResponse) ProtoReflect() protoreflect.Message
- func (x *ChunksExistResponse) Reset()
- func (x *ChunksExistResponse) String() string
- type CopyRequest
- type DownloadResponse
- type Empty
- type File
- type FileID
- type FileInfo
- func (*FileInfo) Descriptor() ([]byte, []int)deprecated
- func (x *FileInfo) GetCreatedAt() int64
- func (x *FileInfo) GetName() string
- func (x *FileInfo) GetSize() uint64
- func (x *FileInfo) GetSum() []byte
- func (*FileInfo) ProtoMessage()
- func (x *FileInfo) ProtoReflect() protoreflect.Message
- func (x *FileInfo) Reset()
- func (x *FileInfo) String() string
- type Filename
- type Files
- type HTTPClient
- type HeadRequest
- func (*HeadRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HeadRequest) GetAscending() bool
- func (x *HeadRequest) GetLimit() uint64
- func (x *HeadRequest) GetName() string
- func (x *HeadRequest) GetNextPageToken() int64
- func (*HeadRequest) ProtoMessage()
- func (x *HeadRequest) ProtoReflect() protoreflect.Message
- func (x *HeadRequest) Reset()
- func (x *HeadRequest) String() string
- type HeadResponse
- func (*HeadResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HeadResponse) GetInfo() []*FileInfo
- func (x *HeadResponse) GetNextPageToken() int64
- func (*HeadResponse) ProtoMessage()
- func (x *HeadResponse) ProtoReflect() protoreflect.Message
- func (x *HeadResponse) Reset()
- func (x *HeadResponse) String() string
- type JotFS
- type ListRequest
- func (*ListRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListRequest) GetAscending() bool
- func (x *ListRequest) GetExclude() string
- func (x *ListRequest) GetInclude() string
- func (x *ListRequest) GetLimit() uint64
- func (x *ListRequest) GetNextPageToken() int64
- func (x *ListRequest) GetPrefix() string
- func (*ListRequest) ProtoMessage()
- func (x *ListRequest) ProtoReflect() protoreflect.Message
- func (x *ListRequest) Reset()
- func (x *ListRequest) String() string
- type ListResponse
- func (*ListResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListResponse) GetInfo() []*FileInfo
- func (x *ListResponse) GetNextPageToken() int64
- func (*ListResponse) ProtoMessage()
- func (x *ListResponse) ProtoReflect() protoreflect.Message
- func (x *ListResponse) Reset()
- func (x *ListResponse) String() string
- type Prefix
- type RenameRequest
- func (*RenameRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RenameRequest) GetDst() string
- func (x *RenameRequest) GetSrcId() []byte
- func (*RenameRequest) ProtoMessage()
- func (x *RenameRequest) ProtoReflect() protoreflect.Message
- func (x *RenameRequest) Reset()
- func (x *RenameRequest) String() string
- type Section
- func (*Section) Descriptor() ([]byte, []int)deprecated
- func (x *Section) GetChunks() []*SectionChunk
- func (x *Section) GetRangeEnd() uint64
- func (x *Section) GetRangeStart() uint64
- func (x *Section) GetUrl() string
- func (*Section) ProtoMessage()
- func (x *Section) ProtoReflect() protoreflect.Message
- func (x *Section) Reset()
- func (x *Section) String() string
- type SectionChunk
- func (*SectionChunk) Descriptor() ([]byte, []int)deprecated
- func (x *SectionChunk) GetBlockOffset() uint64
- func (x *SectionChunk) GetSequence() uint64
- func (x *SectionChunk) GetSize() uint64
- func (x *SectionChunk) GetSum() []byte
- func (*SectionChunk) ProtoMessage()
- func (x *SectionChunk) ProtoReflect() protoreflect.Message
- func (x *SectionChunk) Reset()
- func (x *SectionChunk) String() string
- type Stats
- func (*Stats) Descriptor() ([]byte, []int)deprecated
- func (x *Stats) GetNumFileVersions() uint64
- func (x *Stats) GetNumFiles() uint64
- func (x *Stats) GetTotalDataSize() uint64
- func (x *Stats) GetTotalFilesSize() uint64
- func (*Stats) ProtoMessage()
- func (x *Stats) ProtoReflect() protoreflect.Message
- func (x *Stats) Reset()
- func (x *Stats) String() string
- type TwirpServer
- type Vacuum
- func (*Vacuum) Descriptor() ([]byte, []int)deprecated
- func (x *Vacuum) GetCompletedAt() int64
- func (x *Vacuum) GetStartedAt() int64
- func (x *Vacuum) GetStatus() string
- func (*Vacuum) ProtoMessage()
- func (x *Vacuum) ProtoReflect() protoreflect.Message
- func (x *Vacuum) Reset()
- func (x *Vacuum) String() string
- type VacuumID
Constants ¶
const JotFSPathPrefix = "/twirp/server.JotFS/"
JotFSPathPrefix is used for all URL paths on a twirp JotFS server. Requests are always: POST JotFSPathPrefix/method It can be used in an HTTP mux to route twirp requests along with non-twirp requests on other routes.
Variables ¶
var File_internal_protos_api_proto protoreflect.FileDescriptor
Functions ¶
func WriteError ¶
func WriteError(resp http.ResponseWriter, err error)
WriteError writes an HTTP response with a valid Twirp error format (code, msg, meta). Useful outside of the Twirp server (e.g. http middleware), but does not trigger hooks. If err is not a twirp.Error, it will get wrapped with twirp.InternalErrorWith(err)
Types ¶
type ChunkerParams ¶
type ChunkerParams struct { MinChunkSize uint64 `protobuf:"varint,1,opt,name=min_chunk_size,json=minChunkSize,proto3" json:"min_chunk_size,omitempty"` AvgChunkSize uint64 `protobuf:"varint,2,opt,name=avg_chunk_size,json=avgChunkSize,proto3" json:"avg_chunk_size,omitempty"` MaxChunkSize uint64 `protobuf:"varint,3,opt,name=max_chunk_size,json=maxChunkSize,proto3" json:"max_chunk_size,omitempty"` Normalization uint64 `protobuf:"varint,4,opt,name=normalization,proto3" json:"normalization,omitempty"` // contains filtered or unexported fields }
func (*ChunkerParams) Descriptor
deprecated
func (*ChunkerParams) Descriptor() ([]byte, []int)
Deprecated: Use ChunkerParams.ProtoReflect.Descriptor instead.
func (*ChunkerParams) GetAvgChunkSize ¶
func (x *ChunkerParams) GetAvgChunkSize() uint64
func (*ChunkerParams) GetMaxChunkSize ¶
func (x *ChunkerParams) GetMaxChunkSize() uint64
func (*ChunkerParams) GetMinChunkSize ¶
func (x *ChunkerParams) GetMinChunkSize() uint64
func (*ChunkerParams) GetNormalization ¶
func (x *ChunkerParams) GetNormalization() uint64
func (*ChunkerParams) ProtoMessage ¶
func (*ChunkerParams) ProtoMessage()
func (*ChunkerParams) ProtoReflect ¶
func (x *ChunkerParams) ProtoReflect() protoreflect.Message
func (*ChunkerParams) Reset ¶
func (x *ChunkerParams) Reset()
func (*ChunkerParams) String ¶
func (x *ChunkerParams) String() string
type ChunksExistRequest ¶
type ChunksExistRequest struct { Sums [][]byte `protobuf:"bytes,1,rep,name=sums,proto3" json:"sums,omitempty"` // contains filtered or unexported fields }
func (*ChunksExistRequest) Descriptor
deprecated
func (*ChunksExistRequest) Descriptor() ([]byte, []int)
Deprecated: Use ChunksExistRequest.ProtoReflect.Descriptor instead.
func (*ChunksExistRequest) GetSums ¶
func (x *ChunksExistRequest) GetSums() [][]byte
func (*ChunksExistRequest) ProtoMessage ¶
func (*ChunksExistRequest) ProtoMessage()
func (*ChunksExistRequest) ProtoReflect ¶
func (x *ChunksExistRequest) ProtoReflect() protoreflect.Message
func (*ChunksExistRequest) Reset ¶
func (x *ChunksExistRequest) Reset()
func (*ChunksExistRequest) String ¶
func (x *ChunksExistRequest) String() string
type ChunksExistResponse ¶
type ChunksExistResponse struct { Exists []bool `protobuf:"varint,1,rep,packed,name=exists,proto3" json:"exists,omitempty"` // contains filtered or unexported fields }
func (*ChunksExistResponse) Descriptor
deprecated
func (*ChunksExistResponse) Descriptor() ([]byte, []int)
Deprecated: Use ChunksExistResponse.ProtoReflect.Descriptor instead.
func (*ChunksExistResponse) GetExists ¶
func (x *ChunksExistResponse) GetExists() []bool
func (*ChunksExistResponse) ProtoMessage ¶
func (*ChunksExistResponse) ProtoMessage()
func (*ChunksExistResponse) ProtoReflect ¶
func (x *ChunksExistResponse) ProtoReflect() protoreflect.Message
func (*ChunksExistResponse) Reset ¶
func (x *ChunksExistResponse) Reset()
func (*ChunksExistResponse) String ¶
func (x *ChunksExistResponse) String() string
type CopyRequest ¶
type CopyRequest struct { SrcId []byte `protobuf:"bytes,1,opt,name=src_id,json=srcId,proto3" json:"src_id,omitempty"` Dst string `protobuf:"bytes,2,opt,name=dst,proto3" json:"dst,omitempty"` // contains filtered or unexported fields }
func (*CopyRequest) Descriptor
deprecated
func (*CopyRequest) Descriptor() ([]byte, []int)
Deprecated: Use CopyRequest.ProtoReflect.Descriptor instead.
func (*CopyRequest) GetDst ¶
func (x *CopyRequest) GetDst() string
func (*CopyRequest) GetSrcId ¶
func (x *CopyRequest) GetSrcId() []byte
func (*CopyRequest) ProtoMessage ¶
func (*CopyRequest) ProtoMessage()
func (*CopyRequest) ProtoReflect ¶
func (x *CopyRequest) ProtoReflect() protoreflect.Message
func (*CopyRequest) Reset ¶
func (x *CopyRequest) Reset()
func (*CopyRequest) String ¶
func (x *CopyRequest) String() string
type DownloadResponse ¶
type DownloadResponse struct { Sections []*Section `protobuf:"bytes,1,rep,name=sections,proto3" json:"sections,omitempty"` // contains filtered or unexported fields }
func (*DownloadResponse) Descriptor
deprecated
func (*DownloadResponse) Descriptor() ([]byte, []int)
Deprecated: Use DownloadResponse.ProtoReflect.Descriptor instead.
func (*DownloadResponse) GetSections ¶
func (x *DownloadResponse) GetSections() []*Section
func (*DownloadResponse) ProtoMessage ¶
func (*DownloadResponse) ProtoMessage()
func (*DownloadResponse) ProtoReflect ¶
func (x *DownloadResponse) ProtoReflect() protoreflect.Message
func (*DownloadResponse) Reset ¶
func (x *DownloadResponse) Reset()
func (*DownloadResponse) String ¶
func (x *DownloadResponse) String() string
type Empty ¶
type Empty struct {
// contains filtered or unexported fields
}
func (*Empty) Descriptor
deprecated
func (*Empty) ProtoMessage ¶
func (*Empty) ProtoMessage()
func (*Empty) ProtoReflect ¶
func (x *Empty) ProtoReflect() protoreflect.Message
type File ¶
type File struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Sums [][]byte `protobuf:"bytes,2,rep,name=sums,proto3" json:"sums,omitempty"` // contains filtered or unexported fields }
func (*File) Descriptor
deprecated
func (*File) ProtoMessage ¶
func (*File) ProtoMessage()
func (*File) ProtoReflect ¶
func (x *File) ProtoReflect() protoreflect.Message
type FileID ¶
type FileID struct { Sum []byte `protobuf:"bytes,1,opt,name=sum,proto3" json:"sum,omitempty"` // contains filtered or unexported fields }
func (*FileID) Descriptor
deprecated
func (*FileID) ProtoMessage ¶
func (*FileID) ProtoMessage()
func (*FileID) ProtoReflect ¶
func (x *FileID) ProtoReflect() protoreflect.Message
type FileInfo ¶
type FileInfo struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` CreatedAt int64 `protobuf:"varint,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"` Size uint64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"` Sum []byte `protobuf:"bytes,4,opt,name=sum,proto3" json:"sum,omitempty"` // contains filtered or unexported fields }
func (*FileInfo) Descriptor
deprecated
func (*FileInfo) GetCreatedAt ¶
func (*FileInfo) ProtoMessage ¶
func (*FileInfo) ProtoMessage()
func (*FileInfo) ProtoReflect ¶
func (x *FileInfo) ProtoReflect() protoreflect.Message
type Filename ¶
type Filename struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*Filename) Descriptor
deprecated
func (*Filename) ProtoMessage ¶
func (*Filename) ProtoMessage()
func (*Filename) ProtoReflect ¶
func (x *Filename) ProtoReflect() protoreflect.Message
type Files ¶
type Files struct { Infos []*FileInfo `protobuf:"bytes,1,rep,name=infos,proto3" json:"infos,omitempty"` // contains filtered or unexported fields }
func (*Files) Descriptor
deprecated
func (*Files) ProtoMessage ¶
func (*Files) ProtoMessage()
func (*Files) ProtoReflect ¶
func (x *Files) ProtoReflect() protoreflect.Message
type HTTPClient ¶
HTTPClient is the interface used by generated clients to send HTTP requests. It is fulfilled by *(net/http).Client, which is sufficient for most users. Users can provide their own implementation for special retry policies.
HTTPClient implementations should not follow redirects. Redirects are automatically disabled if *(net/http).Client is passed to client constructors. See the withoutRedirects function in this file for more details.
type HeadRequest ¶
type HeadRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Limit uint64 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` NextPageToken int64 `protobuf:"varint,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` Ascending bool `protobuf:"varint,4,opt,name=ascending,proto3" json:"ascending,omitempty"` // contains filtered or unexported fields }
func (*HeadRequest) Descriptor
deprecated
func (*HeadRequest) Descriptor() ([]byte, []int)
Deprecated: Use HeadRequest.ProtoReflect.Descriptor instead.
func (*HeadRequest) GetAscending ¶
func (x *HeadRequest) GetAscending() bool
func (*HeadRequest) GetLimit ¶
func (x *HeadRequest) GetLimit() uint64
func (*HeadRequest) GetName ¶
func (x *HeadRequest) GetName() string
func (*HeadRequest) GetNextPageToken ¶
func (x *HeadRequest) GetNextPageToken() int64
func (*HeadRequest) ProtoMessage ¶
func (*HeadRequest) ProtoMessage()
func (*HeadRequest) ProtoReflect ¶
func (x *HeadRequest) ProtoReflect() protoreflect.Message
func (*HeadRequest) Reset ¶
func (x *HeadRequest) Reset()
func (*HeadRequest) String ¶
func (x *HeadRequest) String() string
type HeadResponse ¶
type HeadResponse struct { Info []*FileInfo `protobuf:"bytes,1,rep,name=info,proto3" json:"info,omitempty"` NextPageToken int64 `protobuf:"varint,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
func (*HeadResponse) Descriptor
deprecated
func (*HeadResponse) Descriptor() ([]byte, []int)
Deprecated: Use HeadResponse.ProtoReflect.Descriptor instead.
func (*HeadResponse) GetInfo ¶
func (x *HeadResponse) GetInfo() []*FileInfo
func (*HeadResponse) GetNextPageToken ¶
func (x *HeadResponse) GetNextPageToken() int64
func (*HeadResponse) ProtoMessage ¶
func (*HeadResponse) ProtoMessage()
func (*HeadResponse) ProtoReflect ¶
func (x *HeadResponse) ProtoReflect() protoreflect.Message
func (*HeadResponse) Reset ¶
func (x *HeadResponse) Reset()
func (*HeadResponse) String ¶
func (x *HeadResponse) String() string
type JotFS ¶
type JotFS interface { ChunksExist(context.Context, *ChunksExistRequest) (*ChunksExistResponse, error) CreateFile(context.Context, *File) (*FileID, error) List(context.Context, *ListRequest) (*ListResponse, error) Head(context.Context, *HeadRequest) (*HeadResponse, error) Download(context.Context, *FileID) (*DownloadResponse, error) Copy(context.Context, *CopyRequest) (*FileID, error) Delete(context.Context, *FileID) (*Empty, error) GetChunkerParams(context.Context, *Empty) (*ChunkerParams, error) StartVacuum(context.Context, *Empty) (*VacuumID, error) VacuumStatus(context.Context, *VacuumID) (*Vacuum, error) ServerStats(context.Context, *Empty) (*Stats, error) }
func NewJotFSJSONClient ¶
func NewJotFSJSONClient(addr string, client HTTPClient, opts ...twirp.ClientOption) JotFS
NewJotFSJSONClient creates a JSON client that implements the JotFS interface. It communicates using JSON and can be configured with a custom HTTPClient.
func NewJotFSProtobufClient ¶
func NewJotFSProtobufClient(addr string, client HTTPClient, opts ...twirp.ClientOption) JotFS
NewJotFSProtobufClient creates a Protobuf client that implements the JotFS interface. It communicates using Protobuf and can be configured with a custom HTTPClient.
type ListRequest ¶
type ListRequest struct { Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"` Limit uint64 `protobuf:"varint,2,opt,name=limit,proto3" json:"limit,omitempty"` NextPageToken int64 `protobuf:"varint,3,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` Exclude string `protobuf:"bytes,4,opt,name=exclude,proto3" json:"exclude,omitempty"` Include string `protobuf:"bytes,5,opt,name=include,proto3" json:"include,omitempty"` Ascending bool `protobuf:"varint,6,opt,name=ascending,proto3" json:"ascending,omitempty"` // contains filtered or unexported fields }
func (*ListRequest) Descriptor
deprecated
func (*ListRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.
func (*ListRequest) GetAscending ¶
func (x *ListRequest) GetAscending() bool
func (*ListRequest) GetExclude ¶
func (x *ListRequest) GetExclude() string
func (*ListRequest) GetInclude ¶
func (x *ListRequest) GetInclude() string
func (*ListRequest) GetLimit ¶
func (x *ListRequest) GetLimit() uint64
func (*ListRequest) GetNextPageToken ¶
func (x *ListRequest) GetNextPageToken() int64
func (*ListRequest) GetPrefix ¶
func (x *ListRequest) GetPrefix() string
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) ProtoReflect ¶
func (x *ListRequest) ProtoReflect() protoreflect.Message
func (*ListRequest) Reset ¶
func (x *ListRequest) Reset()
func (*ListRequest) String ¶
func (x *ListRequest) String() string
type ListResponse ¶
type ListResponse struct { Info []*FileInfo `protobuf:"bytes,1,rep,name=info,proto3" json:"info,omitempty"` NextPageToken int64 `protobuf:"varint,2,opt,name=next_page_token,json=nextPageToken,proto3" json:"next_page_token,omitempty"` // contains filtered or unexported fields }
func (*ListResponse) Descriptor
deprecated
func (*ListResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.
func (*ListResponse) GetInfo ¶
func (x *ListResponse) GetInfo() []*FileInfo
func (*ListResponse) GetNextPageToken ¶
func (x *ListResponse) GetNextPageToken() int64
func (*ListResponse) ProtoMessage ¶
func (*ListResponse) ProtoMessage()
func (*ListResponse) ProtoReflect ¶
func (x *ListResponse) ProtoReflect() protoreflect.Message
func (*ListResponse) Reset ¶
func (x *ListResponse) Reset()
func (*ListResponse) String ¶
func (x *ListResponse) String() string
type Prefix ¶
type Prefix struct { Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"` // contains filtered or unexported fields }
func (*Prefix) Descriptor
deprecated
func (*Prefix) ProtoMessage ¶
func (*Prefix) ProtoMessage()
func (*Prefix) ProtoReflect ¶
func (x *Prefix) ProtoReflect() protoreflect.Message
type RenameRequest ¶
type RenameRequest struct { SrcId []byte `protobuf:"bytes,1,opt,name=src_id,json=srcId,proto3" json:"src_id,omitempty"` Dst string `protobuf:"bytes,2,opt,name=dst,proto3" json:"dst,omitempty"` // contains filtered or unexported fields }
func (*RenameRequest) Descriptor
deprecated
func (*RenameRequest) Descriptor() ([]byte, []int)
Deprecated: Use RenameRequest.ProtoReflect.Descriptor instead.
func (*RenameRequest) GetDst ¶
func (x *RenameRequest) GetDst() string
func (*RenameRequest) GetSrcId ¶
func (x *RenameRequest) GetSrcId() []byte
func (*RenameRequest) ProtoMessage ¶
func (*RenameRequest) ProtoMessage()
func (*RenameRequest) ProtoReflect ¶
func (x *RenameRequest) ProtoReflect() protoreflect.Message
func (*RenameRequest) Reset ¶
func (x *RenameRequest) Reset()
func (*RenameRequest) String ¶
func (x *RenameRequest) String() string
type Section ¶
type Section struct { Chunks []*SectionChunk `protobuf:"bytes,1,rep,name=chunks,proto3" json:"chunks,omitempty"` Url string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"` RangeStart uint64 `protobuf:"varint,3,opt,name=range_start,json=rangeStart,proto3" json:"range_start,omitempty"` RangeEnd uint64 `protobuf:"varint,4,opt,name=range_end,json=rangeEnd,proto3" json:"range_end,omitempty"` // contains filtered or unexported fields }
func (*Section) Descriptor
deprecated
func (*Section) GetChunks ¶
func (x *Section) GetChunks() []*SectionChunk
func (*Section) GetRangeEnd ¶
func (*Section) GetRangeStart ¶
func (*Section) ProtoMessage ¶
func (*Section) ProtoMessage()
func (*Section) ProtoReflect ¶
func (x *Section) ProtoReflect() protoreflect.Message
type SectionChunk ¶
type SectionChunk struct { Sequence uint64 `protobuf:"varint,1,opt,name=sequence,proto3" json:"sequence,omitempty"` Size uint64 `protobuf:"varint,2,opt,name=size,proto3" json:"size,omitempty"` Sum []byte `protobuf:"bytes,3,opt,name=sum,proto3" json:"sum,omitempty"` BlockOffset uint64 `protobuf:"varint,4,opt,name=block_offset,json=blockOffset,proto3" json:"block_offset,omitempty"` // contains filtered or unexported fields }
func (*SectionChunk) Descriptor
deprecated
func (*SectionChunk) Descriptor() ([]byte, []int)
Deprecated: Use SectionChunk.ProtoReflect.Descriptor instead.
func (*SectionChunk) GetBlockOffset ¶
func (x *SectionChunk) GetBlockOffset() uint64
func (*SectionChunk) GetSequence ¶
func (x *SectionChunk) GetSequence() uint64
func (*SectionChunk) GetSize ¶
func (x *SectionChunk) GetSize() uint64
func (*SectionChunk) GetSum ¶
func (x *SectionChunk) GetSum() []byte
func (*SectionChunk) ProtoMessage ¶
func (*SectionChunk) ProtoMessage()
func (*SectionChunk) ProtoReflect ¶
func (x *SectionChunk) ProtoReflect() protoreflect.Message
func (*SectionChunk) Reset ¶
func (x *SectionChunk) Reset()
func (*SectionChunk) String ¶
func (x *SectionChunk) String() string
type Stats ¶
type Stats struct { NumFiles uint64 `protobuf:"varint,1,opt,name=num_files,json=numFiles,proto3" json:"num_files,omitempty"` NumFileVersions uint64 `protobuf:"varint,2,opt,name=num_file_versions,json=numFileVersions,proto3" json:"num_file_versions,omitempty"` TotalFilesSize uint64 `protobuf:"varint,3,opt,name=total_files_size,json=totalFilesSize,proto3" json:"total_files_size,omitempty"` TotalDataSize uint64 `protobuf:"varint,4,opt,name=total_data_size,json=totalDataSize,proto3" json:"total_data_size,omitempty"` // contains filtered or unexported fields }
func (*Stats) Descriptor
deprecated
func (*Stats) GetNumFileVersions ¶
func (*Stats) GetNumFiles ¶
func (*Stats) GetTotalDataSize ¶
func (*Stats) GetTotalFilesSize ¶
func (*Stats) ProtoMessage ¶
func (*Stats) ProtoMessage()
func (*Stats) ProtoReflect ¶
func (x *Stats) ProtoReflect() protoreflect.Message
type TwirpServer ¶
type TwirpServer interface { http.Handler // ServiceDescriptor returns gzipped bytes describing the .proto file that // this service was generated from. Once unzipped, the bytes can be // unmarshalled as a // github.com/golang/protobuf/protoc-gen-go/descriptor.FileDescriptorProto. // // The returned integer is the index of this particular service within that // FileDescriptorProto's 'Service' slice of ServiceDescriptorProtos. This is a // low-level field, expected to be used for reflection. ServiceDescriptor() ([]byte, int) // ProtocGenTwirpVersion is the semantic version string of the version of // twirp used to generate this file. ProtocGenTwirpVersion() string // PathPrefix returns the HTTP URL path prefix for all methods handled by this // service. This can be used with an HTTP mux to route twirp requests // alongside non-twirp requests on one HTTP listener. PathPrefix() string }
TwirpServer is the interface generated server structs will support: they're HTTP handlers with additional methods for accessing metadata about the service. Those accessors are a low-level API for building reflection tools. Most people can think of TwirpServers as just http.Handlers.
func NewJotFSServer ¶
func NewJotFSServer(svc JotFS, hooks *twirp.ServerHooks) TwirpServer
type Vacuum ¶
type Vacuum struct { Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"` StartedAt int64 `protobuf:"varint,2,opt,name=started_at,json=startedAt,proto3" json:"started_at,omitempty"` CompletedAt int64 `protobuf:"varint,3,opt,name=completed_at,json=completedAt,proto3" json:"completed_at,omitempty"` // contains filtered or unexported fields }
func (*Vacuum) Descriptor
deprecated
func (*Vacuum) GetCompletedAt ¶
func (*Vacuum) GetStartedAt ¶
func (*Vacuum) ProtoMessage ¶
func (*Vacuum) ProtoMessage()
func (*Vacuum) ProtoReflect ¶
func (x *Vacuum) ProtoReflect() protoreflect.Message
type VacuumID ¶
type VacuumID struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // contains filtered or unexported fields }
func (*VacuumID) Descriptor
deprecated
func (*VacuumID) ProtoMessage ¶
func (*VacuumID) ProtoMessage()
func (*VacuumID) ProtoReflect ¶
func (x *VacuumID) ProtoReflect() protoreflect.Message