writer

package

v0.0.0-...-371bc73 Latest Latest Go to latest Published: May 13, 2022 License: Apache-2.0 Imports: 3 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type Interface interface {
	Write(Record) error
	SendIdentifier() error
}

Interface to write records to Goat server.

type Record interface {
	Reset()
	String() string
	ProtoMessage()
}

Record represents data for writing.

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

Writer structure to write data to Goat server.

func CreateWriter(w writerI, conn *grpc.ClientConn) *Writer

CreateWriter creates writer with writer interface and gRPC connection.

func (w *Writer) 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 (w *Writer) SendIdentifier() error

SendIdentifier sends identifier to Goat server.

func (w *Writer) Write(rec Record) error

Write writes to Goat server.