satellite

package
v0.0.0-...-e477e18 Latest Latest
Warning

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

 Go to latest Published: May 3, 2024 License: AGPL-3.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type GC 

type GC struct {
	URL string `arg:""`
}

func (GC) Run 

func (g GC) Run() error

type HeldAmountEndpoint 

type HeldAmountEndpoint struct {
	// contains filtered or unexported fields
}

func (HeldAmountEndpoint) GetAllPayments 

func (h HeldAmountEndpoint) GetAllPayments(ctx context.Context, request *pb.GetAllPaymentsRequest) (*pb.GetAllPaymentsResponse, error)

func (HeldAmountEndpoint) GetAllPaystubs 

func (h HeldAmountEndpoint) GetAllPaystubs(ctx context.Context, request *pb.GetAllPaystubsRequest) (*pb.GetAllPaystubsResponse, error)

func (HeldAmountEndpoint) GetPayStub 

func (h HeldAmountEndpoint) GetPayStub(ctx context.Context, request *pb.GetHeldAmountRequest) (*pb.GetHeldAmountResponse, error)

func (HeldAmountEndpoint) GetPayment 

func (h HeldAmountEndpoint) GetPayment(ctx context.Context, request *pb.GetPaymentRequest) (*pb.GetPaymentResponse, error)

type Metainfo 

type Metainfo struct {
	// contains filtered or unexported fields
}

func NewMetainfo 

func NewMetainfo(identity *identity.FullIdentity) *Metainfo

func (*Metainfo) Batch 

func (m *Metainfo) Batch(ctx context.Context, request *pb.BatchRequest) (*pb.BatchResponse, error)

func (*Metainfo) BeginCopyObject 

func (m *Metainfo) BeginCopyObject(ctx context.Context, request *pb.BeginCopyObjectRequest) (*pb.BeginCopyObjectResponse, error)

func (*Metainfo) BeginDeleteObject 

func (m *Metainfo) BeginDeleteObject(ctx context.Context, request *pb.BeginDeleteObjectRequest) (*pb.BeginDeleteObjectResponse, error)

func (*Metainfo) BeginDeleteSegment 

func (m *Metainfo) BeginDeleteSegment(ctx context.Context, request *pb.BeginDeleteSegmentRequest) (*pb.BeginDeleteSegmentResponse, error)

func (*Metainfo) BeginMoveObject 

func (m *Metainfo) BeginMoveObject(ctx context.Context, request *pb.BeginMoveObjectRequest) (*pb.BeginMoveObjectResponse, error)

func (*Metainfo) BeginObject 

func (m *Metainfo) BeginObject(ctx context.Context, request *pb.BeginObjectRequest) (*pb.BeginObjectResponse, error)

func (*Metainfo) BeginSegment 

func (m *Metainfo) BeginSegment(ctx context.Context, request *pb.BeginSegmentRequest) (*pb.BeginSegmentResponse, error)

func (*Metainfo) CommitObject 

func (m *Metainfo) CommitObject(ctx context.Context, request *pb.CommitObjectRequest) (*pb.CommitObjectResponse, error)

func (*Metainfo) CommitSegment 

func (m *Metainfo) CommitSegment(ctx context.Context, request *pb.CommitSegmentRequest) (*pb.CommitSegmentResponse, error)

func (*Metainfo) CompressedBatch 

func (m *Metainfo) CompressedBatch(ctx context.Context, request *pb.CompressedBatchRequest) (*pb.CompressedBatchResponse, error)

func (*Metainfo) CreateBucket 

func (m *Metainfo) CreateBucket(ctx context.Context, request *pb.CreateBucketRequest) (*pb.CreateBucketResponse, error)

func (*Metainfo) DeleteBucket 

func (m *Metainfo) DeleteBucket(ctx context.Context, request *pb.DeleteBucketRequest) (*pb.DeleteBucketResponse, error)

func (*Metainfo) DeletePart 

func (m *Metainfo) DeletePart(ctx context.Context, request *pb.DeletePartRequest) (*pb.DeletePartResponse, error)

func (*Metainfo) DownloadObject 

func (m *Metainfo) DownloadObject(ctx context.Context, request *pb.DownloadObjectRequest) (*pb.DownloadObjectResponse, error)

func (*Metainfo) DownloadSegment 

func (m *Metainfo) DownloadSegment(ctx context.Context, request *pb.DownloadSegmentRequest) (*pb.DownloadSegmentResponse, error)

func (*Metainfo) FinishCopyObject 

func (m *Metainfo) FinishCopyObject(ctx context.Context, request *pb.FinishCopyObjectRequest) (*pb.FinishCopyObjectResponse, error)

func (*Metainfo) FinishDeleteObject 

func (m *Metainfo) FinishDeleteObject(ctx context.Context, request *pb.FinishDeleteObjectRequest) (*pb.FinishDeleteObjectResponse, error)

func (*Metainfo) FinishDeleteSegment 

func (m *Metainfo) FinishDeleteSegment(ctx context.Context, request *pb.FinishDeleteSegmentRequest) (*pb.FinishDeleteSegmentResponse, error)

func (*Metainfo) FinishMoveObject 

func (m *Metainfo) FinishMoveObject(ctx context.Context, request *pb.FinishMoveObjectRequest) (*pb.FinishMoveObjectResponse, error)

func (*Metainfo) GetBucket 

func (m *Metainfo) GetBucket(ctx context.Context, request *pb.GetBucketRequest) (*pb.GetBucketResponse, error)

func (*Metainfo) GetBucketLocation 

func (m *Metainfo) GetBucketLocation(ctx context.Context, request *pb.GetBucketLocationRequest) (*pb.GetBucketLocationResponse, error)

func (*Metainfo) GetBucketObjectLockConfiguration 

func (m *Metainfo) GetBucketObjectLockConfiguration(ctx context.Context, request *pb.GetBucketObjectLockConfigurationRequest) (*pb.GetBucketObjectLockConfigurationResponse, error)

func (*Metainfo) GetBucketVersioning 

func (m *Metainfo) GetBucketVersioning(ctx context.Context, request *pb.GetBucketVersioningRequest) (*pb.GetBucketVersioningResponse, error)

func (*Metainfo) GetObject 

func (m *Metainfo) GetObject(ctx context.Context, request *pb.GetObjectRequest) (*pb.GetObjectResponse, error)

func (*Metainfo) GetObjectIPs 

func (m *Metainfo) GetObjectIPs(ctx context.Context, request *pb.GetObjectIPsRequest) (*pb.GetObjectIPsResponse, error)

func (*Metainfo) GetObjectRetention 

func (m *Metainfo) GetObjectRetention(ctx context.Context, request *pb.GetObjectRetentionRequest) (*pb.GetObjectRetentionResponse, error)

func (*Metainfo) ListBuckets 

func (m *Metainfo) ListBuckets(ctx context.Context, request *pb.ListBucketsRequest) (*pb.ListBucketsResponse, error)

func (*Metainfo) ListObjects 

func (m *Metainfo) ListObjects(ctx context.Context, request *pb.ListObjectsRequest) (*pb.ListObjectsResponse, error)

func (*Metainfo) ListPendingObjectStreams 

func (m *Metainfo) ListPendingObjectStreams(ctx context.Context, request *pb.ListPendingObjectStreamsRequest) (*pb.ListPendingObjectStreamsResponse, error)

func (*Metainfo) ListSegments 

func (m *Metainfo) ListSegments(ctx context.Context, request *pb.ListSegmentsRequest) (*pb.ListSegmentsResponse, error)

func (*Metainfo) MakeInlineSegment 

func (m *Metainfo) MakeInlineSegment(ctx context.Context, request *pb.MakeInlineSegmentRequest) (*pb.MakeInlineSegmentResponse, error)

func (*Metainfo) ProjectInfo 

func (m *Metainfo) ProjectInfo(ctx context.Context, request *pb.ProjectInfoRequest) (*pb.ProjectInfoResponse, error)

func (*Metainfo) RetryBeginSegmentPieces 

func (m *Metainfo) RetryBeginSegmentPieces(ctx context.Context, request *pb.RetryBeginSegmentPiecesRequest) (*pb.RetryBeginSegmentPiecesResponse, error)

func (*Metainfo) RevokeAPIKey 

func (m *Metainfo) RevokeAPIKey(ctx context.Context, request *pb.RevokeAPIKeyRequest) (*pb.RevokeAPIKeyResponse, error)

func (*Metainfo) SetBucketVersioning 

func (m *Metainfo) SetBucketVersioning(ctx context.Context, request *pb.SetBucketVersioningRequest) (*pb.SetBucketVersioningResponse, error)

func (*Metainfo) SetObjectRetention 

func (m *Metainfo) SetObjectRetention(ctx context.Context, request *pb.SetObjectRetentionRequest) (*pb.SetObjectRetentionResponse, error)

func (*Metainfo) UpdateObjectMetadata 

func (m *Metainfo) UpdateObjectMetadata(ctx context.Context, request *pb.UpdateObjectMetadataRequest) (*pb.UpdateObjectMetadataResponse, error)

type NodeEndpoint 

type NodeEndpoint struct {
	pb.DRPCNodeUnimplementedServer
}

func (*NodeEndpoint) CheckIn 

func (s *NodeEndpoint) CheckIn(context.Context, *pb.CheckInRequest) (*pb.CheckInResponse, error)

func (*NodeEndpoint) GetTime 

func (s *NodeEndpoint) GetTime(context.Context, *pb.GetTimeRequest) (*pb.GetTimeResponse, error)

type NodeStatEndpoint 

type NodeStatEndpoint struct {
}

func (*NodeStatEndpoint) DailyStorageUsage 

func (n *NodeStatEndpoint) DailyStorageUsage(ctx context.Context, request *pb.DailyStorageUsageRequest) (*pb.DailyStorageUsageResponse, error)

func (*NodeStatEndpoint) GetStats 

func (n *NodeStatEndpoint) GetStats(context.Context, *pb.GetStatsRequest) (*pb.GetStatsResponse, error)

func (*NodeStatEndpoint) PricingModel 

func (n *NodeStatEndpoint) PricingModel(ctx context.Context, request *pb.PricingModelRequest) (*pb.PricingModelResponse, error)

type OrdersEndpoint 

type OrdersEndpoint struct {
}

func (*OrdersEndpoint) SettlementWithWindow 

func (o *OrdersEndpoint) SettlementWithWindow(stream pb.DRPCOrders_SettlementWithWindowStream) error

type Ping 

type Ping struct {
	URL string `arg:""`
	util.DialerHelper
}

func (Ping) Run 

func (p Ping) Run() error

type Restore 

type Restore struct {
	URL  string `arg:""`
	Keys string
}

func (Restore) Run 

func (r Restore) Run() error

type Run 

type Run struct {
}

func (Run) Run 

func (r Run) Run() error

type Satellite 

type Satellite struct {
	Run     Run     `cmd:"" help:"Run mock satellite"`
	Restore Restore `cmd:"" help:"Send restore trash request to the storagenode (satellite->sn)"`
	Ping    Ping    `cmd:"" help:"Send ping to the storagenode (satellite->sn)"`
	Time    Time    `cmd:"" help:"Get time of the satellite (sn->satellite)"`
	GC      GC      `cmd:"" help:"Send gc request to the storagenode"`
}

type Time 

type Time struct {
	URL string `arg:""`
	util.DialerHelper
}

func (Time) Run 

func (p Time) Run() 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.