storage

package
v0.0.0-...-371bc73 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: May 13, 2022 License: Apache-2.0 Imports: 26 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Filter

type Filter struct {
}

Filter to filter storage data.

func CreateFilter

func CreateFilter() *Filter

CreateFilter creates Filter.

func (*Filter) Filtering

func (f *Filter) Filtering(storage resource.Resource, filtered chan resource.Resource, wg *sync.WaitGroup)

Filtering - only for VM relevant.

type PImage

type PImage struct {
	Project *projects.Project
	Image   *images.Image
}

PImage represents "Resource" with information about project and his image.

func (*PImage) UnmarshalJSON

func (pi *PImage) UnmarshalJSON(b []byte) error

UnmarshalJSON function to implement Resource interface.

type PShare

type PShare struct {
	Project *projects.Project
	Share   *shares.Share
}

PShare represents "Resource" with information about project and his share.

func (*PShare) UnmarshalJSON

func (ps *PShare) UnmarshalJSON(b []byte) error

UnmarshalJSON function to implement Resource interface.

type PVolume

type PVolume struct {
	Project *projects.Project
	Volume  *volumes.Volume
}

PVolume represents "Resource" with information about project and his volume.

func (*PVolume) UnmarshalJSON

func (pv *PVolume) UnmarshalJSON(b []byte) error

UnmarshalJSON function to implement Resource interface.

type Preparer

type Preparer struct {
	Writer writer.Writer
	// contains filtered or unexported fields
}

Preparer to prepare storage data to specific structure for writing to Goat server.

func CreatePreparer

func CreatePreparer(ir *reader.Reader, limiter *rate.Limiter, conn *grpc.ClientConn) *Preparer

CreatePreparer creates Preparer for storage records.

func (*Preparer) Finish

func (p *Preparer) Finish()

Finish gets to know to the Goat server that a writing is finished and a response is expected. Then, it closes the gRPC connection.

func (*Preparer) InitializeMaps

func (p *Preparer) InitializeMaps(wg *sync.WaitGroup)

InitializeMaps reads additional data for storage record.

func (*Preparer) Preparation

func (p *Preparer) Preparation(acc resource.Resource, wg *sync.WaitGroup)

Preparation prepares storage data for writing and call method to write.

func (*Preparer) SendIdentifier

func (p *Preparer) SendIdentifier() error

SendIdentifier sends identifier to Goat server.

type Processor

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

Processor to process storage data.

func CreateProcessor

func CreateProcessor(r *reader.Reader) *Processor

CreateProcessor creates Processor to manage reading from Openstack.

func (*Processor) Process

func (p *Processor) Process(project projects.Project, osClient *gophercloud.ProviderClient, read chan resource.Resource,
	wg *sync.WaitGroup)

Process provides listing of the images with pagination.

func (*Processor) Reader

func (p *Processor) Reader() *reader.Reader

Reader gets reader.

type SwiftContainer

type SwiftContainer struct {
	Project   *projects.Project
	Container *containers.Container
}

SwiftContainer represents "Resource" with information about project and his container.

func (*SwiftContainer) UnmarshalJSON

func (sc *SwiftContainer) UnmarshalJSON(b []byte) error

UnmarshalJSON function to implement Resource interface.

type Writer

type Writer struct {
	Stream pb.AccountingService_ProcessStoragesClient
	// contains filtered or unexported fields
}

Writer structure to write storage data to Goat server.

func CreateWriter

func CreateWriter(limiter *rate.Limiter) *Writer

CreateWriter creates Writer for storage data.

func (*Writer) Close

func (w *Writer) Close() (*empty.Empty, error)

Close gets to know to the goat server that a writing is finished and a response is expected.

func (*Writer) SendIdentifier

func (w *Writer) SendIdentifier() error

SendIdentifier sends identifier to Goat server.

func (*Writer) SetUp

func (w *Writer) SetUp(conn *grpc.ClientConn)

SetUp creates gRPC client and sets up Stream to process storages to Writer.

func (*Writer) Write

func (w *Writer) Write(record writer.Record) error

Write writes network record to Goat server.

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL