domain

Documentation

Index

• Constants
• Variables
• func ToResourceVersion(version string) int
• type Batch
• type BatchItems
  • func (items BatchItems) Length() int
• type BatchType
• type Callbacks
• type ClientIdentifier
  • func (c ClientIdentifier) ConnectionString() string
  • func (c ClientIdentifier) String() string
• type Event
  • func (op Event) Value() any
• type Generic
• type GetObject
• type Kind
  • func KindFromString(ctx context.Context, kind string) *Kind
  • func (k Kind) String() string
• type KindName
  • func FromUnstructured(u *unstructured.Unstructured) KindName
  • func (c KindName) String() string
  • func (c KindName) ToCustomProperties() map[string]string
• type NewChecksum
• type ObjectDeleted
• type PatchObject
• type PutObject
• type Strategy

Constants

const (
	ContextKeyClientIdentifier contextKey = "clientIdentifier"
	ContextKeyDepth            contextKey = "depth"
	ContextKeyMsgId            contextKey = "msgId"
)

Variables

var EventValues = []any{"newChecksum", "objectAdded", "objectDeleted", "objectModified", "getObject", "patchObject", "putObject", "ping", "batch"}

var ValuesToEvent = map[any]Event{
	EventValues[EventNewChecksum]:    EventNewChecksum,
	EventValues[EventObjectAdded]:    EventObjectAdded,
	EventValues[EventObjectDeleted]:  EventObjectDeleted,
	EventValues[EventObjectModified]: EventObjectModified,
	EventValues[EventGetObject]:      EventGetObject,
	EventValues[EventPatchObject]:    EventPatchObject,
	EventValues[EventPutObject]:      EventPutObject,
	EventValues[EventPing]:           EventPing,
	EventValues[EventBatch]:          EventBatch,
}

Functions

func ToResourceVersion

func ToResourceVersion(version string) int

Types

type Batch

type Batch struct {
	Depth                int
	Event                *Event
	MsgId                string
	Kind                 *Kind
	BatchType            string
	Items                *BatchItems
	AdditionalProperties map[string]interface{}
}

Batch represents a Batch model.

type BatchItems

type BatchItems struct {
	PutObject            []PutObject
	NewChecksum          []NewChecksum
	ObjectDeleted        []ObjectDeleted
	GetObject            []GetObject
	PatchObject          []PatchObject
	AdditionalProperties map[string]interface{}
}

BatchItems represents a BatchItems model.

func (BatchItems) Length

func (items BatchItems) Length() int

type BatchType

type BatchType string

const (
	DefaultBatch        BatchType = ""
	ReconciliationBatch BatchType = "reconciliation"
)

type Callbacks

type Callbacks struct {
	DeleteObject func(ctx context.Context, id KindName) error
	GetObject    func(ctx context.Context, id KindName, baseObject []byte) error
	PatchObject  func(ctx context.Context, id KindName, checksum string, patch []byte) error
	PutObject    func(ctx context.Context, id KindName, object []byte) error
	VerifyObject func(ctx context.Context, id KindName, checksum string) error
	Batch        func(ctx context.Context, kind Kind, batchType BatchType, items BatchItems) error
}

type ClientIdentifier

type ClientIdentifier struct {
	Account        string
	Cluster        string
	ConnectionId   string
	ConnectionTime time.Time
	HelmVersion    string
	SyncVersion    string
	GitVersion     string
	CloudProvider  string
}

func (ClientIdentifier) ConnectionString

func (c ClientIdentifier) ConnectionString() string

func (ClientIdentifier) String

func (c ClientIdentifier) String() string

type Event

type Event uint

Event represents an enum of Event.

const (
	EventNewChecksum Event = iota
	EventObjectAdded
	EventObjectDeleted
	EventObjectModified
	EventGetObject
	EventPatchObject
	EventPutObject
	EventPing
	EventBatch
)

func (Event) Value

func (op Event) Value() any

Value returns the value of the enum.

type Generic

type Generic struct {
	Depth                int
	Event                *Event
	Kind                 *Kind
	MsgId                string
	AdditionalProperties map[string]interface{}
}

Generic represents a Generic model.

type GetObject

type GetObject struct {
	ResourceVersion      int
	BaseObject           string
	Depth                int
	Event                *Event
	Kind                 *Kind
	MsgId                string
	Name                 string
	Namespace            string
	AdditionalProperties map[string]interface{}
}

GetObject represents a GetObject model.

type Kind

type Kind struct {
	Group                string
	Version              string
	Resource             string
	AdditionalProperties map[string]interface{}
}

Kind represents a Kind model.

func KindFromString

func KindFromString(ctx context.Context, kind string) *Kind

func (Kind) String

func (k Kind) String() string

Kind returns group/version/resource as a string.

type KindName

type KindName struct {
	Kind            *Kind
	Name            string
	Namespace       string
	ResourceVersion int
}

func FromUnstructured

func FromUnstructured(u *unstructured.Unstructured) KindName

func (KindName) String

func (c KindName) String() string

func (KindName) ToCustomProperties

func (c KindName) ToCustomProperties() map[string]string

type NewChecksum

type NewChecksum struct {
	ResourceVersion      int
	Checksum             string
	Depth                int
	Event                *Event
	Kind                 *Kind
	MsgId                string
	Name                 string
	Namespace            string
	AdditionalProperties map[string]interface{}
}

NewChecksum represents a NewChecksum model.

type ObjectDeleted

type ObjectDeleted struct {
	ResourceVersion      int
	Depth                int
	Event                *Event
	Kind                 *Kind
	MsgId                string
	Name                 string
	Namespace            string
	AdditionalProperties map[string]interface{}
}

ObjectDeleted represents a ObjectDeleted model.

type PatchObject

type PatchObject struct {
	Checksum             string
	ResourceVersion      int
	Depth                int
	Event                *Event
	Kind                 *Kind
	MsgId                string
	Name                 string
	Namespace            string
	Patch                string
	AdditionalProperties map[string]interface{}
}

PatchObject represents a PatchObject model.

type PutObject

type PutObject struct {
	ResourceVersion      int
	Depth                int
	Event                *Event
	Kind                 *Kind
	MsgId                string
	Name                 string
	Namespace            string
	Object               string
	AdditionalProperties map[string]interface{}
}

PutObject represents a PutObject model.

type Strategy

type Strategy string

const (
	CopyStrategy  Strategy = "copy"
	PatchStrategy Strategy = "patch"
)