Documentation
¶
Index ¶
- Constants
- func NewProducerMessage(producerMessageKey, account, cluster, eventType string, payload []byte, ...) *pulsar.ProducerMessage
- type Adapter
- func (b *Adapter) Batch(ctx context.Context, kind domain.Kind, batchType domain.BatchType, ...) error
- func (b *Adapter) Callbacks(ctx context.Context) (domain.Callbacks, error)
- func (b *Adapter) DeleteObject(ctx context.Context, id domain.KindName) error
- func (b *Adapter) GetObject(ctx context.Context, id domain.KindName, baseObject []byte) error
- func (b *Adapter) IsRelated(ctx context.Context, id domain.ClientIdentifier) bool
- func (b *Adapter) PatchObject(ctx context.Context, id domain.KindName, checksum string, patch []byte) error
- func (b *Adapter) PutObject(ctx context.Context, id domain.KindName, object []byte) error
- func (b *Adapter) RegisterCallbacks(ctx context.Context, callbacks domain.Callbacks)
- func (b *Adapter) Start(ctx context.Context) error
- func (b *Adapter) Stop(ctx context.Context) error
- func (b *Adapter) VerifyObject(ctx context.Context, id domain.KindName, checksum string) error
- type Client
- func (c *Client) Batch(ctx context.Context, kind domain.Kind, batchType domain.BatchType, ...) error
- func (c *Client) Callbacks(_ context.Context) (domain.Callbacks, error)
- func (c *Client) DeleteObject(ctx context.Context, id domain.KindName) error
- func (c *Client) GetObject(ctx context.Context, id domain.KindName, baseObject []byte) error
- func (c *Client) IsRelated(ctx context.Context, id domain.ClientIdentifier) bool
- func (c *Client) PatchObject(ctx context.Context, id domain.KindName, checksum string, patch []byte) error
- func (c *Client) PutObject(ctx context.Context, id domain.KindName, object []byte) error
- func (c *Client) RegisterCallbacks(_ context.Context, callbacks domain.Callbacks)
- func (c *Client) SendReconciliationRequestMessage(ctx context.Context) error
- func (c *Client) Start(ctx context.Context) error
- func (c *Client) Stop(_ context.Context) error
- func (c *Client) VerifyObject(ctx context.Context, id domain.KindName, checksum string) error
- type PulsarMessageProducer
- type PulsarMessageReader
Constants ¶
View Source
const (
// this will be used to filter out messages by the synchronizer server consumer (so it doesn't process its own messages)
SynchronizerServerProducerKey = "SynchronizerServerProducer"
)
Variables ¶
This section is empty.
Functions ¶
func NewProducerMessage ¶ added in v0.0.5
Types ¶
type Adapter ¶
type Adapter struct {
// contains filtered or unexported fields
}
func NewBackendAdapter ¶
func (*Adapter) DeleteObject ¶
func (*Adapter) PatchObject ¶
func (*Adapter) RegisterCallbacks ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func NewClient ¶
func NewClient(producer messaging.MessageProducer) *Client
func (*Client) DeleteObject ¶
func (*Client) PatchObject ¶
func (*Client) RegisterCallbacks ¶
func (*Client) SendReconciliationRequestMessage ¶ added in v0.0.47
type PulsarMessageProducer ¶ added in v0.0.5
type PulsarMessageProducer struct {
// contains filtered or unexported fields
}
func NewPulsarMessageProducer ¶ added in v0.0.5
func NewPulsarMessageProducer(cfg config.Config, pulsarClient pulsarconnector.Client) (*PulsarMessageProducer, error)
func (*PulsarMessageProducer) ProduceMessage ¶ added in v0.0.5
func (p *PulsarMessageProducer) ProduceMessage(ctx context.Context, id domain.ClientIdentifier, eventType string, payload []byte, optionalProperties ...map[string]string) error
func (*PulsarMessageProducer) ProduceMessageWithoutIdentifier ¶ added in v0.0.64
type PulsarMessageReader ¶ added in v0.0.40
type PulsarMessageReader struct {
// contains filtered or unexported fields
}
func NewPulsarMessageReader ¶ added in v0.0.40
func NewPulsarMessageReader(cfg config.Config, pulsarClient pulsarconnector.Client) (*PulsarMessageReader, error)
Source Files
Click to show internal directories.
Click to hide internal directories.