Documentation
¶
Index ¶
Constants ¶
View Source
const ( ContextKeyClientIdentifier contextKey = "clientIdentifier" ContextKeyDepth contextKey = "depth" ContextKeyMsgId contextKey = "msgId" )
Variables ¶
View Source
var EventValues = []any{"newChecksum", "objectAdded", "objectDeleted", "objectModified", "getObject", "patchObject", "putObject", "ping", "batch"}
View Source
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 ¶ added in v0.0.47
Types ¶
type Batch ¶ added in v0.0.47
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 ¶ added in v0.0.47
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 ¶ added in v0.0.47
func (items BatchItems) Length() int
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, checksum string, 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 ¶ added in v0.0.5
type ClientIdentifier struct {
Account string
Cluster string
ConnectionId string
ConnectionTime time.Time
HelmVersion string
SyncVersion string
GitVersion string
CloudProvider string
}
func (ClientIdentifier) ConnectionString ¶ added in v0.0.40
func (c ClientIdentifier) ConnectionString() string
func (ClientIdentifier) String ¶ added in v0.0.5
func (c ClientIdentifier) String() string
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.
type KindName ¶ added in v0.0.5
func FromUnstructured ¶ added in v0.0.67
func FromUnstructured(u *unstructured.Unstructured) KindName
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.
Click to show internal directories.
Click to hide internal directories.