proxyerror

Documentation

Index

• type ProxyError
  • func BrokersNotSetError(messages ...string) *ProxyError
  • func ConnectionError(messages ...string) *ProxyError
  • func ResourceCloseError(messages ...string) *ProxyError
  • func ResourceClosedError(messages ...string) *ProxyError
  • func ResourceWriteError(messages ...string) *ProxyError
  • func (e *ProxyError) Error() string

Types

type ProxyError

type ProxyError struct {
	Code    int
	Time    time.Time
	Message string
}

ProxyError is error(s) occurring during communication with Kafka Use Code for error reference Try to use predefined errors (such as ConnectionError) Add new if required

func BrokersNotSetError

func BrokersNotSetError(messages ...string) *ProxyError

BrokersNotSetError represents error when brokers are not specified

func ConnectionError

func ConnectionError(messages ...string) *ProxyError

ConnectionError represents error while connecting to some resource

func ResourceCloseError

func ResourceCloseError(messages ...string) *ProxyError

ResourceCloseError represents error while closing some resource

func ResourceClosedError

func ResourceClosedError(messages ...string) *ProxyError

ResourceClosedError represents error while trying to access a closed resource

func ResourceWriteError

func ResourceWriteError(messages ...string) *ProxyError

ResourceWriteError represents error while writing to a resource

func (*ProxyError) Error

func (e *ProxyError) Error() string