Documentation

Index

• Variables
• type Link
• type MessageQueue

Constants

This section is empty.

Variables

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

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
}