access

type API interface {
	// Put object once if size is not greater than MaxSizePutOnce, otherwise put blobs one by one.
	// return a location and map of hash summary bytes you excepted.
	//
	// If PutArgs' body is of type *bytes.Buffer, *bytes.Reader, or *strings.Reader,
	// GetBody is populated, then the Put once request has retry ability.
	Put(ctx context.Context, args *PutArgs) (location Location, hashSumMap HashSumMap, err error)
	// Get object, range is supported.
	Get(ctx context.Context, args *GetArgs) (body io.ReadCloser, err error)
	// Delete all blobs in these locations.
	// return failed locations which have yet been deleted if error is not nil.
	Delete(ctx context.Context, args *DeleteArgs) (failedLocations []Location, err error)
}

type AllocArgs struct {
	Size            uint64            `json:"size"`
	BlobSize        uint32            `json:"blob_size"`
	AssignClusterID proto.ClusterID   `json:"assign_cluster_id"`
	CodeMode        codemode.CodeMode `json:"code_mode"`
}

type AllocResp struct {
	Location Location `json:"location"`
	Tokens   []string `json:"tokens"`
}

type Blob struct {
	Bid  proto.BlobID
	Vid  proto.Vid
	Size uint32
}

type Config struct {
	// ConnMode rpc connection timeout setting
	ConnMode RPCConnectMode
	// ClientTimeoutMs the whole request and response timeout
	ClientTimeoutMs int64
	// BodyBandwidthMBPs reading body timeout, request or response
	//   timeout = ContentLength/BodyBandwidthMBPs + BodyBaseTimeoutMs
	BodyBandwidthMBPs float64
	// BodyBaseTimeoutMs base timeout for read body
	BodyBaseTimeoutMs int64

	// Consul is consul config for discovering service
	Consul ConsulConfig
	// ServiceIntervalS is interval seconds for discovering service
	ServiceIntervalS int
	// PriorityAddrs priority addrs of access service when retry
	PriorityAddrs []string
	// MaxSizePutOnce max size using once-put object interface
	MaxSizePutOnce int64
	// MaxPartRetry max retry times when putting one part, 0 means forever
	MaxPartRetry int
	// MaxHostRetry max retry hosts of access service
	MaxHostRetry int
	// PartConcurrence concurrence of put parts
	PartConcurrence int

	// rpc selector config
	// Failure retry interval, default value is -1, if FailRetryIntervalS < 0,
	// remove failed hosts will not work.
	FailRetryIntervalS int
	// Within MaxFailsPeriodS, if the number of failures is greater than or equal to MaxFails,
	// the host is considered disconnected.
	MaxFailsPeriodS int
	// HostTryTimes Number of host failure retries
	HostTryTimes int

	// RPCConfig user-defined rpc config
	// All connections will use the config if it's not nil
	// ConnMode will be ignored if rpc config is setting
	RPCConfig *rpc.Config

	// LogLevel client output logging level.
	LogLevel log.Level

	// Logger trace all logging to the logger if setting.
	// It is an io.WriteCloser that writes to the specified filename.
	// YOU should CLOSE it after you do not use the client anymore.
	Logger *Logger
}

type ConsulConfig = api.Config

type DeleteArgs struct {
	Locations []Location `json:"locations"`
}

type DeleteBlobArgs struct {
	ClusterID proto.ClusterID `json:"clusterid"`
	Vid       proto.Vid       `json:"volumeid"`
	BlobID    proto.BlobID    `json:"blobid"`
	Size      int64           `json:"size"`
	Token     string          `json:"token"`
}

type DeleteResp struct {
	FailedLocations []Location `json:"failed_locations,omitempty"`
}

type GetArgs struct {
	Location Location `json:"location"`
	Offset   uint64   `json:"offset"`
	ReadSize uint64   `json:"read_size"`
}

type HashAlgorithm uint8

type HashSumMap map[HashAlgorithm][]byte

type HasherMap map[HashAlgorithm]hash.Hash

type Location struct {
	ClusterID proto.ClusterID   `json:"cluster_id"`
	CodeMode  codemode.CodeMode `json:"code_mode"`
	Size      uint64            `json:"size"`
	BlobSize  uint32            `json:"blob_size"`
	Crc       uint32            `json:"crc"`
	Blobs     []SliceInfo       `json:"blobs"`
	// contains filtered or unexported fields
}

type Logger = lumberjack.Logger

type PutArgs struct {
	Size   int64         `json:"size"`
	Hashes HashAlgorithm `json:"hashes,omitempty"`
	Body   io.Reader     `json:"-"`
}

type PutAtArgs struct {
	ClusterID proto.ClusterID `json:"clusterid"`
	Vid       proto.Vid       `json:"volumeid"`
	BlobID    proto.BlobID    `json:"blobid"`
	Size      int64           `json:"size"`
	Hashes    HashAlgorithm   `json:"hashes,omitempty"`
	Token     string          `json:"token"`
	Body      io.Reader       `json:"-"`
}

type PutAtResp struct {
	HashSumMap HashSumMap `json:"hashsum"`
}

type PutResp struct {
	Location   Location   `json:"location"`
	HashSumMap HashSumMap `json:"hashsum"`
}

type RPCConnectMode uint8

type SignArgs struct {
	Locations []Location `json:"locations"`
	Location  Location   `json:"location"`
}

type SignResp struct {
	Location Location `json:"location"`
}

type SliceInfo struct {
	MinBid proto.BlobID `json:"min_bid"`
	Vid    proto.Vid    `json:"vid"`
	Count  uint32       `json:"count"`
	// contains filtered or unexported fields
}