pb

package
v0.8.6 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// ErrRenter wraps errors related to renter bandwidth allocations
	ErrRenter = errs.Class("Renter agreement")
	// ErrPayer wraps errors related to payer bandwidth allocations
	ErrPayer = errs.Class("Payer agreement")
)
View Source 
var AgreementsSummary_Status_name = map[int32]string{
	0: "FAIL",
	1: "OK",
	2: "REJECTED",
}
View Source 
var AgreementsSummary_Status_value = map[string]int32{
	"FAIL":     0,
	"OK":       1,
	"REJECTED": 2,
}
View Source 
var BandwidthAction_name = map[int32]string{
	0: "PUT",
	1: "GET",
	2: "GET_AUDIT",
	3: "GET_REPAIR",
	4: "PUT_REPAIR",
}
View Source 
var BandwidthAction_value = map[string]int32{
	"PUT":        0,
	"GET":        1,
	"GET_AUDIT":  2,
	"GET_REPAIR": 3,
	"PUT_REPAIR": 4,
}
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 RegisterBandwidthServer 

func RegisterBandwidthServer(s *grpc.Server, srv BandwidthServer)

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)

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 AgreementsSummary 

type AgreementsSummary struct {
	Status               AgreementsSummary_Status `protobuf:"varint,1,opt,name=status,proto3,enum=bandwidth.AgreementsSummary_Status" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*AgreementsSummary) Descriptor 

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

func (*AgreementsSummary) GetStatus 

func (m *AgreementsSummary) GetStatus() AgreementsSummary_Status

func (*AgreementsSummary) ProtoMessage 

func (*AgreementsSummary) ProtoMessage()

func (*AgreementsSummary) Reset 

func (m *AgreementsSummary) Reset()

func (*AgreementsSummary) String 

func (m *AgreementsSummary) String() string

func (*AgreementsSummary) XXX_DiscardUnknown 

func (m *AgreementsSummary) XXX_DiscardUnknown()

func (*AgreementsSummary) XXX_Marshal 

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

func (*AgreementsSummary) XXX_Merge 

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

func (*AgreementsSummary) XXX_Size 

func (m *AgreementsSummary) XXX_Size() int

func (*AgreementsSummary) XXX_Unmarshal 

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

type AgreementsSummary_Status 

type AgreementsSummary_Status int32
const (
	AgreementsSummary_FAIL     AgreementsSummary_Status = 0
	AgreementsSummary_OK       AgreementsSummary_Status = 1
	AgreementsSummary_REJECTED AgreementsSummary_Status = 2
)

func (AgreementsSummary_Status) EnumDescriptor 

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

func (AgreementsSummary_Status) String 

func (x AgreementsSummary_Status) String() string

type BandwidthAction 

type BandwidthAction int32
const (
	BandwidthAction_PUT        BandwidthAction = 0
	BandwidthAction_GET        BandwidthAction = 1
	BandwidthAction_GET_AUDIT  BandwidthAction = 2
	BandwidthAction_GET_REPAIR BandwidthAction = 3
	BandwidthAction_PUT_REPAIR BandwidthAction = 4
)

func (BandwidthAction) EnumDescriptor 

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

func (BandwidthAction) String 

func (x BandwidthAction) String() string

type BandwidthClient 

type BandwidthClient interface {
	BandwidthAgreements(ctx context.Context, in *RenterBandwidthAllocation, opts ...grpc.CallOption) (*AgreementsSummary, error)
	Settlement(ctx context.Context, opts ...grpc.CallOption) (Bandwidth_SettlementClient, error)
}

BandwidthClient is the client API for Bandwidth service.

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

func NewBandwidthClient 

func NewBandwidthClient(cc *grpc.ClientConn) BandwidthClient

type BandwidthServer 

type BandwidthServer interface {
	BandwidthAgreements(context.Context, *RenterBandwidthAllocation) (*AgreementsSummary, error)
	Settlement(Bandwidth_SettlementServer) error
}

BandwidthServer is the server API for Bandwidth service.

type BandwidthSettlementRequest 

type BandwidthSettlementRequest struct {
	Allocation           *RenterBandwidthAllocation `protobuf:"bytes,1,opt,name=allocation,proto3" json:"allocation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*BandwidthSettlementRequest) Descriptor 

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

func (*BandwidthSettlementRequest) GetAllocation 

func (m *BandwidthSettlementRequest) GetAllocation() *RenterBandwidthAllocation

func (*BandwidthSettlementRequest) ProtoMessage 

func (*BandwidthSettlementRequest) ProtoMessage()

func (*BandwidthSettlementRequest) Reset 

func (m *BandwidthSettlementRequest) Reset()

func (*BandwidthSettlementRequest) String 

func (m *BandwidthSettlementRequest) String() string

func (*BandwidthSettlementRequest) XXX_DiscardUnknown 

func (m *BandwidthSettlementRequest) XXX_DiscardUnknown()

func (*BandwidthSettlementRequest) XXX_Marshal 

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

func (*BandwidthSettlementRequest) XXX_Merge 

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

func (*BandwidthSettlementRequest) XXX_Size 

func (m *BandwidthSettlementRequest) XXX_Size() int

func (*BandwidthSettlementRequest) XXX_Unmarshal 

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

type BandwidthSettlementResponse 

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

func (*BandwidthSettlementResponse) Descriptor 

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

func (*BandwidthSettlementResponse) GetSerialNumber 

func (m *BandwidthSettlementResponse) GetSerialNumber() string

func (*BandwidthSettlementResponse) GetStatus 

func (m *BandwidthSettlementResponse) GetStatus() AgreementsSummary_Status

func (*BandwidthSettlementResponse) ProtoMessage 

func (*BandwidthSettlementResponse) ProtoMessage()

func (*BandwidthSettlementResponse) Reset 

func (m *BandwidthSettlementResponse) Reset()

func (*BandwidthSettlementResponse) String 

func (m *BandwidthSettlementResponse) String() string

func (*BandwidthSettlementResponse) XXX_DiscardUnknown 

func (m *BandwidthSettlementResponse) XXX_DiscardUnknown()

func (*BandwidthSettlementResponse) XXX_Marshal 

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

func (*BandwidthSettlementResponse) XXX_Merge 

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

func (*BandwidthSettlementResponse) XXX_Size 

func (m *BandwidthSettlementResponse) XXX_Size() int

func (*BandwidthSettlementResponse) XXX_Unmarshal 

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

type Bandwidth_SettlementClient 

type Bandwidth_SettlementClient interface {
	Send(*BandwidthSettlementRequest) error
	Recv() (*BandwidthSettlementResponse, error)
	grpc.ClientStream
}

type Bandwidth_SettlementServer 

type Bandwidth_SettlementServer interface {
	Send(*BandwidthSettlementResponse) error
	Recv() (*BandwidthSettlementRequest, error)
	grpc.ServerStream
}

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 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 returns stats about the health of an object
	ObjectHealth(ctx context.Context, in *ObjectHealthRequest, opts ...grpc.CallOption) (*ObjectHealthResponse, error)
	// SegmentHealth will returns 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 returns stats about the health of an object
	ObjectHealth(context.Context, *ObjectHealthRequest) (*ObjectHealthResponse, error)
	// SegmentHealth will returns 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)
}

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

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 (m *ListIrreparableSegmentsRequest) String() 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 (m *ListIrreparableSegmentsResponse) GetSegments() []*IrreparableSegment

func (*ListIrreparableSegmentsResponse) ProtoMessage 

func (*ListIrreparableSegmentsResponse) ProtoMessage()

func (*ListIrreparableSegmentsResponse) Reset 

func (m *ListIrreparableSegmentsResponse) Reset()

func (*ListIrreparableSegmentsResponse) String 

func (m *ListIrreparableSegmentsResponse) String() 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 (m *ListSegmentsResponse) GetItems() []*ListSegmentsResponse_Item

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 

type MetainfoServer interface {
	CreateSegment(context.Context, *SegmentWriteRequest) (*SegmentWriteResponse, error)
	CommitSegment(context.Context, *SegmentCommitRequest) (*SegmentCommitResponse, error)
	SegmentInfo(context.Context, *SegmentInfoRequest) (*SegmentInfoResponse, error)
	DownloadSegment(context.Context, *SegmentDownloadRequest) (*SegmentDownloadResponse, error)
	DeleteSegment(context.Context, *SegmentDeleteRequest) (*SegmentDeleteResponse, error)
	ListSegments(context.Context, *ListSegmentsRequest) (*ListSegmentsResponse, error)
}

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"`
	Type                 NodeType          `protobuf:"varint,3,opt,name=type,proto3,enum=node.NodeType" json:"type,omitempty"`
	Restrictions         *NodeRestrictions `protobuf:"bytes,4,opt,name=restrictions,proto3" json:"restrictions,omitempty"`
	Reputation           *NodeStats        `protobuf:"bytes,5,opt,name=reputation,proto3" json:"reputation,omitempty"`
	Metadata             *NodeMetadata     `protobuf:"bytes,6,opt,name=metadata,proto3" json:"metadata,omitempty"`
	LatencyList          []int64           `protobuf:"varint,7,rep,packed,name=latency_list,json=latencyList,proto3" json:"latency_list,omitempty"`
	AuditSuccess         bool              `protobuf:"varint,8,opt,name=audit_success,json=auditSuccess,proto3" json:"audit_success,omitempty"`
	IsUp                 bool              `protobuf:"varint,9,opt,name=is_up,json=isUp,proto3" json:"is_up,omitempty"`
	UpdateLatency        bool              `protobuf:"varint,10,opt,name=update_latency,json=updateLatency,proto3" json:"update_latency,omitempty"`
	UpdateAuditSuccess   bool              `protobuf:"varint,11,opt,name=update_audit_success,json=updateAuditSuccess,proto3" json:"update_audit_success,omitempty"`
	UpdateUptime         bool              `protobuf:"varint,12,opt,name=update_uptime,json=updateUptime,proto3" json:"update_uptime,omitempty"`
	Version              *NodeVersion      `protobuf:"bytes,13,opt,name=version,proto3" json:"version,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) GetAuditSuccess 

func (m *Node) GetAuditSuccess() bool

func (*Node) GetIsUp 

func (m *Node) GetIsUp() bool

func (*Node) GetLatencyList 

func (m *Node) GetLatencyList() []int64

func (*Node) GetMetadata 

func (m *Node) GetMetadata() *NodeMetadata

func (*Node) GetReputation 

func (m *Node) GetReputation() *NodeStats

func (*Node) GetRestrictions 

func (m *Node) GetRestrictions() *NodeRestrictions

func (*Node) GetType 

func (m *Node) GetType() NodeType

func (*Node) GetUpdateAuditSuccess 

func (m *Node) GetUpdateAuditSuccess() bool

func (*Node) GetUpdateLatency 

func (m *Node) GetUpdateLatency() bool

func (*Node) GetUpdateUptime 

func (m *Node) GetUpdateUptime() bool

func (*Node) GetVersion added in v0.8.1 

func (m *Node) GetVersion() *NodeVersion

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"`
	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) 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"`
	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) 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 Order 

type Order = RenterBandwidthAllocation

Order aliases RenterBandwidthAllocation

func (*Order) Scan 

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

Scan implements the Scanner interface.

func (*Order) SetCerts 

func (m *Order) SetCerts(certs [][]byte)

SetCerts updates the certs field, completing the auth.SignedMsg interface

func (*Order) SetSignature 

func (m *Order) SetSignature(signature []byte)

SetSignature updates the signature field, completing the auth.SignedMsg interface

func (Order) Value 

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

Value implements the driver Valuer interface.

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 OrderLimit 

type OrderLimit = PayerBandwidthAllocation

OrderLimit aliases PayerBandwidthAllocation

func (*OrderLimit) Clone 

func (m *OrderLimit) Clone() (pba OrderLimit)

Clone creates a deep copy of PayerBandwidthAllocation

func (*OrderLimit) SetCerts 

func (m *OrderLimit) SetCerts(certs [][]byte)

SetCerts updates the certs field, completing the auth.SignedMsg interface

func (*OrderLimit) SetSignature 

func (m *OrderLimit) SetSignature(signature []byte)

SetSignature updates the signature field, completing the auth.SignedMsg interface

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 PayerBandwidthAllocation 

type PayerBandwidthAllocation struct {
	SatelliteId          NodeID          `protobuf:"bytes,1,opt,name=satellite_id,json=satelliteId,proto3,customtype=NodeID" json:"satellite_id"`
	UplinkId             NodeID          `protobuf:"bytes,2,opt,name=uplink_id,json=uplinkId,proto3,customtype=NodeID" json:"uplink_id"`
	MaxSize              int64           `protobuf:"varint,3,opt,name=max_size,json=maxSize,proto3" json:"max_size,omitempty"`
	ExpirationUnixSec    int64           `protobuf:"varint,4,opt,name=expiration_unix_sec,json=expirationUnixSec,proto3" json:"expiration_unix_sec,omitempty"`
	SerialNumber         string          `protobuf:"bytes,5,opt,name=serial_number,json=serialNumber,proto3" json:"serial_number,omitempty"`
	Action               BandwidthAction `protobuf:"varint,6,opt,name=action,proto3,enum=piecestoreroutes.BandwidthAction" json:"action,omitempty"`
	CreatedUnixSec       int64           `protobuf:"varint,7,opt,name=created_unix_sec,json=createdUnixSec,proto3" json:"created_unix_sec,omitempty"`
	Certs                [][]byte        `protobuf:"bytes,8,rep,name=certs,proto3" json:"certs,omitempty"`
	Signature            []byte          `protobuf:"bytes,9,opt,name=signature,proto3" json:"signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*PayerBandwidthAllocation) Descriptor 

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

func (*PayerBandwidthAllocation) GetAction 

func (m *PayerBandwidthAllocation) GetAction() BandwidthAction

func (*PayerBandwidthAllocation) GetCerts 

func (m *PayerBandwidthAllocation) GetCerts() [][]byte

func (*PayerBandwidthAllocation) GetCreatedUnixSec 

func (m *PayerBandwidthAllocation) GetCreatedUnixSec() int64

func (*PayerBandwidthAllocation) GetExpirationUnixSec 

func (m *PayerBandwidthAllocation) GetExpirationUnixSec() int64

func (*PayerBandwidthAllocation) GetMaxSize 

func (m *PayerBandwidthAllocation) GetMaxSize() int64

func (*PayerBandwidthAllocation) GetSerialNumber 

func (m *PayerBandwidthAllocation) GetSerialNumber() string

func (*PayerBandwidthAllocation) GetSignature 

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

func (*PayerBandwidthAllocation) ProtoMessage 

func (*PayerBandwidthAllocation) ProtoMessage()

func (*PayerBandwidthAllocation) Reset 

func (m *PayerBandwidthAllocation) Reset()

func (*PayerBandwidthAllocation) String 

func (m *PayerBandwidthAllocation) String() string

func (*PayerBandwidthAllocation) XXX_DiscardUnknown 

func (m *PayerBandwidthAllocation) XXX_DiscardUnknown()

func (*PayerBandwidthAllocation) XXX_Marshal 

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

func (*PayerBandwidthAllocation) XXX_Merge 

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

func (*PayerBandwidthAllocation) XXX_Size 

func (m *PayerBandwidthAllocation) XXX_Size() int

func (*PayerBandwidthAllocation) XXX_Unmarshal 

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

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 (m *PieceDownloadRequest) GetChunk() *PieceDownloadRequest_Chunk

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 (m *PieceDownloadResponse) GetChunk() *PieceDownloadResponse_Chunk

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 (m *PieceUploadRequest) GetChunk() *PieceUploadRequest_Chunk

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 (m *RedundancyScheme) GetType() RedundancyScheme_SchemeType

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 

func (x RedundancyScheme_SchemeType) String() 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 RenterBandwidthAllocation 

type RenterBandwidthAllocation struct {
	PayerAllocation      PayerBandwidthAllocation `protobuf:"bytes,1,opt,name=payer_allocation,json=payerAllocation,proto3" json:"payer_allocation"`
	Total                int64                    `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	StorageNodeId        NodeID                   `protobuf:"bytes,3,opt,name=storage_node_id,json=storageNodeId,proto3,customtype=NodeID" json:"storage_node_id"`
	Certs                [][]byte                 `protobuf:"bytes,4,rep,name=certs,proto3" json:"certs,omitempty"`
	Signature            []byte                   `protobuf:"bytes,5,opt,name=signature,proto3" json:"signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*RenterBandwidthAllocation) Descriptor 

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

func (*RenterBandwidthAllocation) GetCerts 

func (m *RenterBandwidthAllocation) GetCerts() [][]byte

func (*RenterBandwidthAllocation) GetPayerAllocation 

func (m *RenterBandwidthAllocation) GetPayerAllocation() PayerBandwidthAllocation

func (*RenterBandwidthAllocation) GetSignature 

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

func (*RenterBandwidthAllocation) GetTotal 

func (m *RenterBandwidthAllocation) GetTotal() int64

func (*RenterBandwidthAllocation) ProtoMessage 

func (*RenterBandwidthAllocation) ProtoMessage()

func (*RenterBandwidthAllocation) Reset 

func (m *RenterBandwidthAllocation) Reset()

func (*RenterBandwidthAllocation) String 

func (m *RenterBandwidthAllocation) String() string

func (*RenterBandwidthAllocation) XXX_DiscardUnknown 

func (m *RenterBandwidthAllocation) XXX_DiscardUnknown()

func (*RenterBandwidthAllocation) XXX_Marshal 

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

func (*RenterBandwidthAllocation) XXX_Merge 

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

func (*RenterBandwidthAllocation) XXX_Size 

func (m *RenterBandwidthAllocation) XXX_Size() int

func (*RenterBandwidthAllocation) XXX_Unmarshal 

func (m *RenterBandwidthAllocation) 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 {
	MinimumRequired      int32    `protobuf:"varint,1,opt,name=minimum_required,json=minimumRequired,proto3" json:"minimum_required,omitempty"`
	Total                int32    `protobuf:"varint,2,opt,name=total,proto3" json:"total,omitempty"`
	RepairThreshold      int32    `protobuf:"varint,3,opt,name=repair_threshold,json=repairThreshold,proto3" json:"repair_threshold,omitempty"`
	SuccessThreshold     int32    `protobuf:"varint,4,opt,name=success_threshold,json=successThreshold,proto3" json:"success_threshold,omitempty"`
	OnlineNodes          int32    `protobuf:"varint,5,opt,name=online_nodes,json=onlineNodes,proto3" json:"online_nodes,omitempty"`
	Segment              []byte   `protobuf:"bytes,6,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) GetMinimumRequired 

func (m *SegmentHealth) GetMinimumRequired() int32

func (*SegmentHealth) GetOnlineNodes 

func (m *SegmentHealth) GetOnlineNodes() int32

func (*SegmentHealth) GetRepairThreshold 

func (m *SegmentHealth) GetRepairThreshold() int32

func (*SegmentHealth) GetSegment 

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

func (*SegmentHealth) GetSuccessThreshold 

func (m *SegmentHealth) GetSuccessThreshold() int32

func (*SegmentHealth) GetTotal 

func (m *SegmentHealth) GetTotal() int32

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 (m *SettlementResponse) GetStatus() SettlementResponse_Status

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 SignedHash 

type SignedHash struct {
	Hash                 []byte   `protobuf:"bytes,1,opt,name=hash,proto3" json:"hash,omitempty"`
	Certs                [][]byte `protobuf:"bytes,2,rep,name=certs,proto3" json:"certs,omitempty"`
	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 (*SignedHash) Descriptor 

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

func (*SignedHash) GetCerts 

func (m *SignedHash) GetCerts() [][]byte

func (*SignedHash) GetHash 

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

func (*SignedHash) GetSignature 

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

func (*SignedHash) ProtoMessage 

func (*SignedHash) ProtoMessage()

func (*SignedHash) Reset 

func (m *SignedHash) Reset()

func (*SignedHash) SetCerts 

func (m *SignedHash) SetCerts(certs [][]byte)

SetCerts updates the certs field, completing the auth.SignedMsg interface

func (*SignedHash) SetSignature 

func (m *SignedHash) SetSignature(signature []byte)

SetSignature updates the signature field, completing the auth.SignedMsg interface

func (*SignedHash) String 

func (m *SignedHash) String() string

func (*SignedHash) XXX_DiscardUnknown 

func (m *SignedHash) XXX_DiscardUnknown()

func (*SignedHash) XXX_Marshal 

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

func (*SignedHash) XXX_Merge 

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

func (*SignedHash) XXX_Size 

func (m *SignedHash) XXX_Size() int

func (*SignedHash) XXX_Unmarshal 

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

type SignedMessage 

type SignedMessage struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	Signature            []byte   `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	PublicKey            []byte   `protobuf:"bytes,3,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SignedMessage) Descriptor 

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

func (*SignedMessage) GetData 

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

func (*SignedMessage) GetPublicKey 

func (m *SignedMessage) GetPublicKey() []byte

func (*SignedMessage) GetSignature 

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

func (*SignedMessage) ProtoMessage 

func (*SignedMessage) ProtoMessage()

func (*SignedMessage) Reset 

func (m *SignedMessage) Reset()

func (*SignedMessage) String 

func (m *SignedMessage) String() string

func (*SignedMessage) XXX_DiscardUnknown 

func (m *SignedMessage) XXX_DiscardUnknown()

func (*SignedMessage) XXX_Marshal 

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

func (*SignedMessage) XXX_Merge 

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

func (*SignedMessage) XXX_Size 

func (m *SignedMessage) XXX_Size() int

func (*SignedMessage) XXX_Unmarshal 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

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