The highest tagged major version is v2.

examples

package

v1.2.0 Latest Latest Go to latest Published: Mar 22, 2018 License: Apache-2.0 Imports: 0 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

Repository

Repository URL not available.

Links

Open Source Insights

README ¶

CN-infra examples

The examples folder contains several executable examples (built from their respective main.go files) used to illustrate the cn-infra functionality. While most of the examples show a very simple use case, they still often need to connect to ETCD/Redis and/or Kafka. Therefore, you need to have instances of Etcd, Redis and Kafka running prior to starting examples.

Examples with the suffix -lib demonstrate the usage of CN-Infra APIs in generic Go programs. You can simply import the CN-Infra library where the API is declared into your program and start using the API.

Examples with the suffix -plugin demonstrate the usage of CN-Infra APIs within the context of plugins. Plugins are the basic building blocks of any given CN-Infra application. The CN-Infra plugin framework provides plugin initialization and graceful shutdown and supports uniform dependency injection mechanism to manage dependencies between plugins.

Current examples:

cassandra-lib shows how to use the Cassandra data broker API to access the Cassandra database,
datasync-plugin demonstrates the usage of the data synchronization APIs of the datasync package inside an example plugin,
etcdv3-lib shows how to use the ETCD data broker API to write data into ETCD and catch this change as an event by the watcher,
flags-lib registers flags and shows their runtime values in an example plugin,
kafka-lib shows how to use the Kafka messaging library on a set of individual tools (sync and async producer, consumer, mux),
kafka-plugin (hash-partitioner) contains a simple plugin which registers a Kafka consumer on specific topics and sends multiple test messages,
kafka-plugin (manual-partitioner) contains a simple plugin which registers a Kafka consumer watching on specific topics/partitions/offsets and sends multiple test messages,
logs-lib shows how to use the logger library and switch between the log levels,
logs-plugin shows how to use the logger library in a simple plugin,
redis-lib contains several examples that use the Redis data broker API,
model shows how to define a custom data model using Protocol Buffers and how to integrate it into an application,
simple-agent demonstrates how easily a set of CN-infra based plugins can be turned into an application.

Documentation ¶

Overview ¶

Package examples contains examples that demonstrate the usage of various cn-infra components.

Source Files ¶

View all Source files

doc.go

Directories ¶

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

Path	Synopsis
cassandra-lib Example application "cassandra-lib" demonstrates the usage of the cassandra library in a plain go program.	Example application "cassandra-lib" demonstrates the usage of the cassandra library in a plain go program.
configs-plugin Example program "configs-plugin" demonstrates the usage of PluginConfig API.	Example program "configs-plugin" demonstrates the usage of PluginConfig API.
datasync-plugin Example application "datasync-plugin" demonstrates the usage of the datasync API.	Example application "datasync-plugin" demonstrates the usage of the datasync API.
etcdv3-lib Package etcdv3lib contains a collection of examples demonstrating the usage of the etcdv3 library.	Package etcdv3lib contains a collection of examples demonstrating the usage of the etcdv3 library.
editor Example program "editor" demonstrates CREATE/UPDATE/DELETE operations with etcdv3 library.	Example program "editor" demonstrates CREATE/UPDATE/DELETE operations with etcdv3 library.
model/phonebook Package phonebook is a generated protocol buffer package.	Package phonebook is a generated protocol buffer package.
view Example program "view" shows how to read data from etcdv3 datastore.	Example program "view" shows how to read data from etcdv3 datastore.
watcher Example program watcher shows how to watch for changes in etcdv3 datastore.	Example program watcher shows how to watch for changes in etcdv3 datastore.
flags-lib Example program "flags-lib" demonstrates how to register CLI flags and how to display their runtime values.	Example program "flags-lib" demonstrates how to register CLI flags and how to display their runtime values.
grpc-plugin Package grpcplugin contains grpc server & grpc client example.	Package grpcplugin contains grpc server & grpc client example.
grpc-client
grpc-server Example demonstrates the use of GRPC plugin API.	Example demonstrates the use of GRPC plugin API.
kafka-lib Package kafkalib contains multiple examples with the kafka library.	Package kafkalib contains multiple examples with the kafka library.
asyncproducer Asyncproducer is a simple command line tool for sending messages to Kafka using an asynchronous Kafka producer.	Asyncproducer is a simple command line tool for sending messages to Kafka using an asynchronous Kafka producer.
consumer Consumer is a simple command line tool for consuming a Kafka topic and printing the received messages to the stdout.	Consumer is a simple command line tool for consuming a Kafka topic and printing the received messages to the stdout.
mux Mux is a simple command line tool demonstrating the usage of Kafka multiplexer API.	Mux is a simple command line tool demonstrating the usage of Kafka multiplexer API.
syncproducer Syncproducer is simple command line tool for sending messages to Kafka using a synchronous Kafka producer.	Syncproducer is simple command line tool for sending messages to Kafka using a synchronous Kafka producer.
utils Package utils implements various tools used in examples for Kafka library.	Package utils implements various tools used in examples for Kafka library.
kafka-plugin Package kafkaplugin contains multiple examples with the kafka plugin.	Package kafkaplugin contains multiple examples with the kafka plugin.
hash-partitioner Example "hash-partitioner" demonstrates the use of Kafka plugin API with automatic (hash-based) partitioning.	Example "hash-partitioner" demonstrates the use of Kafka plugin API with automatic (hash-based) partitioning.
manual-partitioner Example "manual-partitioner" demonstrates the use of Kafka plugin API with a focus on manual partitioning.	Example "manual-partitioner" demonstrates the use of Kafka plugin API with a focus on manual partitioning.
post-init-consumer Example "later-stage" demonstrates the use partition watcher initialized and used after multiplexer Init()	Example "later-stage" demonstrates the use partition watcher initialized and used after multiplexer Init()
logs-lib Package logslib contains multiple examples showing how to use the logger library with a focus on switching between the log levels.	Package logslib contains multiple examples showing how to use the logger library with a focus on switching between the log levels.
basic Example "basic" presents the most commonly used APIs of the logger library.	Example "basic" presents the most commonly used APIs of the logger library.
custom Example "custom" shows how to customize the logger.	Example "custom" shows how to customize the logger.
http Example "http" demonstrates how to change the log level remotely via REST.	Example "http" demonstrates how to change the log level remotely via REST.
logs-plugin Example "logs-plugin" shows how to use the logger library from a simple plugin.	Example "logs-plugin" shows how to use the logger library from a simple plugin.
model Package etcdexample explains how to generate Golang structures from protobuf-formatted data.	Package etcdexample explains how to generate Golang structures from protobuf-formatted data.
prometheus-plugin
redis-lib Package redislib contains a collection of examples demonstrating the usage of the redis library.	Package redislib contains a collection of examples demonstrating the usage of the redis library.
airport A bit more advanced example demonstrating the redis library API.	A bit more advanced example demonstrating the redis library API.
airport/model Package flight defines protobuf-formatted data as used by the airport example.	Package flight defines protobuf-formatted data as used by the airport example.
simple A simple example demonstrating the redis library API.	A simple example demonstrating the redis library API.
redis-plugin Example demonstrates creating a Redis plugin	Example demonstrates creating a Redis plugin
simple-agent Example simple-agent shows how easily a set of CN-infra based plugins can be turned into an application.	Example simple-agent shows how easily a set of CN-infra based plugins can be turned into an application.
statuscheck-plugin Example application "statuscheck-plugin" demonstrates the usage of statusCheck plugin etcdv3-plugin is monitored by StatusCheck plugin and examplePlugin reads the state.	Example application "statuscheck-plugin" demonstrates the usage of statusCheck plugin etcdv3-plugin is monitored by StatusCheck plugin and examplePlugin reads the state.