adapters

Documentation

Index

• type Adapter
• type Client
• type MockAdapter
  • func NewMockAdapter(isClient bool) *MockAdapter
  • func (m *MockAdapter) Batch(ctx context.Context, kind domain.Kind, _ domain.BatchType, ...) error
  • func (m *MockAdapter) Callbacks(_ context.Context) (domain.Callbacks, error)
  • func (m *MockAdapter) DeleteObject(_ context.Context, id domain.KindName) error
  • func (m *MockAdapter) GetObject(ctx context.Context, id domain.KindName, baseObject []byte) error
  • func (m *MockAdapter) IsRelated(ctx context.Context, id domain.ClientIdentifier) bool
  • func (m *MockAdapter) PatchObject(ctx context.Context, id domain.KindName, checksum string, patch []byte) error
  • func (m *MockAdapter) PutObject(_ context.Context, id domain.KindName, object []byte) error
  • func (m *MockAdapter) RegisterCallbacks(_ context.Context, callbacks domain.Callbacks)
  • func (m *MockAdapter) Start(_ context.Context) error
  • func (m *MockAdapter) Stop(_ context.Context) error
  • func (m *MockAdapter) TestCallDeleteObject(ctx context.Context, id domain.KindName) error
  • func (m *MockAdapter) TestCallPutOrPatch(ctx context.Context, id domain.KindName, baseObject []byte, newObject []byte) error
  • func (m *MockAdapter) TestCallVerifyObject(ctx context.Context, id domain.KindName, object []byte) error
  • func (m *MockAdapter) VerifyObject(ctx context.Context, id domain.KindName, newChecksum string) error

Types

type Adapter

type Adapter interface {
	Start(ctx context.Context) error
	Stop(ctx context.Context) error
	IsRelated(ctx context.Context, id domain.ClientIdentifier) bool
	RegisterCallbacks(ctx context.Context, callbacks domain.Callbacks)
	Callbacks(ctx context.Context) (domain.Callbacks, error) // returns the callbacks for the given context
	DeleteObject(ctx context.Context, id domain.KindName) error
	GetObject(ctx context.Context, id domain.KindName, baseObject []byte) error
	PatchObject(ctx context.Context, id domain.KindName, checksum string, patch []byte) error
	PutObject(ctx context.Context, id domain.KindName, object []byte) error
	VerifyObject(ctx context.Context, id domain.KindName, checksum string) error
	Batch(ctx context.Context, id domain.Kind, batchType domain.BatchType, items domain.BatchItems) error
}

type Client

type Client Adapter

type MockAdapter

type MockAdapter struct {
	Resources map[string][]byte
	// contains filtered or unexported fields
}

func NewMockAdapter

func NewMockAdapter(isClient bool) *MockAdapter

func (*MockAdapter) Batch

func (m *MockAdapter) Batch(ctx context.Context, kind domain.Kind, _ domain.BatchType, items domain.BatchItems) error

func (*MockAdapter) Callbacks

func (m *MockAdapter) Callbacks(_ context.Context) (domain.Callbacks, error)

func (*MockAdapter) DeleteObject

func (m *MockAdapter) DeleteObject(_ context.Context, id domain.KindName) error

func (*MockAdapter) GetObject

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

func (*MockAdapter) IsRelated

func (m *MockAdapter) IsRelated(ctx context.Context, id domain.ClientIdentifier) bool

func (*MockAdapter) PatchObject

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

func (*MockAdapter) PutObject

func (m *MockAdapter) PutObject(_ context.Context, id domain.KindName, object []byte) error

func (*MockAdapter) RegisterCallbacks

func (m *MockAdapter) RegisterCallbacks(_ context.Context, callbacks domain.Callbacks)

func (*MockAdapter) Start

func (m *MockAdapter) Start(_ context.Context) error

func (*MockAdapter) Stop

func (m *MockAdapter) Stop(_ context.Context) error

func (*MockAdapter) TestCallDeleteObject

func (m *MockAdapter) TestCallDeleteObject(ctx context.Context, id domain.KindName) error

TestCallDeleteObject is used for testing purposes only, it is similar to incluster.client response to watch.Deleted event

func (*MockAdapter) TestCallPutOrPatch

func (m *MockAdapter) TestCallPutOrPatch(ctx context.Context, id domain.KindName, baseObject []byte, newObject []byte) error

TestCallPutOrPatch is used for testing purposes only, it is similar to incluster.client.callPutOrPatch

func (*MockAdapter) TestCallVerifyObject

func (m *MockAdapter) TestCallVerifyObject(ctx context.Context, id domain.KindName, object []byte) error

TestCallVerifyObject is used for testing purposes only, it is similar to incluster.client.callVerifyObject

func (*MockAdapter) VerifyObject

func (m *MockAdapter) VerifyObject(ctx context.Context, id domain.KindName, newChecksum string) error