messaging

Feb 28, 2024

Changes in this version

+ const MsgPropEventValueConnectedClientsMessage

+ type ConnectedClient struct

+ Account string

+ Cluster string

+ ConnectionId string

+ ConnectionTime time.Time

+ HelmVersion string

+ SynchronizerVersion string

+ type ConnectedClientsMessage struct

+ Clients []ConnectedClient

+ Depth int

+ MsgId string

+ ServerName string

+ Timestamp time.Time

type MessageProducer

+ ProduceMessageWithoutIdentifier func(ctx context.Context, eventType string, payload []byte) error

Feb 6, 2024

Changes in this version

+ const MsgPropEventValueReconciliationRequestMessage

type DeleteObjectMessage

+ ResourceVersion int

type GetObjectMessage

+ ResourceVersion int

type NewChecksumMessage

+ ResourceVersion int

type NewObjectMessage

+ ResourceVersion int

type PatchObjectMessage

+ ResourceVersion int

type PutObjectMessage

+ ResourceVersion int

+ type ReconciliationRequestMessage struct

+ Account string

+ Cluster string

+ Depth int

+ KindToObjects map[string][]ReconciliationRequestObject

+ MsgId string

+ ServerInitiated bool

+ type ReconciliationRequestObject struct

+ Checksum string

+ Name string

+ Namespace string

+ ResourceVersion int

type VerifyObjectMessage

+ ResourceVersion int

Jan 24, 2024

Changes in this version

+ type MessageReader interface

+ Start func(mainContext context.Context, adapter adapters.Adapter)

Nov 15, 2023

Changes in this version

+ const MsgPropAccount

+ const MsgPropCluster

+ const MsgPropEvent

+ const MsgPropEventValueDeleteObjectMessage

+ const MsgPropEventValueGetObjectMessage

+ const MsgPropEventValuePatchObjectMessage

+ const MsgPropEventValuePutObjectMessage

+ const MsgPropEventValueServerConnectedMessage

+ const MsgPropEventValueVerifyObjectMessage

+ const MsgPropTimestamp

+ type DeleteObjectMessage struct

+ Account string

+ Cluster string

+ Depth int

+ Kind string

+ MsgId string

+ Name string

+ Namespace string

+ type GetObjectMessage struct

+ Account string

+ BaseObject []byte

+ Cluster string

+ Depth int

+ Kind string

+ MsgId string

+ Name string

+ Namespace string

+ type MessageConsumer interface

+ Start func(mainContext context.Context, adapter adapters.Adapter)

+ type MessageProducer interface

+ ProduceMessage func(ctx context.Context, id domain.ClientIdentifier, eventType string, ...) error

+ type NewChecksumMessage struct

+ Account string

+ Checksum string

+ Cluster string

+ Depth int

+ Kind string

+ MsgId string

+ Name string

+ Namespace string

+ type NewObjectMessage struct

+ Account string

+ Cluster string

+ Depth int

+ Kind string

+ MsgId string

+ Name string

+ Namespace string

+ Object []byte

+ type PatchObjectMessage struct

+ Account string

+ Checksum string

+ Cluster string

+ Depth int

+ Kind string

+ MsgId string

+ Name string

+ Namespace string

+ Patch []byte

+ type PutObjectMessage struct

+ Account string

+ Cluster string

+ Depth int

+ Kind string

+ MsgId string

+ Name string

+ Namespace string

+ Object []byte

+ type ServerConnectedMessage struct

+ Account string

+ Cluster string

+ Depth int

+ MsgId string

+ type VerifyObjectMessage struct

+ Account string

+ Checksum string

+ Cluster string

+ Depth int

+ Kind string

+ MsgId string

+ Name string

+ Namespace string