agent

Documentation

Overview

This package provides some convenient auto-configuration functionality for Meeko agents. All available Meeko service clients are configured from the environment variables and then they are accessible using the service getter functions.

Make sure to listen on Stopped() channel to terminate the agent.

Index

• func Logging() *logging.Service
• func PubSub() *pubsub.Service
• func RPC() *rpc.Service
• func Stopped() <-chan struct{}

Functions

func Logging

func Logging() *logging.Service

Logging returns an instance of the Meeko Logging service.

func PubSub

func PubSub() *pubsub.Service

PubSub returns and instance of the Meeko PubSub service.

func RPC

func RPC() *rpc.Service

RPC returns an instance of the Meeko RPC service.

func Stopped

func Stopped() <-chan struct{}

Stopped returns a channel that is closed when the agent receives the stop signal. The agent process should react by exiting as soon as possible, unless it wants to be killed mercilessly.