core

Documentation

Index

• Constants
• type Synchronizer
  • func NewSynchronizerClient(mainCtx context.Context, adapter []adapters.Adapter, conn net.Conn, ...) (*Synchronizer, error)
  • func NewSynchronizerServer(mainCtx context.Context, adapter []adapters.Adapter, conn net.Conn) (*Synchronizer, error)
  • func (s *Synchronizer) BatchCallback(ctx context.Context, kind domain.Kind, batchType domain.BatchType, ...) error
  • 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) Stop(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"
	HelmVersionHeader   = "X-HELM-VERSION"
	VersionHeader       = "X-SYNCHRONIZER-VERSION"
	GitVersionHeader    = "X-GIT-VERSION"
	CloudProviderHeader = "X-CLOUD-PROVIDER"
)

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

func NewSynchronizerServer

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

func (*Synchronizer) BatchCallback

func (s *Synchronizer) BatchCallback(ctx context.Context, kind domain.Kind, batchType domain.BatchType, items domain.BatchItems) error

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

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

func (*Synchronizer) VerifyObjectCallback

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