internalpb

package
v1.75.2 Latest Latest
Warning

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

 Go to latest Published: Mar 20, 2023 License: AGPL-3.0 Imports: 11 Imported by: 0

Documentation

Overview

Package internalpb contains proto definitions for storagenode internal tools.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func DRPCRegisterNodeGracefulExit 

func DRPCRegisterNodeGracefulExit(mux drpc.Mux, impl DRPCNodeGracefulExitServer) error

func DRPCRegisterPieceStoreInspector 

func DRPCRegisterPieceStoreInspector(mux drpc.Mux, impl DRPCPieceStoreInspectorServer) error

Types

type DRPCNodeGracefulExitClient 

type DRPCNodeGracefulExitClient interface {
	DRPCConn() drpc.Conn

	GetNonExitingSatellites(ctx context.Context, in *GetNonExitingSatellitesRequest) (*GetNonExitingSatellitesResponse, error)
	InitiateGracefulExit(ctx context.Context, in *InitiateGracefulExitRequest) (*ExitProgress, error)
	GetExitProgress(ctx context.Context, in *GetExitProgressRequest) (*GetExitProgressResponse, error)
	GracefulExitFeasibility(ctx context.Context, in *GracefulExitFeasibilityRequest) (*GracefulExitFeasibilityResponse, error)
}

func NewDRPCNodeGracefulExitClient 

func NewDRPCNodeGracefulExitClient(cc drpc.Conn) DRPCNodeGracefulExitClient

type DRPCNodeGracefulExitDescription 

type DRPCNodeGracefulExitDescription struct{}

func (DRPCNodeGracefulExitDescription) Method 

func (DRPCNodeGracefulExitDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)

func (DRPCNodeGracefulExitDescription) NumMethods 

func (DRPCNodeGracefulExitDescription) NumMethods() int

type DRPCNodeGracefulExitServer 

type DRPCNodeGracefulExitServer interface {
	GetNonExitingSatellites(context.Context, *GetNonExitingSatellitesRequest) (*GetNonExitingSatellitesResponse, error)
	InitiateGracefulExit(context.Context, *InitiateGracefulExitRequest) (*ExitProgress, error)
	GetExitProgress(context.Context, *GetExitProgressRequest) (*GetExitProgressResponse, error)
	GracefulExitFeasibility(context.Context, *GracefulExitFeasibilityRequest) (*GracefulExitFeasibilityResponse, error)
}

type DRPCNodeGracefulExitUnimplementedServer added in v1.26.2 

type DRPCNodeGracefulExitUnimplementedServer struct{}

func (*DRPCNodeGracefulExitUnimplementedServer) GetExitProgress added in v1.26.2 

func (s *DRPCNodeGracefulExitUnimplementedServer) GetExitProgress(context.Context, *GetExitProgressRequest) (*GetExitProgressResponse, error)

func (*DRPCNodeGracefulExitUnimplementedServer) GetNonExitingSatellites added in v1.26.2 

func (s *DRPCNodeGracefulExitUnimplementedServer) GetNonExitingSatellites(context.Context, *GetNonExitingSatellitesRequest) (*GetNonExitingSatellitesResponse, error)

func (*DRPCNodeGracefulExitUnimplementedServer) GracefulExitFeasibility added in v1.26.2 

func (s *DRPCNodeGracefulExitUnimplementedServer) GracefulExitFeasibility(context.Context, *GracefulExitFeasibilityRequest) (*GracefulExitFeasibilityResponse, error)

func (*DRPCNodeGracefulExitUnimplementedServer) InitiateGracefulExit added in v1.26.2 

func (s *DRPCNodeGracefulExitUnimplementedServer) InitiateGracefulExit(context.Context, *InitiateGracefulExitRequest) (*ExitProgress, error)

type DRPCNodeGracefulExit_GetExitProgressStream 

type DRPCNodeGracefulExit_GetExitProgressStream interface {
	drpc.Stream
	SendAndClose(*GetExitProgressResponse) error
}

type DRPCNodeGracefulExit_GetNonExitingSatellitesStream 

type DRPCNodeGracefulExit_GetNonExitingSatellitesStream interface {
	drpc.Stream
	SendAndClose(*GetNonExitingSatellitesResponse) error
}

type DRPCNodeGracefulExit_GracefulExitFeasibilityStream 

type DRPCNodeGracefulExit_GracefulExitFeasibilityStream interface {
	drpc.Stream
	SendAndClose(*GracefulExitFeasibilityResponse) error
}

type DRPCNodeGracefulExit_InitiateGracefulExitStream 

type DRPCNodeGracefulExit_InitiateGracefulExitStream interface {
	drpc.Stream
	SendAndClose(*ExitProgress) error
}

type DRPCPieceStoreInspectorClient 

type DRPCPieceStoreInspectorClient interface {
	DRPCConn() drpc.Conn

	Stats(ctx context.Context, in *StatsRequest) (*StatSummaryResponse, error)
	Dashboard(ctx context.Context, in *DashboardRequest) (*DashboardResponse, error)
}

func NewDRPCPieceStoreInspectorClient 

func NewDRPCPieceStoreInspectorClient(cc drpc.Conn) DRPCPieceStoreInspectorClient

type DRPCPieceStoreInspectorDescription 

type DRPCPieceStoreInspectorDescription struct{}

func (DRPCPieceStoreInspectorDescription) Method 

func (DRPCPieceStoreInspectorDescription) Method(n int) (string, drpc.Encoding, drpc.Receiver, interface{}, bool)

func (DRPCPieceStoreInspectorDescription) NumMethods 

func (DRPCPieceStoreInspectorDescription) NumMethods() int

type DRPCPieceStoreInspectorServer 

type DRPCPieceStoreInspectorServer interface {
	Stats(context.Context, *StatsRequest) (*StatSummaryResponse, error)
	Dashboard(context.Context, *DashboardRequest) (*DashboardResponse, error)
}

type DRPCPieceStoreInspectorUnimplementedServer added in v1.26.2 

type DRPCPieceStoreInspectorUnimplementedServer struct{}

func (*DRPCPieceStoreInspectorUnimplementedServer) Dashboard added in v1.26.2 

func (s *DRPCPieceStoreInspectorUnimplementedServer) Dashboard(context.Context, *DashboardRequest) (*DashboardResponse, error)

func (*DRPCPieceStoreInspectorUnimplementedServer) Stats added in v1.26.2 

func (s *DRPCPieceStoreInspectorUnimplementedServer) Stats(context.Context, *StatsRequest) (*StatSummaryResponse, error)

type DRPCPieceStoreInspector_DashboardStream 

type DRPCPieceStoreInspector_DashboardStream interface {
	drpc.Stream
	SendAndClose(*DashboardResponse) error
}

type DRPCPieceStoreInspector_StatsStream 

type DRPCPieceStoreInspector_StatsStream interface {
	drpc.Stream
	SendAndClose(*StatSummaryResponse) 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"` // Deprecated: Do not use.
	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"`
	DashboardAddress     string               `protobuf:"bytes,6,opt,name=dashboard_address,json=dashboardAddress,proto3" json:"dashboard_address,omitempty"`
	Stats                *StatSummaryResponse `protobuf:"bytes,7,opt,name=stats,proto3" json:"stats,omitempty"`
	Uptime               string               `protobuf:"bytes,8,opt,name=uptime,proto3" json:"uptime,omitempty"`
	LastPinged           time.Time            `protobuf:"bytes,9,opt,name=last_pinged,json=lastPinged,proto3,stdtime" json:"last_pinged"`
	LastQueried          time.Time            `protobuf:"bytes,10,opt,name=last_queried,json=lastQueried,proto3,stdtime" json:"last_queried"`
	LastPingFromId       *NodeID              `` /* 126-byte string literal not displayed */
	LastPingFromAddress  string               `protobuf:"bytes,12,opt,name=last_ping_from_address,json=lastPingFromAddress,proto3" json:"last_ping_from_address,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*DashboardResponse) Descriptor 

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

func (*DashboardResponse) GetBootstrapAddress deprecated 

func (m *DashboardResponse) GetBootstrapAddress() string

Deprecated: Do not use.

func (*DashboardResponse) GetDashboardAddress 

func (m *DashboardResponse) GetDashboardAddress() string

func (*DashboardResponse) GetExternalAddress 

func (m *DashboardResponse) GetExternalAddress() string

func (*DashboardResponse) GetInternalAddress 

func (m *DashboardResponse) GetInternalAddress() string

func (*DashboardResponse) GetLastPingFromAddress 

func (m *DashboardResponse) GetLastPingFromAddress() string

func (*DashboardResponse) GetLastPinged 

func (m *DashboardResponse) GetLastPinged() time.Time

func (*DashboardResponse) GetLastQueried 

func (m *DashboardResponse) GetLastQueried() time.Time

func (*DashboardResponse) GetNodeConnections 

func (m *DashboardResponse) GetNodeConnections() int64

func (*DashboardResponse) GetStats 

func (m *DashboardResponse) GetStats() *StatSummaryResponse

func (*DashboardResponse) GetUptime 

func (m *DashboardResponse) GetUptime() string

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 ExitProgress 

type ExitProgress struct {
	DomainName           string   `protobuf:"bytes,1,opt,name=domain_name,json=domainName,proto3" json:"domain_name,omitempty"`
	NodeId               NodeID   `protobuf:"bytes,2,opt,name=node_id,json=nodeId,proto3,customtype=NodeID" json:"node_id"`
	PercentComplete      float32  `protobuf:"fixed32,3,opt,name=percent_complete,json=percentComplete,proto3" json:"percent_complete,omitempty"`
	Successful           bool     `protobuf:"varint,4,opt,name=successful,proto3" json:"successful,omitempty"`
	CompletionReceipt    []byte   `protobuf:"bytes,5,opt,name=completion_receipt,json=completionReceipt,proto3" json:"completion_receipt,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ExitProgress) Descriptor 

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

func (*ExitProgress) GetCompletionReceipt 

func (m *ExitProgress) GetCompletionReceipt() []byte

func (*ExitProgress) GetDomainName 

func (m *ExitProgress) GetDomainName() string

func (*ExitProgress) GetPercentComplete 

func (m *ExitProgress) GetPercentComplete() float32

func (*ExitProgress) GetSuccessful 

func (m *ExitProgress) GetSuccessful() bool

func (*ExitProgress) ProtoMessage 

func (*ExitProgress) ProtoMessage()

func (*ExitProgress) Reset 

func (m *ExitProgress) Reset()

func (*ExitProgress) String 

func (m *ExitProgress) String() string

func (*ExitProgress) XXX_DiscardUnknown 

func (m *ExitProgress) XXX_DiscardUnknown()

func (*ExitProgress) XXX_Marshal 

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

func (*ExitProgress) XXX_Merge 

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

func (*ExitProgress) XXX_Size 

func (m *ExitProgress) XXX_Size() int

func (*ExitProgress) XXX_Unmarshal 

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

type GetExitProgressRequest 

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

func (*GetExitProgressRequest) Descriptor 

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

func (*GetExitProgressRequest) ProtoMessage 

func (*GetExitProgressRequest) ProtoMessage()

func (*GetExitProgressRequest) Reset 

func (m *GetExitProgressRequest) Reset()

func (*GetExitProgressRequest) String 

func (m *GetExitProgressRequest) String() string

func (*GetExitProgressRequest) XXX_DiscardUnknown 

func (m *GetExitProgressRequest) XXX_DiscardUnknown()

func (*GetExitProgressRequest) XXX_Marshal 

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

func (*GetExitProgressRequest) XXX_Merge 

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

func (*GetExitProgressRequest) XXX_Size 

func (m *GetExitProgressRequest) XXX_Size() int

func (*GetExitProgressRequest) XXX_Unmarshal 

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

type GetExitProgressResponse 

type GetExitProgressResponse struct {
	Progress             []*ExitProgress `protobuf:"bytes,1,rep,name=progress,proto3" json:"progress,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetExitProgressResponse) Descriptor 

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

func (*GetExitProgressResponse) GetProgress 

func (m *GetExitProgressResponse) GetProgress() []*ExitProgress

func (*GetExitProgressResponse) ProtoMessage 

func (*GetExitProgressResponse) ProtoMessage()

func (*GetExitProgressResponse) Reset 

func (m *GetExitProgressResponse) Reset()

func (*GetExitProgressResponse) String 

func (m *GetExitProgressResponse) String() string

func (*GetExitProgressResponse) XXX_DiscardUnknown 

func (m *GetExitProgressResponse) XXX_DiscardUnknown()

func (*GetExitProgressResponse) XXX_Marshal 

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

func (*GetExitProgressResponse) XXX_Merge 

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

func (*GetExitProgressResponse) XXX_Size 

func (m *GetExitProgressResponse) XXX_Size() int

func (*GetExitProgressResponse) XXX_Unmarshal 

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

type GetNonExitingSatellitesRequest 

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

func (*GetNonExitingSatellitesRequest) Descriptor 

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

func (*GetNonExitingSatellitesRequest) ProtoMessage 

func (*GetNonExitingSatellitesRequest) ProtoMessage()

func (*GetNonExitingSatellitesRequest) Reset 

func (m *GetNonExitingSatellitesRequest) Reset()

func (*GetNonExitingSatellitesRequest) String 

func (m *GetNonExitingSatellitesRequest) String() string

func (*GetNonExitingSatellitesRequest) XXX_DiscardUnknown 

func (m *GetNonExitingSatellitesRequest) XXX_DiscardUnknown()

func (*GetNonExitingSatellitesRequest) XXX_Marshal 

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

func (*GetNonExitingSatellitesRequest) XXX_Merge 

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

func (*GetNonExitingSatellitesRequest) XXX_Size 

func (m *GetNonExitingSatellitesRequest) XXX_Size() int

func (*GetNonExitingSatellitesRequest) XXX_Unmarshal 

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

type GetNonExitingSatellitesResponse 

type GetNonExitingSatellitesResponse struct {
	Satellites           []*NonExitingSatellite `protobuf:"bytes,1,rep,name=satellites,proto3" json:"satellites,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*GetNonExitingSatellitesResponse) Descriptor 

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

func (*GetNonExitingSatellitesResponse) GetSatellites 

func (m *GetNonExitingSatellitesResponse) GetSatellites() []*NonExitingSatellite

func (*GetNonExitingSatellitesResponse) ProtoMessage 

func (*GetNonExitingSatellitesResponse) ProtoMessage()

func (*GetNonExitingSatellitesResponse) Reset 

func (m *GetNonExitingSatellitesResponse) Reset()

func (*GetNonExitingSatellitesResponse) String 

func (m *GetNonExitingSatellitesResponse) String() string

func (*GetNonExitingSatellitesResponse) XXX_DiscardUnknown 

func (m *GetNonExitingSatellitesResponse) XXX_DiscardUnknown()

func (*GetNonExitingSatellitesResponse) XXX_Marshal 

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

func (*GetNonExitingSatellitesResponse) XXX_Merge 

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

func (*GetNonExitingSatellitesResponse) XXX_Size 

func (m *GetNonExitingSatellitesResponse) XXX_Size() int

func (*GetNonExitingSatellitesResponse) XXX_Unmarshal 

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

type GracefulExitFeasibilityRequest 

type GracefulExitFeasibilityRequest 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:"-"`
}

func (*GracefulExitFeasibilityRequest) Descriptor 

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

func (*GracefulExitFeasibilityRequest) ProtoMessage 

func (*GracefulExitFeasibilityRequest) ProtoMessage()

func (*GracefulExitFeasibilityRequest) Reset 

func (m *GracefulExitFeasibilityRequest) Reset()

func (*GracefulExitFeasibilityRequest) String 

func (m *GracefulExitFeasibilityRequest) String() string

func (*GracefulExitFeasibilityRequest) XXX_DiscardUnknown 

func (m *GracefulExitFeasibilityRequest) XXX_DiscardUnknown()

func (*GracefulExitFeasibilityRequest) XXX_Marshal 

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

func (*GracefulExitFeasibilityRequest) XXX_Merge 

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

func (*GracefulExitFeasibilityRequest) XXX_Size 

func (m *GracefulExitFeasibilityRequest) XXX_Size() int

func (*GracefulExitFeasibilityRequest) XXX_Unmarshal 

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

type GracefulExitFeasibilityResponse 

type GracefulExitFeasibilityResponse struct {
	JoinedAt             time.Time `protobuf:"bytes,1,opt,name=joined_at,json=joinedAt,proto3,stdtime" json:"joined_at"`
	MonthsRequired       int32     `protobuf:"varint,2,opt,name=months_required,json=monthsRequired,proto3" json:"months_required,omitempty"`
	IsAllowed            bool      `protobuf:"varint,3,opt,name=is_allowed,json=isAllowed,proto3" json:"is_allowed,omitempty"`
	XXX_NoUnkeyedLiteral struct{}  `json:"-"`
	XXX_unrecognized     []byte    `json:"-"`
	XXX_sizecache        int32     `json:"-"`
}

func (*GracefulExitFeasibilityResponse) Descriptor 

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

func (*GracefulExitFeasibilityResponse) GetIsAllowed 

func (m *GracefulExitFeasibilityResponse) GetIsAllowed() bool

func (*GracefulExitFeasibilityResponse) GetJoinedAt 

func (m *GracefulExitFeasibilityResponse) GetJoinedAt() time.Time

func (*GracefulExitFeasibilityResponse) GetMonthsRequired 

func (m *GracefulExitFeasibilityResponse) GetMonthsRequired() int32

func (*GracefulExitFeasibilityResponse) ProtoMessage 

func (*GracefulExitFeasibilityResponse) ProtoMessage()

func (*GracefulExitFeasibilityResponse) Reset 

func (m *GracefulExitFeasibilityResponse) Reset()

func (*GracefulExitFeasibilityResponse) String 

func (m *GracefulExitFeasibilityResponse) String() string

func (*GracefulExitFeasibilityResponse) XXX_DiscardUnknown 

func (m *GracefulExitFeasibilityResponse) XXX_DiscardUnknown()

func (*GracefulExitFeasibilityResponse) XXX_Marshal 

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

func (*GracefulExitFeasibilityResponse) XXX_Merge 

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

func (*GracefulExitFeasibilityResponse) XXX_Size 

func (m *GracefulExitFeasibilityResponse) XXX_Size() int

func (*GracefulExitFeasibilityResponse) XXX_Unmarshal 

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

type InitiateGracefulExitRequest 

type InitiateGracefulExitRequest 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:"-"`
}

func (*InitiateGracefulExitRequest) Descriptor 

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

func (*InitiateGracefulExitRequest) ProtoMessage 

func (*InitiateGracefulExitRequest) ProtoMessage()

func (*InitiateGracefulExitRequest) Reset 

func (m *InitiateGracefulExitRequest) Reset()

func (*InitiateGracefulExitRequest) String 

func (m *InitiateGracefulExitRequest) String() string

func (*InitiateGracefulExitRequest) XXX_DiscardUnknown 

func (m *InitiateGracefulExitRequest) XXX_DiscardUnknown()

func (*InitiateGracefulExitRequest) XXX_Marshal 

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

func (*InitiateGracefulExitRequest) XXX_Merge 

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

func (*InitiateGracefulExitRequest) XXX_Size 

func (m *InitiateGracefulExitRequest) XXX_Size() int

func (*InitiateGracefulExitRequest) XXX_Unmarshal 

func (m *InitiateGracefulExitRequest) 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 NonExitingSatellite 

type NonExitingSatellite struct {
	NodeId               NodeID   `protobuf:"bytes,1,opt,name=node_id,json=nodeId,proto3,customtype=NodeID" json:"node_id"`
	DomainName           string   `protobuf:"bytes,2,opt,name=domain_name,json=domainName,proto3" json:"domain_name,omitempty"`
	SpaceUsed            float64  `protobuf:"fixed64,3,opt,name=space_used,json=spaceUsed,proto3" json:"space_used,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

NonExitingSatellite contains information that's needed for a storagenode to start graceful exit.

func (*NonExitingSatellite) Descriptor 

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

func (*NonExitingSatellite) GetDomainName 

func (m *NonExitingSatellite) GetDomainName() string

func (*NonExitingSatellite) GetSpaceUsed 

func (m *NonExitingSatellite) GetSpaceUsed() float64

func (*NonExitingSatellite) ProtoMessage 

func (*NonExitingSatellite) ProtoMessage()

func (*NonExitingSatellite) Reset 

func (m *NonExitingSatellite) Reset()

func (*NonExitingSatellite) String 

func (m *NonExitingSatellite) String() string

func (*NonExitingSatellite) XXX_DiscardUnknown 

func (m *NonExitingSatellite) XXX_DiscardUnknown()

func (*NonExitingSatellite) XXX_Marshal 

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

func (*NonExitingSatellite) XXX_Merge 

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

func (*NonExitingSatellite) XXX_Size 

func (m *NonExitingSatellite) XXX_Size() int

func (*NonExitingSatellite) XXX_Unmarshal 

func (m *NonExitingSatellite) 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 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

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.