meshsync

Documentation

Index

• Constants
• Variables
• func ErrCopyBuffer(err error) error
• func ErrExecTerminal(err error) error
• func ErrGetObject(err error) error
• func ErrInitRequest(err error) error
• func ErrKubeConfig(err error) error
• func ErrLogStream(err error) error
• func ErrNewInformer(err error) error
• func ErrNewPipeline(err error) error
• func ErrSubscribeRequest(err error) error
• type Handler
  • func New(config config.Handler, log logger.Handler, br broker.Handler, ...) (*Handler, error)
  • func (h *Handler) ListenToRequests()
  • func (h *Handler) Run()

Constants

const KB = 1024

KB stands for KiloByte

Variables

var (
	ErrGetObjectCode        = "1004"
	ErrNewPipelineCode      = "1005"
	ErrNewInformerCode      = "1006"
	ErrKubeConfigCode       = "1007"
	ErrInitRequestCode      = "1008"
	ErrSubscribeRequestCode = "1009"
	ErrLogStreamCode        = "1010"
	ErrCopyBufferCode       = "1011"
	ErrInvalidRequestCode   = "1012"
	ErrExecTerminalCode     = "1013"

	ErrInvalidRequest = errors.New(ErrInvalidRequestCode, errors.Alert, []string{"Request is invalid"}, []string{}, []string{"Stale request on the broker"}, []string{"Make sure the request format is correctly configured"})
)

Functions

func ErrCopyBuffer

func ErrCopyBuffer(err error) error

func ErrExecTerminal

func ErrExecTerminal(err error) error

func ErrGetObject

func ErrGetObject(err error) error

func ErrInitRequest

func ErrInitRequest(err error) error

func ErrKubeConfig

func ErrKubeConfig(err error) error

func ErrLogStream

func ErrLogStream(err error) error

func ErrNewInformer

func ErrNewInformer(err error) error

func ErrNewPipeline

func ErrNewPipeline(err error) error

func ErrSubscribeRequest

func ErrSubscribeRequest(err error) error

Types

type Handler

type Handler struct {
	Config config.Handler
	Log    logger.Handler
	Broker broker.Handler
	// contains filtered or unexported fields
}

Handler contains all handlers, channels, clients, and other parameters for an adapter. Use type embedding in a specific adapter to extend it.

func New

func New(config config.Handler, log logger.Handler, br broker.Handler, pool map[string]channels.GenericChannel) (*Handler, error)

func (*Handler) ListenToRequests

func (h *Handler) ListenToRequests()

func (*Handler) Run

func (h *Handler) Run()