source

Documentation

Index

• Constants
• type MQTTSource
  • func NewMQTTSource(configFile string) *MQTTSource
  • func (m *MQTTSource) Host() string
  • func (m *MQTTSource) Start(ctx context.Context) error
  • func (m *MQTTSource) Stop() error
  • func (m *MQTTSource) Workclientset() workclientset.Interface
• type ManifestBundleCodec
  • func (c *ManifestBundleCodec) Decode(evt *cloudevents.Event) (*workv1.ManifestWork, error)
  • func (d *ManifestBundleCodec) Encode(source string, eventType types.CloudEventsType, work *workv1.ManifestWork) (*cloudevents.Event, error)
  • func (c *ManifestBundleCodec) EventDataType() types.CloudEventsDataType
• type ManifestCodec
  • func (c *ManifestCodec) Decode(evt *cloudevents.Event) (*workv1.ManifestWork, error)
  • func (d *ManifestCodec) Encode(source string, eventType types.CloudEventsType, work *workv1.ManifestWork) (*cloudevents.Event, error)
  • func (c *ManifestCodec) EventDataType() types.CloudEventsDataType
• type Source

Constants

const (
	UpdateRequestAction = "update_request"
	DeleteRequestAction = "delete_request"
)

const ManifestWorkFinalizer = "cluster.open-cluster-management.io/manifest-work-cleanup"

const ManifestsDeleted = "Deleted"

Types

type MQTTSource

type MQTTSource struct {
	// contains filtered or unexported fields
}

func NewMQTTSource

func NewMQTTSource(configFile string) *MQTTSource

func (*MQTTSource) Host

func (m *MQTTSource) Host() string

func (*MQTTSource) Start

func (m *MQTTSource) Start(ctx context.Context) error

func (*MQTTSource) Stop

func (m *MQTTSource) Stop() error

func (*MQTTSource) Workclientset

func (m *MQTTSource) Workclientset() workclientset.Interface

type ManifestBundleCodec

type ManifestBundleCodec struct{}

func (*ManifestBundleCodec) Decode

func (c *ManifestBundleCodec) Decode(evt *cloudevents.Event) (*workv1.ManifestWork, error)

func (*ManifestBundleCodec) Encode

func (d *ManifestBundleCodec) Encode(source string, eventType types.CloudEventsType, work *workv1.ManifestWork) (*cloudevents.Event, error)

func (*ManifestBundleCodec) EventDataType

func (c *ManifestBundleCodec) EventDataType() types.CloudEventsDataType

type ManifestCodec

type ManifestCodec struct{}

func (*ManifestCodec) Decode

func (c *ManifestCodec) Decode(evt *cloudevents.Event) (*workv1.ManifestWork, error)

func (*ManifestCodec) Encode

func (d *ManifestCodec) Encode(source string, eventType types.CloudEventsType, work *workv1.ManifestWork) (*cloudevents.Event, error)

func (*ManifestCodec) EventDataType

func (c *ManifestCodec) EventDataType() types.CloudEventsDataType

type Source

type Source interface {
	Host() string
	Start(ctx context.Context) error
	Stop() error
	Workclientset() workclientset.Interface
}