util

Documentation

Index

• Constants
• Variables
• func AddWorkFinalizer(ctx context.Context, workClient workv1client.ManifestWorkInterface, ...) error
• func AppendCAToCertPool(caCert *x509.Certificate) (*x509.CertPool, error)
• func AssertUpdatedWork(ctx context.Context, workClient workv1client.ManifestWorkInterface, ...) error
• func AssertWorkFinalizers(ctx context.Context, workClient workv1client.ManifestWorkInterface, ...) error
• func AssertWorkStatus(ctx context.Context, workClient workv1client.ManifestWorkInterface, ...) error
• func NewGRPCAgentOptions(brokerURL string) *grpc.GRPCOptions
• func NewMQTTAgentOptions(brokerHost, sourceID, clusterName string) *mqtt.MQTTOptions
• func NewMQTTAgentOptionsWithSourceBroadcast(brokerHost, sourceID, clusterName string) *mqtt.MQTTOptions
• func NewMQTTSourceOptions(brokerHost, sourceID string) *mqtt.MQTTOptions
• func NewMQTTSourceOptionsWithSourceBroadcast(brokerHost, sourceID string) *mqtt.MQTTOptions
• func NewManifest(name string) workv1.Manifest
• func NewManifestWork(namespace, name string, withVersion bool) *workv1.ManifestWork
• func NewManifestWorkWithStatus(namespace, name string) *workv1.ManifestWork
• func RemoveWorkFinalizer(ctx context.Context, workClient workv1client.ManifestWorkInterface, ...) error
• func UpdateWork(ctx context.Context, workClient workv1client.ManifestWorkInterface, ...) error
• func UpdateWorkStatus(ctx context.Context, workClient workv1client.ManifestWorkInterface, ...) error
• func WriteCertToTempFile(cert *x509.Certificate) (string, error)
• func WriteTokenToTempFile(token string) (string, error)
• type AllowHook
  • func (h *AllowHook) ID() string
  • func (h *AllowHook) OnACLCheck(cl *mqtt.Client, topic string, write bool) bool
  • func (h *AllowHook) OnConnectAuthenticate(cl *mqtt.Client, pk packets.Packet) bool
  • func (h *AllowHook) Provides(b byte) bool
• type ClientCertPairs
  • func SignClientCert(caCert *x509.Certificate, caKey *rsa.PrivateKey, d time.Duration) (*ClientCertPairs, error)
• type ServerCertPairs
  • func NewServerCertPairs() (*ServerCertPairs, error)

Constants

const RSAPrivateKeyBlockType = "RSA PRIVATE KEY"

Variables

var WorkCreatedCondition = metav1.Condition{Type: "Created", Status: metav1.ConditionTrue}

var WorkUpdatedCondition = metav1.Condition{Type: "Updated", Status: metav1.ConditionTrue}

Functions

func AddWorkFinalizer

func AddWorkFinalizer(ctx context.Context, workClient workv1client.ManifestWorkInterface, name string) error

func AppendCAToCertPool

func AppendCAToCertPool(caCert *x509.Certificate) (*x509.CertPool, error)

func AssertUpdatedWork

func AssertUpdatedWork(ctx context.Context, workClient workv1client.ManifestWorkInterface, name string) error

func AssertWorkFinalizers

func AssertWorkFinalizers(ctx context.Context, workClient workv1client.ManifestWorkInterface, name string) error

func AssertWorkStatus

func AssertWorkStatus(ctx context.Context, workClient workv1client.ManifestWorkInterface, name string, condition metav1.Condition) error

func NewGRPCAgentOptions

func NewGRPCAgentOptions(brokerURL string) *grpc.GRPCOptions

func NewMQTTAgentOptions

func NewMQTTAgentOptions(brokerHost, sourceID, clusterName string) *mqtt.MQTTOptions

func NewMQTTAgentOptionsWithSourceBroadcast

func NewMQTTAgentOptionsWithSourceBroadcast(brokerHost, sourceID, clusterName string) *mqtt.MQTTOptions

func NewMQTTSourceOptions

func NewMQTTSourceOptions(brokerHost, sourceID string) *mqtt.MQTTOptions

func NewMQTTSourceOptionsWithSourceBroadcast

func NewMQTTSourceOptionsWithSourceBroadcast(brokerHost, sourceID string) *mqtt.MQTTOptions

func NewManifest

func NewManifest(name string) workv1.Manifest

func NewManifestWork

func NewManifestWork(namespace, name string, withVersion bool) *workv1.ManifestWork

func NewManifestWorkWithStatus

func NewManifestWorkWithStatus(namespace, name string) *workv1.ManifestWork

func RemoveWorkFinalizer

func RemoveWorkFinalizer(ctx context.Context, workClient workv1client.ManifestWorkInterface, name string) error

func UpdateWork

func UpdateWork(ctx context.Context, workClient workv1client.ManifestWorkInterface, name string, withVersion bool) error

func UpdateWorkStatus

func UpdateWorkStatus(ctx context.Context, workClient workv1client.ManifestWorkInterface, name string, condition metav1.Condition) error

func WriteCertToTempFile

func WriteCertToTempFile(cert *x509.Certificate) (string, error)

func WriteTokenToTempFile

func WriteTokenToTempFile(token string) (string, error)

Types

type AllowHook

type AllowHook struct {
	mqtt.HookBase
}

func (*AllowHook) ID

func (h *AllowHook) ID() string

ID returns the ID of the hook.

func (*AllowHook) OnACLCheck

func (h *AllowHook) OnACLCheck(cl *mqtt.Client, topic string, write bool) bool

OnACLCheck returns true/allowed for all checks.

func (*AllowHook) OnConnectAuthenticate

func (h *AllowHook) OnConnectAuthenticate(cl *mqtt.Client, pk packets.Packet) bool

OnConnectAuthenticate returns true/allowed for all requests.

func (*AllowHook) Provides

func (h *AllowHook) Provides(b byte) bool

Provides indicates which hook methods this hook provides.

type ClientCertPairs

type ClientCertPairs struct {
	ClientCert []byte
	ClientKey  []byte
}

func SignClientCert

func SignClientCert(caCert *x509.Certificate, caKey *rsa.PrivateKey, d time.Duration) (*ClientCertPairs, error)

type ServerCertPairs

type ServerCertPairs struct {
	CA            *x509.Certificate
	CAKey         *rsa.PrivateKey
	ServerTLSCert tls.Certificate
}

func NewServerCertPairs

func NewServerCertPairs() (*ServerCertPairs, error)