retriever

Documentation

Index

• Constants
• Variables
• func DefaultRetrieverOptions(receiver *RetrieveModular, cfg *gfspconfig.GfSpConfig) error
• func NewRetrieveModular(app *gfspapp.GfSpBaseApp, cfg *gfspconfig.GfSpConfig) (coremodule.Modular, error)
• type RetrieveModular
  • func (r *RetrieveModular) GfSpGetBucketReadQuota(ctx context.Context, req *types.GfSpGetBucketReadQuotaRequest) (*types.GfSpGetBucketReadQuotaResponse, error)
  • func (r *RetrieveModular) GfSpListBucketReadRecord(ctx context.Context, req *types.GfSpListBucketReadRecordRequest) (*types.GfSpListBucketReadRecordResponse, error)
  • func (r *RetrieveModular) GfSpQueryUploadProgress(ctx context.Context, req *types.GfSpQueryUploadProgressRequest) (*types.GfSpQueryUploadProgressResponse, error)
  • func (r *RetrieveModular) Name() string
  • func (r *RetrieveModular) ReleaseResource(ctx context.Context, span rcmgr.ResourceScopeSpan)
  • func (r *RetrieveModular) ReserveResource(ctx context.Context, state *rcmgr.ScopeStat) (rcmgr.ResourceScopeSpan, error)
  • func (r *RetrieveModular) Start(ctx context.Context) error
  • func (r *RetrieveModular) Stop(ctx context.Context) error

Constants

const (
	// DefaultQuerySPParallelPerNode defines the max parallel for retrieving request
	DefaultQuerySPParallelPerNode int64 = 10240
)

const (
	DefaultRetrieverStatisticsInterval = 60
)

Variables

var (
	ErrDanglingPointer = gfsperrors.Register(RetrieveModularName, http.StatusInternalServerError, 90001, "OoooH... request lost, try again later")
	ErrExceedRequest   = gfsperrors.Register(RetrieveModularName, http.StatusServiceUnavailable, 90002, "request exceed")
	ErrNoRecord        = gfsperrors.Register(RetrieveModularName, http.StatusNotFound, 90003, "no uploading record")
	ErrGfSpDB          = gfsperrors.Register(RetrieveModularName, http.StatusInternalServerError, 95202, "server slipped away, try again later")
)

var (
	RetrieveModularName        = strings.ToLower("Retriever")
	RetrieveModularDescription = "Retrieves sp metadata and info."
)

Functions

func DefaultRetrieverOptions

func DefaultRetrieverOptions(receiver *RetrieveModular, cfg *gfspconfig.GfSpConfig) error

func NewRetrieveModular

func NewRetrieveModular(app *gfspapp.GfSpBaseApp, cfg *gfspconfig.GfSpConfig) (coremodule.Modular, error)

Types

type RetrieveModular

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

func (*RetrieveModular) GfSpGetBucketReadQuota

func (r *RetrieveModular) GfSpGetBucketReadQuota(
	ctx context.Context,
	req *types.GfSpGetBucketReadQuotaRequest) (
	*types.GfSpGetBucketReadQuotaResponse, error)

func (*RetrieveModular) GfSpListBucketReadRecord

func (r *RetrieveModular) GfSpListBucketReadRecord(
	ctx context.Context,
	req *types.GfSpListBucketReadRecordRequest) (
	*types.GfSpListBucketReadRecordResponse,
	error)

func (*RetrieveModular) GfSpQueryUploadProgress

func (r *RetrieveModular) GfSpQueryUploadProgress(
	ctx context.Context,
	req *types.GfSpQueryUploadProgressRequest) (
	*types.GfSpQueryUploadProgressResponse, error)

func (*RetrieveModular) Name

func (r *RetrieveModular) Name() string

func (*RetrieveModular) ReleaseResource

func (r *RetrieveModular) ReleaseResource(
	ctx context.Context,
	span rcmgr.ResourceScopeSpan)

func (*RetrieveModular) ReserveResource

func (r *RetrieveModular) ReserveResource(
	ctx context.Context,
	state *rcmgr.ScopeStat) (
	rcmgr.ResourceScopeSpan, error)

func (*RetrieveModular) Start

func (r *RetrieveModular) Start(ctx context.Context) error

func (*RetrieveModular) Stop

func (r *RetrieveModular) Stop(ctx context.Context) error