storage

Documentation

Index

• type Filter
  • func CreateFilter() *Filter
  • func (f *Filter) Filtering(storage resource.Resource, filtered chan resource.Resource, wg *sync.WaitGroup)
• type Preparer
  • func CreatePreparer(reader *reader.Reader, limiter *rate.Limiter, conn *grpc.ClientConn) *Preparer
  • func (p *Preparer) Finish()
  • func (p *Preparer) InitializeMaps(wg *sync.WaitGroup)
  • func (p *Preparer) Preparation(acc resource.Resource, wg *sync.WaitGroup)
  • func (p *Preparer) SendIdentifier() error
• type Processor
  • func CreateProcessor(r *reader.Reader) *Processor
  • func (p *Processor) Process(read chan resource.Resource, readDone chan bool, ...)
  • func (p *Processor) RetrieveInfo(fullInfo chan resource.Resource, wg *sync.WaitGroup, image resource.Resource)
• type Writer
  • func CreateWriter(limiter *rate.Limiter) *Writer
  • func (w *Writer) Close() (*empty.Empty, error)
  • func (w *Writer) SendIdentifier() error
  • func (w *Writer) SetUp(conn *grpc.ClientConn)
  • func (w *Writer) Write(record writer.Record) error

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 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(reader *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 OpenNebula.

func (*Processor) Process

func (p *Processor) Process(read chan resource.Resource, readDone chan bool, swg *sizedwaitgroup.SizedWaitGroup)

Process provides listing of the storages once.

func (*Processor) RetrieveInfo

func (p *Processor) RetrieveInfo(fullInfo chan resource.Resource, wg *sync.WaitGroup, image resource.Resource)

RetrieveInfo - only for VM relevant.

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.