storj/pkg/pb/metainfo.pb.go

1302 lines
50 KiB
Go
Raw Normal View History

// Code generated by protoc-gen-gogo. DO NOT EDIT.
// source: metainfo.proto
package pb
import (
context "context"
fmt "fmt"
_ "github.com/gogo/protobuf/gogoproto"
proto "github.com/gogo/protobuf/proto"
timestamp "github.com/golang/protobuf/ptypes/timestamp"
grpc "google.golang.org/grpc"
math "math"
)
// Reference imports to suppress errors if they are not otherwise used.
var _ = proto.Marshal
var _ = fmt.Errorf
var _ = math.Inf
// This is a compile-time assertion to ensure that this generated file
// is compatible with the proto package it is being compiled against.
// A compilation error at this line likely means your copy of the
// proto package needs to be updated.
const _ = proto.GoGoProtoPackageIsVersion2 // please upgrade the proto package
type AddressedOrderLimit struct {
Limit *OrderLimit `protobuf:"bytes,1,opt,name=limit,proto3" json:"limit,omitempty"`
StorageNodeAddress *NodeAddress `protobuf:"bytes,2,opt,name=storage_node_address,json=storageNodeAddress,proto3" json:"storage_node_address,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *AddressedOrderLimit) Reset() { *m = AddressedOrderLimit{} }
func (m *AddressedOrderLimit) String() string { return proto.CompactTextString(m) }
func (*AddressedOrderLimit) ProtoMessage() {}
func (*AddressedOrderLimit) Descriptor() ([]byte, []int) {
return fileDescriptor_631e2f30a93cd64e, []int{0}
}
func (m *AddressedOrderLimit) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_AddressedOrderLimit.Unmarshal(m, b)
}
func (m *AddressedOrderLimit) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_AddressedOrderLimit.Marshal(b, m, deterministic)
}
func (m *AddressedOrderLimit) XXX_Merge(src proto.Message) {
xxx_messageInfo_AddressedOrderLimit.Merge(m, src)
}
func (m *AddressedOrderLimit) XXX_Size() int {
return xxx_messageInfo_AddressedOrderLimit.Size(m)
}
func (m *AddressedOrderLimit) XXX_DiscardUnknown() {
xxx_messageInfo_AddressedOrderLimit.DiscardUnknown(m)
}
var xxx_messageInfo_AddressedOrderLimit proto.InternalMessageInfo
func (m *AddressedOrderLimit) GetLimit() *OrderLimit {
if m != nil {
return m.Limit
}
return nil
}
func (m *AddressedOrderLimit) GetStorageNodeAddress() *NodeAddress {
if m != nil {
return m.StorageNodeAddress
}
return nil
}
type SegmentWriteRequest struct {
Bucket []byte `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
Path []byte `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
Segment int64 `protobuf:"varint,3,opt,name=segment,proto3" json:"segment,omitempty"`
Redundancy *RedundancyScheme `protobuf:"bytes,4,opt,name=redundancy,proto3" json:"redundancy,omitempty"`
MaxEncryptedSegmentSize int64 `protobuf:"varint,5,opt,name=max_encrypted_segment_size,json=maxEncryptedSegmentSize,proto3" json:"max_encrypted_segment_size,omitempty"`
Expiration *timestamp.Timestamp `protobuf:"bytes,6,opt,name=expiration,proto3" json:"expiration,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SegmentWriteRequest) Reset() { *m = SegmentWriteRequest{} }
func (m *SegmentWriteRequest) String() string { return proto.CompactTextString(m) }
func (*SegmentWriteRequest) ProtoMessage() {}
func (*SegmentWriteRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_631e2f30a93cd64e, []int{1}
}
func (m *SegmentWriteRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SegmentWriteRequest.Unmarshal(m, b)
}
func (m *SegmentWriteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SegmentWriteRequest.Marshal(b, m, deterministic)
}
func (m *SegmentWriteRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_SegmentWriteRequest.Merge(m, src)
}
func (m *SegmentWriteRequest) XXX_Size() int {
return xxx_messageInfo_SegmentWriteRequest.Size(m)
}
func (m *SegmentWriteRequest) XXX_DiscardUnknown() {
xxx_messageInfo_SegmentWriteRequest.DiscardUnknown(m)
}
var xxx_messageInfo_SegmentWriteRequest proto.InternalMessageInfo
func (m *SegmentWriteRequest) GetBucket() []byte {
if m != nil {
return m.Bucket
}
return nil
}
func (m *SegmentWriteRequest) GetPath() []byte {
if m != nil {
return m.Path
}
return nil
}
func (m *SegmentWriteRequest) GetSegment() int64 {
if m != nil {
return m.Segment
}
return 0
}
func (m *SegmentWriteRequest) GetRedundancy() *RedundancyScheme {
if m != nil {
return m.Redundancy
}
return nil
}
func (m *SegmentWriteRequest) GetMaxEncryptedSegmentSize() int64 {
if m != nil {
return m.MaxEncryptedSegmentSize
}
return 0
}
func (m *SegmentWriteRequest) GetExpiration() *timestamp.Timestamp {
if m != nil {
return m.Expiration
}
return nil
}
type SegmentWriteResponse struct {
AddressedLimits []*AddressedOrderLimit `protobuf:"bytes,1,rep,name=addressed_limits,json=addressedLimits,proto3" json:"addressed_limits,omitempty"`
RootPieceId PieceID `protobuf:"bytes,2,opt,name=root_piece_id,json=rootPieceId,proto3,customtype=PieceID" json:"root_piece_id"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SegmentWriteResponse) Reset() { *m = SegmentWriteResponse{} }
func (m *SegmentWriteResponse) String() string { return proto.CompactTextString(m) }
func (*SegmentWriteResponse) ProtoMessage() {}
func (*SegmentWriteResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_631e2f30a93cd64e, []int{2}
}
func (m *SegmentWriteResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SegmentWriteResponse.Unmarshal(m, b)
}
func (m *SegmentWriteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SegmentWriteResponse.Marshal(b, m, deterministic)
}
func (m *SegmentWriteResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_SegmentWriteResponse.Merge(m, src)
}
func (m *SegmentWriteResponse) XXX_Size() int {
return xxx_messageInfo_SegmentWriteResponse.Size(m)
}
func (m *SegmentWriteResponse) XXX_DiscardUnknown() {
xxx_messageInfo_SegmentWriteResponse.DiscardUnknown(m)
}
var xxx_messageInfo_SegmentWriteResponse proto.InternalMessageInfo
func (m *SegmentWriteResponse) GetAddressedLimits() []*AddressedOrderLimit {
if m != nil {
return m.AddressedLimits
}
return nil
}
type SegmentCommitRequest struct {
Bucket []byte `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
Path []byte `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
Segment int64 `protobuf:"varint,3,opt,name=segment,proto3" json:"segment,omitempty"`
Pointer *Pointer `protobuf:"bytes,4,opt,name=pointer,proto3" json:"pointer,omitempty"`
OriginalLimits []*OrderLimit `protobuf:"bytes,5,rep,name=original_limits,json=originalLimits,proto3" json:"original_limits,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SegmentCommitRequest) Reset() { *m = SegmentCommitRequest{} }
func (m *SegmentCommitRequest) String() string { return proto.CompactTextString(m) }
func (*SegmentCommitRequest) ProtoMessage() {}
func (*SegmentCommitRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_631e2f30a93cd64e, []int{3}
}
func (m *SegmentCommitRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SegmentCommitRequest.Unmarshal(m, b)
}
func (m *SegmentCommitRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SegmentCommitRequest.Marshal(b, m, deterministic)
}
func (m *SegmentCommitRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_SegmentCommitRequest.Merge(m, src)
}
func (m *SegmentCommitRequest) XXX_Size() int {
return xxx_messageInfo_SegmentCommitRequest.Size(m)
}
func (m *SegmentCommitRequest) XXX_DiscardUnknown() {
xxx_messageInfo_SegmentCommitRequest.DiscardUnknown(m)
}
var xxx_messageInfo_SegmentCommitRequest proto.InternalMessageInfo
func (m *SegmentCommitRequest) GetBucket() []byte {
if m != nil {
return m.Bucket
}
return nil
}
func (m *SegmentCommitRequest) GetPath() []byte {
if m != nil {
return m.Path
}
return nil
}
func (m *SegmentCommitRequest) GetSegment() int64 {
if m != nil {
return m.Segment
}
return 0
}
func (m *SegmentCommitRequest) GetPointer() *Pointer {
if m != nil {
return m.Pointer
}
return nil
}
func (m *SegmentCommitRequest) GetOriginalLimits() []*OrderLimit {
if m != nil {
return m.OriginalLimits
}
return nil
}
type SegmentCommitResponse struct {
Pointer *Pointer `protobuf:"bytes,1,opt,name=pointer,proto3" json:"pointer,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SegmentCommitResponse) Reset() { *m = SegmentCommitResponse{} }
func (m *SegmentCommitResponse) String() string { return proto.CompactTextString(m) }
func (*SegmentCommitResponse) ProtoMessage() {}
func (*SegmentCommitResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_631e2f30a93cd64e, []int{4}
}
func (m *SegmentCommitResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SegmentCommitResponse.Unmarshal(m, b)
}
func (m *SegmentCommitResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SegmentCommitResponse.Marshal(b, m, deterministic)
}
func (m *SegmentCommitResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_SegmentCommitResponse.Merge(m, src)
}
func (m *SegmentCommitResponse) XXX_Size() int {
return xxx_messageInfo_SegmentCommitResponse.Size(m)
}
func (m *SegmentCommitResponse) XXX_DiscardUnknown() {
xxx_messageInfo_SegmentCommitResponse.DiscardUnknown(m)
}
var xxx_messageInfo_SegmentCommitResponse proto.InternalMessageInfo
func (m *SegmentCommitResponse) GetPointer() *Pointer {
if m != nil {
return m.Pointer
}
return nil
}
type SegmentDownloadRequest struct {
Bucket []byte `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
Path []byte `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
Segment int64 `protobuf:"varint,3,opt,name=segment,proto3" json:"segment,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SegmentDownloadRequest) Reset() { *m = SegmentDownloadRequest{} }
func (m *SegmentDownloadRequest) String() string { return proto.CompactTextString(m) }
func (*SegmentDownloadRequest) ProtoMessage() {}
func (*SegmentDownloadRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_631e2f30a93cd64e, []int{5}
}
func (m *SegmentDownloadRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SegmentDownloadRequest.Unmarshal(m, b)
}
func (m *SegmentDownloadRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SegmentDownloadRequest.Marshal(b, m, deterministic)
}
func (m *SegmentDownloadRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_SegmentDownloadRequest.Merge(m, src)
}
func (m *SegmentDownloadRequest) XXX_Size() int {
return xxx_messageInfo_SegmentDownloadRequest.Size(m)
}
func (m *SegmentDownloadRequest) XXX_DiscardUnknown() {
xxx_messageInfo_SegmentDownloadRequest.DiscardUnknown(m)
}
var xxx_messageInfo_SegmentDownloadRequest proto.InternalMessageInfo
func (m *SegmentDownloadRequest) GetBucket() []byte {
if m != nil {
return m.Bucket
}
return nil
}
func (m *SegmentDownloadRequest) GetPath() []byte {
if m != nil {
return m.Path
}
return nil
}
func (m *SegmentDownloadRequest) GetSegment() int64 {
if m != nil {
return m.Segment
}
return 0
}
type SegmentDownloadResponse struct {
AddressedLimits []*AddressedOrderLimit `protobuf:"bytes,1,rep,name=addressed_limits,json=addressedLimits,proto3" json:"addressed_limits,omitempty"`
Pointer *Pointer `protobuf:"bytes,2,opt,name=pointer,proto3" json:"pointer,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SegmentDownloadResponse) Reset() { *m = SegmentDownloadResponse{} }
func (m *SegmentDownloadResponse) String() string { return proto.CompactTextString(m) }
func (*SegmentDownloadResponse) ProtoMessage() {}
func (*SegmentDownloadResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_631e2f30a93cd64e, []int{6}
}
func (m *SegmentDownloadResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SegmentDownloadResponse.Unmarshal(m, b)
}
func (m *SegmentDownloadResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SegmentDownloadResponse.Marshal(b, m, deterministic)
}
func (m *SegmentDownloadResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_SegmentDownloadResponse.Merge(m, src)
}
func (m *SegmentDownloadResponse) XXX_Size() int {
return xxx_messageInfo_SegmentDownloadResponse.Size(m)
}
func (m *SegmentDownloadResponse) XXX_DiscardUnknown() {
xxx_messageInfo_SegmentDownloadResponse.DiscardUnknown(m)
}
var xxx_messageInfo_SegmentDownloadResponse proto.InternalMessageInfo
func (m *SegmentDownloadResponse) GetAddressedLimits() []*AddressedOrderLimit {
if m != nil {
return m.AddressedLimits
}
return nil
}
func (m *SegmentDownloadResponse) GetPointer() *Pointer {
if m != nil {
return m.Pointer
}
return nil
}
type SegmentInfoRequest struct {
Bucket []byte `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
Path []byte `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
Segment int64 `protobuf:"varint,3,opt,name=segment,proto3" json:"segment,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SegmentInfoRequest) Reset() { *m = SegmentInfoRequest{} }
func (m *SegmentInfoRequest) String() string { return proto.CompactTextString(m) }
func (*SegmentInfoRequest) ProtoMessage() {}
func (*SegmentInfoRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_631e2f30a93cd64e, []int{7}
}
func (m *SegmentInfoRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SegmentInfoRequest.Unmarshal(m, b)
}
func (m *SegmentInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SegmentInfoRequest.Marshal(b, m, deterministic)
}
func (m *SegmentInfoRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_SegmentInfoRequest.Merge(m, src)
}
func (m *SegmentInfoRequest) XXX_Size() int {
return xxx_messageInfo_SegmentInfoRequest.Size(m)
}
func (m *SegmentInfoRequest) XXX_DiscardUnknown() {
xxx_messageInfo_SegmentInfoRequest.DiscardUnknown(m)
}
var xxx_messageInfo_SegmentInfoRequest proto.InternalMessageInfo
func (m *SegmentInfoRequest) GetBucket() []byte {
if m != nil {
return m.Bucket
}
return nil
}
func (m *SegmentInfoRequest) GetPath() []byte {
if m != nil {
return m.Path
}
return nil
}
func (m *SegmentInfoRequest) GetSegment() int64 {
if m != nil {
return m.Segment
}
return 0
}
type SegmentInfoResponse struct {
Pointer *Pointer `protobuf:"bytes,2,opt,name=pointer,proto3" json:"pointer,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SegmentInfoResponse) Reset() { *m = SegmentInfoResponse{} }
func (m *SegmentInfoResponse) String() string { return proto.CompactTextString(m) }
func (*SegmentInfoResponse) ProtoMessage() {}
func (*SegmentInfoResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_631e2f30a93cd64e, []int{8}
}
func (m *SegmentInfoResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SegmentInfoResponse.Unmarshal(m, b)
}
func (m *SegmentInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SegmentInfoResponse.Marshal(b, m, deterministic)
}
func (m *SegmentInfoResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_SegmentInfoResponse.Merge(m, src)
}
func (m *SegmentInfoResponse) XXX_Size() int {
return xxx_messageInfo_SegmentInfoResponse.Size(m)
}
func (m *SegmentInfoResponse) XXX_DiscardUnknown() {
xxx_messageInfo_SegmentInfoResponse.DiscardUnknown(m)
}
var xxx_messageInfo_SegmentInfoResponse proto.InternalMessageInfo
func (m *SegmentInfoResponse) GetPointer() *Pointer {
if m != nil {
return m.Pointer
}
return nil
}
type SegmentDeleteRequest struct {
Bucket []byte `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
Path []byte `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
Segment int64 `protobuf:"varint,3,opt,name=segment,proto3" json:"segment,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SegmentDeleteRequest) Reset() { *m = SegmentDeleteRequest{} }
func (m *SegmentDeleteRequest) String() string { return proto.CompactTextString(m) }
func (*SegmentDeleteRequest) ProtoMessage() {}
func (*SegmentDeleteRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_631e2f30a93cd64e, []int{9}
}
func (m *SegmentDeleteRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SegmentDeleteRequest.Unmarshal(m, b)
}
func (m *SegmentDeleteRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SegmentDeleteRequest.Marshal(b, m, deterministic)
}
func (m *SegmentDeleteRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_SegmentDeleteRequest.Merge(m, src)
}
func (m *SegmentDeleteRequest) XXX_Size() int {
return xxx_messageInfo_SegmentDeleteRequest.Size(m)
}
func (m *SegmentDeleteRequest) XXX_DiscardUnknown() {
xxx_messageInfo_SegmentDeleteRequest.DiscardUnknown(m)
}
var xxx_messageInfo_SegmentDeleteRequest proto.InternalMessageInfo
func (m *SegmentDeleteRequest) GetBucket() []byte {
if m != nil {
return m.Bucket
}
return nil
}
func (m *SegmentDeleteRequest) GetPath() []byte {
if m != nil {
return m.Path
}
return nil
}
func (m *SegmentDeleteRequest) GetSegment() int64 {
if m != nil {
return m.Segment
}
return 0
}
type SegmentDeleteResponse struct {
AddressedLimits []*AddressedOrderLimit `protobuf:"bytes,1,rep,name=addressed_limits,json=addressedLimits,proto3" json:"addressed_limits,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SegmentDeleteResponse) Reset() { *m = SegmentDeleteResponse{} }
func (m *SegmentDeleteResponse) String() string { return proto.CompactTextString(m) }
func (*SegmentDeleteResponse) ProtoMessage() {}
func (*SegmentDeleteResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_631e2f30a93cd64e, []int{10}
}
func (m *SegmentDeleteResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SegmentDeleteResponse.Unmarshal(m, b)
}
func (m *SegmentDeleteResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SegmentDeleteResponse.Marshal(b, m, deterministic)
}
func (m *SegmentDeleteResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_SegmentDeleteResponse.Merge(m, src)
}
func (m *SegmentDeleteResponse) XXX_Size() int {
return xxx_messageInfo_SegmentDeleteResponse.Size(m)
}
func (m *SegmentDeleteResponse) XXX_DiscardUnknown() {
xxx_messageInfo_SegmentDeleteResponse.DiscardUnknown(m)
}
var xxx_messageInfo_SegmentDeleteResponse proto.InternalMessageInfo
func (m *SegmentDeleteResponse) GetAddressedLimits() []*AddressedOrderLimit {
if m != nil {
return m.AddressedLimits
}
return nil
}
type ListSegmentsRequest struct {
Bucket []byte `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
Prefix []byte `protobuf:"bytes,2,opt,name=prefix,proto3" json:"prefix,omitempty"`
StartAfter []byte `protobuf:"bytes,3,opt,name=start_after,json=startAfter,proto3" json:"start_after,omitempty"`
EndBefore []byte `protobuf:"bytes,4,opt,name=end_before,json=endBefore,proto3" json:"end_before,omitempty"`
Recursive bool `protobuf:"varint,5,opt,name=recursive,proto3" json:"recursive,omitempty"`
Limit int32 `protobuf:"varint,6,opt,name=limit,proto3" json:"limit,omitempty"`
MetaFlags uint32 `protobuf:"fixed32,7,opt,name=meta_flags,json=metaFlags,proto3" json:"meta_flags,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ListSegmentsRequest) Reset() { *m = ListSegmentsRequest{} }
func (m *ListSegmentsRequest) String() string { return proto.CompactTextString(m) }
func (*ListSegmentsRequest) ProtoMessage() {}
func (*ListSegmentsRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_631e2f30a93cd64e, []int{11}
}
func (m *ListSegmentsRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ListSegmentsRequest.Unmarshal(m, b)
}
func (m *ListSegmentsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ListSegmentsRequest.Marshal(b, m, deterministic)
}
func (m *ListSegmentsRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_ListSegmentsRequest.Merge(m, src)
}
func (m *ListSegmentsRequest) XXX_Size() int {
return xxx_messageInfo_ListSegmentsRequest.Size(m)
}
func (m *ListSegmentsRequest) XXX_DiscardUnknown() {
xxx_messageInfo_ListSegmentsRequest.DiscardUnknown(m)
}
var xxx_messageInfo_ListSegmentsRequest proto.InternalMessageInfo
func (m *ListSegmentsRequest) GetBucket() []byte {
if m != nil {
return m.Bucket
}
return nil
}
func (m *ListSegmentsRequest) GetPrefix() []byte {
if m != nil {
return m.Prefix
}
return nil
}
func (m *ListSegmentsRequest) GetStartAfter() []byte {
if m != nil {
return m.StartAfter
}
return nil
}
func (m *ListSegmentsRequest) GetEndBefore() []byte {
if m != nil {
return m.EndBefore
}
return nil
}
func (m *ListSegmentsRequest) GetRecursive() bool {
if m != nil {
return m.Recursive
}
return false
}
func (m *ListSegmentsRequest) GetLimit() int32 {
if m != nil {
return m.Limit
}
return 0
}
func (m *ListSegmentsRequest) GetMetaFlags() uint32 {
if m != nil {
return m.MetaFlags
}
return 0
}
type ListSegmentsResponse struct {
Items []*ListSegmentsResponse_Item `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
More bool `protobuf:"varint,2,opt,name=more,proto3" json:"more,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ListSegmentsResponse) Reset() { *m = ListSegmentsResponse{} }
func (m *ListSegmentsResponse) String() string { return proto.CompactTextString(m) }
func (*ListSegmentsResponse) ProtoMessage() {}
func (*ListSegmentsResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_631e2f30a93cd64e, []int{12}
}
func (m *ListSegmentsResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ListSegmentsResponse.Unmarshal(m, b)
}
func (m *ListSegmentsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ListSegmentsResponse.Marshal(b, m, deterministic)
}
func (m *ListSegmentsResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_ListSegmentsResponse.Merge(m, src)
}
func (m *ListSegmentsResponse) XXX_Size() int {
return xxx_messageInfo_ListSegmentsResponse.Size(m)
}
func (m *ListSegmentsResponse) XXX_DiscardUnknown() {
xxx_messageInfo_ListSegmentsResponse.DiscardUnknown(m)
}
var xxx_messageInfo_ListSegmentsResponse proto.InternalMessageInfo
func (m *ListSegmentsResponse) GetItems() []*ListSegmentsResponse_Item {
if m != nil {
return m.Items
}
return nil
}
func (m *ListSegmentsResponse) GetMore() bool {
if m != nil {
return m.More
}
return false
}
type ListSegmentsResponse_Item struct {
Path []byte `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
Pointer *Pointer `protobuf:"bytes,2,opt,name=pointer,proto3" json:"pointer,omitempty"`
IsPrefix bool `protobuf:"varint,3,opt,name=is_prefix,json=isPrefix,proto3" json:"is_prefix,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ListSegmentsResponse_Item) Reset() { *m = ListSegmentsResponse_Item{} }
func (m *ListSegmentsResponse_Item) String() string { return proto.CompactTextString(m) }
func (*ListSegmentsResponse_Item) ProtoMessage() {}
func (*ListSegmentsResponse_Item) Descriptor() ([]byte, []int) {
return fileDescriptor_631e2f30a93cd64e, []int{12, 0}
}
func (m *ListSegmentsResponse_Item) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ListSegmentsResponse_Item.Unmarshal(m, b)
}
func (m *ListSegmentsResponse_Item) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ListSegmentsResponse_Item.Marshal(b, m, deterministic)
}
func (m *ListSegmentsResponse_Item) XXX_Merge(src proto.Message) {
xxx_messageInfo_ListSegmentsResponse_Item.Merge(m, src)
}
func (m *ListSegmentsResponse_Item) XXX_Size() int {
return xxx_messageInfo_ListSegmentsResponse_Item.Size(m)
}
func (m *ListSegmentsResponse_Item) XXX_DiscardUnknown() {
xxx_messageInfo_ListSegmentsResponse_Item.DiscardUnknown(m)
}
var xxx_messageInfo_ListSegmentsResponse_Item proto.InternalMessageInfo
func (m *ListSegmentsResponse_Item) GetPath() []byte {
if m != nil {
return m.Path
}
return nil
}
func (m *ListSegmentsResponse_Item) GetPointer() *Pointer {
if m != nil {
return m.Pointer
}
return nil
}
func (m *ListSegmentsResponse_Item) GetIsPrefix() bool {
if m != nil {
return m.IsPrefix
}
return false
}
type SetAttributionRequest struct {
BucketName []byte `protobuf:"bytes,1,opt,name=bucket_name,json=bucketName,proto3" json:"bucket_name,omitempty"`
PartnerId []byte `protobuf:"bytes,2,opt,name=partner_id,json=partnerId,proto3" json:"partner_id,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SetAttributionRequest) Reset() { *m = SetAttributionRequest{} }
func (m *SetAttributionRequest) String() string { return proto.CompactTextString(m) }
func (*SetAttributionRequest) ProtoMessage() {}
func (*SetAttributionRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_631e2f30a93cd64e, []int{13}
}
func (m *SetAttributionRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SetAttributionRequest.Unmarshal(m, b)
}
func (m *SetAttributionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SetAttributionRequest.Marshal(b, m, deterministic)
}
func (m *SetAttributionRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_SetAttributionRequest.Merge(m, src)
}
func (m *SetAttributionRequest) XXX_Size() int {
return xxx_messageInfo_SetAttributionRequest.Size(m)
}
func (m *SetAttributionRequest) XXX_DiscardUnknown() {
xxx_messageInfo_SetAttributionRequest.DiscardUnknown(m)
}
var xxx_messageInfo_SetAttributionRequest proto.InternalMessageInfo
func (m *SetAttributionRequest) GetBucketName() []byte {
if m != nil {
return m.BucketName
}
return nil
}
func (m *SetAttributionRequest) GetPartnerId() []byte {
if m != nil {
return m.PartnerId
}
return nil
}
type SetAttributionResponse struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *SetAttributionResponse) Reset() { *m = SetAttributionResponse{} }
func (m *SetAttributionResponse) String() string { return proto.CompactTextString(m) }
func (*SetAttributionResponse) ProtoMessage() {}
func (*SetAttributionResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_631e2f30a93cd64e, []int{14}
}
func (m *SetAttributionResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_SetAttributionResponse.Unmarshal(m, b)
}
func (m *SetAttributionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_SetAttributionResponse.Marshal(b, m, deterministic)
}
func (m *SetAttributionResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_SetAttributionResponse.Merge(m, src)
}
func (m *SetAttributionResponse) XXX_Size() int {
return xxx_messageInfo_SetAttributionResponse.Size(m)
}
func (m *SetAttributionResponse) XXX_DiscardUnknown() {
xxx_messageInfo_SetAttributionResponse.DiscardUnknown(m)
}
var xxx_messageInfo_SetAttributionResponse proto.InternalMessageInfo
type ProjectInfoRequest struct {
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ProjectInfoRequest) Reset() { *m = ProjectInfoRequest{} }
func (m *ProjectInfoRequest) String() string { return proto.CompactTextString(m) }
func (*ProjectInfoRequest) ProtoMessage() {}
func (*ProjectInfoRequest) Descriptor() ([]byte, []int) {
return fileDescriptor_631e2f30a93cd64e, []int{15}
}
func (m *ProjectInfoRequest) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ProjectInfoRequest.Unmarshal(m, b)
}
func (m *ProjectInfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ProjectInfoRequest.Marshal(b, m, deterministic)
}
func (m *ProjectInfoRequest) XXX_Merge(src proto.Message) {
xxx_messageInfo_ProjectInfoRequest.Merge(m, src)
}
func (m *ProjectInfoRequest) XXX_Size() int {
return xxx_messageInfo_ProjectInfoRequest.Size(m)
}
func (m *ProjectInfoRequest) XXX_DiscardUnknown() {
xxx_messageInfo_ProjectInfoRequest.DiscardUnknown(m)
}
var xxx_messageInfo_ProjectInfoRequest proto.InternalMessageInfo
type ProjectInfoResponse struct {
ProjectSalt []byte `protobuf:"bytes,1,opt,name=project_salt,json=projectSalt,proto3" json:"project_salt,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
func (m *ProjectInfoResponse) Reset() { *m = ProjectInfoResponse{} }
func (m *ProjectInfoResponse) String() string { return proto.CompactTextString(m) }
func (*ProjectInfoResponse) ProtoMessage() {}
func (*ProjectInfoResponse) Descriptor() ([]byte, []int) {
return fileDescriptor_631e2f30a93cd64e, []int{16}
}
func (m *ProjectInfoResponse) XXX_Unmarshal(b []byte) error {
return xxx_messageInfo_ProjectInfoResponse.Unmarshal(m, b)
}
func (m *ProjectInfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
return xxx_messageInfo_ProjectInfoResponse.Marshal(b, m, deterministic)
}
func (m *ProjectInfoResponse) XXX_Merge(src proto.Message) {
xxx_messageInfo_ProjectInfoResponse.Merge(m, src)
}
func (m *ProjectInfoResponse) XXX_Size() int {
return xxx_messageInfo_ProjectInfoResponse.Size(m)
}
func (m *ProjectInfoResponse) XXX_DiscardUnknown() {
xxx_messageInfo_ProjectInfoResponse.DiscardUnknown(m)
}
var xxx_messageInfo_ProjectInfoResponse proto.InternalMessageInfo
func (m *ProjectInfoResponse) GetProjectSalt() []byte {
if m != nil {
return m.ProjectSalt
}
return nil
}
func init() {
proto.RegisterType((*AddressedOrderLimit)(nil), "metainfo.AddressedOrderLimit")
proto.RegisterType((*SegmentWriteRequest)(nil), "metainfo.SegmentWriteRequest")
proto.RegisterType((*SegmentWriteResponse)(nil), "metainfo.SegmentWriteResponse")
proto.RegisterType((*SegmentCommitRequest)(nil), "metainfo.SegmentCommitRequest")
proto.RegisterType((*SegmentCommitResponse)(nil), "metainfo.SegmentCommitResponse")
proto.RegisterType((*SegmentDownloadRequest)(nil), "metainfo.SegmentDownloadRequest")
proto.RegisterType((*SegmentDownloadResponse)(nil), "metainfo.SegmentDownloadResponse")
proto.RegisterType((*SegmentInfoRequest)(nil), "metainfo.SegmentInfoRequest")
proto.RegisterType((*SegmentInfoResponse)(nil), "metainfo.SegmentInfoResponse")
proto.RegisterType((*SegmentDeleteRequest)(nil), "metainfo.SegmentDeleteRequest")
proto.RegisterType((*SegmentDeleteResponse)(nil), "metainfo.SegmentDeleteResponse")
proto.RegisterType((*ListSegmentsRequest)(nil), "metainfo.ListSegmentsRequest")
proto.RegisterType((*ListSegmentsResponse)(nil), "metainfo.ListSegmentsResponse")
proto.RegisterType((*ListSegmentsResponse_Item)(nil), "metainfo.ListSegmentsResponse.Item")
proto.RegisterType((*SetAttributionRequest)(nil), "metainfo.SetAttributionRequest")
proto.RegisterType((*SetAttributionResponse)(nil), "metainfo.SetAttributionResponse")
proto.RegisterType((*ProjectInfoRequest)(nil), "metainfo.ProjectInfoRequest")
proto.RegisterType((*ProjectInfoResponse)(nil), "metainfo.ProjectInfoResponse")
2019-03-18 13:08:24 +00:00
}
func init() { proto.RegisterFile("metainfo.proto", fileDescriptor_631e2f30a93cd64e) }
var fileDescriptor_631e2f30a93cd64e = []byte{
// 965 bytes of a gzipped FileDescriptorProto
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0xac, 0x56, 0xdd, 0x6e, 0x1b, 0x45,
0x14, 0x66, 0xed, 0x38, 0x8e, 0x8f, 0x9d, 0x18, 0x26, 0x26, 0x5d, 0x6d, 0x1b, 0xec, 0x2e, 0x37,
0xbe, 0x40, 0xae, 0x94, 0xde, 0x00, 0xb9, 0xca, 0x4f, 0x11, 0x41, 0x6d, 0xb0, 0xd6, 0x88, 0x4a,
0x15, 0x62, 0x35, 0xf6, 0x1e, 0xbb, 0x03, 0xde, 0x9d, 0x65, 0x66, 0x0c, 0x69, 0xaf, 0x79, 0x81,
0x22, 0xf1, 0x4c, 0x70, 0xc1, 0x03, 0x20, 0x2e, 0xfa, 0x2c, 0x68, 0x67, 0x66, 0xed, 0x75, 0x6c,
0x13, 0x2a, 0xf9, 0x6e, 0xce, 0x99, 0x33, 0xe7, 0xe7, 0xfb, 0x8e, 0xbf, 0x35, 0x1c, 0xc4, 0xa8,
0x28, 0x4b, 0xc6, 0xbc, 0x97, 0x0a, 0xae, 0x38, 0xd9, 0xcb, 0x6d, 0x0f, 0x26, 0x7c, 0x62, 0xbd,
0x5e, 0x7b, 0xc2, 0xf9, 0x64, 0x8a, 0x8f, 0xb4, 0x35, 0x9c, 0x8d, 0x1f, 0x29, 0x16, 0xa3, 0x54,
0x34, 0x4e, 0x6d, 0x00, 0x24, 0x3c, 0x42, 0x7b, 0x6e, 0xa6, 0x9c, 0x25, 0x0a, 0x45, 0x34, 0xb4,
0x8e, 0x06, 0x17, 0x11, 0x0a, 0x69, 0x2c, 0xff, 0x57, 0x07, 0x0e, 0xcf, 0xa2, 0x48, 0xa0, 0x94,
0x18, 0x7d, 0x9d, 0xdd, 0x3c, 0x65, 0x31, 0x53, 0xa4, 0x0b, 0x95, 0x69, 0x76, 0x70, 0x9d, 0x8e,
0xd3, 0xad, 0x9f, 0x90, 0x9e, 0x7d, 0xb5, 0x08, 0x09, 0x4c, 0x00, 0xb9, 0x80, 0x96, 0x54, 0x5c,
0xd0, 0x09, 0x86, 0x59, 0xd9, 0x90, 0x9a, 0x6c, 0x6e, 0x49, 0x3f, 0xfc, 0xa0, 0xa7, 0x7b, 0xb9,
0xe6, 0x11, 0xda, 0x32, 0x01, 0xb1, 0xe1, 0x05, 0x9f, 0xff, 0xa6, 0x04, 0x87, 0x03, 0x9c, 0xc4,
0x98, 0xa8, 0xe7, 0x82, 0x29, 0x0c, 0xf0, 0xa7, 0x19, 0x4a, 0x45, 0x8e, 0x60, 0x77, 0x38, 0x1b,
0xfd, 0x88, 0xa6, 0x8f, 0x46, 0x60, 0x2d, 0x42, 0x60, 0x27, 0xa5, 0xea, 0xa5, 0x2e, 0xd2, 0x08,
0xf4, 0x99, 0xb8, 0x50, 0x95, 0x26, 0x85, 0x5b, 0xee, 0x38, 0xdd, 0x72, 0x90, 0x9b, 0xe4, 0x14,
0x40, 0x60, 0x34, 0x4b, 0x22, 0x9a, 0x8c, 0x5e, 0xb9, 0x3b, 0xba, 0xb1, 0xfb, 0xbd, 0x05, 0x30,
0xc1, 0xfc, 0x72, 0x30, 0x7a, 0x89, 0x31, 0x06, 0x85, 0x70, 0x72, 0x0a, 0x5e, 0x4c, 0x6f, 0x42,
0x4c, 0x46, 0xe2, 0x55, 0xaa, 0x30, 0x0a, 0x6d, 0xd6, 0x50, 0xb2, 0xd7, 0xe8, 0x56, 0x74, 0xa5,
0x7b, 0x31, 0xbd, 0x79, 0x92, 0x07, 0xd8, 0x39, 0x06, 0xec, 0x35, 0x92, 0xcf, 0x01, 0xf0, 0x26,
0x65, 0x82, 0x2a, 0xc6, 0x13, 0x77, 0x57, 0x57, 0xf6, 0x7a, 0x86, 0xbf, 0x5e, 0xce, 0x5f, 0xef,
0x9b, 0x9c, 0xbf, 0xa0, 0x10, 0xed, 0xff, 0xee, 0x40, 0x6b, 0x19, 0x13, 0x99, 0xf2, 0x44, 0x22,
0xf9, 0x12, 0xde, 0xa7, 0x39, 0x65, 0xa1, 0x26, 0x41, 0xba, 0x4e, 0xa7, 0xdc, 0xad, 0x9f, 0x1c,
0xf7, 0xe6, 0x0b, 0xb4, 0x86, 0xd4, 0xa0, 0x39, 0x7f, 0xa6, 0x6d, 0x49, 0x1e, 0xc3, 0xbe, 0xe0,
0x5c, 0x85, 0x29, 0xc3, 0x11, 0x86, 0x2c, 0x32, 0x78, 0x9e, 0x37, 0xff, 0x7c, 0xdb, 0x7e, 0xef,
0x9f, 0xb7, 0xed, 0x6a, 0x3f, 0xf3, 0x5f, 0x5d, 0x06, 0xf5, 0x2c, 0xca, 0x18, 0x91, 0xff, 0xc7,
0xa2, 0xaf, 0x0b, 0x1e, 0x67, 0x79, 0xb7, 0x4a, 0xd6, 0x27, 0x50, 0xb5, 0xcc, 0x58, 0xa6, 0x48,
0x81, 0xa9, 0xbe, 0x39, 0x05, 0x79, 0x08, 0x39, 0x85, 0x26, 0x17, 0x6c, 0xc2, 0x12, 0x3a, 0xcd,
0xa1, 0xa8, 0x68, 0x28, 0xd6, 0x6d, 0xec, 0x41, 0x1e, 0x6a, 0xc6, 0xf7, 0x9f, 0xc0, 0x87, 0xb7,
0x06, 0xb1, 0x08, 0x17, 0x7a, 0x70, 0xee, 0xec, 0xc1, 0xff, 0x1e, 0x8e, 0x6c, 0x9a, 0x4b, 0xfe,
0x4b, 0x32, 0xe5, 0x34, 0xda, 0x2a, 0x22, 0xfe, 0x1b, 0x07, 0xee, 0xad, 0x14, 0xd8, 0xfa, 0x2e,
0x14, 0x66, 0x2e, 0xdd, 0x3d, 0xf3, 0x0b, 0x20, 0xb6, 0xa5, 0xab, 0x64, 0xcc, 0xb7, 0x3b, 0xef,
0xc5, 0x5c, 0x0b, 0x4c, 0xee, 0x55, 0x52, 0xfe, 0x47, 0x83, 0xdf, 0xcd, 0x97, 0xf4, 0x12, 0xa7,
0xb8, 0x65, 0x45, 0xf1, 0xe9, 0x7c, 0x73, 0xf2, 0xec, 0xdb, 0xe6, 0xc3, 0xff, 0xdb, 0x81, 0xc3,
0xa7, 0x4c, 0x2a, 0x5b, 0x47, 0xde, 0x35, 0xc0, 0x11, 0xec, 0xa6, 0x02, 0xc7, 0xec, 0xc6, 0x8e,
0x60, 0x2d, 0xd2, 0x86, 0xba, 0x54, 0x54, 0xa8, 0x90, 0x8e, 0x33, 0xe8, 0xca, 0xfa, 0x12, 0xb4,
0xeb, 0x2c, 0xf3, 0x90, 0x63, 0x00, 0x4c, 0xa2, 0x70, 0x88, 0x63, 0x2e, 0x50, 0xff, 0xe6, 0x1a,
0x41, 0x0d, 0x93, 0xe8, 0x5c, 0x3b, 0xc8, 0x03, 0xa8, 0x09, 0x1c, 0xcd, 0x84, 0x64, 0x3f, 0x1b,
0xb9, 0xdb, 0x0b, 0x16, 0x0e, 0xd2, 0xca, 0xbf, 0x13, 0x99, 0xb6, 0x55, 0xf2, 0x6f, 0xc2, 0x31,
0x40, 0x36, 0x6c, 0x38, 0x9e, 0xd2, 0x89, 0x74, 0xab, 0x1d, 0xa7, 0x5b, 0x0d, 0x6a, 0x99, 0xe7,
0x8b, 0xcc, 0xe1, 0xff, 0xe5, 0x40, 0x6b, 0x79, 0x34, 0x8b, 0xde, 0x67, 0x50, 0x61, 0x0a, 0xe3,
0x1c, 0xb2, 0x8f, 0x17, 0x90, 0xad, 0x0b, 0xef, 0x5d, 0x29, 0x8c, 0x03, 0xf3, 0x22, 0xe3, 0x2f,
0xce, 0xfa, 0x2f, 0xe9, 0x0e, 0xf5, 0xd9, 0x43, 0xd8, 0xc9, 0x42, 0xe6, 0xdc, 0x3a, 0x05, 0x6e,
0xdf, 0x69, 0x9b, 0xc8, 0x7d, 0xa8, 0x31, 0x19, 0x5a, 0x7c, 0xcb, 0xba, 0xc4, 0x1e, 0x93, 0x7d,
0x6d, 0xfb, 0xcf, 0xb3, 0x65, 0x50, 0x67, 0x4a, 0x09, 0x36, 0x9c, 0x65, 0xd2, 0x9d, 0x53, 0xd5,
0x86, 0xba, 0x21, 0x27, 0x4c, 0x68, 0x8c, 0xb6, 0x3c, 0x18, 0xd7, 0x35, 0x8d, 0x31, 0xc3, 0x29,
0xa5, 0x42, 0x25, 0x28, 0xe6, 0xe2, 0x1b, 0xd4, 0xac, 0xe7, 0x2a, 0xf2, 0xdd, 0x4c, 0x58, 0x96,
0x13, 0x9b, 0xc9, 0xfd, 0x16, 0x90, 0xbe, 0xe0, 0x3f, 0xe0, 0xa8, 0xf8, 0xf3, 0xf3, 0x3f, 0x85,
0xc3, 0x25, 0xaf, 0x45, 0xf5, 0x21, 0x34, 0x52, 0xe3, 0x0e, 0x25, 0x9d, 0xe6, 0x7b, 0x53, 0xb7,
0xbe, 0x01, 0x9d, 0xaa, 0x93, 0xdf, 0x2a, 0xb0, 0xf7, 0xcc, 0x62, 0x4d, 0xae, 0x61, 0xff, 0x42,
0x20, 0x55, 0x68, 0x01, 0x27, 0x85, 0xd5, 0x5d, 0xf3, 0x91, 0xf6, 0x3e, 0xda, 0x74, 0x6d, 0xeb,
0xf7, 0x61, 0xdf, 0xe8, 0x6b, 0x9e, 0x6f, 0xf5, 0xc1, 0xd2, 0x87, 0xc4, 0x6b, 0x6f, 0xbc, 0xb7,
0x19, 0xbf, 0x82, 0x7a, 0x41, 0x21, 0xc8, 0x83, 0x95, 0xf8, 0x02, 0x2a, 0xde, 0xf1, 0x86, 0x5b,
0x9b, 0xeb, 0x5b, 0x68, 0xe6, 0xaa, 0x9a, 0xf7, 0xd7, 0x59, 0x79, 0x71, 0x4b, 0xd8, 0xbd, 0x87,
0xff, 0x11, 0xb1, 0x98, 0xda, 0x68, 0xc3, 0xe6, 0xa9, 0x97, 0x94, 0x69, 0xcd, 0xd4, 0xb7, 0xb4,
0xe5, 0x19, 0x34, 0x8a, 0x3f, 0x83, 0x22, 0x2d, 0x6b, 0x84, 0xa2, 0x48, 0xcb, 0xda, 0x1f, 0xdb,
0x00, 0x0e, 0x96, 0xb7, 0x8b, 0x2c, 0x75, 0xb0, 0x66, 0xa1, 0xbd, 0xce, 0xe6, 0x80, 0x05, 0x33,
0x85, 0x15, 0x2c, 0x32, 0xb3, 0xba, 0xaf, 0x45, 0x66, 0xd6, 0xec, 0xed, 0xf9, 0xce, 0x8b, 0x52,
0x3a, 0x1c, 0xee, 0xea, 0xbf, 0x49, 0x8f, 0xff, 0x0d, 0x00, 0x00, 0xff, 0xff, 0x06, 0xec, 0x5b,
0x84, 0x1c, 0x0b, 0x00, 0x00,
}
// Reference imports to suppress errors if they are not otherwise used.
var _ context.Context
var _ grpc.ClientConn
// This is a compile-time assertion to ensure that this generated file
// is compatible with the grpc package it is being compiled against.
const _ = grpc.SupportPackageIsVersion4
// MetainfoClient is the client API for Metainfo service.
//
// For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
type MetainfoClient interface {
CreateSegment(ctx context.Context, in *SegmentWriteRequest, opts ...grpc.CallOption) (*SegmentWriteResponse, error)
CommitSegment(ctx context.Context, in *SegmentCommitRequest, opts ...grpc.CallOption) (*SegmentCommitResponse, error)
SegmentInfo(ctx context.Context, in *SegmentInfoRequest, opts ...grpc.CallOption) (*SegmentInfoResponse, error)
DownloadSegment(ctx context.Context, in *SegmentDownloadRequest, opts ...grpc.CallOption) (*SegmentDownloadResponse, error)
DeleteSegment(ctx context.Context, in *SegmentDeleteRequest, opts ...grpc.CallOption) (*SegmentDeleteResponse, error)
ListSegments(ctx context.Context, in *ListSegmentsRequest, opts ...grpc.CallOption) (*ListSegmentsResponse, error)
SetAttribution(ctx context.Context, in *SetAttributionRequest, opts ...grpc.CallOption) (*SetAttributionResponse, error)
ProjectInfo(ctx context.Context, in *ProjectInfoRequest, opts ...grpc.CallOption) (*ProjectInfoResponse, error)
}
type metainfoClient struct {
cc *grpc.ClientConn
}
func NewMetainfoClient(cc *grpc.ClientConn) MetainfoClient {
return &metainfoClient{cc}
}
func (c *metainfoClient) CreateSegment(ctx context.Context, in *SegmentWriteRequest, opts ...grpc.CallOption) (*SegmentWriteResponse, error) {
out := new(SegmentWriteResponse)
err := c.cc.Invoke(ctx, "/metainfo.Metainfo/CreateSegment", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *metainfoClient) CommitSegment(ctx context.Context, in *SegmentCommitRequest, opts ...grpc.CallOption) (*SegmentCommitResponse, error) {
out := new(SegmentCommitResponse)
err := c.cc.Invoke(ctx, "/metainfo.Metainfo/CommitSegment", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *metainfoClient) SegmentInfo(ctx context.Context, in *SegmentInfoRequest, opts ...grpc.CallOption) (*SegmentInfoResponse, error) {
out := new(SegmentInfoResponse)
err := c.cc.Invoke(ctx, "/metainfo.Metainfo/SegmentInfo", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *metainfoClient) DownloadSegment(ctx context.Context, in *SegmentDownloadRequest, opts ...grpc.CallOption) (*SegmentDownloadResponse, error) {
out := new(SegmentDownloadResponse)
err := c.cc.Invoke(ctx, "/metainfo.Metainfo/DownloadSegment", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *metainfoClient) DeleteSegment(ctx context.Context, in *SegmentDeleteRequest, opts ...grpc.CallOption) (*SegmentDeleteResponse, error) {
out := new(SegmentDeleteResponse)
err := c.cc.Invoke(ctx, "/metainfo.Metainfo/DeleteSegment", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *metainfoClient) ListSegments(ctx context.Context, in *ListSegmentsRequest, opts ...grpc.CallOption) (*ListSegmentsResponse, error) {
out := new(ListSegmentsResponse)
err := c.cc.Invoke(ctx, "/metainfo.Metainfo/ListSegments", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *metainfoClient) SetAttribution(ctx context.Context, in *SetAttributionRequest, opts ...grpc.CallOption) (*SetAttributionResponse, error) {
out := new(SetAttributionResponse)
err := c.cc.Invoke(ctx, "/metainfo.Metainfo/SetAttribution", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
func (c *metainfoClient) ProjectInfo(ctx context.Context, in *ProjectInfoRequest, opts ...grpc.CallOption) (*ProjectInfoResponse, error) {
out := new(ProjectInfoResponse)
err := c.cc.Invoke(ctx, "/metainfo.Metainfo/ProjectInfo", in, out, opts...)
if err != nil {
return nil, err
}
return out, nil
}
// MetainfoServer is the server API for Metainfo service.
type MetainfoServer interface {
CreateSegment(context.Context, *SegmentWriteRequest) (*SegmentWriteResponse, error)
CommitSegment(context.Context, *SegmentCommitRequest) (*SegmentCommitResponse, error)
SegmentInfo(context.Context, *SegmentInfoRequest) (*SegmentInfoResponse, error)
DownloadSegment(context.Context, *SegmentDownloadRequest) (*SegmentDownloadResponse, error)
DeleteSegment(context.Context, *SegmentDeleteRequest) (*SegmentDeleteResponse, error)
ListSegments(context.Context, *ListSegmentsRequest) (*ListSegmentsResponse, error)
SetAttribution(context.Context, *SetAttributionRequest) (*SetAttributionResponse, error)
ProjectInfo(context.Context, *ProjectInfoRequest) (*ProjectInfoResponse, error)
}
func RegisterMetainfoServer(s *grpc.Server, srv MetainfoServer) {
s.RegisterService(&_Metainfo_serviceDesc, srv)
}
func _Metainfo_CreateSegment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(SegmentWriteRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetainfoServer).CreateSegment(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/metainfo.Metainfo/CreateSegment",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetainfoServer).CreateSegment(ctx, req.(*SegmentWriteRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Metainfo_CommitSegment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(SegmentCommitRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetainfoServer).CommitSegment(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/metainfo.Metainfo/CommitSegment",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetainfoServer).CommitSegment(ctx, req.(*SegmentCommitRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Metainfo_SegmentInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(SegmentInfoRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetainfoServer).SegmentInfo(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/metainfo.Metainfo/SegmentInfo",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetainfoServer).SegmentInfo(ctx, req.(*SegmentInfoRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Metainfo_DownloadSegment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(SegmentDownloadRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetainfoServer).DownloadSegment(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/metainfo.Metainfo/DownloadSegment",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetainfoServer).DownloadSegment(ctx, req.(*SegmentDownloadRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Metainfo_DeleteSegment_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(SegmentDeleteRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetainfoServer).DeleteSegment(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/metainfo.Metainfo/DeleteSegment",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetainfoServer).DeleteSegment(ctx, req.(*SegmentDeleteRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Metainfo_ListSegments_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ListSegmentsRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetainfoServer).ListSegments(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/metainfo.Metainfo/ListSegments",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetainfoServer).ListSegments(ctx, req.(*ListSegmentsRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Metainfo_SetAttribution_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(SetAttributionRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetainfoServer).SetAttribution(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/metainfo.Metainfo/SetAttribution",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetainfoServer).SetAttribution(ctx, req.(*SetAttributionRequest))
}
return interceptor(ctx, in, info, handler)
}
func _Metainfo_ProjectInfo_Handler(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor) (interface{}, error) {
in := new(ProjectInfoRequest)
if err := dec(in); err != nil {
return nil, err
}
if interceptor == nil {
return srv.(MetainfoServer).ProjectInfo(ctx, in)
}
info := &grpc.UnaryServerInfo{
Server: srv,
FullMethod: "/metainfo.Metainfo/ProjectInfo",
}
handler := func(ctx context.Context, req interface{}) (interface{}, error) {
return srv.(MetainfoServer).ProjectInfo(ctx, req.(*ProjectInfoRequest))
}
return interceptor(ctx, in, info, handler)
}
var _Metainfo_serviceDesc = grpc.ServiceDesc{
ServiceName: "metainfo.Metainfo",
HandlerType: (*MetainfoServer)(nil),
Methods: []grpc.MethodDesc{
{
MethodName: "CreateSegment",
Handler: _Metainfo_CreateSegment_Handler,
},
{
MethodName: "CommitSegment",
Handler: _Metainfo_CommitSegment_Handler,
},
{
MethodName: "SegmentInfo",
Handler: _Metainfo_SegmentInfo_Handler,
},
{
MethodName: "DownloadSegment",
Handler: _Metainfo_DownloadSegment_Handler,
},
{
MethodName: "DeleteSegment",
Handler: _Metainfo_DeleteSegment_Handler,
},
{
MethodName: "ListSegments",
Handler: _Metainfo_ListSegments_Handler,
},
{
MethodName: "SetAttribution",
Handler: _Metainfo_SetAttribution_Handler,
},
{
MethodName: "ProjectInfo",
Handler: _Metainfo_ProjectInfo_Handler,
},
},
Streams: []grpc.StreamDesc{},
Metadata: "metainfo.proto",
}