Documentation ¶
Index ¶
Constants ¶
View Source
const ( STORAGE_TYPE_LABEL string = "storage_type" NAME_LABEL string = "name" FLOW_LABEL string = "flow" )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ObjStorageWithMetadata ¶
type ObjStorageWithMetadata interface { worker.ObjStorage Type() string Name() string }
func New ¶
func New(l *zap.SugaredLogger, metricRegistry *prometheus.Registry, flowName string, conf *config.ObjectStorage) (ObjStorageWithMetadata, error)
func NewStorageWithMetrics ¶
func NewStorageWithMetrics(storage ObjStorageWithMetadata, metricRegistry *prometheus.Registry, name string) ObjStorageWithMetadata
Click to show internal directories.
Click to hide internal directories.