core

Documentation

Index

• Constants
• type Synchronizer
  • func NewSynchronizerClient(mainCtx context.Context, adapter adapters.Adapter, conn net.Conn, ...) *Synchronizer
  • func NewSynchronizerServer(mainCtx context.Context, adapter adapters.Adapter, conn net.Conn) *Synchronizer
  • func (s *Synchronizer) DeleteObjectCallback(ctx context.Context, id domain.KindName) error
  • func (s *Synchronizer) GetObjectCallback(ctx context.Context, id domain.KindName, baseObject []byte) error
  • func (s *Synchronizer) PatchObjectCallback(ctx context.Context, id domain.KindName, checksum string, patch []byte) error
  • func (s *Synchronizer) PutObjectCallback(ctx context.Context, id domain.KindName, object []byte) error
  • func (s *Synchronizer) Start(ctx context.Context) error
  • func (s *Synchronizer) VerifyObjectCallback(ctx context.Context, id domain.KindName, checksum string) error

Constants

const (
	AccessKeyHeader   = "X-API-KEY"
	AccountHeader     = "X-API-ACCOUNT"
	ClusterNameHeader = "X-API-CLUSTER"
)

These headers are required for client-server authentication

Types

type Synchronizer

type Synchronizer struct {
	Conn *net.Conn
	// contains filtered or unexported fields
}

func NewSynchronizerClient

func NewSynchronizerClient(mainCtx context.Context, adapter adapters.Adapter, conn net.Conn, newConn func() (net.Conn, error)) *Synchronizer

func NewSynchronizerServer

func NewSynchronizerServer(mainCtx context.Context, adapter adapters.Adapter, conn net.Conn) *Synchronizer

func (*Synchronizer) DeleteObjectCallback

func (s *Synchronizer) DeleteObjectCallback(ctx context.Context, id domain.KindName) error

func (*Synchronizer) GetObjectCallback

func (s *Synchronizer) GetObjectCallback(ctx context.Context, id domain.KindName, baseObject []byte) error

func (*Synchronizer) PatchObjectCallback

func (s *Synchronizer) PatchObjectCallback(ctx context.Context, id domain.KindName, checksum string, patch []byte) error

func (*Synchronizer) PutObjectCallback

func (s *Synchronizer) PutObjectCallback(ctx context.Context, id domain.KindName, object []byte) error

func (*Synchronizer) Start

func (s *Synchronizer) Start(ctx context.Context) error

func (*Synchronizer) VerifyObjectCallback

func (s *Synchronizer) VerifyObjectCallback(ctx context.Context, id domain.KindName, checksum string) error