s3x

package
v0.1.0 Latest Latest
Warning

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

 Go to latest Published: Apr 20, 2020 License: Apache-2.0 Imports: 44 Imported by: 0

Documentation

Overview

Package s3x is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	//DSTypeBadger is a badger(v2) backed datastore
	DSTypeBadger = DSType("badger")
	//DSTypeCrdt is a crdt backed backed datastore
	DSTypeCrdt = DSType("crdt")
)

Variables

View Source 
var (
	// ErrLedgerBucketExists is an error message returned from the internal
	// ledgerStore indicating that a bucket already exists
	ErrLedgerBucketExists = errors.New("bucket exists")
	// ErrLedgerBucketDoesNotExist is an error message returned from the internal
	// ledgerStore indicating that a bucket does not exist
	ErrLedgerBucketDoesNotExist = errors.New("bucket does not exist")
	// ErrLedgerObjectDoesNotExist is an error message returned from the internal
	// ledgerStore indicating that a object does not exist
	ErrLedgerObjectDoesNotExist = errors.New("object does not exist")
	// ErrLedgerNonEmptyBucket is an error message returned from the internal
	// ledgerStore indicating that a bucket is not empty
	ErrLedgerNonEmptyBucket = errors.New("bucket is not empty")
	// ErrInvalidUploadID is an error message returned when the multipart upload id
	// does not exist
	ErrInvalidUploadID = errors.New("invalid multipart upload id")
	// ErrInvalidPartNumber is an error message returned when the multipart part
	// number is out of range (not mappable to a minio error type)
	ErrInvalidPartNumber = errors.New("invalid multipart part number")
)
View Source 
var (
	ErrInvalidLengthS3        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowS3          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupS3 = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterInfoAPIHandler 

func RegisterInfoAPIHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterInfoAPIHandler registers the http handlers for service InfoAPI to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterInfoAPIHandlerClient 

func RegisterInfoAPIHandlerClient(ctx context.Context, mux *runtime.ServeMux, client InfoAPIClient) error

RegisterInfoAPIHandlerClient registers the http handlers for service InfoAPI to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "InfoAPIClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "InfoAPIClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "InfoAPIClient" to call the correct interceptors.

func RegisterInfoAPIHandlerFromEndpoint 

func RegisterInfoAPIHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterInfoAPIHandlerFromEndpoint is same as RegisterInfoAPIHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterInfoAPIHandlerServer 

func RegisterInfoAPIHandlerServer(ctx context.Context, mux *runtime.ServeMux, server InfoAPIServer) error

RegisterInfoAPIHandlerServer registers the http handlers for service InfoAPI to "mux". UnaryRPC :call InfoAPIServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906.

func RegisterInfoAPIServer 

func RegisterInfoAPIServer(s *grpc.Server, srv InfoAPIServer)

Types

type Bucket 

type Bucket struct {
	// data associated with the object
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// information associated with this bucket
	BucketInfo BucketInfo `protobuf:"bytes,2,opt,name=bucketInfo,proto3" json:"bucketInfo"`
	// maps object names to object hashes
	Objects map[string]string `` /* 145-byte string literal not displayed */
}

Bucket is a data repositroy for S3 objects

func (*Bucket) Descriptor 

func (*Bucket) Descriptor() ([]byte, []int)

func (*Bucket) GetBucketInfo 

func (m *Bucket) GetBucketInfo() BucketInfo

func (*Bucket) GetData 

func (m *Bucket) GetData() []byte

func (*Bucket) GetObjects 

func (m *Bucket) GetObjects() map[string]string

func (*Bucket) Marshal 

func (m *Bucket) Marshal() (dAtA []byte, err error)

func (*Bucket) MarshalTo 

func (m *Bucket) MarshalTo(dAtA []byte) (int, error)

func (*Bucket) MarshalToSizedBuffer 

func (m *Bucket) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Bucket) ProtoMessage 

func (*Bucket) ProtoMessage()

func (*Bucket) Reset 

func (m *Bucket) Reset()

func (*Bucket) Size 

func (m *Bucket) Size() (n int)

func (*Bucket) String 

func (m *Bucket) String() string

func (*Bucket) Unmarshal 

func (m *Bucket) Unmarshal(dAtA []byte) error

func (*Bucket) XXX_DiscardUnknown 

func (m *Bucket) XXX_DiscardUnknown()

func (*Bucket) XXX_Marshal 

func (m *Bucket) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Bucket) XXX_Merge 

func (m *Bucket) XXX_Merge(src proto.Message)

func (*Bucket) XXX_Size 

func (m *Bucket) XXX_Size() int

func (*Bucket) XXX_Unmarshal 

func (m *Bucket) XXX_Unmarshal(b []byte) error

type BucketInfo 

type BucketInfo struct {
	// name is the name of the bucket
	Name    string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Created time.Time `protobuf:"bytes,2,opt,name=created,proto3,stdtime" json:"created"`
	// the location of the bucket
	Location string `protobuf:"bytes,3,opt,name=location,proto3" json:"location,omitempty"`
}

BucketInfo is used to store s3 bucket metadata

func (*BucketInfo) Descriptor 

func (*BucketInfo) Descriptor() ([]byte, []int)

func (*BucketInfo) GetCreated 

func (m *BucketInfo) GetCreated() time.Time

func (*BucketInfo) GetLocation 

func (m *BucketInfo) GetLocation() string

func (*BucketInfo) GetName 

func (m *BucketInfo) GetName() string

func (*BucketInfo) Marshal 

func (m *BucketInfo) Marshal() (dAtA []byte, err error)

func (*BucketInfo) MarshalTo 

func (m *BucketInfo) MarshalTo(dAtA []byte) (int, error)

func (*BucketInfo) MarshalToSizedBuffer 

func (m *BucketInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BucketInfo) ProtoMessage 

func (*BucketInfo) ProtoMessage()

func (*BucketInfo) Reset 

func (m *BucketInfo) Reset()

func (*BucketInfo) Size 

func (m *BucketInfo) Size() (n int)

func (*BucketInfo) String 

func (m *BucketInfo) String() string

func (*BucketInfo) Unmarshal 

func (m *BucketInfo) Unmarshal(dAtA []byte) error

func (*BucketInfo) XXX_DiscardUnknown 

func (m *BucketInfo) XXX_DiscardUnknown()

func (*BucketInfo) XXX_Marshal 

func (m *BucketInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BucketInfo) XXX_Merge 

func (m *BucketInfo) XXX_Merge(src proto.Message)

func (*BucketInfo) XXX_Size 

func (m *BucketInfo) XXX_Size() int

func (*BucketInfo) XXX_Unmarshal 

func (m *BucketInfo) XXX_Unmarshal(b []byte) error

type DSType added in v0.0.7 

type DSType string

DSType is a type of datastore that s3x supports, please remove all existing data before changing the datastore

type InfoAPIClient 

type InfoAPIClient interface {
	GetHash(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)
}

InfoAPIClient is the client API for InfoAPI service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewInfoAPIClient 

func NewInfoAPIClient(cc *grpc.ClientConn) InfoAPIClient

type InfoAPIServer 

type InfoAPIServer interface {
	GetHash(context.Context, *InfoRequest) (*InfoResponse, error)
}

InfoAPIServer is the server API for InfoAPI service.

type InfoRequest 

type InfoRequest struct {
	Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Object string `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
	// if set return the object data hash, not the hash of the protocol buffer object
	// this is only applicable to requests for object info
	ObjectDataOnly bool `protobuf:"varint,3,opt,name=objectDataOnly,proto3" json:"objectDataOnly,omitempty"`
}

func (*InfoRequest) Descriptor 

func (*InfoRequest) Descriptor() ([]byte, []int)

func (*InfoRequest) GetBucket 

func (m *InfoRequest) GetBucket() string

func (*InfoRequest) GetObject 

func (m *InfoRequest) GetObject() string

func (*InfoRequest) GetObjectDataOnly 

func (m *InfoRequest) GetObjectDataOnly() bool

func (*InfoRequest) Marshal 

func (m *InfoRequest) Marshal() (dAtA []byte, err error)

func (*InfoRequest) MarshalTo 

func (m *InfoRequest) MarshalTo(dAtA []byte) (int, error)

func (*InfoRequest) MarshalToSizedBuffer 

func (m *InfoRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InfoRequest) ProtoMessage 

func (*InfoRequest) ProtoMessage()

func (*InfoRequest) Reset 

func (m *InfoRequest) Reset()

func (*InfoRequest) Size 

func (m *InfoRequest) Size() (n int)

func (*InfoRequest) String 

func (m *InfoRequest) String() string

func (*InfoRequest) Unmarshal 

func (m *InfoRequest) Unmarshal(dAtA []byte) error

func (*InfoRequest) XXX_DiscardUnknown 

func (m *InfoRequest) XXX_DiscardUnknown()

func (*InfoRequest) XXX_Marshal 

func (m *InfoRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InfoRequest) XXX_Merge 

func (m *InfoRequest) XXX_Merge(src proto.Message)

func (*InfoRequest) XXX_Size 

func (m *InfoRequest) XXX_Size() int

func (*InfoRequest) XXX_Unmarshal 

func (m *InfoRequest) XXX_Unmarshal(b []byte) error

type InfoResponse 

type InfoResponse struct {
	Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Object string `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
	Hash   string `protobuf:"bytes,3,opt,name=hash,proto3" json:"hash,omitempty"`
}

func (*InfoResponse) Descriptor 

func (*InfoResponse) Descriptor() ([]byte, []int)

func (*InfoResponse) GetBucket 

func (m *InfoResponse) GetBucket() string

func (*InfoResponse) GetHash 

func (m *InfoResponse) GetHash() string

func (*InfoResponse) GetObject 

func (m *InfoResponse) GetObject() string

func (*InfoResponse) Marshal 

func (m *InfoResponse) Marshal() (dAtA []byte, err error)

func (*InfoResponse) MarshalTo 

func (m *InfoResponse) MarshalTo(dAtA []byte) (int, error)

func (*InfoResponse) MarshalToSizedBuffer 

func (m *InfoResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*InfoResponse) ProtoMessage 

func (*InfoResponse) ProtoMessage()

func (*InfoResponse) Reset 

func (m *InfoResponse) Reset()

func (*InfoResponse) Size 

func (m *InfoResponse) Size() (n int)

func (*InfoResponse) String 

func (m *InfoResponse) String() string

func (*InfoResponse) Unmarshal 

func (m *InfoResponse) Unmarshal(dAtA []byte) error

func (*InfoResponse) XXX_DiscardUnknown 

func (m *InfoResponse) XXX_DiscardUnknown()

func (*InfoResponse) XXX_Marshal 

func (m *InfoResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*InfoResponse) XXX_Merge 

func (m *InfoResponse) XXX_Merge(src proto.Message)

func (*InfoResponse) XXX_Size 

func (m *InfoResponse) XXX_Size() int

func (*InfoResponse) XXX_Unmarshal 

func (m *InfoResponse) XXX_Unmarshal(b []byte) error

type Ledger 

type Ledger struct {
	// key = bucket name
	Buckets map[string]*LedgerBucketEntry `` /* 155-byte string literal not displayed */
	// key = partID
	MultipartUploads map[string]*MultipartUpload `` /* 173-byte string literal not displayed */
}

Ledger is our internal state keeper, and is responsible for keeping track of buckets, objects, and their corresponding IPFS hashes

func (*Ledger) Descriptor 

func (*Ledger) Descriptor() ([]byte, []int)

func (*Ledger) GetBuckets 

func (m *Ledger) GetBuckets() map[string]*LedgerBucketEntry

func (*Ledger) GetMultipartUploads 

func (m *Ledger) GetMultipartUploads() map[string]*MultipartUpload

func (*Ledger) Marshal 

func (m *Ledger) Marshal() (dAtA []byte, err error)

func (*Ledger) MarshalTo 

func (m *Ledger) MarshalTo(dAtA []byte) (int, error)

func (*Ledger) MarshalToSizedBuffer 

func (m *Ledger) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Ledger) ProtoMessage 

func (*Ledger) ProtoMessage()

func (*Ledger) Reset 

func (m *Ledger) Reset()

func (*Ledger) Size 

func (m *Ledger) Size() (n int)

func (*Ledger) String 

func (m *Ledger) String() string

func (*Ledger) Unmarshal 

func (m *Ledger) Unmarshal(dAtA []byte) error

func (*Ledger) XXX_DiscardUnknown 

func (m *Ledger) XXX_DiscardUnknown()

func (*Ledger) XXX_Marshal 

func (m *Ledger) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Ledger) XXX_Merge 

func (m *Ledger) XXX_Merge(src proto.Message)

func (*Ledger) XXX_Size 

func (m *Ledger) XXX_Size() int

func (*Ledger) XXX_Unmarshal 

func (m *Ledger) XXX_Unmarshal(b []byte) error

type LedgerBucketEntry 

type LedgerBucketEntry struct {
	//if bucket is nil, this entry can be lazy loaded from ifps
	Bucket   *Bucket `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	IpfsHash string  `protobuf:"bytes,2,opt,name=ipfsHash,proto3" json:"ipfsHash,omitempty"`
}

LedgerBucketEntry is an individual entry within the ledger containing information about a bucket

func (*LedgerBucketEntry) Descriptor 

func (*LedgerBucketEntry) Descriptor() ([]byte, []int)

func (*LedgerBucketEntry) GetBucket added in v0.0.2 

func (m *LedgerBucketEntry) GetBucket() *Bucket

func (*LedgerBucketEntry) GetIpfsHash 

func (m *LedgerBucketEntry) GetIpfsHash() string

func (*LedgerBucketEntry) Marshal 

func (m *LedgerBucketEntry) Marshal() (dAtA []byte, err error)

func (*LedgerBucketEntry) MarshalTo 

func (m *LedgerBucketEntry) MarshalTo(dAtA []byte) (int, error)

func (*LedgerBucketEntry) MarshalToSizedBuffer 

func (m *LedgerBucketEntry) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LedgerBucketEntry) ProtoMessage 

func (*LedgerBucketEntry) ProtoMessage()

func (*LedgerBucketEntry) Reset 

func (m *LedgerBucketEntry) Reset()

func (*LedgerBucketEntry) Size 

func (m *LedgerBucketEntry) Size() (n int)

func (*LedgerBucketEntry) String 

func (m *LedgerBucketEntry) String() string

func (*LedgerBucketEntry) Unmarshal 

func (m *LedgerBucketEntry) Unmarshal(dAtA []byte) error

func (*LedgerBucketEntry) XXX_DiscardUnknown 

func (m *LedgerBucketEntry) XXX_DiscardUnknown()

func (*LedgerBucketEntry) XXX_Marshal 

func (m *LedgerBucketEntry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LedgerBucketEntry) XXX_Merge 

func (m *LedgerBucketEntry) XXX_Merge(src proto.Message)

func (*LedgerBucketEntry) XXX_Size 

func (m *LedgerBucketEntry) XXX_Size() int

func (*LedgerBucketEntry) XXX_Unmarshal 

func (m *LedgerBucketEntry) XXX_Unmarshal(b []byte) error

type MultipartUpload 

type MultipartUpload struct {
	ObjectInfo *ObjectInfo `protobuf:"bytes,1,opt,name=objectInfo,proto3" json:"objectInfo,omitempty"`
	Id         string      `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	//map of index to parts
	ObjectParts map[int64]ObjectPartInfo `` /* 154-byte string literal not displayed */
}

func (*MultipartUpload) Descriptor 

func (*MultipartUpload) Descriptor() ([]byte, []int)

func (*MultipartUpload) GetId 

func (m *MultipartUpload) GetId() string

func (*MultipartUpload) GetObjectInfo added in v0.0.2 

func (m *MultipartUpload) GetObjectInfo() *ObjectInfo

func (*MultipartUpload) GetObjectParts 

func (m *MultipartUpload) GetObjectParts() map[int64]ObjectPartInfo

func (*MultipartUpload) Marshal 

func (m *MultipartUpload) Marshal() (dAtA []byte, err error)

func (*MultipartUpload) MarshalTo 

func (m *MultipartUpload) MarshalTo(dAtA []byte) (int, error)

func (*MultipartUpload) MarshalToSizedBuffer 

func (m *MultipartUpload) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MultipartUpload) ProtoMessage 

func (*MultipartUpload) ProtoMessage()

func (*MultipartUpload) Reset 

func (m *MultipartUpload) Reset()

func (*MultipartUpload) Size 

func (m *MultipartUpload) Size() (n int)

func (*MultipartUpload) String 

func (m *MultipartUpload) String() string

func (*MultipartUpload) Unmarshal 

func (m *MultipartUpload) Unmarshal(dAtA []byte) error

func (*MultipartUpload) XXX_DiscardUnknown 

func (m *MultipartUpload) XXX_DiscardUnknown()

func (*MultipartUpload) XXX_Marshal 

func (m *MultipartUpload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MultipartUpload) XXX_Merge 

func (m *MultipartUpload) XXX_Merge(src proto.Message)

func (*MultipartUpload) XXX_Size 

func (m *MultipartUpload) XXX_Size() int

func (*MultipartUpload) XXX_Unmarshal 

func (m *MultipartUpload) XXX_Unmarshal(b []byte) error

type Object 

type Object struct {
	DataHash   string     `protobuf:"bytes,1,opt,name=dataHash,proto3" json:"dataHash,omitempty"`
	ObjectInfo ObjectInfo `protobuf:"bytes,2,opt,name=objectInfo,proto3" json:"objectInfo"`
}

Object is a singular s3 object. the data field contains the actual data referred to by this object, while the objectInfo field is used to contain the information associated wth the object

func (*Object) Descriptor 

func (*Object) Descriptor() ([]byte, []int)

func (*Object) GetDataHash 

func (m *Object) GetDataHash() string

func (*Object) GetObjectInfo 

func (m *Object) GetObjectInfo() ObjectInfo

func (*Object) Marshal 

func (m *Object) Marshal() (dAtA []byte, err error)

func (*Object) MarshalTo 

func (m *Object) MarshalTo(dAtA []byte) (int, error)

func (*Object) MarshalToSizedBuffer 

func (m *Object) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Object) ProtoMessage 

func (*Object) ProtoMessage()

func (*Object) Reset 

func (m *Object) Reset()

func (*Object) Size 

func (m *Object) Size() (n int)

func (*Object) String 

func (m *Object) String() string

func (*Object) Unmarshal 

func (m *Object) Unmarshal(dAtA []byte) error

func (*Object) XXX_DiscardUnknown 

func (m *Object) XXX_DiscardUnknown()

func (*Object) XXX_Marshal 

func (m *Object) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Object) XXX_Merge 

func (m *Object) XXX_Merge(src proto.Message)

func (*Object) XXX_Size 

func (m *Object) XXX_Size() int

func (*Object) XXX_Unmarshal 

func (m *Object) XXX_Unmarshal(b []byte) error

type ObjectInfo 

type ObjectInfo struct {
	Bucket             string            `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Name               string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	ModTime            time.Time         `protobuf:"bytes,3,opt,name=modTime,proto3,stdtime" json:"modTime"`
	Size_              int64             `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	IsDir              bool              `protobuf:"varint,5,opt,name=isDir,proto3" json:"isDir,omitempty"`
	Etag               string            `protobuf:"bytes,6,opt,name=etag,proto3" json:"etag,omitempty"`
	ContentType        string            `protobuf:"bytes,7,opt,name=contentType,proto3" json:"contentType,omitempty"`
	ContentEncoding    string            `protobuf:"bytes,8,opt,name=contentEncoding,proto3" json:"contentEncoding,omitempty"`
	Expires            string            `protobuf:"bytes,9,opt,name=expires,proto3" json:"expires,omitempty"`
	StorageClass       string            `protobuf:"bytes,10,opt,name=storageClass,proto3" json:"storageClass,omitempty"`
	Parts              []ObjectPartInfo  `protobuf:"bytes,11,rep,name=parts,proto3" json:"parts"`
	UserDefined        map[string]string `` /* 164-byte string literal not displayed */
	MetadataOnly       bool              `protobuf:"varint,13,opt,name=metadataOnly,proto3" json:"metadataOnly,omitempty"`
	AccTime            *time.Time        `protobuf:"bytes,14,opt,name=accTime,proto3,stdtime" json:"accTime,omitempty"`
	BackendType        string            `protobuf:"bytes,15,opt,name=backendType,proto3" json:"backendType,omitempty"`
	ContentDisposition string            `protobuf:"bytes,16,opt,name=contentDisposition,proto3" json:"contentDisposition,omitempty"`
	ContentLanguage    string            `protobuf:"bytes,17,opt,name=contentLanguage,proto3" json:"contentLanguage,omitempty"`
}

ObjectInfo contains information about the object

func (*ObjectInfo) Descriptor 

func (*ObjectInfo) Descriptor() ([]byte, []int)

func (*ObjectInfo) GetAccTime 

func (m *ObjectInfo) GetAccTime() *time.Time

func (*ObjectInfo) GetBackendType 

func (m *ObjectInfo) GetBackendType() string

func (*ObjectInfo) GetBucket 

func (m *ObjectInfo) GetBucket() string

func (*ObjectInfo) GetContentDisposition 

func (m *ObjectInfo) GetContentDisposition() string

func (*ObjectInfo) GetContentEncoding 

func (m *ObjectInfo) GetContentEncoding() string

func (*ObjectInfo) GetContentLanguage 

func (m *ObjectInfo) GetContentLanguage() string

func (*ObjectInfo) GetContentType 

func (m *ObjectInfo) GetContentType() string

func (*ObjectInfo) GetEtag 

func (m *ObjectInfo) GetEtag() string

func (*ObjectInfo) GetExpires 

func (m *ObjectInfo) GetExpires() string

func (*ObjectInfo) GetIsDir 

func (m *ObjectInfo) GetIsDir() bool

func (*ObjectInfo) GetMetadataOnly 

func (m *ObjectInfo) GetMetadataOnly() bool

func (*ObjectInfo) GetModTime 

func (m *ObjectInfo) GetModTime() time.Time

func (*ObjectInfo) GetName 

func (m *ObjectInfo) GetName() string

func (*ObjectInfo) GetParts 

func (m *ObjectInfo) GetParts() []ObjectPartInfo

func (*ObjectInfo) GetSize_ 

func (m *ObjectInfo) GetSize_() int64

func (*ObjectInfo) GetStorageClass 

func (m *ObjectInfo) GetStorageClass() string

func (*ObjectInfo) GetUserDefined 

func (m *ObjectInfo) GetUserDefined() map[string]string

func (*ObjectInfo) Marshal 

func (m *ObjectInfo) Marshal() (dAtA []byte, err error)

func (*ObjectInfo) MarshalTo 

func (m *ObjectInfo) MarshalTo(dAtA []byte) (int, error)

func (*ObjectInfo) MarshalToSizedBuffer 

func (m *ObjectInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ObjectInfo) ProtoMessage 

func (*ObjectInfo) ProtoMessage()

func (*ObjectInfo) Reset 

func (m *ObjectInfo) Reset()

func (*ObjectInfo) Size 

func (m *ObjectInfo) Size() (n int)

func (*ObjectInfo) String 

func (m *ObjectInfo) String() string

func (*ObjectInfo) Unmarshal 

func (m *ObjectInfo) Unmarshal(dAtA []byte) error

func (*ObjectInfo) XXX_DiscardUnknown 

func (m *ObjectInfo) XXX_DiscardUnknown()

func (*ObjectInfo) XXX_Marshal 

func (m *ObjectInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ObjectInfo) XXX_Merge 

func (m *ObjectInfo) XXX_Merge(src proto.Message)

func (*ObjectInfo) XXX_Size 

func (m *ObjectInfo) XXX_Size() int

func (*ObjectInfo) XXX_Unmarshal 

func (m *ObjectInfo) XXX_Unmarshal(b []byte) error

type ObjectPartInfo 

type ObjectPartInfo struct {
	// convertable to "int" type in minio.PartInfo
	Number int64 `protobuf:"varint,1,opt,name=number,proto3" json:"number,omitempty"`
	// name of object in bucket
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Date and time at which the part was uploaded.
	LastModified time.Time `protobuf:"bytes,3,opt,name=lastModified,proto3,stdtime" json:"lastModified"`
	// Size in bytes of the part.
	Size_ int64 `protobuf:"varint,4,opt,name=size,proto3" json:"size,omitempty"`
	// Decompressed Size.
	ActualSize int64 `protobuf:"varint,5,opt,name=actualSize,proto3" json:"actualSize,omitempty"`
	// the hash of the data on ipfs
	// in the case of multipart uploads
	// this will refer to a unixfs object
	DataHash string `protobuf:"bytes,6,opt,name=dataHash,proto3" json:"dataHash,omitempty"`
}

ObjectPartInfo contains information an individual object client. For Etag, use dataHash

func (*ObjectPartInfo) Descriptor 

func (*ObjectPartInfo) Descriptor() ([]byte, []int)

func (*ObjectPartInfo) GetActualSize 

func (m *ObjectPartInfo) GetActualSize() int64

func (*ObjectPartInfo) GetDataHash 

func (m *ObjectPartInfo) GetDataHash() string

func (*ObjectPartInfo) GetLastModified added in v0.0.3 

func (m *ObjectPartInfo) GetLastModified() time.Time

func (*ObjectPartInfo) GetName 

func (m *ObjectPartInfo) GetName() string

func (*ObjectPartInfo) GetNumber 

func (m *ObjectPartInfo) GetNumber() int64

func (*ObjectPartInfo) GetSize_ 

func (m *ObjectPartInfo) GetSize_() int64

func (*ObjectPartInfo) Marshal 

func (m *ObjectPartInfo) Marshal() (dAtA []byte, err error)

func (*ObjectPartInfo) MarshalTo 

func (m *ObjectPartInfo) MarshalTo(dAtA []byte) (int, error)

func (*ObjectPartInfo) MarshalToSizedBuffer 

func (m *ObjectPartInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ObjectPartInfo) ProtoMessage 

func (*ObjectPartInfo) ProtoMessage()

func (*ObjectPartInfo) Reset 

func (m *ObjectPartInfo) Reset()

func (*ObjectPartInfo) Size 

func (m *ObjectPartInfo) Size() (n int)

func (*ObjectPartInfo) String 

func (m *ObjectPartInfo) String() string

func (*ObjectPartInfo) Unmarshal 

func (m *ObjectPartInfo) Unmarshal(dAtA []byte) error

func (*ObjectPartInfo) XXX_DiscardUnknown 

func (m *ObjectPartInfo) XXX_DiscardUnknown()

func (*ObjectPartInfo) XXX_Marshal 

func (m *ObjectPartInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ObjectPartInfo) XXX_Merge 

func (m *ObjectPartInfo) XXX_Merge(src proto.Message)

func (*ObjectPartInfo) XXX_Size 

func (m *ObjectPartInfo) XXX_Size() int

func (*ObjectPartInfo) XXX_Unmarshal 

func (m *ObjectPartInfo) XXX_Unmarshal(b []byte) error

type TEMX 

type TEMX struct {
	HTTPAddr  string
	GRPCAddr  string
	DSType    DSType
	DSPath    string
	CrdtTopic string
	XAddr     string
	Insecure  bool // whether or not we have an insecure connection to TemporalX
}

TEMX implements a MinIO gateway on top of TemporalX

func (*TEMX) Name 

func (g *TEMX) Name() string

Name returns the name of the TemporalX gateway backend

func (*TEMX) NewGatewayLayer 

func (g *TEMX) NewGatewayLayer(creds auth.Credentials) (minio.ObjectLayer, error)

NewGatewayLayer creates a minio gateway layer powered y TemporalX

func (*TEMX) Production 

func (g *TEMX) Production() bool

Production indicates that this backend is suitable for production use

type UnimplementedInfoAPIServer 

type UnimplementedInfoAPIServer struct {
}

UnimplementedInfoAPIServer can be embedded to have forward compatible implementations.

func (*UnimplementedInfoAPIServer) GetHash 

func (*UnimplementedInfoAPIServer) GetHash(ctx context.Context, req *InfoRequest) (*InfoResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.