fakedatastore

Documentation

Index

• type DataStore
  • func New(tb testing.TB) *DataStore
  • func (s *DataStore) AppendBundle(ctx context.Context, bundle *common.Bundle) (*common.Bundle, error)
  • func (s *DataStore) AppendNextError(err error)
  • func (s *DataStore) CountAttestedNodes(ctx context.Context) (int32, error)
  • func (s *DataStore) CountBundles(ctx context.Context) (int32, error)
  • func (s *DataStore) CountRegistrationEntries(ctx context.Context) (int32, error)
  • func (s *DataStore) CreateAttestedNode(ctx context.Context, node *common.AttestedNode) (*common.AttestedNode, error)
  • func (s *DataStore) CreateBundle(ctx context.Context, bundle *common.Bundle) (*common.Bundle, error)
  • func (s *DataStore) CreateJoinToken(ctx context.Context, token *datastore.JoinToken) error
  • func (s *DataStore) CreateRegistrationEntry(ctx context.Context, entry *common.RegistrationEntry) (*common.RegistrationEntry, error)
  • func (s *DataStore) DeleteAttestedNode(ctx context.Context, spiffeID string) (*common.AttestedNode, error)
  • func (s *DataStore) DeleteBundle(ctx context.Context, trustDomain string, mode datastore.DeleteMode) error
  • func (s *DataStore) DeleteJoinToken(ctx context.Context, token string) error
  • func (s *DataStore) DeleteRegistrationEntry(ctx context.Context, entryID string) (*common.RegistrationEntry, error)
  • func (s *DataStore) FetchAttestedNode(ctx context.Context, spiffeID string) (*common.AttestedNode, error)
  • func (s *DataStore) FetchBundle(ctx context.Context, trustDomain string) (*common.Bundle, error)
  • func (s *DataStore) FetchJoinToken(ctx context.Context, token string) (*datastore.JoinToken, error)
  • func (s *DataStore) FetchRegistrationEntry(ctx context.Context, entryID string) (*common.RegistrationEntry, error)
  • func (s *DataStore) GetNodeSelectors(ctx context.Context, spiffeID string, ...) ([]*common.Selector, error)
  • func (s *DataStore) ListAttestedNodes(ctx context.Context, req *datastore.ListAttestedNodesRequest) (*datastore.ListAttestedNodesResponse, error)
  • func (s *DataStore) ListBundles(ctx context.Context, req *datastore.ListBundlesRequest) (*datastore.ListBundlesResponse, error)
  • func (s *DataStore) ListNodeSelectors(ctx context.Context, req *datastore.ListNodeSelectorsRequest) (*datastore.ListNodeSelectorsResponse, error)
  • func (s *DataStore) ListRegistrationEntries(ctx context.Context, req *datastore.ListRegistrationEntriesRequest) (*datastore.ListRegistrationEntriesResponse, error)
  • func (s *DataStore) PruneBundle(ctx context.Context, trustDomainID string, expiresBefore time.Time) (bool, error)
  • func (s *DataStore) PruneJoinTokens(ctx context.Context, expiresBefore time.Time) error
  • func (s *DataStore) PruneRegistrationEntries(ctx context.Context, expiresBefore time.Time) error
  • func (s *DataStore) SetBundle(ctx context.Context, bundle *common.Bundle) (*common.Bundle, error)
  • func (s *DataStore) SetNextError(err error)
  • func (s *DataStore) SetNodeSelectors(ctx context.Context, spiffeID string, selectors []*common.Selector) error
  • func (s *DataStore) UpdateAttestedNode(ctx context.Context, node *common.AttestedNode, mask *common.AttestedNodeMask) (*common.AttestedNode, error)
  • func (s *DataStore) UpdateBundle(ctx context.Context, bundle *common.Bundle, mask *common.BundleMask) (*common.Bundle, error)
  • func (s *DataStore) UpdateRegistrationEntry(ctx context.Context, entry *common.RegistrationEntry, ...) (*common.RegistrationEntry, error)

Types

type DataStore

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

func New

func New(tb testing.TB) *DataStore

func (*DataStore) AppendBundle

func (s *DataStore) AppendBundle(ctx context.Context, bundle *common.Bundle) (*common.Bundle, error)

func (*DataStore) AppendNextError

func (s *DataStore) AppendNextError(err error)

func (*DataStore) CountAttestedNodes

func (s *DataStore) CountAttestedNodes(ctx context.Context) (int32, error)

func (*DataStore) CountBundles

func (s *DataStore) CountBundles(ctx context.Context) (int32, error)

func (*DataStore) CountRegistrationEntries

func (s *DataStore) CountRegistrationEntries(ctx context.Context) (int32, error)

func (*DataStore) CreateAttestedNode

func (s *DataStore) CreateAttestedNode(ctx context.Context, node *common.AttestedNode) (*common.AttestedNode, error)

func (*DataStore) CreateBundle

func (s *DataStore) CreateBundle(ctx context.Context, bundle *common.Bundle) (*common.Bundle, error)

func (*DataStore) CreateJoinToken

func (s *DataStore) CreateJoinToken(ctx context.Context, token *datastore.JoinToken) error

func (*DataStore) CreateRegistrationEntry

func (s *DataStore) CreateRegistrationEntry(ctx context.Context, entry *common.RegistrationEntry) (*common.RegistrationEntry, error)

func (*DataStore) DeleteAttestedNode

func (s *DataStore) DeleteAttestedNode(ctx context.Context, spiffeID string) (*common.AttestedNode, error)

func (*DataStore) DeleteBundle

func (s *DataStore) DeleteBundle(ctx context.Context, trustDomain string, mode datastore.DeleteMode) error

func (*DataStore) DeleteJoinToken

func (s *DataStore) DeleteJoinToken(ctx context.Context, token string) error

func (*DataStore) DeleteRegistrationEntry

func (s *DataStore) DeleteRegistrationEntry(ctx context.Context, entryID string) (*common.RegistrationEntry, error)

func (*DataStore) FetchAttestedNode

func (s *DataStore) FetchAttestedNode(ctx context.Context, spiffeID string) (*common.AttestedNode, error)

func (*DataStore) FetchBundle

func (s *DataStore) FetchBundle(ctx context.Context, trustDomain string) (*common.Bundle, error)

func (*DataStore) FetchJoinToken

func (s *DataStore) FetchJoinToken(ctx context.Context, token string) (*datastore.JoinToken, error)

func (*DataStore) FetchRegistrationEntry

func (s *DataStore) FetchRegistrationEntry(ctx context.Context, entryID string) (*common.RegistrationEntry, error)

func (*DataStore) GetNodeSelectors

func (s *DataStore) GetNodeSelectors(ctx context.Context, spiffeID string, dataConsistency datastore.DataConsistency) ([]*common.Selector, error)

func (*DataStore) ListAttestedNodes

func (s *DataStore) ListAttestedNodes(ctx context.Context, req *datastore.ListAttestedNodesRequest) (*datastore.ListAttestedNodesResponse, error)

func (*DataStore) ListBundles

func (s *DataStore) ListBundles(ctx context.Context, req *datastore.ListBundlesRequest) (*datastore.ListBundlesResponse, error)

func (*DataStore) ListNodeSelectors

func (s *DataStore) ListNodeSelectors(ctx context.Context, req *datastore.ListNodeSelectorsRequest) (*datastore.ListNodeSelectorsResponse, error)

func (*DataStore) ListRegistrationEntries

func (s *DataStore) ListRegistrationEntries(ctx context.Context, req *datastore.ListRegistrationEntriesRequest) (*datastore.ListRegistrationEntriesResponse, error)

func (*DataStore) PruneBundle

func (s *DataStore) PruneBundle(ctx context.Context, trustDomainID string, expiresBefore time.Time) (bool, error)

func (*DataStore) PruneJoinTokens

func (s *DataStore) PruneJoinTokens(ctx context.Context, expiresBefore time.Time) error

func (*DataStore) PruneRegistrationEntries

func (s *DataStore) PruneRegistrationEntries(ctx context.Context, expiresBefore time.Time) error

func (*DataStore) SetBundle

func (s *DataStore) SetBundle(ctx context.Context, bundle *common.Bundle) (*common.Bundle, error)

func (*DataStore) SetNextError

func (s *DataStore) SetNextError(err error)

func (*DataStore) SetNodeSelectors

func (s *DataStore) SetNodeSelectors(ctx context.Context, spiffeID string, selectors []*common.Selector) error

func (*DataStore) UpdateAttestedNode

func (s *DataStore) UpdateAttestedNode(ctx context.Context, node *common.AttestedNode, mask *common.AttestedNodeMask) (*common.AttestedNode, error)

func (*DataStore) UpdateBundle

func (s *DataStore) UpdateBundle(ctx context.Context, bundle *common.Bundle, mask *common.BundleMask) (*common.Bundle, error)

func (*DataStore) UpdateRegistrationEntry

func (s *DataStore) UpdateRegistrationEntry(ctx context.Context, entry *common.RegistrationEntry, mask *common.RegistrationEntryMask) (*common.RegistrationEntry, error)