client

Documentation

Index

• type GatewayClient
  • func NewGatewayClient(address string) (*GatewayClient, error)
  • func (client *GatewayClient) ReplicateObjectPieceStream(objectID uint64, pieceSize uint32, contentLength int64, redundancyIdx uint32, ...) (integrityHash []byte, signature []byte, err error)

Types

type GatewayClient

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

GatewayClient is a http client wrapper

func NewGatewayClient

func NewGatewayClient(address string) (*GatewayClient, error)

NewGatewayClient return a gateway grpc client instance, and use http://ip:port or http://domain_name as address

func (*GatewayClient) ReplicateObjectPieceStream

func (client *GatewayClient) ReplicateObjectPieceStream(objectID uint64, pieceSize uint32, contentLength int64, redundancyIdx uint32,
	approval *p2ptypes.GetApprovalResponse, objectDataReader io.Reader) (integrityHash []byte, signature []byte, err error)

ReplicateObjectPieceStream replicates object piece stream to the target storage-provider.