gateway

package
v0.0.0-...-6d5efb9 Latest Latest
Warning

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

 Go to latest Published: Mar 12, 2023 License: Apache-2.0 Imports: 21 Imported by: 0

Documentation

Index

Constants

View Source 
const IPFSBackendGateway = "ipfs"

Variables

This section is empty.

Functions

This section is empty.

Types

type Gateway 

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

Gateway implements Gateway.

func (*Gateway) Name 

func (g *Gateway) Name() string

Name implements Gateway interface.

func (*Gateway) NewGatewayLayer 

func (g *Gateway) NewGatewayLayer(madmin.Credentials) (minio.ObjectLayer, error)

NewGatewayLayer returns nas gatewaylayer.

type IPFSObjects 

type IPFSObjects struct {
	minio.GatewayUnsupported
	// contains filtered or unexported fields
}

func NewIPFSObjects 

func NewIPFSObjects(
	ctx context.Context,
	address, root string,
	bootstrap []string,
	m metadata.DB,
) (*IPFSObjects, error)

func (*IPFSObjects) DeleteBucket 

func (o *IPFSObjects) DeleteBucket(ctx context.Context, bucket string, opts minio.DeleteBucketOptions) error

func (*IPFSObjects) DeleteObject 

func (o *IPFSObjects) DeleteObject(ctx context.Context, bucket, object string, opts minio.ObjectOptions) (minio.ObjectInfo, error)

func (*IPFSObjects) DeleteObjects 

func (o *IPFSObjects) DeleteObjects(ctx context.Context, bucket string, objects []minio.ObjectToDelete, opts minio.ObjectOptions) ([]minio.DeletedObject, []error)

func (*IPFSObjects) GetBucketInfo 

func (o *IPFSObjects) GetBucketInfo(
	ctx context.Context,
	bucket string,
	opts minio.BucketOptions,
) (bucketInfo minio.BucketInfo, err error)

func (*IPFSObjects) GetObjectInfo 

func (o *IPFSObjects) GetObjectInfo(
	ctx context.Context,
	bucket, object string,
	opts minio.ObjectOptions,
) (objInfo minio.ObjectInfo, err error)

func (*IPFSObjects) GetObjectNInfo 

func (o *IPFSObjects) GetObjectNInfo(ctx context.Context, bucket, object string, rs *minio.HTTPRangeSpec, h http.Header, lockType minio.LockType, opts minio.ObjectOptions) (reader *minio.GetObjectReader, err error)

func (*IPFSObjects) ListBuckets 

func (o *IPFSObjects) ListBuckets(ctx context.Context, opts minio.BucketOptions) (buckets []minio.BucketInfo, err error)

func (*IPFSObjects) ListObjects 

func (o *IPFSObjects) ListObjects(ctx context.Context, bucket, prefix, marker, delimiter string, maxKeys int) (result minio.ListObjectsInfo, err error)

func (*IPFSObjects) MakeBucketWithLocation 

func (o *IPFSObjects) MakeBucketWithLocation(
	ctx context.Context,
	bucket string,
	opts minio.MakeBucketOptions,
) error

func (*IPFSObjects) NewMultipartUpload 

func (o *IPFSObjects) NewMultipartUpload(ctx context.Context, bucket, object string, opts minio.ObjectOptions) (result *minio.NewMultipartUploadResult, err error)

func (*IPFSObjects) PutObject 

func (o *IPFSObjects) PutObject(ctx context.Context, bucket, object string, data *minio.PutObjReader, opts minio.ObjectOptions) (objInfo minio.ObjectInfo, err error)

func (*IPFSObjects) Shutdown 

func (o *IPFSObjects) Shutdown(context.Context) error

func (*IPFSObjects) StorageInfo 

func (o *IPFSObjects) StorageInfo(context.Context) (minio.StorageInfo, []error)

type Node 

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

Node gateway Node.

func NewNode 

func NewNode(ctx context.Context, cfg *config.Config) (*Node, error)

func (*Node) Nodes 

func (n *Node) Nodes() []string

func (*Node) Run 

func (n *Node) Run()

type NodeManager 

type NodeManager struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func (*NodeManager) DeadlineTask 

func (m *NodeManager) DeadlineTask()

func (*NodeManager) FindPeerHandle 

func (m *NodeManager) FindPeerHandle(p *proto.UpdatePeer)

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.