httpendpoint

Documentation

Index

• type Adapter
  • func NewHTTPEndpointAdapter(cfg config.Config) *Adapter
  • func (a *Adapter) Batch(ctx context.Context, kind domain.Kind, batchType domain.BatchType, ...) error
  • func (a *Adapter) Callbacks(_ context.Context) (domain.Callbacks, error)
  • func (a *Adapter) DeleteObject(ctx context.Context, id domain.KindName) error
  • func (a *Adapter) GetConfig() config.Config
  • func (a *Adapter) GetObject(ctx context.Context, id domain.KindName, baseObject []byte) error
  • func (a *Adapter) IsRelated(ctx context.Context, id domain.ClientIdentifier) bool
  • func (a *Adapter) PatchObject(ctx context.Context, id domain.KindName, checksum string, patch []byte) error
  • func (a *Adapter) PutObject(ctx context.Context, id domain.KindName, object []byte) error
  • func (a *Adapter) RegisterCallbacks(mainCtx context.Context, callbacks domain.Callbacks)
  • func (a *Adapter) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (a *Adapter) Start(ctx context.Context) error
  • func (a *Adapter) Stop(ctx context.Context) error
  • func (a *Adapter) VerifyObject(ctx context.Context, id domain.KindName, checksum string) error

Types

type Adapter

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

func NewHTTPEndpointAdapter

func NewHTTPEndpointAdapter(cfg config.Config) *Adapter

func (*Adapter) Batch

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

func (*Adapter) Callbacks

func (a *Adapter) Callbacks(_ context.Context) (domain.Callbacks, error)

func (*Adapter) DeleteObject

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

No-OP functions for functions needed only for backend re-sync

func (*Adapter) GetConfig

func (a *Adapter) GetConfig() config.Config

func (*Adapter) GetObject

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

func (*Adapter) IsRelated

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

func (*Adapter) PatchObject

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

func (*Adapter) PutObject

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

func (*Adapter) RegisterCallbacks

func (a *Adapter) RegisterCallbacks(mainCtx context.Context, callbacks domain.Callbacks)

func (*Adapter) ServeHTTP

func (a *Adapter) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*Adapter) Start

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

func (*Adapter) Stop

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

func (*Adapter) VerifyObject

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