logging

Documentation

Index

• Constants
• Variables
• func NewEndpoint(config *EndpointConfig, handler logging.Exchange) (logging.Endpoint, error)
• type Endpoint
• type EndpointConfig
  • func NewEndpointConfig() *EndpointConfig
  • func (config *EndpointConfig) FeedFromEnv(prefix string) error
  • func (config *EndpointConfig) IsComplete() bool
  • func (config *EndpointConfig) MustBeComplete()
  • func (config *EndpointConfig) MustFeedFromEnv(prefix string) *EndpointConfig

Constants

const Header = "CDR#LOGGING@01"

Variables

var ErrConfigIncomplete = errors.New("Logging endpoint is not fully configured")

var HeaderFrame = []byte(Header)

Functions

func NewEndpoint

func NewEndpoint(config *EndpointConfig, handler logging.Exchange) (logging.Endpoint, error)

Types

type Endpoint

type Endpoint struct {
	// contains filtered or unexported fields
}

type EndpointConfig

type EndpointConfig struct {
	Endpoint string
	Rcvhwm   int
}

func NewEndpointConfig

func NewEndpointConfig() *EndpointConfig

func (*EndpointConfig) FeedFromEnv

func (config *EndpointConfig) FeedFromEnv(prefix string) error

func (*EndpointConfig) IsComplete

func (config *EndpointConfig) IsComplete() bool

func (*EndpointConfig) MustBeComplete

func (config *EndpointConfig) MustBeComplete()

func (*EndpointConfig) MustFeedFromEnv

func (config *EndpointConfig) MustFeedFromEnv(prefix string) *EndpointConfig