Documentation ¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type PImage ¶
PImage represents "Resource" with information about project and his image.
func (*PImage) UnmarshalJSON ¶
UnmarshalJSON function to implement Resource interface.
type PShare ¶
type PShare struct {}
PShare represents "Resource" with information about project and his share.
func (*PShare) UnmarshalJSON ¶
UnmarshalJSON function to implement Resource interface.
type PVolume ¶
PVolume represents "Resource" with information about project and his volume.
func (*PVolume) UnmarshalJSON ¶
UnmarshalJSON function to implement Resource interface.
type Preparer ¶
Preparer to prepare storage data to specific structure for writing to Goat server.
func CreatePreparer ¶
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 ¶
InitializeMaps reads additional data for storage record.
func (*Preparer) Preparation ¶
Preparation prepares storage 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 storage data.
func CreateProcessor ¶
CreateProcessor creates Processor to manage reading from Openstack.
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 ¶
CreateWriter creates Writer for storage 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 storages to Writer.