backend

Documentation

Index

• Constants
• func NewProducerMessage(producerMessageKey, account, cluster, eventType string, payload []byte, ...) *pulsar.ProducerMessage
• type Adapter
  • func NewBackendAdapter(mainContext context.Context, messageProducer messaging.MessageProducer, ...) *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 NewClient(producer messaging.MessageProducer, skipKdrFrom []string) *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
  • func NewPulsarMessageProducer(cfg config.Config, pulsarClient pulsarconnector.Client) (*PulsarMessageProducer, error)
  • func (p *PulsarMessageProducer) ProduceMessage(ctx context.Context, id domain.ClientIdentifier, eventType string, ...) error
  • func (p *PulsarMessageProducer) ProduceMessageWithoutIdentifier(ctx context.Context, eventType string, payload []byte) error
• type PulsarMessageReader
  • func NewPulsarMessageReader(cfg config.Config, pulsarClient pulsarconnector.Client) (*PulsarMessageReader, error)
  • func (c *PulsarMessageReader) Start(mainCtx context.Context, adapter adapters.Adapter)

Constants

const (
	// this will be used to filter out messages by the synchronizer server consumer (so it doesn't process its own messages)
	SynchronizerServerProducerKey = "SynchronizerServerProducer"
)

Functions

func NewProducerMessage

func NewProducerMessage(producerMessageKey, account, cluster, eventType string, payload []byte, optionalProperties ...map[string]string) *pulsar.ProducerMessage

Types

type Adapter

type Adapter struct {
	// contains filtered or unexported fields
}

func NewBackendAdapter

func NewBackendAdapter(mainContext context.Context, messageProducer messaging.MessageProducer, cfg config.Backend) *Adapter

func (*Adapter) Batch

func (b *Adapter) Batch(ctx context.Context, kind domain.Kind, batchType domain.BatchType, items domain.BatchItems) error

func (*Adapter) Callbacks

func (b *Adapter) Callbacks(ctx context.Context) (domain.Callbacks, error)

func (*Adapter) DeleteObject

func (b *Adapter) DeleteObject(ctx context.Context, id domain.KindName) error

func (*Adapter) GetObject

func (b *Adapter) GetObject(ctx context.Context, id domain.KindName, baseObject []byte) error

func (*Adapter) IsRelated

func (b *Adapter) IsRelated(ctx context.Context, id domain.ClientIdentifier) bool

func (*Adapter) PatchObject

func (b *Adapter) PatchObject(ctx context.Context, id domain.KindName, checksum string, patch []byte) error

func (*Adapter) PutObject

func (b *Adapter) PutObject(ctx context.Context, id domain.KindName, object []byte) error

func (*Adapter) RegisterCallbacks

func (b *Adapter) RegisterCallbacks(ctx context.Context, callbacks domain.Callbacks)

func (*Adapter) Start

func (b *Adapter) Start(ctx context.Context) error

func (*Adapter) Stop

func (b *Adapter) Stop(ctx context.Context) error

func (*Adapter) VerifyObject

func (b *Adapter) VerifyObject(ctx context.Context, id domain.KindName, checksum string) error

type Client

type Client struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(producer messaging.MessageProducer, skipKdrFrom []string) *Client

func (*Client) Batch

func (c *Client) Batch(ctx context.Context, kind domain.Kind, batchType domain.BatchType, items domain.BatchItems) error

func (*Client) Callbacks

func (c *Client) Callbacks(_ context.Context) (domain.Callbacks, error)

func (*Client) DeleteObject

func (c *Client) DeleteObject(ctx context.Context, id domain.KindName) error

func (*Client) GetObject

func (c *Client) GetObject(ctx context.Context, id domain.KindName, baseObject []byte) error

func (*Client) IsRelated

func (c *Client) IsRelated(ctx context.Context, id domain.ClientIdentifier) bool

func (*Client) PatchObject

func (c *Client) PatchObject(ctx context.Context, id domain.KindName, checksum string, patch []byte) error

func (*Client) PutObject

func (c *Client) PutObject(ctx context.Context, id domain.KindName, object []byte) error

func (*Client) RegisterCallbacks

func (c *Client) RegisterCallbacks(_ context.Context, callbacks domain.Callbacks)

func (*Client) SendReconciliationRequestMessage

func (c *Client) SendReconciliationRequestMessage(ctx context.Context) error

func (*Client) Start

func (c *Client) Start(ctx context.Context) error

func (*Client) Stop

func (c *Client) Stop(_ context.Context) error

func (*Client) VerifyObject

func (c *Client) VerifyObject(ctx context.Context, id domain.KindName, checksum string) error

type PulsarMessageProducer

type PulsarMessageProducer struct {
	// contains filtered or unexported fields
}

func NewPulsarMessageProducer

func NewPulsarMessageProducer(cfg config.Config, pulsarClient pulsarconnector.Client) (*PulsarMessageProducer, error)

func (*PulsarMessageProducer) ProduceMessage

func (p *PulsarMessageProducer) ProduceMessage(ctx context.Context, id domain.ClientIdentifier, eventType string, payload []byte, optionalProperties ...map[string]string) error

func (*PulsarMessageProducer) ProduceMessageWithoutIdentifier

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

type PulsarMessageReader

type PulsarMessageReader struct {
	// contains filtered or unexported fields
}

func NewPulsarMessageReader

func NewPulsarMessageReader(cfg config.Config, pulsarClient pulsarconnector.Client) (*PulsarMessageReader, error)

func (*PulsarMessageReader) Start

func (c *PulsarMessageReader) Start(mainCtx context.Context, adapter adapters.Adapter)