concord-go

Concord Go(lang) client

Installation

go get -u github.com/concord/concord-go

Usage

Make sure you're familiar with Concord concepts. The best place to start is to read Concord docs.

Then, implement interface concord.Computation to be used within Concord:

type Computation interface {
    // Perform initialization of computation.
    Init(*Context) error

    // Perform some cleanup.
    Destroy() error

    // Process record from stream.
    ProcessRecords(*Context, *Record) error

    // Typically used to periodically write record to stream.
    ProcessTimer(*Context, int64, string) error

    // Defines name, input and output streams of computation.
    Metadata() *Metadata
}

In func main create instance comp of your Computation and invoke concord.Serve(comp) to start.

Documentation

See GoDoc documentation

Examples

See examples in examples/ directory.