Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	// ErrSyncTLSConfigMissing certificate bidirectional authentication is required for connection with cloud
	ErrLinkTLSConfigMissing = fmt.Errorf("certificate bidirectional authentication is required for connection with cloud")
	ConfFile                string
)

Functions

This section is empty.

Types

type Link interface {
	Receive() (<-chan *v1.Message, <-chan error)
	Request(msg *v1.Message) (*v1.Message, error)
	Send(msg *v1.Message) error
	IsAsyncSupported() bool
}

    go:generate mockgen -destination=../mock/plugin/link.go -package=plugin -source=link.go

    type MessageQueue

    type MessageQueue interface {
    	mq.MessageQueue
    }

    Source Files

    Directories

    Path Synopsis