cli

Documentation

Index

• Constants
• func AddClusterFlags(root *cobra.Command)
• func JoinConsulPeers(api *consul.Client, service string, selfAddress string, selfPort int, ...) error
• func Run(cmd *cobra.Command, name string, ...)
• type Service

Constants

const (
	FLAG_NAME_CLUSTER            = "cluster"
	FLAG_NAME_SERVICE            = "service"
	FLAG_NAME_SERVICE_GOSSIP     = "gossip"
	FLAG_NAME_SERVICE_GOSSIP_RPC = "gossip_rpc"
)

Functions

func AddClusterFlags

func AddClusterFlags(root *cobra.Command)

func JoinConsulPeers

func JoinConsulPeers(api *consul.Client, service string, selfAddress string, selfPort int, mesh cluster.Mesh, logger *zap.Logger) error

func Run

func Run(cmd *cobra.Command, name string, serviceFunc func(id string, logger *zap.Logger, mesh cluster.DiscoveryLayer) Service)

Types

type Service

type Service interface {
	Serve(port int) net.Listener
	Shutdown()
	JoinServiceLayer(string, *zap.Logger, cluster.ServiceConfig, cluster.ServiceConfig, cluster.DiscoveryLayer)
	Health() string
}