pb

package
v0.13.0 Latest Latest
Warning

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

Go to latest
Published: Jun 11, 2019 License: AGPL-3.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var NodeTransport_name = map[int32]string{
	0: "TCP_TLS_GRPC",
}
View Source
var NodeTransport_value = map[string]int32{
	"TCP_TLS_GRPC": 0,
}
View Source
var NodeType_name = map[int32]string{
	0: "INVALID",
	1: "SATELLITE",
	2: "STORAGE",
	3: "UPLINK",
	4: "BOOTSTRAP",
}
View Source
var NodeType_value = map[string]int32{
	"INVALID":   0,
	"SATELLITE": 1,
	"STORAGE":   2,
	"UPLINK":    3,
	"BOOTSTRAP": 4,
}
View Source
var PieceAction_name = map[int32]string{
	0: "INVALID",
	1: "PUT",
	2: "GET",
	3: "GET_AUDIT",
	4: "GET_REPAIR",
	5: "PUT_REPAIR",
	6: "DELETE",
}
View Source
var PieceAction_value = map[string]int32{
	"INVALID":    0,
	"PUT":        1,
	"GET":        2,
	"GET_AUDIT":  3,
	"GET_REPAIR": 4,
	"PUT_REPAIR": 5,
	"DELETE":     6,
}
View Source
var Pointer_DataType_name = map[int32]string{
	0: "INLINE",
	1: "REMOTE",
}
View Source
var Pointer_DataType_value = map[string]int32{
	"INLINE": 0,
	"REMOTE": 1,
}
View Source
var RedundancyScheme_SchemeType_name = map[int32]string{
	0: "RS",
}
View Source
var RedundancyScheme_SchemeType_value = map[string]int32{
	"RS": 0,
}
View Source
var Restriction_Operand_name = map[int32]string{
	0: "FREE_BANDWIDTH",
	1: "FREE_DISK",
}
View Source
var Restriction_Operand_value = map[string]int32{
	"FREE_BANDWIDTH": 0,
	"FREE_DISK":      1,
}
View Source
var Restriction_Operator_name = map[int32]string{
	0: "LT",
	1: "EQ",
	2: "GT",
	3: "LTE",
	4: "GTE",
}
View Source
var Restriction_Operator_value = map[string]int32{
	"LT":  0,
	"EQ":  1,
	"GT":  2,
	"LTE": 3,
	"GTE": 4,
}
View Source
var SettlementResponse_Status_name = map[int32]string{
	0: "INVALID",
	1: "ACCEPTED",
	2: "REJECTED",
}
View Source
var SettlementResponse_Status_value = map[string]int32{
	"INVALID":  0,
	"ACCEPTED": 1,
	"REJECTED": 2,
}

Functions

func AddressEqual

func AddressEqual(a1, a2 *NodeAddress) bool

AddressEqual compares two node addresses

func Equal

func Equal(msg1, msg2 proto.Message) bool

Equal compares two Protobuf messages via serialization

func NodesToIDs

func NodesToIDs(nodes []*Node) storj.NodeIDList

NodesToIDs extracts Node-s into a list of ids

func RegisterCertificatesServer

func RegisterCertificatesServer(s *grpc.Server, srv CertificatesServer)

func RegisterHealthInspectorServer

func RegisterHealthInspectorServer(s *grpc.Server, srv HealthInspectorServer)

func RegisterIrreparableInspectorServer

func RegisterIrreparableInspectorServer(s *grpc.Server, srv IrreparableInspectorServer)

func RegisterKadInspectorServer

func RegisterKadInspectorServer(s *grpc.Server, srv KadInspectorServer)

func RegisterMetainfoServer

func RegisterMetainfoServer(s *grpc.Server, srv MetainfoServer)

func RegisterNodesServer

func RegisterNodesServer(s *grpc.Server, srv NodesServer)

func RegisterOrdersServer

func RegisterOrdersServer(s *grpc.Server, srv OrdersServer)

func RegisterOverlayInspectorServer

func RegisterOverlayInspectorServer(s *grpc.Server, srv OverlayInspectorServer)

func RegisterPieceStoreInspectorServer

func RegisterPieceStoreInspectorServer(s *grpc.Server, srv PieceStoreInspectorServer)

func RegisterPiecestoreServer

func RegisterPiecestoreServer(s *grpc.Server, srv PiecestoreServer)

func RegisterVouchersServer added in v0.12.0

func RegisterVouchersServer(s *grpc.Server, srv VouchersServer)

Types

type AddressedOrderLimit

type AddressedOrderLimit struct {
	Limit                *OrderLimit2 `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 (*AddressedOrderLimit) Descriptor

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

func (*AddressedOrderLimit) GetLimit

func (m *AddressedOrderLimit) GetLimit() *OrderLimit2

func (*AddressedOrderLimit) GetStorageNodeAddress

func (m *AddressedOrderLimit) GetStorageNodeAddress() *NodeAddress

func (*AddressedOrderLimit) ProtoMessage

func (*AddressedOrderLimit) ProtoMessage()

func (*AddressedOrderLimit) Reset

func (m *AddressedOrderLimit) Reset()

func (*AddressedOrderLimit) String

func (m *AddressedOrderLimit) String() string

func (*AddressedOrderLimit) XXX_DiscardUnknown

func (m *AddressedOrderLimit) XXX_DiscardUnknown()

func (*AddressedOrderLimit) XXX_Marshal

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

func (*AddressedOrderLimit) XXX_Merge

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

func (*AddressedOrderLimit) XXX_Size

func (m *AddressedOrderLimit) XXX_Size() int

func (*AddressedOrderLimit) XXX_Unmarshal

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

type Bucket

type Bucket struct {
	Nodes                []*Node  `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Bucket) Descriptor

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

func (*Bucket) GetNodes

func (m *Bucket) GetNodes() []*Node

func (*Bucket) ProtoMessage

func (*Bucket) ProtoMessage()

func (*Bucket) Reset

func (m *Bucket) Reset()

func (*Bucket) String

func (m *Bucket) String() string

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 BucketList

type BucketList struct {
	Nodes                []*Node  `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BucketList) Descriptor

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

func (*BucketList) GetNodes

func (m *BucketList) GetNodes() []*Node

func (*BucketList) ProtoMessage

func (*BucketList) ProtoMessage()

func (*BucketList) Reset

func (m *BucketList) Reset()

func (*BucketList) String

func (m *BucketList) String() string

func (*BucketList) XXX_DiscardUnknown

func (m *BucketList) XXX_DiscardUnknown()

func (*BucketList) XXX_Marshal

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

func (*BucketList) XXX_Merge

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

func (*BucketList) XXX_Size

func (m *BucketList) XXX_Size() int

func (*BucketList) XXX_Unmarshal

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

type CertificatesClient

type CertificatesClient interface {
	Sign(ctx context.Context, in *SigningRequest, opts ...grpc.CallOption) (*SigningResponse, error)
}

CertificatesClient is the client API for Certificates service.

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

func NewCertificatesClient

func NewCertificatesClient(cc *grpc.ClientConn) CertificatesClient

type CertificatesServer

type CertificatesServer interface {
	Sign(context.Context, *SigningRequest) (*SigningResponse, error)
}

CertificatesServer is the server API for Certificates service.

type CountNodesRequest

type CountNodesRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CountNodesRequest) Descriptor

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

func (*CountNodesRequest) ProtoMessage

func (*CountNodesRequest) ProtoMessage()

func (*CountNodesRequest) Reset

func (m *CountNodesRequest) Reset()

func (*CountNodesRequest) String

func (m *CountNodesRequest) String() string

func (*CountNodesRequest) XXX_DiscardUnknown

func (m *CountNodesRequest) XXX_DiscardUnknown()

func (*CountNodesRequest) XXX_Marshal

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

func (*CountNodesRequest) XXX_Merge

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

func (*CountNodesRequest) XXX_Size

func (m *CountNodesRequest) XXX_Size() int

func (*CountNodesRequest) XXX_Unmarshal

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

type CountNodesResponse

type CountNodesResponse struct {
	Count                int64    `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CountNodes

func (*CountNodesResponse) Descriptor

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

func (*CountNodesResponse) GetCount

func (m *CountNodesResponse) GetCount() int64

func (*CountNodesResponse) ProtoMessage

func (*CountNodesResponse) ProtoMessage()

func (*CountNodesResponse) Reset

func (m *CountNodesResponse) Reset()

func (*CountNodesResponse) String

func (m *CountNodesResponse) String() string

func (*CountNodesResponse) XXX_DiscardUnknown

func (m *CountNodesResponse) XXX_DiscardUnknown()

func (*CountNodesResponse) XXX_Marshal

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

func (*CountNodesResponse) XXX_Merge

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

func (*CountNodesResponse) XXX_Size

func (m *CountNodesResponse) XXX_Size() int

func (*CountNodesResponse) XXX_Unmarshal

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

type CreateStatsRequest

type CreateStatsRequest struct {
	NodeId               NodeID   `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3,customtype=NodeID" json:"node_id"`
	AuditCount           int64    `protobuf:"varint,2,opt,name=audit_count,json=auditCount,proto3" json:"audit_count,omitempty"`
	AuditSuccessCount    int64    `protobuf:"varint,3,opt,name=audit_success_count,json=auditSuccessCount,proto3" json:"audit_success_count,omitempty"`
	UptimeCount          int64    `protobuf:"varint,4,opt,name=uptime_count,json=uptimeCount,proto3" json:"uptime_count,omitempty"`
	UptimeSuccessCount   int64    `protobuf:"varint,5,opt,name=uptime_success_count,json=uptimeSuccessCount,proto3" json:"uptime_success_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

CreateStats

func (*CreateStatsRequest) Descriptor

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

func (*CreateStatsRequest) GetAuditCount

func (m *CreateStatsRequest) GetAuditCount() int64

func (*CreateStatsRequest) GetAuditSuccessCount

func (m *CreateStatsRequest) GetAuditSuccessCount() int64

func (*CreateStatsRequest) GetUptimeCount

func (m *CreateStatsRequest) GetUptimeCount() int64

func (*CreateStatsRequest) GetUptimeSuccessCount

func (m *CreateStatsRequest) GetUptimeSuccessCount() int64

func (*CreateStatsRequest) ProtoMessage

func (*CreateStatsRequest) ProtoMessage()

func (*CreateStatsRequest) Reset

func (m *CreateStatsRequest) Reset()

func (*CreateStatsRequest) String

func (m *CreateStatsRequest) String() string

func (*CreateStatsRequest) XXX_DiscardUnknown

func (m *CreateStatsRequest) XXX_DiscardUnknown()

func (*CreateStatsRequest) XXX_Marshal

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

func (*CreateStatsRequest) XXX_Merge

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

func (*CreateStatsRequest) XXX_Size

func (m *CreateStatsRequest) XXX_Size() int

func (*CreateStatsRequest) XXX_Unmarshal

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

type CreateStatsResponse

type CreateStatsResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateStatsResponse) Descriptor

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

func (*CreateStatsResponse) ProtoMessage

func (*CreateStatsResponse) ProtoMessage()

func (*CreateStatsResponse) Reset

func (m *CreateStatsResponse) Reset()

func (*CreateStatsResponse) String

func (m *CreateStatsResponse) String() string

func (*CreateStatsResponse) XXX_DiscardUnknown

func (m *CreateStatsResponse) XXX_DiscardUnknown()

func (*CreateStatsResponse) XXX_Marshal

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

func (*CreateStatsResponse) XXX_Merge

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

func (*CreateStatsResponse) XXX_Size

func (m *CreateStatsResponse) XXX_Size() int

func (*CreateStatsResponse) XXX_Unmarshal

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

type DashboardRequest

type DashboardRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DashboardRequest) Descriptor

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

func (*DashboardRequest) ProtoMessage

func (*DashboardRequest) ProtoMessage()

func (*DashboardRequest) Reset

func (m *DashboardRequest) Reset()

func (*DashboardRequest) String

func (m *DashboardRequest) String() string

func (*DashboardRequest) XXX_DiscardUnknown

func (m *DashboardRequest) XXX_DiscardUnknown()

func (*DashboardRequest) XXX_Marshal

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

func (*DashboardRequest) XXX_Merge

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

func (*DashboardRequest) XXX_Size

func (m *DashboardRequest) XXX_Size() int

func (*DashboardRequest) XXX_Unmarshal

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

type DashboardResponse

type DashboardResponse struct {
	NodeId               NodeID               `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3,customtype=NodeID" json:"node_id"`
	NodeConnections      int64                `protobuf:"varint,2,opt,name=node_connections,json=nodeConnections,proto3" json:"node_connections,omitempty"`
	BootstrapAddress     string               `protobuf:"bytes,3,opt,name=bootstrap_address,json=bootstrapAddress,proto3" json:"bootstrap_address,omitempty"`
	InternalAddress      string               `protobuf:"bytes,4,opt,name=internal_address,json=internalAddress,proto3" json:"internal_address,omitempty"`
	ExternalAddress      string               `protobuf:"bytes,5,opt,name=external_address,json=externalAddress,proto3" json:"external_address,omitempty"`
	Stats                *StatSummaryResponse `protobuf:"bytes,6,opt,name=stats,proto3" json:"stats,omitempty"`
	Uptime               *duration.Duration   `protobuf:"bytes,7,opt,name=uptime,proto3" json:"uptime,omitempty"`
	LastPinged           *timestamp.Timestamp `protobuf:"bytes,8,opt,name=last_pinged,json=lastPinged,proto3" json:"last_pinged,omitempty"`
	LastQueried          *timestamp.Timestamp `protobuf:"bytes,9,opt,name=last_queried,json=lastQueried,proto3" json:"last_queried,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*DashboardResponse) Descriptor

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

func (*DashboardResponse) GetBootstrapAddress

func (m *DashboardResponse) GetBootstrapAddress() string

func (*DashboardResponse) GetExternalAddress

func (m *DashboardResponse) GetExternalAddress() string

func (*DashboardResponse) GetInternalAddress

func (m *DashboardResponse) GetInternalAddress() string

func (*DashboardResponse) GetLastPinged

func (m *DashboardResponse) GetLastPinged() *timestamp.Timestamp

func (*DashboardResponse) GetLastQueried

func (m *DashboardResponse) GetLastQueried() *timestamp.Timestamp

func (*DashboardResponse) GetNodeConnections

func (m *DashboardResponse) GetNodeConnections() int64

func (*DashboardResponse) GetStats

func (m *DashboardResponse) GetStats() *StatSummaryResponse

func (*DashboardResponse) GetUptime

func (m *DashboardResponse) GetUptime() *duration.Duration

func (*DashboardResponse) ProtoMessage

func (*DashboardResponse) ProtoMessage()

func (*DashboardResponse) Reset

func (m *DashboardResponse) Reset()

func (*DashboardResponse) String

func (m *DashboardResponse) String() string

func (*DashboardResponse) XXX_DiscardUnknown

func (m *DashboardResponse) XXX_DiscardUnknown()

func (*DashboardResponse) XXX_Marshal

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

func (*DashboardResponse) XXX_Merge

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

func (*DashboardResponse) XXX_Size

func (m *DashboardResponse) XXX_Size() int

func (*DashboardResponse) XXX_Unmarshal

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

type DumpNodesRequest

type DumpNodesRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DumpNodesRequest) Descriptor

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

func (*DumpNodesRequest) ProtoMessage

func (*DumpNodesRequest) ProtoMessage()

func (*DumpNodesRequest) Reset

func (m *DumpNodesRequest) Reset()

func (*DumpNodesRequest) String

func (m *DumpNodesRequest) String() string

func (*DumpNodesRequest) XXX_DiscardUnknown

func (m *DumpNodesRequest) XXX_DiscardUnknown()

func (*DumpNodesRequest) XXX_Marshal

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

func (*DumpNodesRequest) XXX_Merge

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

func (*DumpNodesRequest) XXX_Size

func (m *DumpNodesRequest) XXX_Size() int

func (*DumpNodesRequest) XXX_Unmarshal

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

type DumpNodesResponse

type DumpNodesResponse struct {
	Nodes                []*Node  `protobuf:"bytes,1,rep,name=nodes,proto3" json:"nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DumpNodesResponse) Descriptor

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

func (*DumpNodesResponse) GetNodes

func (m *DumpNodesResponse) GetNodes() []*Node

func (*DumpNodesResponse) ProtoMessage

func (*DumpNodesResponse) ProtoMessage()

func (*DumpNodesResponse) Reset

func (m *DumpNodesResponse) Reset()

func (*DumpNodesResponse) String

func (m *DumpNodesResponse) String() string

func (*DumpNodesResponse) XXX_DiscardUnknown

func (m *DumpNodesResponse) XXX_DiscardUnknown()

func (*DumpNodesResponse) XXX_Marshal

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

func (*DumpNodesResponse) XXX_Merge

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

func (*DumpNodesResponse) XXX_Size

func (m *DumpNodesResponse) XXX_Size() int

func (*DumpNodesResponse) XXX_Unmarshal

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

type FindNearRequest

type FindNearRequest struct {
	Id                   NodeID   `protobuf:"bytes,1,opt,name=id,proto3,customtype=NodeID" json:"id"`
	Start                NodeID   `protobuf:"bytes,2,opt,name=start,proto3,customtype=NodeID" json:"start"`
	Limit                int64    `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FindNearRequest) Descriptor

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

func (*FindNearRequest) GetLimit

func (m *FindNearRequest) GetLimit() int64

func (*FindNearRequest) ProtoMessage

func (*FindNearRequest) ProtoMessage()

func (*FindNearRequest) Reset

func (m *FindNearRequest) Reset()

func (*FindNearRequest) String

func (m *FindNearRequest) String() string

func (*FindNearRequest) XXX_DiscardUnknown

func (m *FindNearRequest) XXX_DiscardUnknown()

func (*FindNearRequest) XXX_Marshal

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

func (*FindNearRequest) XXX_Merge

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

func (*FindNearRequest) XXX_Size

func (m *FindNearRequest) XXX_Size() int

func (*FindNearRequest) XXX_Unmarshal

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

type FindNearResponse

type FindNearResponse struct {
	Nodes                []*Node  `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FindNearResponse) Descriptor

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

func (*FindNearResponse) GetNodes

func (m *FindNearResponse) GetNodes() []*Node

func (*FindNearResponse) ProtoMessage

func (*FindNearResponse) ProtoMessage()

func (*FindNearResponse) Reset

func (m *FindNearResponse) Reset()

func (*FindNearResponse) String

func (m *FindNearResponse) String() string

func (*FindNearResponse) XXX_DiscardUnknown

func (m *FindNearResponse) XXX_DiscardUnknown()

func (*FindNearResponse) XXX_Marshal

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

func (*FindNearResponse) XXX_Merge

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

func (*FindNearResponse) XXX_Size

func (m *FindNearResponse) XXX_Size() int

func (*FindNearResponse) XXX_Unmarshal

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

type GetBucketListRequest added in v0.10.0

type GetBucketListRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetBucketListRequest) Descriptor added in v0.10.0

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

func (*GetBucketListRequest) ProtoMessage added in v0.10.0

func (*GetBucketListRequest) ProtoMessage()

func (*GetBucketListRequest) Reset added in v0.10.0

func (m *GetBucketListRequest) Reset()

func (*GetBucketListRequest) String added in v0.10.0

func (m *GetBucketListRequest) String() string

func (*GetBucketListRequest) XXX_DiscardUnknown added in v0.10.0

func (m *GetBucketListRequest) XXX_DiscardUnknown()

func (*GetBucketListRequest) XXX_Marshal added in v0.10.0

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

func (*GetBucketListRequest) XXX_Merge added in v0.10.0

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

func (*GetBucketListRequest) XXX_Size added in v0.10.0

func (m *GetBucketListRequest) XXX_Size() int

func (*GetBucketListRequest) XXX_Unmarshal added in v0.10.0

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

type GetBucketListResponse added in v0.10.0

type GetBucketListResponse struct {
	Buckets              []*GetBucketListResponse_Bucket `protobuf:"bytes,1,rep,name=buckets,proto3" json:"buckets,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*GetBucketListResponse) Descriptor added in v0.10.0

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

func (*GetBucketListResponse) GetBuckets added in v0.10.0

func (*GetBucketListResponse) ProtoMessage added in v0.10.0

func (*GetBucketListResponse) ProtoMessage()

func (*GetBucketListResponse) Reset added in v0.10.0

func (m *GetBucketListResponse) Reset()

func (*GetBucketListResponse) String added in v0.10.0

func (m *GetBucketListResponse) String() string

func (*GetBucketListResponse) XXX_DiscardUnknown added in v0.10.0

func (m *GetBucketListResponse) XXX_DiscardUnknown()

func (*GetBucketListResponse) XXX_Marshal added in v0.10.0

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

func (*GetBucketListResponse) XXX_Merge added in v0.10.0

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

func (*GetBucketListResponse) XXX_Size added in v0.10.0

func (m *GetBucketListResponse) XXX_Size() int

func (*GetBucketListResponse) XXX_Unmarshal added in v0.10.0

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

type GetBucketListResponse_Bucket added in v0.10.0

type GetBucketListResponse_Bucket struct {
	BucketId             NodeID   `protobuf:"bytes,1,opt,name=bucket_id,json=bucketId,proto3,customtype=NodeID" json:"bucket_id"`
	RoutingNodes         []*Node  `protobuf:"bytes,2,rep,name=routing_nodes,json=routingNodes,proto3" json:"routing_nodes,omitempty"`
	CachedNodes          []*Node  `protobuf:"bytes,3,rep,name=cached_nodes,json=cachedNodes,proto3" json:"cached_nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetBucketListResponse_Bucket) Descriptor added in v0.10.0

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

func (*GetBucketListResponse_Bucket) GetCachedNodes added in v0.10.0

func (m *GetBucketListResponse_Bucket) GetCachedNodes() []*Node

func (*GetBucketListResponse_Bucket) GetRoutingNodes added in v0.10.0

func (m *GetBucketListResponse_Bucket) GetRoutingNodes() []*Node

func (*GetBucketListResponse_Bucket) ProtoMessage added in v0.10.0

func (*GetBucketListResponse_Bucket) ProtoMessage()

func (*GetBucketListResponse_Bucket) Reset added in v0.10.0

func (m *GetBucketListResponse_Bucket) Reset()

func (*GetBucketListResponse_Bucket) String added in v0.10.0

func (*GetBucketListResponse_Bucket) XXX_DiscardUnknown added in v0.10.0

func (m *GetBucketListResponse_Bucket) XXX_DiscardUnknown()

func (*GetBucketListResponse_Bucket) XXX_Marshal added in v0.10.0

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

func (*GetBucketListResponse_Bucket) XXX_Merge added in v0.10.0

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

func (*GetBucketListResponse_Bucket) XXX_Size added in v0.10.0

func (m *GetBucketListResponse_Bucket) XXX_Size() int

func (*GetBucketListResponse_Bucket) XXX_Unmarshal added in v0.10.0

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

type GetBucketRequest

type GetBucketRequest struct {
	Id                   NodeID   `protobuf:"bytes,1,opt,name=id,proto3,customtype=NodeID" json:"id"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetBucket

func (*GetBucketRequest) Descriptor

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

func (*GetBucketRequest) ProtoMessage

func (*GetBucketRequest) ProtoMessage()

func (*GetBucketRequest) Reset

func (m *GetBucketRequest) Reset()

func (*GetBucketRequest) String

func (m *GetBucketRequest) String() string

func (*GetBucketRequest) XXX_DiscardUnknown

func (m *GetBucketRequest) XXX_DiscardUnknown()

func (*GetBucketRequest) XXX_Marshal

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

func (*GetBucketRequest) XXX_Merge

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

func (*GetBucketRequest) XXX_Size

func (m *GetBucketRequest) XXX_Size() int

func (*GetBucketRequest) XXX_Unmarshal

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

type GetBucketResponse

type GetBucketResponse struct {
	Id                   NodeID   `protobuf:"bytes,1,opt,name=id,proto3,customtype=NodeID" json:"id"`
	Nodes                []*Node  `protobuf:"bytes,2,rep,name=nodes,proto3" json:"nodes,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetBucketResponse) Descriptor

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

func (*GetBucketResponse) GetNodes

func (m *GetBucketResponse) GetNodes() []*Node

func (*GetBucketResponse) ProtoMessage

func (*GetBucketResponse) ProtoMessage()

func (*GetBucketResponse) Reset

func (m *GetBucketResponse) Reset()

func (*GetBucketResponse) String

func (m *GetBucketResponse) String() string

func (*GetBucketResponse) XXX_DiscardUnknown

func (m *GetBucketResponse) XXX_DiscardUnknown()

func (*GetBucketResponse) XXX_Marshal

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

func (*GetBucketResponse) XXX_Merge

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

func (*GetBucketResponse) XXX_Size

func (m *GetBucketResponse) XXX_Size() int

func (*GetBucketResponse) XXX_Unmarshal

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

type GetBucketsRequest

type GetBucketsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetBuckets

func (*GetBucketsRequest) Descriptor

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

func (*GetBucketsRequest) ProtoMessage

func (*GetBucketsRequest) ProtoMessage()

func (*GetBucketsRequest) Reset

func (m *GetBucketsRequest) Reset()

func (*GetBucketsRequest) String

func (m *GetBucketsRequest) String() string

func (*GetBucketsRequest) XXX_DiscardUnknown

func (m *GetBucketsRequest) XXX_DiscardUnknown()

func (*GetBucketsRequest) XXX_Marshal

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

func (*GetBucketsRequest) XXX_Merge

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

func (*GetBucketsRequest) XXX_Size

func (m *GetBucketsRequest) XXX_Size() int

func (*GetBucketsRequest) XXX_Unmarshal

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

type GetBucketsResponse

type GetBucketsResponse struct {
	Total                int64    `protobuf:"varint,1,opt,name=total,proto3" json:"total,omitempty"`
	Ids                  []NodeID `protobuf:"bytes,2,rep,name=ids,proto3,customtype=NodeID" json:"ids,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetBucketsResponse) Descriptor

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

func (*GetBucketsResponse) GetTotal

func (m *GetBucketsResponse) GetTotal() int64

func (*GetBucketsResponse) ProtoMessage

func (*GetBucketsResponse) ProtoMessage()

func (*GetBucketsResponse) Reset

func (m *GetBucketsResponse) Reset()

func (*GetBucketsResponse) String

func (m *GetBucketsResponse) String() string

func (*GetBucketsResponse) XXX_DiscardUnknown

func (m *GetBucketsResponse) XXX_DiscardUnknown()

func (*GetBucketsResponse) XXX_Marshal

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

func (*GetBucketsResponse) XXX_Merge

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

func (*GetBucketsResponse) XXX_Size

func (m *GetBucketsResponse) XXX_Size() int

func (*GetBucketsResponse) XXX_Unmarshal

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

type GetStatsRequest

type GetStatsRequest struct {
	NodeId               NodeID   `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3,customtype=NodeID" json:"node_id"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetStats

func (*GetStatsRequest) Descriptor

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

func (*GetStatsRequest) ProtoMessage

func (*GetStatsRequest) ProtoMessage()

func (*GetStatsRequest) Reset

func (m *GetStatsRequest) Reset()

func (*GetStatsRequest) String

func (m *GetStatsRequest) String() string

func (*GetStatsRequest) XXX_DiscardUnknown

func (m *GetStatsRequest) XXX_DiscardUnknown()

func (*GetStatsRequest) XXX_Marshal

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

func (*GetStatsRequest) XXX_Merge

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

func (*GetStatsRequest) XXX_Size

func (m *GetStatsRequest) XXX_Size() int

func (*GetStatsRequest) XXX_Unmarshal

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

type GetStatsResponse

type GetStatsResponse struct {
	AuditCount           int64    `protobuf:"varint,1,opt,name=audit_count,json=auditCount,proto3" json:"audit_count,omitempty"`
	AuditRatio           float64  `protobuf:"fixed64,2,opt,name=audit_ratio,json=auditRatio,proto3" json:"audit_ratio,omitempty"`
	UptimeCount          int64    `protobuf:"varint,3,opt,name=uptime_count,json=uptimeCount,proto3" json:"uptime_count,omitempty"`
	UptimeRatio          float64  `protobuf:"fixed64,4,opt,name=uptime_ratio,json=uptimeRatio,proto3" json:"uptime_ratio,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetStatsResponse) Descriptor

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

func (*GetStatsResponse) GetAuditCount

func (m *GetStatsResponse) GetAuditCount() int64

func (*GetStatsResponse) GetAuditRatio

func (m *GetStatsResponse) GetAuditRatio() float64

func (*GetStatsResponse) GetUptimeCount

func (m *GetStatsResponse) GetUptimeCount() int64

func (*GetStatsResponse) GetUptimeRatio

func (m *GetStatsResponse) GetUptimeRatio() float64

func (*GetStatsResponse) ProtoMessage

func (*GetStatsResponse) ProtoMessage()

func (*GetStatsResponse) Reset

func (m *GetStatsResponse) Reset()

func (*GetStatsResponse) String

func (m *GetStatsResponse) String() string

func (*GetStatsResponse) XXX_DiscardUnknown

func (m *GetStatsResponse) XXX_DiscardUnknown()

func (*GetStatsResponse) XXX_Marshal

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

func (*GetStatsResponse) XXX_Merge

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

func (*GetStatsResponse) XXX_Size

func (m *GetStatsResponse) XXX_Size() int

func (*GetStatsResponse) XXX_Unmarshal

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

type HealthInspectorClient

type HealthInspectorClient interface {
	// ObjectHealth will return stats about the health of an object
	ObjectHealth(ctx context.Context, in *ObjectHealthRequest, opts ...grpc.CallOption) (*ObjectHealthResponse, error)
	// SegmentHealth will return stats about the health of a segment
	SegmentHealth(ctx context.Context, in *SegmentHealthRequest, opts ...grpc.CallOption) (*SegmentHealthResponse, error)
}

HealthInspectorClient is the client API for HealthInspector service.

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

func NewHealthInspectorClient

func NewHealthInspectorClient(cc *grpc.ClientConn) HealthInspectorClient

type HealthInspectorServer

type HealthInspectorServer interface {
	// ObjectHealth will return stats about the health of an object
	ObjectHealth(context.Context, *ObjectHealthRequest) (*ObjectHealthResponse, error)
	// SegmentHealth will return stats about the health of a segment
	SegmentHealth(context.Context, *SegmentHealthRequest) (*SegmentHealthResponse, error)
}

HealthInspectorServer is the server API for HealthInspector service.

type InfoRequest

type InfoRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

TODO: add fields that validate who is requesting the info

func (*InfoRequest) Descriptor

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

func (*InfoRequest) ProtoMessage

func (*InfoRequest) ProtoMessage()

func (*InfoRequest) Reset

func (m *InfoRequest) Reset()

func (*InfoRequest) String

func (m *InfoRequest) String() string

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 {
	Type                 NodeType      `protobuf:"varint,2,opt,name=type,proto3,enum=node.NodeType" json:"type,omitempty"`
	Operator             *NodeOperator `protobuf:"bytes,3,opt,name=operator,proto3" json:"operator,omitempty"`
	Capacity             *NodeCapacity `protobuf:"bytes,4,opt,name=capacity,proto3" json:"capacity,omitempty"`
	Version              *NodeVersion  `protobuf:"bytes,5,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*InfoResponse) Descriptor

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

func (*InfoResponse) GetCapacity

func (m *InfoResponse) GetCapacity() *NodeCapacity

func (*InfoResponse) GetOperator

func (m *InfoResponse) GetOperator() *NodeOperator

func (*InfoResponse) GetType

func (m *InfoResponse) GetType() NodeType

func (*InfoResponse) GetVersion added in v0.8.1

func (m *InfoResponse) GetVersion() *NodeVersion

func (*InfoResponse) ProtoMessage

func (*InfoResponse) ProtoMessage()

func (*InfoResponse) Reset

func (m *InfoResponse) Reset()

func (*InfoResponse) String

func (m *InfoResponse) String() string

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 InjuredSegment

type InjuredSegment struct {
	Path                 string   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	LostPieces           []int32  `protobuf:"varint,2,rep,packed,name=lost_pieces,json=lostPieces,proto3" json:"lost_pieces,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

InjuredSegment is the queue item used for the data repair queue

func (*InjuredSegment) Descriptor

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

func (*InjuredSegment) GetLostPieces

func (m *InjuredSegment) GetLostPieces() []int32

func (*InjuredSegment) GetPath

func (m *InjuredSegment) GetPath() string

func (*InjuredSegment) ProtoMessage

func (*InjuredSegment) ProtoMessage()

func (*InjuredSegment) Reset

func (m *InjuredSegment) Reset()

func (*InjuredSegment) Scan

func (n *InjuredSegment) Scan(value interface{}) error

Scan implements the Scanner interface.

func (*InjuredSegment) String

func (m *InjuredSegment) String() string

func (InjuredSegment) Value

func (n InjuredSegment) Value() (driver.Value, error)

Value implements the driver Valuer interface.

func (*InjuredSegment) XXX_DiscardUnknown

func (m *InjuredSegment) XXX_DiscardUnknown()

func (*InjuredSegment) XXX_Marshal

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

func (*InjuredSegment) XXX_Merge

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

func (*InjuredSegment) XXX_Size

func (m *InjuredSegment) XXX_Size() int

func (*InjuredSegment) XXX_Unmarshal

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

type IrreparableInspectorClient

type IrreparableInspectorClient interface {
	// ListIrreparableSegments returns damaged segments
	ListIrreparableSegments(ctx context.Context, in *ListIrreparableSegmentsRequest, opts ...grpc.CallOption) (*ListIrreparableSegmentsResponse, error)
}

IrreparableInspectorClient is the client API for IrreparableInspector service.

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

func NewIrreparableInspectorClient

func NewIrreparableInspectorClient(cc *grpc.ClientConn) IrreparableInspectorClient

type IrreparableInspectorServer

type IrreparableInspectorServer interface {
	// ListIrreparableSegments returns damaged segments
	ListIrreparableSegments(context.Context, *ListIrreparableSegmentsRequest) (*ListIrreparableSegmentsResponse, error)
}

IrreparableInspectorServer is the server API for IrreparableInspector service.

type IrreparableSegment

type IrreparableSegment struct {
	Path                 []byte   `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
	SegmentDetail        *Pointer `protobuf:"bytes,2,opt,name=segment_detail,json=segmentDetail,proto3" json:"segment_detail,omitempty"`
	LostPieces           int32    `protobuf:"varint,3,opt,name=lost_pieces,json=lostPieces,proto3" json:"lost_pieces,omitempty"`
	LastRepairAttempt    int64    `protobuf:"varint,4,opt,name=last_repair_attempt,json=lastRepairAttempt,proto3" json:"last_repair_attempt,omitempty"`
	RepairAttemptCount   int64    `protobuf:"varint,5,opt,name=repair_attempt_count,json=repairAttemptCount,proto3" json:"repair_attempt_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IrreparableSegment) Descriptor

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

func (*IrreparableSegment) GetLastRepairAttempt

func (m *IrreparableSegment) GetLastRepairAttempt() int64

func (*IrreparableSegment) GetLostPieces

func (m *IrreparableSegment) GetLostPieces() int32

func (*IrreparableSegment) GetPath

func (m *IrreparableSegment) GetPath() []byte

func (*IrreparableSegment) GetRepairAttemptCount

func (m *IrreparableSegment) GetRepairAttemptCount() int64

func (*IrreparableSegment) GetSegmentDetail

func (m *IrreparableSegment) GetSegmentDetail() *Pointer

func (*IrreparableSegment) ProtoMessage

func (*IrreparableSegment) ProtoMessage()

func (*IrreparableSegment) Reset

func (m *IrreparableSegment) Reset()

func (*IrreparableSegment) String

func (m *IrreparableSegment) String() string

func (*IrreparableSegment) XXX_DiscardUnknown

func (m *IrreparableSegment) XXX_DiscardUnknown()

func (*IrreparableSegment) XXX_Marshal

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

func (*IrreparableSegment) XXX_Merge

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

func (*IrreparableSegment) XXX_Size

func (m *IrreparableSegment) XXX_Size() int

func (*IrreparableSegment) XXX_Unmarshal

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

type KadInspectorClient

type KadInspectorClient interface {
	// CountNodes returns the number of nodes in the routing table
	CountNodes(ctx context.Context, in *CountNodesRequest, opts ...grpc.CallOption) (*CountNodesResponse, error)
	// PingNode sends a PING RPC to a node and returns its availability
	PingNode(ctx context.Context, in *PingNodeRequest, opts ...grpc.CallOption) (*PingNodeResponse, error)
	// LookupNode triggers a Kademlia FindNode and returns the response
	LookupNode(ctx context.Context, in *LookupNodeRequest, opts ...grpc.CallOption) (*LookupNodeResponse, error)
	// NodeInfo sends a PING RPC to a node and returns its local info
	NodeInfo(ctx context.Context, in *NodeInfoRequest, opts ...grpc.CallOption) (*NodeInfoResponse, error)
	// FindNear returns limit number of IDs "near" the Start ID
	FindNear(ctx context.Context, in *FindNearRequest, opts ...grpc.CallOption) (*FindNearResponse, error)
	// DumpNodes returns all the nodes in the node database
	DumpNodes(ctx context.Context, in *DumpNodesRequest, opts ...grpc.CallOption) (*DumpNodesResponse, error)
	// GetBucketList returns all the buckets with all their nodes
	GetBucketList(ctx context.Context, in *GetBucketListRequest, opts ...grpc.CallOption) (*GetBucketListResponse, error)
}

KadInspectorClient is the client API for KadInspector service.

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

func NewKadInspectorClient

func NewKadInspectorClient(cc *grpc.ClientConn) KadInspectorClient

type KadInspectorServer

type KadInspectorServer interface {
	// CountNodes returns the number of nodes in the routing table
	CountNodes(context.Context, *CountNodesRequest) (*CountNodesResponse, error)
	// PingNode sends a PING RPC to a node and returns its availability
	PingNode(context.Context, *PingNodeRequest) (*PingNodeResponse, error)
	// LookupNode triggers a Kademlia FindNode and returns the response
	LookupNode(context.Context, *LookupNodeRequest) (*LookupNodeResponse, error)
	// NodeInfo sends a PING RPC to a node and returns its local info
	NodeInfo(context.Context, *NodeInfoRequest) (*NodeInfoResponse, error)
	// FindNear returns limit number of IDs "near" the Start ID
	FindNear(context.Context, *FindNearRequest) (*FindNearResponse, error)
	// DumpNodes returns all the nodes in the node database
	DumpNodes(context.Context, *DumpNodesRequest) (*DumpNodesResponse, error)
	// GetBucketList returns all the buckets with all their nodes
	GetBucketList(context.Context, *GetBucketListRequest) (*GetBucketListResponse, error)
}

KadInspectorServer is the server API for KadInspector service.

type ListIrreparableSegmentsRequest

type ListIrreparableSegmentsRequest struct {
	Limit                int32    `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Offset               int32    `protobuf:"varint,2,opt,name=offset,proto3" json:"offset,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

ListSegments

func (*ListIrreparableSegmentsRequest) Descriptor

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

func (*ListIrreparableSegmentsRequest) GetLimit

func (m *ListIrreparableSegmentsRequest) GetLimit() int32

func (*ListIrreparableSegmentsRequest) GetOffset

func (m *ListIrreparableSegmentsRequest) GetOffset() int32

func (*ListIrreparableSegmentsRequest) ProtoMessage

func (*ListIrreparableSegmentsRequest) ProtoMessage()

func (*ListIrreparableSegmentsRequest) Reset

func (m *ListIrreparableSegmentsRequest) Reset()

func (*ListIrreparableSegmentsRequest) String

func (*ListIrreparableSegmentsRequest) XXX_DiscardUnknown

func (m *ListIrreparableSegmentsRequest) XXX_DiscardUnknown()

func (*ListIrreparableSegmentsRequest) XXX_Marshal

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

func (*ListIrreparableSegmentsRequest) XXX_Merge

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

func (*ListIrreparableSegmentsRequest) XXX_Size

func (m *ListIrreparableSegmentsRequest) XXX_Size() int

func (*ListIrreparableSegmentsRequest) XXX_Unmarshal

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

type ListIrreparableSegmentsResponse

type ListIrreparableSegmentsResponse struct {
	Segments             []*IrreparableSegment `protobuf:"bytes,1,rep,name=segments,proto3" json:"segments,omitempty"`
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*ListIrreparableSegmentsResponse) Descriptor

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

func (*ListIrreparableSegmentsResponse) GetSegments

func (*ListIrreparableSegmentsResponse) ProtoMessage

func (*ListIrreparableSegmentsResponse) ProtoMessage()

func (*ListIrreparableSegmentsResponse) Reset

func (*ListIrreparableSegmentsResponse) String

func (*ListIrreparableSegmentsResponse) XXX_DiscardUnknown

func (m *ListIrreparableSegmentsResponse) XXX_DiscardUnknown()

func (*ListIrreparableSegmentsResponse) XXX_Marshal

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

func (*ListIrreparableSegmentsResponse) XXX_Merge

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

func (*ListIrreparableSegmentsResponse) XXX_Size

func (m *ListIrreparableSegmentsResponse) XXX_Size() int

func (*ListIrreparableSegmentsResponse) XXX_Unmarshal

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

type ListResponse

type ListResponse struct {
	Items                []*ListResponse_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:"-"`
}

ListResponse is a response message for the List rpc call

func (*ListResponse) Descriptor

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

func (*ListResponse) GetItems

func (m *ListResponse) GetItems() []*ListResponse_Item

func (*ListResponse) GetMore

func (m *ListResponse) GetMore() bool

func (*ListResponse) ProtoMessage

func (*ListResponse) ProtoMessage()

func (*ListResponse) Reset

func (m *ListResponse) Reset()

func (*ListResponse) String

func (m *ListResponse) String() string

func (*ListResponse) XXX_DiscardUnknown

func (m *ListResponse) XXX_DiscardUnknown()

func (*ListResponse) XXX_Marshal

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

func (*ListResponse) XXX_Merge

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

func (*ListResponse) XXX_Size

func (m *ListResponse) XXX_Size() int

func (*ListResponse) XXX_Unmarshal

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

type ListResponse_Item

type ListResponse_Item struct {
	Path                 string   `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 (*ListResponse_Item) Descriptor

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

func (*ListResponse_Item) GetIsPrefix

func (m *ListResponse_Item) GetIsPrefix() bool

func (*ListResponse_Item) GetPath

func (m *ListResponse_Item) GetPath() string

func (*ListResponse_Item) GetPointer

func (m *ListResponse_Item) GetPointer() *Pointer

func (*ListResponse_Item) ProtoMessage

func (*ListResponse_Item) ProtoMessage()

func (*ListResponse_Item) Reset

func (m *ListResponse_Item) Reset()

func (*ListResponse_Item) String

func (m *ListResponse_Item) String() string

func (*ListResponse_Item) XXX_DiscardUnknown

func (m *ListResponse_Item) XXX_DiscardUnknown()

func (*ListResponse_Item) XXX_Marshal

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

func (*ListResponse_Item) XXX_Merge

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

func (*ListResponse_Item) XXX_Size

func (m *ListResponse_Item) XXX_Size() int

func (*ListResponse_Item) XXX_Unmarshal

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

type ListSegmentsRequest

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 (*ListSegmentsRequest) Descriptor

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

func (*ListSegmentsRequest) GetBucket

func (m *ListSegmentsRequest) GetBucket() []byte

func (*ListSegmentsRequest) GetEndBefore

func (m *ListSegmentsRequest) GetEndBefore() []byte

func (*ListSegmentsRequest) GetLimit

func (m *ListSegmentsRequest) GetLimit() int32

func (*ListSegmentsRequest) GetMetaFlags

func (m *ListSegmentsRequest) GetMetaFlags() uint32

func (*ListSegmentsRequest) GetPrefix

func (m *ListSegmentsRequest) GetPrefix() []byte

func (*ListSegmentsRequest) GetRecursive

func (m *ListSegmentsRequest) GetRecursive() bool

func (*ListSegmentsRequest) GetStartAfter

func (m *ListSegmentsRequest) GetStartAfter() []byte

func (*ListSegmentsRequest) ProtoMessage

func (*ListSegmentsRequest) ProtoMessage()

func (*ListSegmentsRequest) Reset

func (m *ListSegmentsRequest) Reset()

func (*ListSegmentsRequest) String

func (m *ListSegmentsRequest) String() string

func (*ListSegmentsRequest) XXX_DiscardUnknown

func (m *ListSegmentsRequest) XXX_DiscardUnknown()

func (*ListSegmentsRequest) XXX_Marshal

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

func (*ListSegmentsRequest) XXX_Merge

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

func (*ListSegmentsRequest) XXX_Size

func (m *ListSegmentsRequest) XXX_Size() int

func (*ListSegmentsRequest) XXX_Unmarshal

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

type ListSegmentsResponse

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 (*ListSegmentsResponse) Descriptor

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

func (*ListSegmentsResponse) GetItems

func (*ListSegmentsResponse) GetMore

func (m *ListSegmentsResponse) GetMore() bool

func (*ListSegmentsResponse) ProtoMessage

func (*ListSegmentsResponse) ProtoMessage()

func (*ListSegmentsResponse) Reset

func (m *ListSegmentsResponse) Reset()

func (*ListSegmentsResponse) String

func (m *ListSegmentsResponse) String() string

func (*ListSegmentsResponse) XXX_DiscardUnknown

func (m *ListSegmentsResponse) XXX_DiscardUnknown()

func (*ListSegmentsResponse) XXX_Marshal

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

func (*ListSegmentsResponse) XXX_Merge

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

func (*ListSegmentsResponse) XXX_Size

func (m *ListSegmentsResponse) XXX_Size() int

func (*ListSegmentsResponse) XXX_Unmarshal

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

type ListSegmentsResponse_Item

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 (*ListSegmentsResponse_Item) Descriptor

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

func (*ListSegmentsResponse_Item) GetIsPrefix

func (m *ListSegmentsResponse_Item) GetIsPrefix() bool

func (*ListSegmentsResponse_Item) GetPath

func (m *ListSegmentsResponse_Item) GetPath() []byte

func (*ListSegmentsResponse_Item) GetPointer

func (m *ListSegmentsResponse_Item) GetPointer() *Pointer

func (*ListSegmentsResponse_Item) ProtoMessage

func (*ListSegmentsResponse_Item) ProtoMessage()

func (*ListSegmentsResponse_Item) Reset

func (m *ListSegmentsResponse_Item) Reset()

func (*ListSegmentsResponse_Item) String

func (m *ListSegmentsResponse_Item) String() string

func (*ListSegmentsResponse_Item) XXX_DiscardUnknown

func (m *ListSegmentsResponse_Item) XXX_DiscardUnknown()

func (*ListSegmentsResponse_Item) XXX_Marshal

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

func (*ListSegmentsResponse_Item) XXX_Merge

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

func (*ListSegmentsResponse_Item) XXX_Size

func (m *ListSegmentsResponse_Item) XXX_Size() int

func (*ListSegmentsResponse_Item) XXX_Unmarshal

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

type LookupNodeRequest

type LookupNodeRequest struct {
	Id                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Address              string   `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*LookupNodeRequest) Descriptor

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

func (*LookupNodeRequest) GetAddress

func (m *LookupNodeRequest) GetAddress() string

func (*LookupNodeRequest) GetId

func (m *LookupNodeRequest) GetId() string

func (*LookupNodeRequest) ProtoMessage

func (*LookupNodeRequest) ProtoMessage()

func (*LookupNodeRequest) Reset

func (m *LookupNodeRequest) Reset()

func (*LookupNodeRequest) String

func (m *LookupNodeRequest) String() string

func (*LookupNodeRequest) XXX_DiscardUnknown

func (m *LookupNodeRequest) XXX_DiscardUnknown()

func (*LookupNodeRequest) XXX_Marshal

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

func (*LookupNodeRequest) XXX_Merge

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

func (*LookupNodeRequest) XXX_Size

func (m *LookupNodeRequest) XXX_Size() int

func (*LookupNodeRequest) XXX_Unmarshal

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

type LookupNodeResponse

type LookupNodeResponse struct {
	Node                 *Node         `protobuf:"bytes,1,opt,name=node,proto3" json:"node,omitempty"`
	Meta                 *NodeMetadata `protobuf:"bytes,2,opt,name=meta,proto3" json:"meta,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*LookupNodeResponse) Descriptor

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

func (*LookupNodeResponse) GetMeta

func (m *LookupNodeResponse) GetMeta() *NodeMetadata

func (*LookupNodeResponse) GetNode

func (m *LookupNodeResponse) GetNode() *Node

func (*LookupNodeResponse) ProtoMessage

func (*LookupNodeResponse) ProtoMessage()

func (*LookupNodeResponse) Reset

func (m *LookupNodeResponse) Reset()

func (*LookupNodeResponse) String

func (m *LookupNodeResponse) String() string

func (*LookupNodeResponse) XXX_DiscardUnknown

func (m *LookupNodeResponse) XXX_DiscardUnknown()

func (*LookupNodeResponse) XXX_Marshal

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

func (*LookupNodeResponse) XXX_Merge

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

func (*LookupNodeResponse) XXX_Size

func (m *LookupNodeResponse) XXX_Size() int

func (*LookupNodeResponse) XXX_Unmarshal

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

type MetainfoClient

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)
}

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.

func NewMetainfoClient

func NewMetainfoClient(cc *grpc.ClientConn) MetainfoClient

type MetainfoServer

MetainfoServer is the server API for Metainfo service.

type Node

type Node struct {
	Id                   NodeID       `protobuf:"bytes,1,opt,name=id,proto3,customtype=NodeID" json:"id"`
	Address              *NodeAddress `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	LastIp               string       `protobuf:"bytes,14,opt,name=last_ip,json=lastIp,proto3" json:"last_ip,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

TODO move statdb.Update() stuff out of here Node represents a node in the overlay network Node is info for a updating a single storagenode, used in the Update rpc calls

func CopyNode

func CopyNode(src *Node) (dst *Node)

CopyNode returns a deep copy of a node It would be better to use `proto.Clone` but it is curently incompatible with gogo's customtype extension. (see https://github.com/gogo/protobuf/issues/147)

func (*Node) Descriptor

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

func (*Node) GetAddress

func (m *Node) GetAddress() *NodeAddress

func (*Node) GetLastIp added in v0.12.0

func (m *Node) GetLastIp() string

func (*Node) ProtoMessage

func (*Node) ProtoMessage()

func (*Node) Reset

func (m *Node) Reset()

func (*Node) String

func (m *Node) String() string

func (*Node) XXX_DiscardUnknown

func (m *Node) XXX_DiscardUnknown()

func (*Node) XXX_Marshal

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

func (*Node) XXX_Merge

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

func (*Node) XXX_Size

func (m *Node) XXX_Size() int

func (*Node) XXX_Unmarshal

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

type NodeAddress

type NodeAddress struct {
	Transport            NodeTransport `protobuf:"varint,1,opt,name=transport,proto3,enum=node.NodeTransport" json:"transport,omitempty"`
	Address              string        `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

NodeAddress contains the information needed to communicate with a node on the network

func (*NodeAddress) Descriptor

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

func (*NodeAddress) GetAddress

func (m *NodeAddress) GetAddress() string

func (*NodeAddress) GetTransport

func (m *NodeAddress) GetTransport() NodeTransport

func (*NodeAddress) ProtoMessage

func (*NodeAddress) ProtoMessage()

func (*NodeAddress) Reset

func (m *NodeAddress) Reset()

func (*NodeAddress) String

func (m *NodeAddress) String() string

func (*NodeAddress) XXX_DiscardUnknown

func (m *NodeAddress) XXX_DiscardUnknown()

func (*NodeAddress) XXX_Marshal

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

func (*NodeAddress) XXX_Merge

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

func (*NodeAddress) XXX_Size

func (m *NodeAddress) XXX_Size() int

func (*NodeAddress) XXX_Unmarshal

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

type NodeCapacity

type NodeCapacity struct {
	FreeBandwidth        int64    `protobuf:"varint,1,opt,name=free_bandwidth,json=freeBandwidth,proto3" json:"free_bandwidth,omitempty"`
	FreeDisk             int64    `protobuf:"varint,2,opt,name=free_disk,json=freeDisk,proto3" json:"free_disk,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

NodeCapacity contains all relevant data about a nodes ability to store data

func (*NodeCapacity) Descriptor

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

func (*NodeCapacity) GetFreeBandwidth

func (m *NodeCapacity) GetFreeBandwidth() int64

func (*NodeCapacity) GetFreeDisk

func (m *NodeCapacity) GetFreeDisk() int64

func (*NodeCapacity) ProtoMessage

func (*NodeCapacity) ProtoMessage()

func (*NodeCapacity) Reset

func (m *NodeCapacity) Reset()

func (*NodeCapacity) String

func (m *NodeCapacity) String() string

func (*NodeCapacity) XXX_DiscardUnknown

func (m *NodeCapacity) XXX_DiscardUnknown()

func (*NodeCapacity) XXX_Marshal

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

func (*NodeCapacity) XXX_Merge

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

func (*NodeCapacity) XXX_Size

func (m *NodeCapacity) XXX_Size() int

func (*NodeCapacity) XXX_Unmarshal

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

type NodeID

type NodeID = storj.NodeID

NodeID is an alias to storj.NodeID for use in generated protobuf code

type NodeIDList

type NodeIDList = storj.NodeIDList

NodeIDList is an alias to storj.NodeIDList for use in generated protobuf code

type NodeInfoRequest

type NodeInfoRequest struct {
	Id                   NodeID       `protobuf:"bytes,1,opt,name=id,proto3,customtype=NodeID" json:"id"`
	Address              *NodeAddress `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*NodeInfoRequest) Descriptor

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

func (*NodeInfoRequest) GetAddress

func (m *NodeInfoRequest) GetAddress() *NodeAddress

func (*NodeInfoRequest) ProtoMessage

func (*NodeInfoRequest) ProtoMessage()

func (*NodeInfoRequest) Reset

func (m *NodeInfoRequest) Reset()

func (*NodeInfoRequest) String

func (m *NodeInfoRequest) String() string

func (*NodeInfoRequest) XXX_DiscardUnknown

func (m *NodeInfoRequest) XXX_DiscardUnknown()

func (*NodeInfoRequest) XXX_Marshal

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

func (*NodeInfoRequest) XXX_Merge

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

func (*NodeInfoRequest) XXX_Size

func (m *NodeInfoRequest) XXX_Size() int

func (*NodeInfoRequest) XXX_Unmarshal

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

type NodeInfoResponse

type NodeInfoResponse struct {
	Type                 NodeType      `protobuf:"varint,1,opt,name=type,proto3,enum=node.NodeType" json:"type,omitempty"`
	Operator             *NodeOperator `protobuf:"bytes,2,opt,name=operator,proto3" json:"operator,omitempty"`
	Capacity             *NodeCapacity `protobuf:"bytes,3,opt,name=capacity,proto3" json:"capacity,omitempty"`
	Version              *NodeVersion  `protobuf:"bytes,4,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*NodeInfoResponse) Descriptor

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

func (*NodeInfoResponse) GetCapacity

func (m *NodeInfoResponse) GetCapacity() *NodeCapacity

func (*NodeInfoResponse) GetOperator

func (m *NodeInfoResponse) GetOperator() *NodeOperator

func (*NodeInfoResponse) GetType

func (m *NodeInfoResponse) GetType() NodeType

func (*NodeInfoResponse) GetVersion added in v0.9.0

func (m *NodeInfoResponse) GetVersion() *NodeVersion

func (*NodeInfoResponse) ProtoMessage

func (*NodeInfoResponse) ProtoMessage()

func (*NodeInfoResponse) Reset

func (m *NodeInfoResponse) Reset()

func (*NodeInfoResponse) String

func (m *NodeInfoResponse) String() string

func (*NodeInfoResponse) XXX_DiscardUnknown

func (m *NodeInfoResponse) XXX_DiscardUnknown()

func (*NodeInfoResponse) XXX_Marshal

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

func (*NodeInfoResponse) XXX_Merge

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

func (*NodeInfoResponse) XXX_Size

func (m *NodeInfoResponse) XXX_Size() int

func (*NodeInfoResponse) XXX_Unmarshal

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

type NodeMetadata deprecated

type NodeMetadata struct {
	Email                string   `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"`
	Wallet               string   `protobuf:"bytes,2,opt,name=wallet,proto3" json:"wallet,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Deprecated: use NodeOperator instead

func (*NodeMetadata) Descriptor

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

func (*NodeMetadata) GetEmail

func (m *NodeMetadata) GetEmail() string

func (*NodeMetadata) GetWallet

func (m *NodeMetadata) GetWallet() string

func (*NodeMetadata) ProtoMessage

func (*NodeMetadata) ProtoMessage()

func (*NodeMetadata) Reset

func (m *NodeMetadata) Reset()

func (*NodeMetadata) String

func (m *NodeMetadata) String() string

func (*NodeMetadata) XXX_DiscardUnknown

func (m *NodeMetadata) XXX_DiscardUnknown()

func (*NodeMetadata) XXX_Marshal

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

func (*NodeMetadata) XXX_Merge

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

func (*NodeMetadata) XXX_Size

func (m *NodeMetadata) XXX_Size() int

func (*NodeMetadata) XXX_Unmarshal

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

type NodeOperator

type NodeOperator struct {
	Email                string   `protobuf:"bytes,1,opt,name=email,proto3" json:"email,omitempty"`
	Wallet               string   `protobuf:"bytes,2,opt,name=wallet,proto3" json:"wallet,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

NodeOperator contains info about the storage node operator

func (*NodeOperator) Descriptor

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

func (*NodeOperator) GetEmail

func (m *NodeOperator) GetEmail() string

func (*NodeOperator) GetWallet

func (m *NodeOperator) GetWallet() string

func (*NodeOperator) ProtoMessage

func (*NodeOperator) ProtoMessage()

func (*NodeOperator) Reset

func (m *NodeOperator) Reset()

func (*NodeOperator) String

func (m *NodeOperator) String() string

func (*NodeOperator) XXX_DiscardUnknown

func (m *NodeOperator) XXX_DiscardUnknown()

func (*NodeOperator) XXX_Marshal

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

func (*NodeOperator) XXX_Merge

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

func (*NodeOperator) XXX_Size

func (m *NodeOperator) XXX_Size() int

func (*NodeOperator) XXX_Unmarshal

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

type NodeRestrictions deprecated

type NodeRestrictions struct {
	FreeBandwidth        int64    `protobuf:"varint,1,opt,name=free_bandwidth,json=freeBandwidth,proto3" json:"free_bandwidth,omitempty"`
	FreeDisk             int64    `protobuf:"varint,2,opt,name=free_disk,json=freeDisk,proto3" json:"free_disk,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Deprecated: use NodeCapacity instead

func (*NodeRestrictions) Descriptor

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

func (*NodeRestrictions) GetFreeBandwidth

func (m *NodeRestrictions) GetFreeBandwidth() int64

func (*NodeRestrictions) GetFreeDisk

func (m *NodeRestrictions) GetFreeDisk() int64

func (*NodeRestrictions) ProtoMessage

func (*NodeRestrictions) ProtoMessage()

func (*NodeRestrictions) Reset

func (m *NodeRestrictions) Reset()

func (*NodeRestrictions) String

func (m *NodeRestrictions) String() string

func (*NodeRestrictions) XXX_DiscardUnknown

func (m *NodeRestrictions) XXX_DiscardUnknown()

func (*NodeRestrictions) XXX_Marshal

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

func (*NodeRestrictions) XXX_Merge

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

func (*NodeRestrictions) XXX_Size

func (m *NodeRestrictions) XXX_Size() int

func (*NodeRestrictions) XXX_Unmarshal

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

type NodeStats

type NodeStats struct {
	NodeId               NodeID               `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3,customtype=NodeID" json:"node_id"`
	Latency_90           int64                `protobuf:"varint,2,opt,name=latency_90,json=latency90,proto3" json:"latency_90,omitempty"`
	AuditSuccessRatio    float64              `protobuf:"fixed64,3,opt,name=audit_success_ratio,json=auditSuccessRatio,proto3" json:"audit_success_ratio,omitempty"`
	UptimeRatio          float64              `protobuf:"fixed64,4,opt,name=uptime_ratio,json=uptimeRatio,proto3" json:"uptime_ratio,omitempty"`
	AuditCount           int64                `protobuf:"varint,5,opt,name=audit_count,json=auditCount,proto3" json:"audit_count,omitempty"`
	AuditSuccessCount    int64                `protobuf:"varint,6,opt,name=audit_success_count,json=auditSuccessCount,proto3" json:"audit_success_count,omitempty"`
	UptimeCount          int64                `protobuf:"varint,7,opt,name=uptime_count,json=uptimeCount,proto3" json:"uptime_count,omitempty"`
	UptimeSuccessCount   int64                `protobuf:"varint,8,opt,name=uptime_success_count,json=uptimeSuccessCount,proto3" json:"uptime_success_count,omitempty"`
	LastContactSuccess   *timestamp.Timestamp `protobuf:"bytes,9,opt,name=last_contact_success,json=lastContactSuccess,proto3" json:"last_contact_success,omitempty"`
	LastContactFailure   *timestamp.Timestamp `protobuf:"bytes,10,opt,name=last_contact_failure,json=lastContactFailure,proto3" json:"last_contact_failure,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

NodeStats is the reputation characteristics of a node

func (*NodeStats) Descriptor

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

func (*NodeStats) GetAuditCount

func (m *NodeStats) GetAuditCount() int64

func (*NodeStats) GetAuditSuccessCount

func (m *NodeStats) GetAuditSuccessCount() int64

func (*NodeStats) GetAuditSuccessRatio

func (m *NodeStats) GetAuditSuccessRatio() float64

func (*NodeStats) GetLastContactFailure added in v0.9.0

func (m *NodeStats) GetLastContactFailure() *timestamp.Timestamp

func (*NodeStats) GetLastContactSuccess added in v0.9.0

func (m *NodeStats) GetLastContactSuccess() *timestamp.Timestamp

func (*NodeStats) GetLatency_90

func (m *NodeStats) GetLatency_90() int64

func (*NodeStats) GetUptimeCount

func (m *NodeStats) GetUptimeCount() int64

func (*NodeStats) GetUptimeRatio

func (m *NodeStats) GetUptimeRatio() float64

func (*NodeStats) GetUptimeSuccessCount

func (m *NodeStats) GetUptimeSuccessCount() int64

func (*NodeStats) ProtoMessage

func (*NodeStats) ProtoMessage()

func (*NodeStats) Reset

func (m *NodeStats) Reset()

func (*NodeStats) String

func (m *NodeStats) String() string

func (*NodeStats) XXX_DiscardUnknown

func (m *NodeStats) XXX_DiscardUnknown()

func (*NodeStats) XXX_Marshal

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

func (*NodeStats) XXX_Merge

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

func (*NodeStats) XXX_Size

func (m *NodeStats) XXX_Size() int

func (*NodeStats) XXX_Unmarshal

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

type NodeTransport

type NodeTransport int32

NodeTransport is an enum of possible transports for the overlay network

const (
	NodeTransport_TCP_TLS_GRPC NodeTransport = 0
)

func (NodeTransport) EnumDescriptor

func (NodeTransport) EnumDescriptor() ([]byte, []int)

func (NodeTransport) String

func (x NodeTransport) String() string

type NodeType

type NodeType int32

NodeType is an enum of possible node types

const (
	NodeType_INVALID   NodeType = 0
	NodeType_SATELLITE NodeType = 1
	NodeType_STORAGE   NodeType = 2
	NodeType_UPLINK    NodeType = 3
	NodeType_BOOTSTRAP NodeType = 4
)

func (NodeType) DPanicOnInvalid

func (nt NodeType) DPanicOnInvalid(from string)

DPanicOnInvalid panics if NodeType is invalid if zap is in development mode, otherwise it logs.

func (NodeType) EnumDescriptor

func (NodeType) EnumDescriptor() ([]byte, []int)

func (NodeType) String

func (x NodeType) String() string

type NodeVersion added in v0.8.1

type NodeVersion struct {
	Version              string               `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	CommitHash           string               `protobuf:"bytes,2,opt,name=commit_hash,json=commitHash,proto3" json:"commit_hash,omitempty"`
	Timestamp            *timestamp.Timestamp `protobuf:"bytes,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Release              bool                 `protobuf:"varint,4,opt,name=release,proto3" json:"release,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

NodeVersion contains

func (*NodeVersion) Descriptor added in v0.8.1

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

func (*NodeVersion) GetCommitHash added in v0.8.1

func (m *NodeVersion) GetCommitHash() string

func (*NodeVersion) GetRelease added in v0.8.1

func (m *NodeVersion) GetRelease() bool

func (*NodeVersion) GetTimestamp added in v0.8.1

func (m *NodeVersion) GetTimestamp() *timestamp.Timestamp

func (*NodeVersion) GetVersion added in v0.8.1

func (m *NodeVersion) GetVersion() string

func (*NodeVersion) ProtoMessage added in v0.8.1

func (*NodeVersion) ProtoMessage()

func (*NodeVersion) Reset added in v0.8.1

func (m *NodeVersion) Reset()

func (*NodeVersion) String added in v0.8.1

func (m *NodeVersion) String() string

func (*NodeVersion) XXX_DiscardUnknown added in v0.8.1

func (m *NodeVersion) XXX_DiscardUnknown()

func (*NodeVersion) XXX_Marshal added in v0.8.1

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

func (*NodeVersion) XXX_Merge added in v0.8.1

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

func (*NodeVersion) XXX_Size added in v0.8.1

func (m *NodeVersion) XXX_Size() int

func (*NodeVersion) XXX_Unmarshal added in v0.8.1

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

type NodesClient

type NodesClient interface {
	Query(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	RequestInfo(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)
}

NodesClient is the client API for Nodes service.

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

func NewNodesClient

func NewNodesClient(cc *grpc.ClientConn) NodesClient

type NodesServer

type NodesServer interface {
	Query(context.Context, *QueryRequest) (*QueryResponse, error)
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	RequestInfo(context.Context, *InfoRequest) (*InfoResponse, error)
}

NodesServer is the server API for Nodes service.

type ObjectHealthRequest

type ObjectHealthRequest struct {
	EncryptedPath        []byte   `protobuf:"bytes,1,opt,name=encrypted_path,json=encryptedPath,proto3" json:"encrypted_path,omitempty"`
	Bucket               []byte   `protobuf:"bytes,2,opt,name=bucket,proto3" json:"bucket,omitempty"`
	ProjectId            []byte   `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	StartAfterSegment    int64    `protobuf:"varint,4,opt,name=start_after_segment,json=startAfterSegment,proto3" json:"start_after_segment,omitempty"`
	EndBeforeSegment     int64    `protobuf:"varint,5,opt,name=end_before_segment,json=endBeforeSegment,proto3" json:"end_before_segment,omitempty"`
	Limit                int32    `protobuf:"varint,6,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ObjectHealthRequest) Descriptor

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

func (*ObjectHealthRequest) GetBucket

func (m *ObjectHealthRequest) GetBucket() []byte

func (*ObjectHealthRequest) GetEncryptedPath

func (m *ObjectHealthRequest) GetEncryptedPath() []byte

func (*ObjectHealthRequest) GetEndBeforeSegment

func (m *ObjectHealthRequest) GetEndBeforeSegment() int64

func (*ObjectHealthRequest) GetLimit

func (m *ObjectHealthRequest) GetLimit() int32

func (*ObjectHealthRequest) GetProjectId

func (m *ObjectHealthRequest) GetProjectId() []byte

func (*ObjectHealthRequest) GetStartAfterSegment

func (m *ObjectHealthRequest) GetStartAfterSegment() int64

func (*ObjectHealthRequest) ProtoMessage

func (*ObjectHealthRequest) ProtoMessage()

func (*ObjectHealthRequest) Reset

func (m *ObjectHealthRequest) Reset()

func (*ObjectHealthRequest) String

func (m *ObjectHealthRequest) String() string

func (*ObjectHealthRequest) XXX_DiscardUnknown

func (m *ObjectHealthRequest) XXX_DiscardUnknown()

func (*ObjectHealthRequest) XXX_Marshal

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

func (*ObjectHealthRequest) XXX_Merge

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

func (*ObjectHealthRequest) XXX_Size

func (m *ObjectHealthRequest) XXX_Size() int

func (*ObjectHealthRequest) XXX_Unmarshal

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

type ObjectHealthResponse

type ObjectHealthResponse struct {
	Segments             []*SegmentHealth  `protobuf:"bytes,1,rep,name=segments,proto3" json:"segments,omitempty"`
	Redundancy           *RedundancyScheme `protobuf:"bytes,2,opt,name=redundancy,proto3" json:"redundancy,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*ObjectHealthResponse) Descriptor

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

func (*ObjectHealthResponse) GetRedundancy

func (m *ObjectHealthResponse) GetRedundancy() *RedundancyScheme

func (*ObjectHealthResponse) GetSegments

func (m *ObjectHealthResponse) GetSegments() []*SegmentHealth

func (*ObjectHealthResponse) ProtoMessage

func (*ObjectHealthResponse) ProtoMessage()

func (*ObjectHealthResponse) Reset

func (m *ObjectHealthResponse) Reset()

func (*ObjectHealthResponse) String

func (m *ObjectHealthResponse) String() string

func (*ObjectHealthResponse) XXX_DiscardUnknown

func (m *ObjectHealthResponse) XXX_DiscardUnknown()

func (*ObjectHealthResponse) XXX_Marshal

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

func (*ObjectHealthResponse) XXX_Merge

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

func (*ObjectHealthResponse) XXX_Size

func (m *ObjectHealthResponse) XXX_Size() int

func (*ObjectHealthResponse) XXX_Unmarshal

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

type Order2

type Order2 struct {
	// serial of the order limit that was signed
	SerialNumber SerialNumber `protobuf:"bytes,1,opt,name=serial_number,json=serialNumber,proto3,customtype=SerialNumber" json:"serial_number"`
	// amount to be signed for
	Amount int64 `protobuf:"varint,2,opt,name=amount,proto3" json:"amount,omitempty"`
	// signature
	UplinkSignature      []byte   `protobuf:"bytes,3,opt,name=uplink_signature,json=uplinkSignature,proto3" json:"uplink_signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Order2 is a one step of fullfilling Amount number of bytes from an OrderLimit2 with SerialNumber

func (*Order2) Descriptor

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

func (*Order2) GetAmount

func (m *Order2) GetAmount() int64

func (*Order2) GetUplinkSignature

func (m *Order2) GetUplinkSignature() []byte

func (*Order2) ProtoMessage

func (*Order2) ProtoMessage()

func (*Order2) Reset

func (m *Order2) Reset()

func (*Order2) String

func (m *Order2) String() string

func (*Order2) XXX_DiscardUnknown

func (m *Order2) XXX_DiscardUnknown()

func (*Order2) XXX_Marshal

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

func (*Order2) XXX_Merge

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

func (*Order2) XXX_Size

func (m *Order2) XXX_Size() int

func (*Order2) XXX_Unmarshal

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

type OrderLimit2

type OrderLimit2 struct {
	// unique serial to avoid replay attacks
	SerialNumber SerialNumber `protobuf:"bytes,1,opt,name=serial_number,json=serialNumber,proto3,customtype=SerialNumber" json:"serial_number"`
	// satellite who issued this order limit allowing orderer to do the specified action
	SatelliteId NodeID `protobuf:"bytes,2,opt,name=satellite_id,json=satelliteId,proto3,customtype=NodeID" json:"satellite_id"`
	// uplink who requested or whom behalf the order limit to do an action
	UplinkId NodeID `protobuf:"bytes,3,opt,name=uplink_id,json=uplinkId,proto3,customtype=NodeID" json:"uplink_id"`
	// storage node who can reclaim the order limit specified by serial
	StorageNodeId NodeID `protobuf:"bytes,4,opt,name=storage_node_id,json=storageNodeId,proto3,customtype=NodeID" json:"storage_node_id"`
	// piece which is allowed to be touched
	PieceId PieceID `protobuf:"bytes,5,opt,name=piece_id,json=pieceId,proto3,customtype=PieceID" json:"piece_id"`
	// limit in bytes how much can be changed
	Limit                int64                `protobuf:"varint,6,opt,name=limit,proto3" json:"limit,omitempty"`
	Action               PieceAction          `protobuf:"varint,7,opt,name=action,proto3,enum=orders.PieceAction" json:"action,omitempty"`
	PieceExpiration      *timestamp.Timestamp `protobuf:"bytes,8,opt,name=piece_expiration,json=pieceExpiration,proto3" json:"piece_expiration,omitempty"`
	OrderExpiration      *timestamp.Timestamp `protobuf:"bytes,9,opt,name=order_expiration,json=orderExpiration,proto3" json:"order_expiration,omitempty"`
	SatelliteSignature   []byte               `protobuf:"bytes,10,opt,name=satellite_signature,json=satelliteSignature,proto3" json:"satellite_signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

OrderLimit2 is provided by satellite to execute specific action on storage node within some limits

func (*OrderLimit2) Descriptor

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

func (*OrderLimit2) GetAction

func (m *OrderLimit2) GetAction() PieceAction

func (*OrderLimit2) GetLimit

func (m *OrderLimit2) GetLimit() int64

func (*OrderLimit2) GetOrderExpiration

func (m *OrderLimit2) GetOrderExpiration() *timestamp.Timestamp

func (*OrderLimit2) GetPieceExpiration

func (m *OrderLimit2) GetPieceExpiration() *timestamp.Timestamp

func (*OrderLimit2) GetSatelliteSignature

func (m *OrderLimit2) GetSatelliteSignature() []byte

func (*OrderLimit2) ProtoMessage

func (*OrderLimit2) ProtoMessage()

func (*OrderLimit2) Reset

func (m *OrderLimit2) Reset()

func (*OrderLimit2) String

func (m *OrderLimit2) String() string

func (*OrderLimit2) XXX_DiscardUnknown

func (m *OrderLimit2) XXX_DiscardUnknown()

func (*OrderLimit2) XXX_Marshal

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

func (*OrderLimit2) XXX_Merge

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

func (*OrderLimit2) XXX_Size

func (m *OrderLimit2) XXX_Size() int

func (*OrderLimit2) XXX_Unmarshal

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

type OrdersClient

type OrdersClient interface {
	Settlement(ctx context.Context, opts ...grpc.CallOption) (Orders_SettlementClient, error)
}

OrdersClient is the client API for Orders service.

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

func NewOrdersClient

func NewOrdersClient(cc *grpc.ClientConn) OrdersClient

type OrdersServer

type OrdersServer interface {
	Settlement(Orders_SettlementServer) error
}

OrdersServer is the server API for Orders service.

type Orders_SettlementClient

type Orders_SettlementClient interface {
	Send(*SettlementRequest) error
	Recv() (*SettlementResponse, error)
	grpc.ClientStream
}

type Orders_SettlementServer

type Orders_SettlementServer interface {
	Send(*SettlementResponse) error
	Recv() (*SettlementRequest, error)
	grpc.ServerStream
}

type OverlayInspectorClient

type OverlayInspectorClient interface {
	// CountNodes returns the number of nodes in the cache
	CountNodes(ctx context.Context, in *CountNodesRequest, opts ...grpc.CallOption) (*CountNodesResponse, error)
	// DumpNodes returns all the nodes in the cache
	DumpNodes(ctx context.Context, in *DumpNodesRequest, opts ...grpc.CallOption) (*DumpNodesResponse, error)
	// GetStats returns the stats for a particular node ID
	GetStats(ctx context.Context, in *GetStatsRequest, opts ...grpc.CallOption) (*GetStatsResponse, error)
	// CreateStats creates a node with specified stats
	CreateStats(ctx context.Context, in *CreateStatsRequest, opts ...grpc.CallOption) (*CreateStatsResponse, error)
}

OverlayInspectorClient is the client API for OverlayInspector service.

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

func NewOverlayInspectorClient

func NewOverlayInspectorClient(cc *grpc.ClientConn) OverlayInspectorClient

type OverlayInspectorServer

type OverlayInspectorServer interface {
	// CountNodes returns the number of nodes in the cache
	CountNodes(context.Context, *CountNodesRequest) (*CountNodesResponse, error)
	// DumpNodes returns all the nodes in the cache
	DumpNodes(context.Context, *DumpNodesRequest) (*DumpNodesResponse, error)
	// GetStats returns the stats for a particular node ID
	GetStats(context.Context, *GetStatsRequest) (*GetStatsResponse, error)
	// CreateStats creates a node with specified stats
	CreateStats(context.Context, *CreateStatsRequest) (*CreateStatsResponse, error)
}

OverlayInspectorServer is the server API for OverlayInspector service.

type Path

type Path = storj.Path

Path represents a object path

type PieceAction

type PieceAction int32

PieceAction is an enumeration of all possible executed actions on storage node

const (
	PieceAction_INVALID    PieceAction = 0
	PieceAction_PUT        PieceAction = 1
	PieceAction_GET        PieceAction = 2
	PieceAction_GET_AUDIT  PieceAction = 3
	PieceAction_GET_REPAIR PieceAction = 4
	PieceAction_PUT_REPAIR PieceAction = 5
	PieceAction_DELETE     PieceAction = 6
)

func (PieceAction) EnumDescriptor

func (PieceAction) EnumDescriptor() ([]byte, []int)

func (PieceAction) String

func (x PieceAction) String() string

type PieceDeleteRequest

type PieceDeleteRequest struct {
	Limit                *OrderLimit2 `protobuf:"bytes,1,opt,name=limit,proto3" json:"limit,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*PieceDeleteRequest) Descriptor

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

func (*PieceDeleteRequest) GetLimit

func (m *PieceDeleteRequest) GetLimit() *OrderLimit2

func (*PieceDeleteRequest) ProtoMessage

func (*PieceDeleteRequest) ProtoMessage()

func (*PieceDeleteRequest) Reset

func (m *PieceDeleteRequest) Reset()

func (*PieceDeleteRequest) String

func (m *PieceDeleteRequest) String() string

func (*PieceDeleteRequest) XXX_DiscardUnknown

func (m *PieceDeleteRequest) XXX_DiscardUnknown()

func (*PieceDeleteRequest) XXX_Marshal

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

func (*PieceDeleteRequest) XXX_Merge

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

func (*PieceDeleteRequest) XXX_Size

func (m *PieceDeleteRequest) XXX_Size() int

func (*PieceDeleteRequest) XXX_Unmarshal

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

type PieceDeleteResponse

type PieceDeleteResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PieceDeleteResponse) Descriptor

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

func (*PieceDeleteResponse) ProtoMessage

func (*PieceDeleteResponse) ProtoMessage()

func (*PieceDeleteResponse) Reset

func (m *PieceDeleteResponse) Reset()

func (*PieceDeleteResponse) String

func (m *PieceDeleteResponse) String() string

func (*PieceDeleteResponse) XXX_DiscardUnknown

func (m *PieceDeleteResponse) XXX_DiscardUnknown()

func (*PieceDeleteResponse) XXX_Marshal

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

func (*PieceDeleteResponse) XXX_Merge

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

func (*PieceDeleteResponse) XXX_Size

func (m *PieceDeleteResponse) XXX_Size() int

func (*PieceDeleteResponse) XXX_Unmarshal

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

type PieceDownloadRequest

type PieceDownloadRequest struct {
	// first message to show that we are allowed to upload
	Limit *OrderLimit2 `protobuf:"bytes,1,opt,name=limit,proto3" json:"limit,omitempty"`
	// order for downloading
	Order *Order2 `protobuf:"bytes,2,opt,name=order,proto3" json:"order,omitempty"`
	// request for the chunk
	Chunk                *PieceDownloadRequest_Chunk `protobuf:"bytes,3,opt,name=chunk,proto3" json:"chunk,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                    `json:"-"`
	XXX_unrecognized     []byte                      `json:"-"`
	XXX_sizecache        int32                       `json:"-"`
}

Expected order of messages from uplink:

{OrderLimit, Chunk} ->
go repeated
   Order -> (async)
go repeated
   <- PieceDownloadResponse.Chunk

func (*PieceDownloadRequest) Descriptor

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

func (*PieceDownloadRequest) GetChunk

func (*PieceDownloadRequest) GetLimit

func (m *PieceDownloadRequest) GetLimit() *OrderLimit2

func (*PieceDownloadRequest) GetOrder

func (m *PieceDownloadRequest) GetOrder() *Order2

func (*PieceDownloadRequest) ProtoMessage

func (*PieceDownloadRequest) ProtoMessage()

func (*PieceDownloadRequest) Reset

func (m *PieceDownloadRequest) Reset()

func (*PieceDownloadRequest) String

func (m *PieceDownloadRequest) String() string

func (*PieceDownloadRequest) XXX_DiscardUnknown

func (m *PieceDownloadRequest) XXX_DiscardUnknown()

func (*PieceDownloadRequest) XXX_Marshal

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

func (*PieceDownloadRequest) XXX_Merge

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

func (*PieceDownloadRequest) XXX_Size

func (m *PieceDownloadRequest) XXX_Size() int

func (*PieceDownloadRequest) XXX_Unmarshal

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

type PieceDownloadRequest_Chunk

type PieceDownloadRequest_Chunk struct {
	Offset               int64    `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	ChunkSize            int64    `protobuf:"varint,2,opt,name=chunk_size,json=chunkSize,proto3" json:"chunk_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Chunk that we wish to download

func (*PieceDownloadRequest_Chunk) Descriptor

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

func (*PieceDownloadRequest_Chunk) GetChunkSize

func (m *PieceDownloadRequest_Chunk) GetChunkSize() int64

func (*PieceDownloadRequest_Chunk) GetOffset

func (m *PieceDownloadRequest_Chunk) GetOffset() int64

func (*PieceDownloadRequest_Chunk) ProtoMessage

func (*PieceDownloadRequest_Chunk) ProtoMessage()

func (*PieceDownloadRequest_Chunk) Reset

func (m *PieceDownloadRequest_Chunk) Reset()

func (*PieceDownloadRequest_Chunk) String

func (m *PieceDownloadRequest_Chunk) String() string

func (*PieceDownloadRequest_Chunk) XXX_DiscardUnknown

func (m *PieceDownloadRequest_Chunk) XXX_DiscardUnknown()

func (*PieceDownloadRequest_Chunk) XXX_Marshal

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

func (*PieceDownloadRequest_Chunk) XXX_Merge

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

func (*PieceDownloadRequest_Chunk) XXX_Size

func (m *PieceDownloadRequest_Chunk) XXX_Size() int

func (*PieceDownloadRequest_Chunk) XXX_Unmarshal

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

type PieceDownloadResponse

type PieceDownloadResponse struct {
	Chunk                *PieceDownloadResponse_Chunk `protobuf:"bytes,1,opt,name=chunk,proto3" json:"chunk,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*PieceDownloadResponse) Descriptor

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

func (*PieceDownloadResponse) GetChunk

func (*PieceDownloadResponse) ProtoMessage

func (*PieceDownloadResponse) ProtoMessage()

func (*PieceDownloadResponse) Reset

func (m *PieceDownloadResponse) Reset()

func (*PieceDownloadResponse) String

func (m *PieceDownloadResponse) String() string

func (*PieceDownloadResponse) XXX_DiscardUnknown

func (m *PieceDownloadResponse) XXX_DiscardUnknown()

func (*PieceDownloadResponse) XXX_Marshal

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

func (*PieceDownloadResponse) XXX_Merge

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

func (*PieceDownloadResponse) XXX_Size

func (m *PieceDownloadResponse) XXX_Size() int

func (*PieceDownloadResponse) XXX_Unmarshal

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

type PieceDownloadResponse_Chunk

type PieceDownloadResponse_Chunk struct {
	Offset               int64    `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Data                 []byte   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Chunk response for download request

func (*PieceDownloadResponse_Chunk) Descriptor

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

func (*PieceDownloadResponse_Chunk) GetData

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

func (*PieceDownloadResponse_Chunk) GetOffset

func (m *PieceDownloadResponse_Chunk) GetOffset() int64

func (*PieceDownloadResponse_Chunk) ProtoMessage

func (*PieceDownloadResponse_Chunk) ProtoMessage()

func (*PieceDownloadResponse_Chunk) Reset

func (m *PieceDownloadResponse_Chunk) Reset()

func (*PieceDownloadResponse_Chunk) String

func (m *PieceDownloadResponse_Chunk) String() string

func (*PieceDownloadResponse_Chunk) XXX_DiscardUnknown

func (m *PieceDownloadResponse_Chunk) XXX_DiscardUnknown()

func (*PieceDownloadResponse_Chunk) XXX_Marshal

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

func (*PieceDownloadResponse_Chunk) XXX_Merge

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

func (*PieceDownloadResponse_Chunk) XXX_Size

func (m *PieceDownloadResponse_Chunk) XXX_Size() int

func (*PieceDownloadResponse_Chunk) XXX_Unmarshal

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

type PieceHash

type PieceHash struct {
	// piece id
	PieceId PieceID `protobuf:"bytes,1,opt,name=piece_id,json=pieceId,proto3,customtype=PieceID" json:"piece_id"`
	// hash of the piece that was/is uploaded
	Hash []byte `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
	// signature either satellite or storage node
	Signature            []byte   `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PieceHash) Descriptor

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

func (*PieceHash) GetHash

func (m *PieceHash) GetHash() []byte

func (*PieceHash) GetSignature

func (m *PieceHash) GetSignature() []byte

func (*PieceHash) ProtoMessage

func (*PieceHash) ProtoMessage()

func (*PieceHash) Reset

func (m *PieceHash) Reset()

func (*PieceHash) String

func (m *PieceHash) String() string

func (*PieceHash) XXX_DiscardUnknown

func (m *PieceHash) XXX_DiscardUnknown()

func (*PieceHash) XXX_Marshal

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

func (*PieceHash) XXX_Merge

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

func (*PieceHash) XXX_Size

func (m *PieceHash) XXX_Size() int

func (*PieceHash) XXX_Unmarshal

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

type PieceID

type PieceID = storj.PieceID

PieceID is an alias to storj.PieceID for use in generated protobuf code

type PieceStoreInspectorClient

type PieceStoreInspectorClient interface {
	// Stats return space and bandwidth stats for a storagenode
	Stats(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption) (*StatSummaryResponse, error)
	// Dashboard returns stats for a specific storagenode
	Dashboard(ctx context.Context, in *DashboardRequest, opts ...grpc.CallOption) (*DashboardResponse, error)
}

PieceStoreInspectorClient is the client API for PieceStoreInspector service.

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

func NewPieceStoreInspectorClient

func NewPieceStoreInspectorClient(cc *grpc.ClientConn) PieceStoreInspectorClient

type PieceStoreInspectorServer

type PieceStoreInspectorServer interface {
	// Stats return space and bandwidth stats for a storagenode
	Stats(context.Context, *StatsRequest) (*StatSummaryResponse, error)
	// Dashboard returns stats for a specific storagenode
	Dashboard(context.Context, *DashboardRequest) (*DashboardResponse, error)
}

PieceStoreInspectorServer is the server API for PieceStoreInspector service.

type PieceUploadRequest

type PieceUploadRequest struct {
	// first message to show that we are allowed to upload
	Limit *OrderLimit2 `protobuf:"bytes,1,opt,name=limit,proto3" json:"limit,omitempty"`
	// order for uploading
	Order *Order2                   `protobuf:"bytes,2,opt,name=order,proto3" json:"order,omitempty"`
	Chunk *PieceUploadRequest_Chunk `protobuf:"bytes,3,opt,name=chunk,proto3" json:"chunk,omitempty"`
	// final message
	Done                 *PieceHash `protobuf:"bytes,4,opt,name=done,proto3" json:"done,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

Expected order of messages from uplink:

OrderLimit ->
repeated
   Order ->
   Chunk ->
PieceHash signed by uplink ->
   <- PieceHash signed by storage node

func (*PieceUploadRequest) Descriptor

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

func (*PieceUploadRequest) GetChunk

func (*PieceUploadRequest) GetDone

func (m *PieceUploadRequest) GetDone() *PieceHash

func (*PieceUploadRequest) GetLimit

func (m *PieceUploadRequest) GetLimit() *OrderLimit2

func (*PieceUploadRequest) GetOrder

func (m *PieceUploadRequest) GetOrder() *Order2

func (*PieceUploadRequest) ProtoMessage

func (*PieceUploadRequest) ProtoMessage()

func (*PieceUploadRequest) Reset

func (m *PieceUploadRequest) Reset()

func (*PieceUploadRequest) String

func (m *PieceUploadRequest) String() string

func (*PieceUploadRequest) XXX_DiscardUnknown

func (m *PieceUploadRequest) XXX_DiscardUnknown()

func (*PieceUploadRequest) XXX_Marshal

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

func (*PieceUploadRequest) XXX_Merge

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

func (*PieceUploadRequest) XXX_Size

func (m *PieceUploadRequest) XXX_Size() int

func (*PieceUploadRequest) XXX_Unmarshal

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

type PieceUploadRequest_Chunk

type PieceUploadRequest_Chunk struct {
	Offset               int64    `protobuf:"varint,1,opt,name=offset,proto3" json:"offset,omitempty"`
	Data                 []byte   `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

data message

func (*PieceUploadRequest_Chunk) Descriptor

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

func (*PieceUploadRequest_Chunk) GetData

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

func (*PieceUploadRequest_Chunk) GetOffset

func (m *PieceUploadRequest_Chunk) GetOffset() int64

func (*PieceUploadRequest_Chunk) ProtoMessage

func (*PieceUploadRequest_Chunk) ProtoMessage()

func (*PieceUploadRequest_Chunk) Reset

func (m *PieceUploadRequest_Chunk) Reset()

func (*PieceUploadRequest_Chunk) String

func (m *PieceUploadRequest_Chunk) String() string

func (*PieceUploadRequest_Chunk) XXX_DiscardUnknown

func (m *PieceUploadRequest_Chunk) XXX_DiscardUnknown()

func (*PieceUploadRequest_Chunk) XXX_Marshal

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

func (*PieceUploadRequest_Chunk) XXX_Merge

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

func (*PieceUploadRequest_Chunk) XXX_Size

func (m *PieceUploadRequest_Chunk) XXX_Size() int

func (*PieceUploadRequest_Chunk) XXX_Unmarshal

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

type PieceUploadResponse

type PieceUploadResponse struct {
	Done                 *PieceHash `protobuf:"bytes,1,opt,name=done,proto3" json:"done,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*PieceUploadResponse) Descriptor

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

func (*PieceUploadResponse) GetDone

func (m *PieceUploadResponse) GetDone() *PieceHash

func (*PieceUploadResponse) ProtoMessage

func (*PieceUploadResponse) ProtoMessage()

func (*PieceUploadResponse) Reset

func (m *PieceUploadResponse) Reset()

func (*PieceUploadResponse) String

func (m *PieceUploadResponse) String() string

func (*PieceUploadResponse) XXX_DiscardUnknown

func (m *PieceUploadResponse) XXX_DiscardUnknown()

func (*PieceUploadResponse) XXX_Marshal

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

func (*PieceUploadResponse) XXX_Merge

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

func (*PieceUploadResponse) XXX_Size

func (m *PieceUploadResponse) XXX_Size() int

func (*PieceUploadResponse) XXX_Unmarshal

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

type PiecestoreClient

type PiecestoreClient interface {
	Upload(ctx context.Context, opts ...grpc.CallOption) (Piecestore_UploadClient, error)
	Download(ctx context.Context, opts ...grpc.CallOption) (Piecestore_DownloadClient, error)
	Delete(ctx context.Context, in *PieceDeleteRequest, opts ...grpc.CallOption) (*PieceDeleteResponse, error)
}

PiecestoreClient is the client API for Piecestore service.

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

func NewPiecestoreClient

func NewPiecestoreClient(cc *grpc.ClientConn) PiecestoreClient

type PiecestoreServer

type PiecestoreServer interface {
	Upload(Piecestore_UploadServer) error
	Download(Piecestore_DownloadServer) error
	Delete(context.Context, *PieceDeleteRequest) (*PieceDeleteResponse, error)
}

PiecestoreServer is the server API for Piecestore service.

type Piecestore_DownloadClient

type Piecestore_DownloadClient interface {
	Send(*PieceDownloadRequest) error
	Recv() (*PieceDownloadResponse, error)
	grpc.ClientStream
}

type Piecestore_DownloadServer

type Piecestore_DownloadServer interface {
	Send(*PieceDownloadResponse) error
	Recv() (*PieceDownloadRequest, error)
	grpc.ServerStream
}

type Piecestore_UploadClient

type Piecestore_UploadClient interface {
	Send(*PieceUploadRequest) error
	CloseAndRecv() (*PieceUploadResponse, error)
	grpc.ClientStream
}

type Piecestore_UploadServer

type Piecestore_UploadServer interface {
	SendAndClose(*PieceUploadResponse) error
	Recv() (*PieceUploadRequest, error)
	grpc.ServerStream
}

type PingNodeRequest

type PingNodeRequest struct {
	Id                   NodeID   `protobuf:"bytes,1,opt,name=id,proto3,customtype=NodeID" json:"id"`
	Address              string   `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PingNode

func (*PingNodeRequest) Descriptor

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

func (*PingNodeRequest) GetAddress

func (m *PingNodeRequest) GetAddress() string

func (*PingNodeRequest) ProtoMessage

func (*PingNodeRequest) ProtoMessage()

func (*PingNodeRequest) Reset

func (m *PingNodeRequest) Reset()

func (*PingNodeRequest) String

func (m *PingNodeRequest) String() string

func (*PingNodeRequest) XXX_DiscardUnknown

func (m *PingNodeRequest) XXX_DiscardUnknown()

func (*PingNodeRequest) XXX_Marshal

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

func (*PingNodeRequest) XXX_Merge

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

func (*PingNodeRequest) XXX_Size

func (m *PingNodeRequest) XXX_Size() int

func (*PingNodeRequest) XXX_Unmarshal

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

type PingNodeResponse

type PingNodeResponse struct {
	Ok                   bool     `protobuf:"varint,1,opt,name=ok,proto3" json:"ok,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PingNodeResponse) Descriptor

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

func (*PingNodeResponse) GetOk

func (m *PingNodeResponse) GetOk() bool

func (*PingNodeResponse) ProtoMessage

func (*PingNodeResponse) ProtoMessage()

func (*PingNodeResponse) Reset

func (m *PingNodeResponse) Reset()

func (*PingNodeResponse) String

func (m *PingNodeResponse) String() string

func (*PingNodeResponse) XXX_DiscardUnknown

func (m *PingNodeResponse) XXX_DiscardUnknown()

func (*PingNodeResponse) XXX_Marshal

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

func (*PingNodeResponse) XXX_Merge

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

func (*PingNodeResponse) XXX_Size

func (m *PingNodeResponse) XXX_Size() int

func (*PingNodeResponse) XXX_Unmarshal

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

type PingRequest

type PingRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PingRequest) Descriptor

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

func (*PingRequest) ProtoMessage

func (*PingRequest) ProtoMessage()

func (*PingRequest) Reset

func (m *PingRequest) Reset()

func (*PingRequest) String

func (m *PingRequest) String() string

func (*PingRequest) XXX_DiscardUnknown

func (m *PingRequest) XXX_DiscardUnknown()

func (*PingRequest) XXX_Marshal

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

func (*PingRequest) XXX_Merge

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

func (*PingRequest) XXX_Size

func (m *PingRequest) XXX_Size() int

func (*PingRequest) XXX_Unmarshal

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

type PingResponse

type PingResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*PingResponse) Descriptor

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

func (*PingResponse) ProtoMessage

func (*PingResponse) ProtoMessage()

func (*PingResponse) Reset

func (m *PingResponse) Reset()

func (*PingResponse) String

func (m *PingResponse) String() string

func (*PingResponse) XXX_DiscardUnknown

func (m *PingResponse) XXX_DiscardUnknown()

func (*PingResponse) XXX_Marshal

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

func (*PingResponse) XXX_Merge

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

func (*PingResponse) XXX_Size

func (m *PingResponse) XXX_Size() int

func (*PingResponse) XXX_Unmarshal

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

type Pointer

type Pointer struct {
	Type                 Pointer_DataType     `protobuf:"varint,1,opt,name=type,proto3,enum=pointerdb.Pointer_DataType" json:"type,omitempty"`
	InlineSegment        []byte               `protobuf:"bytes,3,opt,name=inline_segment,json=inlineSegment,proto3" json:"inline_segment,omitempty"`
	Remote               *RemoteSegment       `protobuf:"bytes,4,opt,name=remote,proto3" json:"remote,omitempty"`
	SegmentSize          int64                `protobuf:"varint,5,opt,name=segment_size,json=segmentSize,proto3" json:"segment_size,omitempty"`
	CreationDate         *timestamp.Timestamp `protobuf:"bytes,6,opt,name=creation_date,json=creationDate,proto3" json:"creation_date,omitempty"`
	ExpirationDate       *timestamp.Timestamp `protobuf:"bytes,7,opt,name=expiration_date,json=expirationDate,proto3" json:"expiration_date,omitempty"`
	Metadata             []byte               `protobuf:"bytes,8,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Pointer) Descriptor

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

func (*Pointer) GetCreationDate

func (m *Pointer) GetCreationDate() *timestamp.Timestamp

func (*Pointer) GetExpirationDate

func (m *Pointer) GetExpirationDate() *timestamp.Timestamp

func (*Pointer) GetInlineSegment

func (m *Pointer) GetInlineSegment() []byte

func (*Pointer) GetMetadata

func (m *Pointer) GetMetadata() []byte

func (*Pointer) GetRemote

func (m *Pointer) GetRemote() *RemoteSegment

func (*Pointer) GetSegmentSize

func (m *Pointer) GetSegmentSize() int64

func (*Pointer) GetType

func (m *Pointer) GetType() Pointer_DataType

func (*Pointer) ProtoMessage

func (*Pointer) ProtoMessage()

func (*Pointer) Reset

func (m *Pointer) Reset()

func (*Pointer) String

func (m *Pointer) String() string

func (*Pointer) XXX_DiscardUnknown

func (m *Pointer) XXX_DiscardUnknown()

func (*Pointer) XXX_Marshal

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

func (*Pointer) XXX_Merge

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

func (*Pointer) XXX_Size

func (m *Pointer) XXX_Size() int

func (*Pointer) XXX_Unmarshal

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

type Pointer_DataType

type Pointer_DataType int32
const (
	Pointer_INLINE Pointer_DataType = 0
	Pointer_REMOTE Pointer_DataType = 1
)

func (Pointer_DataType) EnumDescriptor

func (Pointer_DataType) EnumDescriptor() ([]byte, []int)

func (Pointer_DataType) String

func (x Pointer_DataType) String() string

type QueryRequest

type QueryRequest struct {
	Sender               *Node    `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	Target               *Node    `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	Limit                int64    `protobuf:"varint,3,opt,name=limit,proto3" json:"limit,omitempty"`
	Pingback             bool     `protobuf:"varint,4,opt,name=pingback,proto3" json:"pingback,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryRequest) Descriptor

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

func (*QueryRequest) GetLimit

func (m *QueryRequest) GetLimit() int64

func (*QueryRequest) GetPingback

func (m *QueryRequest) GetPingback() bool

func (*QueryRequest) GetSender

func (m *QueryRequest) GetSender() *Node

func (*QueryRequest) GetTarget

func (m *QueryRequest) GetTarget() *Node

func (*QueryRequest) ProtoMessage

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) Reset

func (m *QueryRequest) Reset()

func (*QueryRequest) String

func (m *QueryRequest) String() string

func (*QueryRequest) XXX_DiscardUnknown

func (m *QueryRequest) XXX_DiscardUnknown()

func (*QueryRequest) XXX_Marshal

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

func (*QueryRequest) XXX_Merge

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

func (*QueryRequest) XXX_Size

func (m *QueryRequest) XXX_Size() int

func (*QueryRequest) XXX_Unmarshal

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

type QueryResponse

type QueryResponse struct {
	Sender               *Node    `protobuf:"bytes,1,opt,name=sender,proto3" json:"sender,omitempty"`
	Response             []*Node  `protobuf:"bytes,2,rep,name=response,proto3" json:"response,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*QueryResponse) Descriptor

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

func (*QueryResponse) GetResponse

func (m *QueryResponse) GetResponse() []*Node

func (*QueryResponse) GetSender

func (m *QueryResponse) GetSender() *Node

func (*QueryResponse) ProtoMessage

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) Reset

func (m *QueryResponse) Reset()

func (*QueryResponse) String

func (m *QueryResponse) String() string

func (*QueryResponse) XXX_DiscardUnknown

func (m *QueryResponse) XXX_DiscardUnknown()

func (*QueryResponse) XXX_Marshal

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

func (*QueryResponse) XXX_Merge

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

func (*QueryResponse) XXX_Size

func (m *QueryResponse) XXX_Size() int

func (*QueryResponse) XXX_Unmarshal

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

type RedundancyScheme

type RedundancyScheme struct {
	Type RedundancyScheme_SchemeType `protobuf:"varint,1,opt,name=type,proto3,enum=pointerdb.RedundancyScheme_SchemeType" json:"type,omitempty"`
	// these values apply to RS encoding
	MinReq               int32    `protobuf:"varint,2,opt,name=min_req,json=minReq,proto3" json:"min_req,omitempty"`
	Total                int32    `protobuf:"varint,3,opt,name=total,proto3" json:"total,omitempty"`
	RepairThreshold      int32    `protobuf:"varint,4,opt,name=repair_threshold,json=repairThreshold,proto3" json:"repair_threshold,omitempty"`
	SuccessThreshold     int32    `protobuf:"varint,5,opt,name=success_threshold,json=successThreshold,proto3" json:"success_threshold,omitempty"`
	ErasureShareSize     int32    `protobuf:"varint,6,opt,name=erasure_share_size,json=erasureShareSize,proto3" json:"erasure_share_size,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RedundancyScheme) Descriptor

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

func (*RedundancyScheme) GetErasureShareSize

func (m *RedundancyScheme) GetErasureShareSize() int32

func (*RedundancyScheme) GetMinReq

func (m *RedundancyScheme) GetMinReq() int32

func (*RedundancyScheme) GetRepairThreshold

func (m *RedundancyScheme) GetRepairThreshold() int32

func (*RedundancyScheme) GetSuccessThreshold

func (m *RedundancyScheme) GetSuccessThreshold() int32

func (*RedundancyScheme) GetTotal

func (m *RedundancyScheme) GetTotal() int32

func (*RedundancyScheme) GetType

func (*RedundancyScheme) ProtoMessage

func (*RedundancyScheme) ProtoMessage()

func (*RedundancyScheme) Reset

func (m *RedundancyScheme) Reset()

func (*RedundancyScheme) String

func (m *RedundancyScheme) String() string

func (*RedundancyScheme) XXX_DiscardUnknown

func (m *RedundancyScheme) XXX_DiscardUnknown()

func (*RedundancyScheme) XXX_Marshal

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

func (*RedundancyScheme) XXX_Merge

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

func (*RedundancyScheme) XXX_Size

func (m *RedundancyScheme) XXX_Size() int

func (*RedundancyScheme) XXX_Unmarshal

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

type RedundancyScheme_SchemeType

type RedundancyScheme_SchemeType int32
const (
	RedundancyScheme_RS RedundancyScheme_SchemeType = 0
)

func (RedundancyScheme_SchemeType) EnumDescriptor

func (RedundancyScheme_SchemeType) EnumDescriptor() ([]byte, []int)

func (RedundancyScheme_SchemeType) String

type RemotePiece

type RemotePiece struct {
	PieceNum             int32      `protobuf:"varint,1,opt,name=piece_num,json=pieceNum,proto3" json:"piece_num,omitempty"`
	NodeId               NodeID     `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3,customtype=NodeID" json:"node_id"`
	Hash                 *PieceHash `protobuf:"bytes,3,opt,name=hash,proto3" json:"hash,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*RemotePiece) Descriptor

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

func (*RemotePiece) GetHash

func (m *RemotePiece) GetHash() *PieceHash

func (*RemotePiece) GetPieceNum

func (m *RemotePiece) GetPieceNum() int32

func (*RemotePiece) ProtoMessage

func (*RemotePiece) ProtoMessage()

func (*RemotePiece) Reset

func (m *RemotePiece) Reset()

func (*RemotePiece) String

func (m *RemotePiece) String() string

func (*RemotePiece) XXX_DiscardUnknown

func (m *RemotePiece) XXX_DiscardUnknown()

func (*RemotePiece) XXX_Marshal

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

func (*RemotePiece) XXX_Merge

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

func (*RemotePiece) XXX_Size

func (m *RemotePiece) XXX_Size() int

func (*RemotePiece) XXX_Unmarshal

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

type RemoteSegment

type RemoteSegment struct {
	Redundancy           *RedundancyScheme `protobuf:"bytes,1,opt,name=redundancy,proto3" json:"redundancy,omitempty"`
	RootPieceId          PieceID           `protobuf:"bytes,2,opt,name=root_piece_id,json=rootPieceId,proto3,customtype=PieceID" json:"root_piece_id"`
	RemotePieces         []*RemotePiece    `protobuf:"bytes,3,rep,name=remote_pieces,json=remotePieces,proto3" json:"remote_pieces,omitempty"`
	MerkleRoot           []byte            `protobuf:"bytes,4,opt,name=merkle_root,json=merkleRoot,proto3" json:"merkle_root,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*RemoteSegment) Descriptor

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

func (*RemoteSegment) GetMerkleRoot

func (m *RemoteSegment) GetMerkleRoot() []byte

func (*RemoteSegment) GetRedundancy

func (m *RemoteSegment) GetRedundancy() *RedundancyScheme

func (*RemoteSegment) GetRemotePieces

func (m *RemoteSegment) GetRemotePieces() []*RemotePiece

func (*RemoteSegment) ProtoMessage

func (*RemoteSegment) ProtoMessage()

func (*RemoteSegment) Reset

func (m *RemoteSegment) Reset()

func (*RemoteSegment) String

func (m *RemoteSegment) String() string

func (*RemoteSegment) XXX_DiscardUnknown

func (m *RemoteSegment) XXX_DiscardUnknown()

func (*RemoteSegment) XXX_Marshal

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

func (*RemoteSegment) XXX_Merge

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

func (*RemoteSegment) XXX_Size

func (m *RemoteSegment) XXX_Size() int

func (*RemoteSegment) XXX_Unmarshal

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

type Restriction

type Restriction struct {
	Operator             Restriction_Operator `protobuf:"varint,1,opt,name=operator,proto3,enum=overlay.Restriction_Operator" json:"operator,omitempty"`
	Operand              Restriction_Operand  `protobuf:"varint,2,opt,name=operand,proto3,enum=overlay.Restriction_Operand" json:"operand,omitempty"`
	Value                int64                `protobuf:"varint,3,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*Restriction) Descriptor

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

func (*Restriction) GetOperand

func (m *Restriction) GetOperand() Restriction_Operand

func (*Restriction) GetOperator

func (m *Restriction) GetOperator() Restriction_Operator

func (*Restriction) GetValue

func (m *Restriction) GetValue() int64

func (*Restriction) ProtoMessage

func (*Restriction) ProtoMessage()

func (*Restriction) Reset

func (m *Restriction) Reset()

func (*Restriction) String

func (m *Restriction) String() string

func (*Restriction) XXX_DiscardUnknown

func (m *Restriction) XXX_DiscardUnknown()

func (*Restriction) XXX_Marshal

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

func (*Restriction) XXX_Merge

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

func (*Restriction) XXX_Size

func (m *Restriction) XXX_Size() int

func (*Restriction) XXX_Unmarshal

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

type Restriction_Operand

type Restriction_Operand int32
const (
	Restriction_FREE_BANDWIDTH Restriction_Operand = 0
	Restriction_FREE_DISK      Restriction_Operand = 1
)

func (Restriction_Operand) EnumDescriptor

func (Restriction_Operand) EnumDescriptor() ([]byte, []int)

func (Restriction_Operand) String

func (x Restriction_Operand) String() string

type Restriction_Operator

type Restriction_Operator int32
const (
	Restriction_LT  Restriction_Operator = 0
	Restriction_EQ  Restriction_Operator = 1
	Restriction_GT  Restriction_Operator = 2
	Restriction_LTE Restriction_Operator = 3
	Restriction_GTE Restriction_Operator = 4
)

func (Restriction_Operator) EnumDescriptor

func (Restriction_Operator) EnumDescriptor() ([]byte, []int)

func (Restriction_Operator) String

func (x Restriction_Operator) String() string

type SegmentCommitRequest

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       []*OrderLimit2 `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 (*SegmentCommitRequest) Descriptor

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

func (*SegmentCommitRequest) GetBucket

func (m *SegmentCommitRequest) GetBucket() []byte

func (*SegmentCommitRequest) GetOriginalLimits

func (m *SegmentCommitRequest) GetOriginalLimits() []*OrderLimit2

func (*SegmentCommitRequest) GetPath

func (m *SegmentCommitRequest) GetPath() []byte

func (*SegmentCommitRequest) GetPointer

func (m *SegmentCommitRequest) GetPointer() *Pointer

func (*SegmentCommitRequest) GetSegment

func (m *SegmentCommitRequest) GetSegment() int64

func (*SegmentCommitRequest) ProtoMessage

func (*SegmentCommitRequest) ProtoMessage()

func (*SegmentCommitRequest) Reset

func (m *SegmentCommitRequest) Reset()

func (*SegmentCommitRequest) String

func (m *SegmentCommitRequest) String() string

func (*SegmentCommitRequest) XXX_DiscardUnknown

func (m *SegmentCommitRequest) XXX_DiscardUnknown()

func (*SegmentCommitRequest) XXX_Marshal

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

func (*SegmentCommitRequest) XXX_Merge

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

func (*SegmentCommitRequest) XXX_Size

func (m *SegmentCommitRequest) XXX_Size() int

func (*SegmentCommitRequest) XXX_Unmarshal

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

type SegmentCommitResponse

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 (*SegmentCommitResponse) Descriptor

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

func (*SegmentCommitResponse) GetPointer

func (m *SegmentCommitResponse) GetPointer() *Pointer

func (*SegmentCommitResponse) ProtoMessage

func (*SegmentCommitResponse) ProtoMessage()

func (*SegmentCommitResponse) Reset

func (m *SegmentCommitResponse) Reset()

func (*SegmentCommitResponse) String

func (m *SegmentCommitResponse) String() string

func (*SegmentCommitResponse) XXX_DiscardUnknown

func (m *SegmentCommitResponse) XXX_DiscardUnknown()

func (*SegmentCommitResponse) XXX_Marshal

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

func (*SegmentCommitResponse) XXX_Merge

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

func (*SegmentCommitResponse) XXX_Size

func (m *SegmentCommitResponse) XXX_Size() int

func (*SegmentCommitResponse) XXX_Unmarshal

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

type SegmentDeleteRequest

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 (*SegmentDeleteRequest) Descriptor

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

func (*SegmentDeleteRequest) GetBucket

func (m *SegmentDeleteRequest) GetBucket() []byte

func (*SegmentDeleteRequest) GetPath

func (m *SegmentDeleteRequest) GetPath() []byte

func (*SegmentDeleteRequest) GetSegment

func (m *SegmentDeleteRequest) GetSegment() int64

func (*SegmentDeleteRequest) ProtoMessage

func (*SegmentDeleteRequest) ProtoMessage()

func (*SegmentDeleteRequest) Reset

func (m *SegmentDeleteRequest) Reset()

func (*SegmentDeleteRequest) String

func (m *SegmentDeleteRequest) String() string

func (*SegmentDeleteRequest) XXX_DiscardUnknown

func (m *SegmentDeleteRequest) XXX_DiscardUnknown()

func (*SegmentDeleteRequest) XXX_Marshal

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

func (*SegmentDeleteRequest) XXX_Merge

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

func (*SegmentDeleteRequest) XXX_Size

func (m *SegmentDeleteRequest) XXX_Size() int

func (*SegmentDeleteRequest) XXX_Unmarshal

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

type SegmentDeleteResponse

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 (*SegmentDeleteResponse) Descriptor

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

func (*SegmentDeleteResponse) GetAddressedLimits

func (m *SegmentDeleteResponse) GetAddressedLimits() []*AddressedOrderLimit

func (*SegmentDeleteResponse) ProtoMessage

func (*SegmentDeleteResponse) ProtoMessage()

func (*SegmentDeleteResponse) Reset

func (m *SegmentDeleteResponse) Reset()

func (*SegmentDeleteResponse) String

func (m *SegmentDeleteResponse) String() string

func (*SegmentDeleteResponse) XXX_DiscardUnknown

func (m *SegmentDeleteResponse) XXX_DiscardUnknown()

func (*SegmentDeleteResponse) XXX_Marshal

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

func (*SegmentDeleteResponse) XXX_Merge

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

func (*SegmentDeleteResponse) XXX_Size

func (m *SegmentDeleteResponse) XXX_Size() int

func (*SegmentDeleteResponse) XXX_Unmarshal

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

type SegmentDownloadRequest

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 (*SegmentDownloadRequest) Descriptor

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

func (*SegmentDownloadRequest) GetBucket

func (m *SegmentDownloadRequest) GetBucket() []byte

func (*SegmentDownloadRequest) GetPath

func (m *SegmentDownloadRequest) GetPath() []byte

func (*SegmentDownloadRequest) GetSegment

func (m *SegmentDownloadRequest) GetSegment() int64

func (*SegmentDownloadRequest) ProtoMessage

func (*SegmentDownloadRequest) ProtoMessage()

func (*SegmentDownloadRequest) Reset

func (m *SegmentDownloadRequest) Reset()

func (*SegmentDownloadRequest) String

func (m *SegmentDownloadRequest) String() string

func (*SegmentDownloadRequest) XXX_DiscardUnknown

func (m *SegmentDownloadRequest) XXX_DiscardUnknown()

func (*SegmentDownloadRequest) XXX_Marshal

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

func (*SegmentDownloadRequest) XXX_Merge

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

func (*SegmentDownloadRequest) XXX_Size

func (m *SegmentDownloadRequest) XXX_Size() int

func (*SegmentDownloadRequest) XXX_Unmarshal

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

type SegmentDownloadResponse

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 (*SegmentDownloadResponse) Descriptor

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

func (*SegmentDownloadResponse) GetAddressedLimits

func (m *SegmentDownloadResponse) GetAddressedLimits() []*AddressedOrderLimit

func (*SegmentDownloadResponse) GetPointer

func (m *SegmentDownloadResponse) GetPointer() *Pointer

func (*SegmentDownloadResponse) ProtoMessage

func (*SegmentDownloadResponse) ProtoMessage()

func (*SegmentDownloadResponse) Reset

func (m *SegmentDownloadResponse) Reset()

func (*SegmentDownloadResponse) String

func (m *SegmentDownloadResponse) String() string

func (*SegmentDownloadResponse) XXX_DiscardUnknown

func (m *SegmentDownloadResponse) XXX_DiscardUnknown()

func (*SegmentDownloadResponse) XXX_Marshal

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

func (*SegmentDownloadResponse) XXX_Merge

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

func (*SegmentDownloadResponse) XXX_Size

func (m *SegmentDownloadResponse) XXX_Size() int

func (*SegmentDownloadResponse) XXX_Unmarshal

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

type SegmentHealth

type SegmentHealth struct {
	OnlineNodes          int32    `protobuf:"varint,1,opt,name=online_nodes,json=onlineNodes,proto3" json:"online_nodes,omitempty"`
	Segment              []byte   `protobuf:"bytes,2,opt,name=segment,proto3" json:"segment,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SegmentHealth) Descriptor

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

func (*SegmentHealth) GetOnlineNodes

func (m *SegmentHealth) GetOnlineNodes() int32

func (*SegmentHealth) GetSegment

func (m *SegmentHealth) GetSegment() []byte

func (*SegmentHealth) ProtoMessage

func (*SegmentHealth) ProtoMessage()

func (*SegmentHealth) Reset

func (m *SegmentHealth) Reset()

func (*SegmentHealth) String

func (m *SegmentHealth) String() string

func (*SegmentHealth) XXX_DiscardUnknown

func (m *SegmentHealth) XXX_DiscardUnknown()

func (*SegmentHealth) XXX_Marshal

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

func (*SegmentHealth) XXX_Merge

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

func (*SegmentHealth) XXX_Size

func (m *SegmentHealth) XXX_Size() int

func (*SegmentHealth) XXX_Unmarshal

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

type SegmentHealthRequest

type SegmentHealthRequest struct {
	Bucket               []byte   `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	EncryptedPath        []byte   `protobuf:"bytes,2,opt,name=encrypted_path,json=encryptedPath,proto3" json:"encrypted_path,omitempty"`
	SegmentIndex         int64    `protobuf:"varint,3,opt,name=segment_index,json=segmentIndex,proto3" json:"segment_index,omitempty"`
	ProjectId            []byte   `protobuf:"bytes,4,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SegmentHealthRequest) Descriptor

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

func (*SegmentHealthRequest) GetBucket

func (m *SegmentHealthRequest) GetBucket() []byte

func (*SegmentHealthRequest) GetEncryptedPath

func (m *SegmentHealthRequest) GetEncryptedPath() []byte

func (*SegmentHealthRequest) GetProjectId

func (m *SegmentHealthRequest) GetProjectId() []byte

func (*SegmentHealthRequest) GetSegmentIndex

func (m *SegmentHealthRequest) GetSegmentIndex() int64

func (*SegmentHealthRequest) ProtoMessage

func (*SegmentHealthRequest) ProtoMessage()

func (*SegmentHealthRequest) Reset

func (m *SegmentHealthRequest) Reset()

func (*SegmentHealthRequest) String

func (m *SegmentHealthRequest) String() string

func (*SegmentHealthRequest) XXX_DiscardUnknown

func (m *SegmentHealthRequest) XXX_DiscardUnknown()

func (*SegmentHealthRequest) XXX_Marshal

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

func (*SegmentHealthRequest) XXX_Merge

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

func (*SegmentHealthRequest) XXX_Size

func (m *SegmentHealthRequest) XXX_Size() int

func (*SegmentHealthRequest) XXX_Unmarshal

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

type SegmentHealthResponse

type SegmentHealthResponse struct {
	Health               *SegmentHealth    `protobuf:"bytes,1,opt,name=health,proto3" json:"health,omitempty"`
	Redundancy           *RedundancyScheme `protobuf:"bytes,2,opt,name=redundancy,proto3" json:"redundancy,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*SegmentHealthResponse) Descriptor

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

func (*SegmentHealthResponse) GetHealth

func (m *SegmentHealthResponse) GetHealth() *SegmentHealth

func (*SegmentHealthResponse) GetRedundancy

func (m *SegmentHealthResponse) GetRedundancy() *RedundancyScheme

func (*SegmentHealthResponse) ProtoMessage

func (*SegmentHealthResponse) ProtoMessage()

func (*SegmentHealthResponse) Reset

func (m *SegmentHealthResponse) Reset()

func (*SegmentHealthResponse) String

func (m *SegmentHealthResponse) String() string

func (*SegmentHealthResponse) XXX_DiscardUnknown

func (m *SegmentHealthResponse) XXX_DiscardUnknown()

func (*SegmentHealthResponse) XXX_Marshal

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

func (*SegmentHealthResponse) XXX_Merge

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

func (*SegmentHealthResponse) XXX_Size

func (m *SegmentHealthResponse) XXX_Size() int

func (*SegmentHealthResponse) XXX_Unmarshal

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

type SegmentInfoRequest

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 (*SegmentInfoRequest) Descriptor

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

func (*SegmentInfoRequest) GetBucket

func (m *SegmentInfoRequest) GetBucket() []byte

func (*SegmentInfoRequest) GetPath

func (m *SegmentInfoRequest) GetPath() []byte

func (*SegmentInfoRequest) GetSegment

func (m *SegmentInfoRequest) GetSegment() int64

func (*SegmentInfoRequest) ProtoMessage

func (*SegmentInfoRequest) ProtoMessage()

func (*SegmentInfoRequest) Reset

func (m *SegmentInfoRequest) Reset()

func (*SegmentInfoRequest) String

func (m *SegmentInfoRequest) String() string

func (*SegmentInfoRequest) XXX_DiscardUnknown

func (m *SegmentInfoRequest) XXX_DiscardUnknown()

func (*SegmentInfoRequest) XXX_Marshal

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

func (*SegmentInfoRequest) XXX_Merge

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

func (*SegmentInfoRequest) XXX_Size

func (m *SegmentInfoRequest) XXX_Size() int

func (*SegmentInfoRequest) XXX_Unmarshal

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

type SegmentInfoResponse

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 (*SegmentInfoResponse) Descriptor

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

func (*SegmentInfoResponse) GetPointer

func (m *SegmentInfoResponse) GetPointer() *Pointer

func (*SegmentInfoResponse) ProtoMessage

func (*SegmentInfoResponse) ProtoMessage()

func (*SegmentInfoResponse) Reset

func (m *SegmentInfoResponse) Reset()

func (*SegmentInfoResponse) String

func (m *SegmentInfoResponse) String() string

func (*SegmentInfoResponse) XXX_DiscardUnknown

func (m *SegmentInfoResponse) XXX_DiscardUnknown()

func (*SegmentInfoResponse) XXX_Marshal

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

func (*SegmentInfoResponse) XXX_Merge

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

func (*SegmentInfoResponse) XXX_Size

func (m *SegmentInfoResponse) XXX_Size() int

func (*SegmentInfoResponse) XXX_Unmarshal

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

type SegmentMeta

type SegmentMeta struct {
	EncryptedKey         []byte   `protobuf:"bytes,1,opt,name=encrypted_key,json=encryptedKey,proto3" json:"encrypted_key,omitempty"`
	KeyNonce             []byte   `protobuf:"bytes,2,opt,name=key_nonce,json=keyNonce,proto3" json:"key_nonce,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SegmentMeta) Descriptor

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

func (*SegmentMeta) GetEncryptedKey

func (m *SegmentMeta) GetEncryptedKey() []byte

func (*SegmentMeta) GetKeyNonce

func (m *SegmentMeta) GetKeyNonce() []byte

func (*SegmentMeta) ProtoMessage

func (*SegmentMeta) ProtoMessage()

func (*SegmentMeta) Reset

func (m *SegmentMeta) Reset()

func (*SegmentMeta) String

func (m *SegmentMeta) String() string

func (*SegmentMeta) XXX_DiscardUnknown

func (m *SegmentMeta) XXX_DiscardUnknown()

func (*SegmentMeta) XXX_Marshal

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

func (*SegmentMeta) XXX_Merge

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

func (*SegmentMeta) XXX_Size

func (m *SegmentMeta) XXX_Size() int

func (*SegmentMeta) XXX_Unmarshal

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

type SegmentWriteRequest

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                `` /* 135-byte string literal not displayed */
	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 (*SegmentWriteRequest) Descriptor

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

func (*SegmentWriteRequest) GetBucket

func (m *SegmentWriteRequest) GetBucket() []byte

func (*SegmentWriteRequest) GetExpiration

func (m *SegmentWriteRequest) GetExpiration() *timestamp.Timestamp

func (*SegmentWriteRequest) GetMaxEncryptedSegmentSize

func (m *SegmentWriteRequest) GetMaxEncryptedSegmentSize() int64

func (*SegmentWriteRequest) GetPath

func (m *SegmentWriteRequest) GetPath() []byte

func (*SegmentWriteRequest) GetRedundancy

func (m *SegmentWriteRequest) GetRedundancy() *RedundancyScheme

func (*SegmentWriteRequest) GetSegment

func (m *SegmentWriteRequest) GetSegment() int64

func (*SegmentWriteRequest) ProtoMessage

func (*SegmentWriteRequest) ProtoMessage()

func (*SegmentWriteRequest) Reset

func (m *SegmentWriteRequest) Reset()

func (*SegmentWriteRequest) String

func (m *SegmentWriteRequest) String() string

func (*SegmentWriteRequest) XXX_DiscardUnknown

func (m *SegmentWriteRequest) XXX_DiscardUnknown()

func (*SegmentWriteRequest) XXX_Marshal

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

func (*SegmentWriteRequest) XXX_Merge

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

func (*SegmentWriteRequest) XXX_Size

func (m *SegmentWriteRequest) XXX_Size() int

func (*SegmentWriteRequest) XXX_Unmarshal

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

type SegmentWriteResponse

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 (*SegmentWriteResponse) Descriptor

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

func (*SegmentWriteResponse) GetAddressedLimits

func (m *SegmentWriteResponse) GetAddressedLimits() []*AddressedOrderLimit

func (*SegmentWriteResponse) ProtoMessage

func (*SegmentWriteResponse) ProtoMessage()

func (*SegmentWriteResponse) Reset

func (m *SegmentWriteResponse) Reset()

func (*SegmentWriteResponse) String

func (m *SegmentWriteResponse) String() string

func (*SegmentWriteResponse) XXX_DiscardUnknown

func (m *SegmentWriteResponse) XXX_DiscardUnknown()

func (*SegmentWriteResponse) XXX_Marshal

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

func (*SegmentWriteResponse) XXX_Merge

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

func (*SegmentWriteResponse) XXX_Size

func (m *SegmentWriteResponse) XXX_Size() int

func (*SegmentWriteResponse) XXX_Unmarshal

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

type SerialNumber

type SerialNumber = storj.SerialNumber

SerialNumber is an alias to storj.SerialNumber for use in generated protobuf code

type SerializableMeta

type SerializableMeta struct {
	ContentType          string            `protobuf:"bytes,1,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	UserDefined          map[string]string `` /* 182-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

SerializableMeta is the object metadata that will be stored serialized

func (*SerializableMeta) Descriptor

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

func (*SerializableMeta) GetContentType

func (m *SerializableMeta) GetContentType() string

func (*SerializableMeta) GetUserDefined

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

func (*SerializableMeta) ProtoMessage

func (*SerializableMeta) ProtoMessage()

func (*SerializableMeta) Reset

func (m *SerializableMeta) Reset()

func (*SerializableMeta) String

func (m *SerializableMeta) String() string

func (*SerializableMeta) XXX_DiscardUnknown

func (m *SerializableMeta) XXX_DiscardUnknown()

func (*SerializableMeta) XXX_Marshal

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

func (*SerializableMeta) XXX_Merge

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

func (*SerializableMeta) XXX_Size

func (m *SerializableMeta) XXX_Size() int

func (*SerializableMeta) XXX_Unmarshal

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

type SettlementRequest

type SettlementRequest struct {
	Limit                *OrderLimit2 `protobuf:"bytes,1,opt,name=limit,proto3" json:"limit,omitempty"`
	Order                *Order2      `protobuf:"bytes,2,opt,name=order,proto3" json:"order,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*SettlementRequest) Descriptor

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

func (*SettlementRequest) GetLimit

func (m *SettlementRequest) GetLimit() *OrderLimit2

func (*SettlementRequest) GetOrder

func (m *SettlementRequest) GetOrder() *Order2

func (*SettlementRequest) ProtoMessage

func (*SettlementRequest) ProtoMessage()

func (*SettlementRequest) Reset

func (m *SettlementRequest) Reset()

func (*SettlementRequest) String

func (m *SettlementRequest) String() string

func (*SettlementRequest) XXX_DiscardUnknown

func (m *SettlementRequest) XXX_DiscardUnknown()

func (*SettlementRequest) XXX_Marshal

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

func (*SettlementRequest) XXX_Merge

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

func (*SettlementRequest) XXX_Size

func (m *SettlementRequest) XXX_Size() int

func (*SettlementRequest) XXX_Unmarshal

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

type SettlementResponse

type SettlementResponse struct {
	SerialNumber         SerialNumber              `protobuf:"bytes,1,opt,name=serial_number,json=serialNumber,proto3,customtype=SerialNumber" json:"serial_number"`
	Status               SettlementResponse_Status `protobuf:"varint,2,opt,name=status,proto3,enum=orders.SettlementResponse_Status" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*SettlementResponse) Descriptor

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

func (*SettlementResponse) GetStatus

func (*SettlementResponse) ProtoMessage

func (*SettlementResponse) ProtoMessage()

func (*SettlementResponse) Reset

func (m *SettlementResponse) Reset()

func (*SettlementResponse) String

func (m *SettlementResponse) String() string

func (*SettlementResponse) XXX_DiscardUnknown

func (m *SettlementResponse) XXX_DiscardUnknown()

func (*SettlementResponse) XXX_Marshal

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

func (*SettlementResponse) XXX_Merge

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

func (*SettlementResponse) XXX_Size

func (m *SettlementResponse) XXX_Size() int

func (*SettlementResponse) XXX_Unmarshal

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

type SettlementResponse_Status

type SettlementResponse_Status int32
const (
	SettlementResponse_INVALID  SettlementResponse_Status = 0
	SettlementResponse_ACCEPTED SettlementResponse_Status = 1
	SettlementResponse_REJECTED SettlementResponse_Status = 2
)

func (SettlementResponse_Status) EnumDescriptor

func (SettlementResponse_Status) EnumDescriptor() ([]byte, []int)

func (SettlementResponse_Status) String

func (x SettlementResponse_Status) String() string

type SigningRequest

type SigningRequest struct {
	AuthToken            string   `protobuf:"bytes,1,opt,name=auth_token,json=authToken,proto3" json:"auth_token,omitempty"`
	Timestamp            int64    `protobuf:"varint,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SigningRequest) Descriptor

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

func (*SigningRequest) GetAuthToken

func (m *SigningRequest) GetAuthToken() string

func (*SigningRequest) GetTimestamp

func (m *SigningRequest) GetTimestamp() int64

func (*SigningRequest) ProtoMessage

func (*SigningRequest) ProtoMessage()

func (*SigningRequest) Reset

func (m *SigningRequest) Reset()

func (*SigningRequest) String

func (m *SigningRequest) String() string

func (*SigningRequest) XXX_DiscardUnknown

func (m *SigningRequest) XXX_DiscardUnknown()

func (*SigningRequest) XXX_Marshal

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

func (*SigningRequest) XXX_Merge

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

func (*SigningRequest) XXX_Size

func (m *SigningRequest) XXX_Size() int

func (*SigningRequest) XXX_Unmarshal

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

type SigningResponse

type SigningResponse struct {
	Chain                [][]byte `protobuf:"bytes,1,rep,name=chain,proto3" json:"chain,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SigningResponse) Descriptor

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

func (*SigningResponse) GetChain

func (m *SigningResponse) GetChain() [][]byte

func (*SigningResponse) ProtoMessage

func (*SigningResponse) ProtoMessage()

func (*SigningResponse) Reset

func (m *SigningResponse) Reset()

func (*SigningResponse) String

func (m *SigningResponse) String() string

func (*SigningResponse) XXX_DiscardUnknown

func (m *SigningResponse) XXX_DiscardUnknown()

func (*SigningResponse) XXX_Marshal

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

func (*SigningResponse) XXX_Merge

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

func (*SigningResponse) XXX_Size

func (m *SigningResponse) XXX_Size() int

func (*SigningResponse) XXX_Unmarshal

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

type StatSummaryResponse

type StatSummaryResponse struct {
	UsedSpace            int64    `protobuf:"varint,1,opt,name=used_space,json=usedSpace,proto3" json:"used_space,omitempty"`
	AvailableSpace       int64    `protobuf:"varint,2,opt,name=available_space,json=availableSpace,proto3" json:"available_space,omitempty"`
	UsedIngress          int64    `protobuf:"varint,3,opt,name=used_ingress,json=usedIngress,proto3" json:"used_ingress,omitempty"`
	UsedEgress           int64    `protobuf:"varint,4,opt,name=used_egress,json=usedEgress,proto3" json:"used_egress,omitempty"`
	UsedBandwidth        int64    `protobuf:"varint,5,opt,name=used_bandwidth,json=usedBandwidth,proto3" json:"used_bandwidth,omitempty"`
	AvailableBandwidth   int64    `protobuf:"varint,6,opt,name=available_bandwidth,json=availableBandwidth,proto3" json:"available_bandwidth,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatSummaryResponse) Descriptor

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

func (*StatSummaryResponse) GetAvailableBandwidth

func (m *StatSummaryResponse) GetAvailableBandwidth() int64

func (*StatSummaryResponse) GetAvailableSpace

func (m *StatSummaryResponse) GetAvailableSpace() int64

func (*StatSummaryResponse) GetUsedBandwidth

func (m *StatSummaryResponse) GetUsedBandwidth() int64

func (*StatSummaryResponse) GetUsedEgress

func (m *StatSummaryResponse) GetUsedEgress() int64

func (*StatSummaryResponse) GetUsedIngress

func (m *StatSummaryResponse) GetUsedIngress() int64

func (*StatSummaryResponse) GetUsedSpace

func (m *StatSummaryResponse) GetUsedSpace() int64

func (*StatSummaryResponse) ProtoMessage

func (*StatSummaryResponse) ProtoMessage()

func (*StatSummaryResponse) Reset

func (m *StatSummaryResponse) Reset()

func (*StatSummaryResponse) String

func (m *StatSummaryResponse) String() string

func (*StatSummaryResponse) XXX_DiscardUnknown

func (m *StatSummaryResponse) XXX_DiscardUnknown()

func (*StatSummaryResponse) XXX_Marshal

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

func (*StatSummaryResponse) XXX_Merge

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

func (*StatSummaryResponse) XXX_Size

func (m *StatSummaryResponse) XXX_Size() int

func (*StatSummaryResponse) XXX_Unmarshal

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

type StatsRequest

type StatsRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StatsRequest) Descriptor

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

func (*StatsRequest) ProtoMessage

func (*StatsRequest) ProtoMessage()

func (*StatsRequest) Reset

func (m *StatsRequest) Reset()

func (*StatsRequest) String

func (m *StatsRequest) String() string

func (*StatsRequest) XXX_DiscardUnknown

func (m *StatsRequest) XXX_DiscardUnknown()

func (*StatsRequest) XXX_Marshal

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

func (*StatsRequest) XXX_Merge

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

func (*StatsRequest) XXX_Size

func (m *StatsRequest) XXX_Size() int

func (*StatsRequest) XXX_Unmarshal

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

type StreamInfo

type StreamInfo struct {
	NumberOfSegments     int64    `protobuf:"varint,1,opt,name=number_of_segments,json=numberOfSegments,proto3" json:"number_of_segments,omitempty"`
	SegmentsSize         int64    `protobuf:"varint,2,opt,name=segments_size,json=segmentsSize,proto3" json:"segments_size,omitempty"`
	LastSegmentSize      int64    `protobuf:"varint,3,opt,name=last_segment_size,json=lastSegmentSize,proto3" json:"last_segment_size,omitempty"`
	Metadata             []byte   `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StreamInfo) Descriptor

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

func (*StreamInfo) GetLastSegmentSize

func (m *StreamInfo) GetLastSegmentSize() int64

func (*StreamInfo) GetMetadata

func (m *StreamInfo) GetMetadata() []byte

func (*StreamInfo) GetNumberOfSegments

func (m *StreamInfo) GetNumberOfSegments() int64

func (*StreamInfo) GetSegmentsSize

func (m *StreamInfo) GetSegmentsSize() int64

func (*StreamInfo) ProtoMessage

func (*StreamInfo) ProtoMessage()

func (*StreamInfo) Reset

func (m *StreamInfo) Reset()

func (*StreamInfo) String

func (m *StreamInfo) String() string

func (*StreamInfo) XXX_DiscardUnknown

func (m *StreamInfo) XXX_DiscardUnknown()

func (*StreamInfo) XXX_Marshal

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

func (*StreamInfo) XXX_Merge

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

func (*StreamInfo) XXX_Size

func (m *StreamInfo) XXX_Size() int

func (*StreamInfo) XXX_Unmarshal

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

type StreamMeta

type StreamMeta struct {
	EncryptedStreamInfo  []byte       `protobuf:"bytes,1,opt,name=encrypted_stream_info,json=encryptedStreamInfo,proto3" json:"encrypted_stream_info,omitempty"`
	EncryptionType       int32        `protobuf:"varint,2,opt,name=encryption_type,json=encryptionType,proto3" json:"encryption_type,omitempty"`
	EncryptionBlockSize  int32        `protobuf:"varint,3,opt,name=encryption_block_size,json=encryptionBlockSize,proto3" json:"encryption_block_size,omitempty"`
	LastSegmentMeta      *SegmentMeta `protobuf:"bytes,4,opt,name=last_segment_meta,json=lastSegmentMeta,proto3" json:"last_segment_meta,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*StreamMeta) Descriptor

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

func (*StreamMeta) GetEncryptedStreamInfo

func (m *StreamMeta) GetEncryptedStreamInfo() []byte

func (*StreamMeta) GetEncryptionBlockSize

func (m *StreamMeta) GetEncryptionBlockSize() int32

func (*StreamMeta) GetEncryptionType

func (m *StreamMeta) GetEncryptionType() int32

func (*StreamMeta) GetLastSegmentMeta

func (m *StreamMeta) GetLastSegmentMeta() *SegmentMeta

func (*StreamMeta) ProtoMessage

func (*StreamMeta) ProtoMessage()

func (*StreamMeta) Reset

func (m *StreamMeta) Reset()

func (*StreamMeta) String

func (m *StreamMeta) String() string

func (*StreamMeta) XXX_DiscardUnknown

func (m *StreamMeta) XXX_DiscardUnknown()

func (*StreamMeta) XXX_Marshal

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

func (*StreamMeta) XXX_Merge

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

func (*StreamMeta) XXX_Size

func (m *StreamMeta) XXX_Size() int

func (*StreamMeta) XXX_Unmarshal

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

type Voucher added in v0.12.0

type Voucher struct {
	SatelliteId          NodeID               `protobuf:"bytes,1,opt,name=satellite_id,json=satelliteId,proto3,customtype=NodeID" json:"satellite_id"`
	StorageNodeId        NodeID               `protobuf:"bytes,2,opt,name=storage_node_id,json=storageNodeId,proto3,customtype=NodeID" json:"storage_node_id"`
	Expiration           *timestamp.Timestamp `protobuf:"bytes,3,opt,name=expiration,proto3" json:"expiration,omitempty"`
	SatelliteSignature   []byte               `protobuf:"bytes,4,opt,name=satellite_signature,json=satelliteSignature,proto3" json:"satellite_signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Voucher is a signed message verifying that a node has been vetted by a particular satellite

func (*Voucher) Descriptor added in v0.12.0

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

func (*Voucher) GetExpiration added in v0.12.0

func (m *Voucher) GetExpiration() *timestamp.Timestamp

func (*Voucher) GetSatelliteSignature added in v0.12.0

func (m *Voucher) GetSatelliteSignature() []byte

func (*Voucher) ProtoMessage added in v0.12.0

func (*Voucher) ProtoMessage()

func (*Voucher) Reset added in v0.12.0

func (m *Voucher) Reset()

func (*Voucher) String added in v0.12.0

func (m *Voucher) String() string

func (*Voucher) XXX_DiscardUnknown added in v0.12.0

func (m *Voucher) XXX_DiscardUnknown()

func (*Voucher) XXX_Marshal added in v0.12.0

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

func (*Voucher) XXX_Merge added in v0.12.0

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

func (*Voucher) XXX_Size added in v0.12.0

func (m *Voucher) XXX_Size() int

func (*Voucher) XXX_Unmarshal added in v0.12.0

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

type VoucherRequest added in v0.12.0

type VoucherRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VoucherRequest) Descriptor added in v0.12.0

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

func (*VoucherRequest) ProtoMessage added in v0.12.0

func (*VoucherRequest) ProtoMessage()

func (*VoucherRequest) Reset added in v0.12.0

func (m *VoucherRequest) Reset()

func (*VoucherRequest) String added in v0.12.0

func (m *VoucherRequest) String() string

func (*VoucherRequest) XXX_DiscardUnknown added in v0.12.0

func (m *VoucherRequest) XXX_DiscardUnknown()

func (*VoucherRequest) XXX_Marshal added in v0.12.0

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

func (*VoucherRequest) XXX_Merge added in v0.12.0

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

func (*VoucherRequest) XXX_Size added in v0.12.0

func (m *VoucherRequest) XXX_Size() int

func (*VoucherRequest) XXX_Unmarshal added in v0.12.0

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

type VouchersClient added in v0.12.0

type VouchersClient interface {
	Request(ctx context.Context, in *VoucherRequest, opts ...grpc.CallOption) (*Voucher, error)
}

VouchersClient is the client API for Vouchers service.

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

func NewVouchersClient added in v0.12.0

func NewVouchersClient(cc *grpc.ClientConn) VouchersClient

type VouchersServer added in v0.12.0

type VouchersServer interface {
	Request(context.Context, *VoucherRequest) (*Voucher, error)
}

VouchersServer is the server API for Vouchers service.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL