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) 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) 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) VerifyObject(ctx context.Context, id domain.KindName, checksum string) error
• type Client
  • func NewClient(producer messaging.MessageProducer) *Client
  • 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) 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) Start(ctx context.Context) error
  • func (c *Client) VerifyObject(ctx context.Context, id domain.KindName, checksum string) error
• type PulsarMessageConsumer
  • func NewPulsarMessageConsumer(cfg config.Config, pulsarClient pulsarconnector.Client) (*PulsarMessageConsumer, error)
  • func (c *PulsarMessageConsumer) Start(ctx context.Context, adapter adapters.Adapter)
• 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

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) *pulsar.ProducerMessage

Types

type Adapter

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

func NewBackendAdapter

func NewBackendAdapter(mainContext context.Context, messageProducer messaging.MessageProducer, messageConsumer messaging.MessageConsumer) *Adapter

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) 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) 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) *Client

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) 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) Start

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

func (*Client) VerifyObject

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

type PulsarMessageConsumer

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

func NewPulsarMessageConsumer

func NewPulsarMessageConsumer(cfg config.Config, pulsarClient pulsarconnector.Client) (*PulsarMessageConsumer, error)

func (*PulsarMessageConsumer) Start

func (c *PulsarMessageConsumer) Start(ctx context.Context, adapter adapters.Adapter)

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) error