Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type NetUser ¶
type NetUser struct {
User *resources.User
ActiveVirtualMachines []*resources.VirtualMachine
}
NetUser represents "Resource" with information about user and his active virtual machines.
type Preparer ¶
Preparer to prepare network data to specific structure for writing to Goat server.
func CreatePreparer ¶
func CreatePreparer(limiter *rate.Limiter, conn *grpc.ClientConn) *Preparer
CreatePreparer creates Preparer for network 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 ¶
InitializeMaps - only for VM relevant.
func (*Preparer) Preparation ¶
Preparation prepares network data for writing and call method to write.
func (*Preparer) SendIdentifier ¶
SendIdentifier sends identifier to Goat server.
type Processor ¶
type Processor struct {
// contains filtered or unexported fields
}
Processor to process network data.
func CreateProcessor ¶
CreateProcessor creates Processor to manage reading from OpenNebula.
func (*Processor) Process ¶
func (p *Processor) Process(read chan resource.Resource, _ chan bool, swg *sizedwaitgroup.SizedWaitGroup)
Process provides listing of the users.
type Writer ¶
type Writer struct {
Stream pb.AccountingService_ProcessIpsClient
// contains filtered or unexported fields
}
Writer structure to write network data to Goat server.
func CreateWriter ¶
CreateWriter creates Writer for network data.
func (*Writer) Close ¶
Close gets to know to the goat server that a writing is finished and a response is expected.
func (*Writer) SendIdentifier ¶
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 networks to Writer.
Source Files