Documentation ¶
Index ¶
- Constants
- func NewAMQPConn(uri, exchange, queue string, errorChan chan error, certChan chan *Certificate, ...)
- func ProcessCertificates(infiles chan string, ch chan *Certificate)
- func ReadCertificates(filenames ...string) []*x509.Certificate
- func StartErrorHandler(errorChan chan error)
- func WatchCertDir(path string, errchan chan error, ch chan string) error
- type AMQPConn
- type Certificate
- type CertificateExport
- type FatalError
- type NonFatalError
Constants ¶
View Source
const (
CONFIRMATIONCHANLEN = 32768
)
Variables ¶
This section is empty.
Functions ¶
func NewAMQPConn ¶
func NewAMQPConn(uri, exchange, queue string, errorChan chan error, certChan chan *Certificate, deleteChan chan string)
start connection and publish certificates
func ProcessCertificates ¶
func ProcessCertificates(infiles chan string, ch chan *Certificate)
func ReadCertificates ¶
func ReadCertificates(filenames ...string) []*x509.Certificate
ReadCertificates reads alls x509 certificates from a list of input files. Errors are logged and skipped.
func StartErrorHandler ¶
func StartErrorHandler(errorChan chan error)
handle errors (exit on fatal error, log otherwise)
Types ¶
type Certificate ¶
type CertificateExport ¶
type FatalError ¶
type FatalError struct {
// contains filtered or unexported fields
}
func NewFatalError ¶
func NewFatalError(err error, description string) FatalError
func NewFatalErrorf ¶
func NewFatalErrorf(err error, format string, a ...interface{}) FatalError
func (FatalError) Error ¶
func (e FatalError) Error() string
type NonFatalError ¶
type NonFatalError struct {
// contains filtered or unexported fields
}
func NewNonFatalError ¶
func NewNonFatalError(err error, description string) NonFatalError
func NewNonFatalErrorf ¶
func NewNonFatalErrorf(err error, format string, a ...interface{}) NonFatalError
func (NonFatalError) Error ¶
func (e NonFatalError) Error() string
Click to show internal directories.
Click to hide internal directories.