ais

Documentation

Overview

Package ais implements an AIStore client.

• Copyright (c) 2018-2022, NVIDIA CORPORATION. All rights reserved.

Package ais implements an AIStore client.

• Copyright (c) 2018-2022, NVIDIA CORPORATION. All rights reserved.

Package ais implements an AIStore client.

• Copyright (c) 2018-2022, NVIDIA CORPORATION. All rights reserved.

Index

• Constants
• type Bucket
  • func NewBucket(name string, apiParams api.BaseParams) (bck Bucket, err error)
• type ErrIO
  • func (e *ErrIO) Error() string
• type Object
  • func NewObject(objName string, bucket Bucket, sizes ...int64) *Object
  • func (obj *Object) Append(r cos.ReadOpenCloser, prevHandle string, size int64) (handle string, err error)
  • func (obj *Object) Bck() cmn.Bck
  • func (obj *Object) Flush(handle string, cksum *cos.Cksum) (err error)
  • func (obj *Object) GetChunk(w io.Writer, offset, length int64) (n int64, err error)
  • func (obj *Object) Put(r cos.ReadOpenCloser) (err error)

Constants

const (
	IOErrorKindBucket = "bucket"
	IOErrorKindObject = "object"
)

Types

type Bucket

type Bucket interface {
	Name() string
	APIParams() api.BaseParams
	Bck() cmn.Bck
	HeadObject(objName string) (obj *Object, exists bool, err error)
	ListObjects(prefix, token string, pageSize uint) (objs []*Object, nextToken string, err error)
	DeleteObject(objName string) (err error)
}

func NewBucket

func NewBucket(name string, apiParams api.BaseParams) (bck Bucket, err error)

type ErrIO

type ErrIO struct {
	Kind   string
	Op     string
	Object string
	Err    error
}

func (*ErrIO) Error

func (e *ErrIO) Error() string

type Object

type Object struct {
	Name  string
	Size  int64
	Atime time.Time
	// contains filtered or unexported fields
}

func NewObject

func NewObject(objName string, bucket Bucket, sizes ...int64) *Object

func (*Object) Append

func (obj *Object) Append(r cos.ReadOpenCloser, prevHandle string, size int64) (handle string, err error)

func (*Object) Bck

func (obj *Object) Bck() cmn.Bck

func (*Object) Flush

func (obj *Object) Flush(handle string, cksum *cos.Cksum) (err error)

func (*Object) GetChunk

func (obj *Object) GetChunk(w io.Writer, offset, length int64) (n int64, err error)

func (*Object) Put

func (obj *Object) Put(r cos.ReadOpenCloser) (err error)