8d8350fea7
* port changes * Task monitor and setup merge from the staging * Restructure + additional interface * Add NewOverlayClient * integrated DHT client interface * added test for interface * PR comments addressed * lint issue * added generated protobuf * adding new interface * added the interface framework * deleted file * fixes compilation errors and integrates new dhtcclient interface * merged netstat latest changes and dht new interface chagnes * fixed the address's port * adding comments * PR comments addressed * netclient interface dial method added * rename and integrated transportclient with minio gateway * rename and code clean up * made changes based on the Dennis's changes on the kad-client * Code review comment changes based on kaloyan review comments * reverted the changes to be similar to master * removed unused file * renamed to transportclient * added the review changes * store the address of the client * updates per the code review comments, changes-> added error retry connection attempt logic, added error conditions including nil parameters * updated the test case to test the bad address passed condition * updated the code per code review comments * Bolt backed overlay cache (#94) * wip * add separate `Process` tests for bolt and redis-backed overlay * more testing * fix gitignore * fix linter error * goimports goimports GOIMPORTS GoImPortS!!!! * fix port madness * forgot to add * add `mux` as handler and shorten context timeouts * gofreakingimports * fix comments * refactor test & add logger/monkit registry * debugging travis * add comment * Set redisAddress to empty string for bolt-test * travis experiment * refactoring tests * Merge remote-tracking branch 'upstream/master' into bolt-backed-overlay-cache * Automatically build, tag and push docker images on merge to master (#103) * port changes * build overlay on successful merge to master * fixes to Makefile * permissions * dep ensure * gopath * let's try vgo * remove dep * maybe alpine is the issue * tagging go version on build * stupid vgo * vgo * adding tags to push * quotes * local linting fixes & stupid travis * prepend storjlabs to docker tag (#108) * port changes * fixing tag name * Use continue instead of return in table tests (#106) I did a dumb mistake for some of the table tests, which made some of the test cases not being executed. * pkg/kademlia tests and restructuring (#97) * port changes * Merge remote-tracking branch 'upstream/master' * Merge remote-tracking branch 'upstream/master' * Merge remote-tracking branch 'upstream/master' * files created * Merge remote-tracking branch 'upstream/master' into coyle/kad-tests * wip * Merge remote-tracking branch 'upstream/master' into coyle/kad-tests * wip * remove bkad dependencie from tests * wip * wip * wip * wip * wip * updated coyle/kademlia * wip * cleanup * ports * overlay upgraded * linter fixes * piecestore kademlia newID * add changes from kad demo * PR comments addresses * go func * force travis build * fixed merge conflicts * fixed merge conflicts * Merge branch 'coyle/kad-tests' of https://github.com/coyle/storj into coyle/kad-tests * linter issues * linting issues * fixed merge conflicts * linter is stupid * Coyle/docker fix (#109) * port changes * Merge remote-tracking branch 'upstream/master' * Merge remote-tracking branch 'upstream/master' * Merge remote-tracking branch 'upstream/master' * Merge remote-tracking branch 'upstream/master' * Merge remote-tracking branch 'upstream/master' * Merge branch 'master' of https://github.com/storj/storj * fixing tag name * no idea * testing * changes * testing on travis * testing * changes to travis build * new approach * Merge branch 'master' into coyle/docker-fix * hardcode version (#111) * hardcode version * adding coveralls / code coverage (#112) * adding coveralls * adding code coverage badge * fixing badges * verbose * swap tests and coverage * extra line * maybe * maybe * moar * gover maybe * testing * cleanup * protos/netstate: remove stuff we're not using (#100) * protos/netstate: remove stuff we're not using * protos/netstate: add metadata field for segmentstore * fix netstate client test * pkg/process: start replacing pkg/process with cobra helpers (#98) * Implement psclient interface (#107) * Implement psclient interface * Add string method to pieceID type * try to fix linter errors * Whoops missed an error * More linter errors * Typo * Lol double typo * Get everything working, begin adding tests for psclient rpc * goimports * Forgot to change the piecestore cli when changed the piecestore code * Fix CLI * remove ID length, added validator to pieceID * Move grpc ranger to client Change client PUT api to take a reader rather than return a writer * GRPCRanger -> PieceRanger; Make PieceRanger a RangeCloser * Forgot to remove offset * Added message upon successful store * Do that thing dennis and kaloyan wanted * goimports * Make closeConn a part of the interface for psclient * Use interface * Removed uneccessary new lines * goimport * Whoops * Actually we don't want to use the interface in Piece Ranger * Renamed piecestore in examples to piecestore-client; moved piecestore-cli to examples * Make comments look nicer * modified transport client based on the the design discussion * modified transport client based on the the design discussion * added the as discussed connection cache interface functionality * added the as discussed connection cache interface functionality * transport client changes * transport client per code review changes * per the code review comments * transport client incorporates review comments * fixes lint warnings * lint warning fixes....client interface has to be Client * initial draft of Objectstore * transport client review changes * client.go changes * transport.go changes * added test case * added test cases * streams iface * comment fix * object store changes * comment fix * initialized the objectstore in gw * Added PutObject with test support for encryption file * added object store test cases * tested & integrated the objectstore with miniogw * handled the ranger and paths * indentation change * Kalyon's code review comments resolution implemented after the 30min code review meeting * Compilation error fix * fixes the tavis build warnings * corrects the ListObject return type to be slice of slice * corrects the ListObject return type to be slice of slice * added the serialization using protobuf * added the unmarshalling of data in getobject() * Jt's Review comments * Kaloyan's review comments, moved the unmarshalling logic and other minor code indentation fixes * more code reivew * more code reivew * Changes the expiration time to zeroTime and added error check in putObject function * Changes the expiration time to zeroTime and added error check in putObject function * minor warning fix- had to add a comment and fix the wording * added a TODO comment per kaloyan * code clean up removed unused variables
203 lines
7.3 KiB
Go
203 lines
7.3 KiB
Go
// Code generated by protoc-gen-go. DO NOT EDIT.
|
|
// source: meta.proto
|
|
|
|
package objects
|
|
|
|
import proto "github.com/golang/protobuf/proto"
|
|
import fmt "fmt"
|
|
import 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.ProtoPackageIsVersion2 // please upgrade the proto package
|
|
|
|
type StorjMetaInfo struct {
|
|
// Name of the bucket.
|
|
Bucket string `protobuf:"bytes,1,opt,name=Bucket,proto3" json:"Bucket,omitempty"`
|
|
// Name of the object.
|
|
Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
|
|
// Total object size.
|
|
Size int64 `protobuf:"varint,4,opt,name=Size,proto3" json:"Size,omitempty"`
|
|
// IsDir indicates if the object is prefix.
|
|
IsDir bool `protobuf:"varint,5,opt,name=IsDir,proto3" json:"IsDir,omitempty"`
|
|
// Hex encoded unique entity tag of the object.
|
|
ETag string `protobuf:"bytes,6,opt,name=ETag,proto3" json:"ETag,omitempty"`
|
|
// A standard MIME type describing the format of the object.
|
|
ContentType string `protobuf:"bytes,7,opt,name=ContentType,proto3" json:"ContentType,omitempty"`
|
|
// Specifies what content encodings have been applied to the object and thus
|
|
// what decoding mechanisms must be applied to obtain the object referenced
|
|
// by the Content-Type header field.
|
|
ContentEncoding string `protobuf:"bytes,8,opt,name=ContentEncoding,proto3" json:"ContentEncoding,omitempty"`
|
|
// Specify object storage class
|
|
StorageClass string `protobuf:"bytes,9,opt,name=StorageClass,proto3" json:"StorageClass,omitempty"`
|
|
// add custom fields here
|
|
Metadata map[string]string `protobuf:"bytes,10,rep,name=metadata,proto3" json:"metadata,omitempty" protobuf_key:"bytes,1,opt,name=key,proto3" protobuf_val:"bytes,2,opt,name=value,proto3"`
|
|
XXX_NoUnkeyedLiteral struct{} `json:"-"`
|
|
XXX_unrecognized []byte `json:"-"`
|
|
XXX_sizecache int32 `json:"-"`
|
|
}
|
|
|
|
func (m *StorjMetaInfo) Reset() { *m = StorjMetaInfo{} }
|
|
func (m *StorjMetaInfo) String() string { return proto.CompactTextString(m) }
|
|
func (*StorjMetaInfo) ProtoMessage() {}
|
|
func (*StorjMetaInfo) Descriptor() ([]byte, []int) {
|
|
return fileDescriptor_meta_e10250e4ca229d04, []int{0}
|
|
}
|
|
func (m *StorjMetaInfo) XXX_Unmarshal(b []byte) error {
|
|
return xxx_messageInfo_StorjMetaInfo.Unmarshal(m, b)
|
|
}
|
|
func (m *StorjMetaInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
|
return xxx_messageInfo_StorjMetaInfo.Marshal(b, m, deterministic)
|
|
}
|
|
func (dst *StorjMetaInfo) XXX_Merge(src proto.Message) {
|
|
xxx_messageInfo_StorjMetaInfo.Merge(dst, src)
|
|
}
|
|
func (m *StorjMetaInfo) XXX_Size() int {
|
|
return xxx_messageInfo_StorjMetaInfo.Size(m)
|
|
}
|
|
func (m *StorjMetaInfo) XXX_DiscardUnknown() {
|
|
xxx_messageInfo_StorjMetaInfo.DiscardUnknown(m)
|
|
}
|
|
|
|
var xxx_messageInfo_StorjMetaInfo proto.InternalMessageInfo
|
|
|
|
func (m *StorjMetaInfo) GetBucket() string {
|
|
if m != nil {
|
|
return m.Bucket
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *StorjMetaInfo) GetName() string {
|
|
if m != nil {
|
|
return m.Name
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *StorjMetaInfo) GetSize() int64 {
|
|
if m != nil {
|
|
return m.Size
|
|
}
|
|
return 0
|
|
}
|
|
|
|
func (m *StorjMetaInfo) GetIsDir() bool {
|
|
if m != nil {
|
|
return m.IsDir
|
|
}
|
|
return false
|
|
}
|
|
|
|
func (m *StorjMetaInfo) GetETag() string {
|
|
if m != nil {
|
|
return m.ETag
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *StorjMetaInfo) GetContentType() string {
|
|
if m != nil {
|
|
return m.ContentType
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *StorjMetaInfo) GetContentEncoding() string {
|
|
if m != nil {
|
|
return m.ContentEncoding
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *StorjMetaInfo) GetStorageClass() string {
|
|
if m != nil {
|
|
return m.StorageClass
|
|
}
|
|
return ""
|
|
}
|
|
|
|
func (m *StorjMetaInfo) GetMetadata() map[string]string {
|
|
if m != nil {
|
|
return m.Metadata
|
|
}
|
|
return nil
|
|
}
|
|
|
|
// Object Info Meta data
|
|
type MetaObjInfo struct {
|
|
Objinfo *StorjMetaInfo `protobuf:"bytes,1,opt,name=objinfo,proto3" json:"objinfo,omitempty"`
|
|
XXX_NoUnkeyedLiteral struct{} `json:"-"`
|
|
XXX_unrecognized []byte `json:"-"`
|
|
XXX_sizecache int32 `json:"-"`
|
|
}
|
|
|
|
func (m *MetaObjInfo) Reset() { *m = MetaObjInfo{} }
|
|
func (m *MetaObjInfo) String() string { return proto.CompactTextString(m) }
|
|
func (*MetaObjInfo) ProtoMessage() {}
|
|
func (*MetaObjInfo) Descriptor() ([]byte, []int) {
|
|
return fileDescriptor_meta_e10250e4ca229d04, []int{1}
|
|
}
|
|
func (m *MetaObjInfo) XXX_Unmarshal(b []byte) error {
|
|
return xxx_messageInfo_MetaObjInfo.Unmarshal(m, b)
|
|
}
|
|
func (m *MetaObjInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) {
|
|
return xxx_messageInfo_MetaObjInfo.Marshal(b, m, deterministic)
|
|
}
|
|
func (dst *MetaObjInfo) XXX_Merge(src proto.Message) {
|
|
xxx_messageInfo_MetaObjInfo.Merge(dst, src)
|
|
}
|
|
func (m *MetaObjInfo) XXX_Size() int {
|
|
return xxx_messageInfo_MetaObjInfo.Size(m)
|
|
}
|
|
func (m *MetaObjInfo) XXX_DiscardUnknown() {
|
|
xxx_messageInfo_MetaObjInfo.DiscardUnknown(m)
|
|
}
|
|
|
|
var xxx_messageInfo_MetaObjInfo proto.InternalMessageInfo
|
|
|
|
func (m *MetaObjInfo) GetObjinfo() *StorjMetaInfo {
|
|
if m != nil {
|
|
return m.Objinfo
|
|
}
|
|
return nil
|
|
}
|
|
|
|
func init() {
|
|
proto.RegisterType((*StorjMetaInfo)(nil), "objects.StorjMetaInfo")
|
|
proto.RegisterMapType((map[string]string)(nil), "objects.StorjMetaInfo.MetadataEntry")
|
|
proto.RegisterType((*MetaObjInfo)(nil), "objects.MetaObjInfo")
|
|
}
|
|
|
|
func init() { proto.RegisterFile("meta.proto", fileDescriptor_meta_e10250e4ca229d04) }
|
|
|
|
var fileDescriptor_meta_e10250e4ca229d04 = []byte{
|
|
// 295 bytes of a gzipped FileDescriptorProto
|
|
0x1f, 0x8b, 0x08, 0x00, 0x00, 0x00, 0x00, 0x00, 0x02, 0xff, 0x6c, 0x51, 0x41, 0x4b, 0xf3, 0x40,
|
|
0x10, 0x25, 0x49, 0x9b, 0xa6, 0x93, 0xaf, 0x7c, 0xb2, 0x48, 0x59, 0x3c, 0x85, 0xe0, 0x21, 0xa7,
|
|
0x20, 0xf5, 0x22, 0x7a, 0x50, 0xac, 0x39, 0xf4, 0x50, 0x85, 0xb4, 0x7f, 0x60, 0x93, 0x6e, 0x43,
|
|
0xd2, 0x76, 0xb7, 0x24, 0x53, 0x21, 0xfe, 0x62, 0x7f, 0x86, 0xec, 0x66, 0x2b, 0x46, 0xbc, 0xbd,
|
|
0xf7, 0xe6, 0x3d, 0x98, 0x79, 0x03, 0x70, 0xe0, 0xc8, 0xe2, 0x63, 0x2d, 0x51, 0x92, 0x91, 0xcc,
|
|
0x2a, 0x9e, 0x63, 0x13, 0x7e, 0xda, 0x30, 0x59, 0xa1, 0xac, 0xab, 0x25, 0x47, 0xb6, 0x10, 0x5b,
|
|
0x49, 0xa6, 0xe0, 0x3e, 0x9f, 0xf2, 0x1d, 0x47, 0x6a, 0x05, 0x56, 0x34, 0x4e, 0x0d, 0x23, 0x04,
|
|
0x06, 0xaf, 0xec, 0xc0, 0xa9, 0xad, 0x55, 0x8d, 0x95, 0xb6, 0x2a, 0x3f, 0x38, 0x1d, 0x04, 0x56,
|
|
0xe4, 0xa4, 0x1a, 0x93, 0x4b, 0x18, 0x2e, 0x9a, 0x97, 0xb2, 0xa6, 0xc3, 0xc0, 0x8a, 0xbc, 0xb4,
|
|
0x23, 0xca, 0x99, 0xac, 0x59, 0x41, 0xdd, 0x2e, 0xad, 0x30, 0x09, 0xc0, 0x9f, 0x4b, 0x81, 0x5c,
|
|
0xe0, 0xba, 0x3d, 0x72, 0x3a, 0xd2, 0xa3, 0x9f, 0x12, 0x89, 0xe0, 0xbf, 0xa1, 0x89, 0xc8, 0xe5,
|
|
0xa6, 0x14, 0x05, 0xf5, 0xb4, 0xeb, 0xb7, 0x4c, 0x42, 0xf8, 0xa7, 0xce, 0x60, 0x05, 0x9f, 0xef,
|
|
0x59, 0xd3, 0xd0, 0xb1, 0xb6, 0xf5, 0x34, 0xf2, 0x04, 0x9e, 0xaa, 0x60, 0xc3, 0x90, 0x51, 0x08,
|
|
0x9c, 0xc8, 0x9f, 0x5d, 0xc7, 0xa6, 0x87, 0xb8, 0xd7, 0x41, 0xbc, 0x34, 0xb6, 0x44, 0x60, 0xdd,
|
|
0xa6, 0xdf, 0xa9, 0xab, 0x07, 0x98, 0xf4, 0x46, 0xe4, 0x02, 0x9c, 0x1d, 0x6f, 0x4d, 0x53, 0x0a,
|
|
0xaa, 0xf3, 0xdf, 0xd9, 0xfe, 0x74, 0xee, 0xa9, 0x23, 0xf7, 0xf6, 0x9d, 0x15, 0x3e, 0x82, 0xaf,
|
|
0xc2, 0x6f, 0x59, 0xa5, 0x7b, 0xbe, 0x01, 0xf5, 0x84, 0x52, 0x6c, 0xa5, 0x8e, 0xfb, 0xb3, 0xe9,
|
|
0xdf, 0xcb, 0xa4, 0x67, 0x5b, 0xe6, 0xea, 0xdf, 0xdd, 0x7e, 0x05, 0x00, 0x00, 0xff, 0xff, 0x22,
|
|
0x25, 0xc4, 0x28, 0xc9, 0x01, 0x00, 0x00,
|
|
}
|