proxymessage

README

proxymessage library for section.io k8s

Dockerfile runs gofmt & go test

Documentation

Index

• type Client
  • func NewClient(redisAddress, registrationKey, listKeyPrefix, listKeySuffix string, ...) *Client
  • func NewClientFromEnvVars() *Client
  • func (pmc *Client) GetListKey() string
• type InfoEventCallback

Types

type Client

type Client struct {

	// Successful messages come in via this InboundMessageChannel
	InboundMessageChannel chan string
	// InfoEventCallback is called with informational string messages related to the redis connection
	InfoEventCallback InfoEventCallback

	DebugLog bool
	// contains filtered or unexported fields
}

Client is the message client for proxy pod handlers

func NewClient

func NewClient(redisAddress, registrationKey, listKeyPrefix, listKeySuffix string, registrationTimeoutSeconds int) *Client

NewClient creates a new proxy message client

func NewClientFromEnvVars

func NewClientFromEnvVars() *Client

NewClientFromEnvVars creates a new proxy message client from environment variables

func (*Client) GetListKey

func (pmc *Client) GetListKey() string

GetListKey returns the list key the client is listening on

type InfoEventCallback

type InfoEventCallback func(event string)

This function is called with informational strings