gateway

Documentation

Index

• Constants
• type Gateway
  • func (g *Gateway) Name() string
  • func (g *Gateway) NewGatewayLayer(madmin.Credentials) (minio.ObjectLayer, error)
• type IPFSObjects
  • func NewIPFSObjects(ctx context.Context, address, root string, bootstrap []string, m metadata.DB) (*IPFSObjects, error)
  • func (o *IPFSObjects) DeleteBucket(ctx context.Context, bucket string, opts minio.DeleteBucketOptions) error
  • func (o *IPFSObjects) DeleteObject(ctx context.Context, bucket, object string, opts minio.ObjectOptions) (minio.ObjectInfo, error)
  • func (o *IPFSObjects) DeleteObjects(ctx context.Context, bucket string, objects []minio.ObjectToDelete, ...) ([]minio.DeletedObject, []error)
  • func (o *IPFSObjects) GetBucketInfo(ctx context.Context, bucket string, opts minio.BucketOptions) (bucketInfo minio.BucketInfo, err error)
  • func (o *IPFSObjects) GetObjectInfo(ctx context.Context, bucket, object string, opts minio.ObjectOptions) (objInfo minio.ObjectInfo, err error)
  • func (o *IPFSObjects) GetObjectNInfo(ctx context.Context, bucket, object string, rs *minio.HTTPRangeSpec, ...) (reader *minio.GetObjectReader, err error)
  • func (o *IPFSObjects) ListBuckets(ctx context.Context, opts minio.BucketOptions) (buckets []minio.BucketInfo, err error)
  • func (o *IPFSObjects) ListObjects(ctx context.Context, bucket, prefix, marker, delimiter string, maxKeys int) (result minio.ListObjectsInfo, err error)
  • func (o *IPFSObjects) MakeBucketWithLocation(ctx context.Context, bucket string, opts minio.MakeBucketOptions) error
  • func (o *IPFSObjects) NewMultipartUpload(ctx context.Context, bucket, object string, opts minio.ObjectOptions) (result *minio.NewMultipartUploadResult, err error)
  • func (o *IPFSObjects) PutObject(ctx context.Context, bucket, object string, data *minio.PutObjReader, ...) (objInfo minio.ObjectInfo, err error)
  • func (o *IPFSObjects) Shutdown(context.Context) error
  • func (o *IPFSObjects) StorageInfo(context.Context) (minio.StorageInfo, []error)
• type Node
  • func NewNode(ctx context.Context, cfg *config.Config) (*Node, error)
  • func (n *Node) Nodes() []string
  • func (n *Node) Run()
• type NodeManager
  • func (m *NodeManager) DeadlineTask()
  • func (m *NodeManager) FindPeerHandle(p *proto.UpdatePeer)

Constants

const IPFSBackendGateway = "ipfs"

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)