cloudevent

Documentation

Index

• Variables
• func Get(ctx context.Context) cloudevents.Client
• func SendEvent(ctx context.Context, eventType KServiceEvent, obj *v1.Service) error
• func SetTarget(ctx context.Context, target string) context.Context
• func ToContext(ctx context.Context, client cloudevents.Client) context.Context
• type CECKey
• type Config
• type KServiceEvent
• type KServiceToCDEventMap
• type Key

Variables

var (
	Map = KServiceToCDEventMap{
		ServiceDeployed: cdevents.ServiceDeployedEventV1,
		ServiceUpgraded: cdevents.ServiceUpgradedEventV1,
		ServiceRemoved:  cdevents.ServiceRemovedEventV1,
	}
)

Functions

func Get

func Get(ctx context.Context) cloudevents.Client

func SendEvent

func SendEvent(ctx context.Context, eventType KServiceEvent, obj *v1.Service) error

func SetTarget

func SetTarget(ctx context.Context, target string) context.Context

func ToContext

func ToContext(ctx context.Context, client cloudevents.Client) context.Context

Types

type CECKey

type CECKey struct{}

type Config

type Config struct {
	EventSink string `default:"http://localhost:8080"`
}

type KServiceEvent

type KServiceEvent string

const (
	ServiceDeployed KServiceEvent = "deployed"
	ServiceUpgraded KServiceEvent = "upgraded"
	ServiceRemoved  KServiceEvent = "removed"
)

type KServiceToCDEventMap

type KServiceToCDEventMap map[KServiceEvent]cdevents.CDEventType

type Key

type Key int

const (
	EventSink Key = iota
)