entry

Documentation

Index

• func RegisterService(s *grpc.Server, service *Service)
• func SyncAuthorizedEntries(stream entryv1.Entry_SyncAuthorizedEntriesServer, entries []*types.Entry, ...) (err error)
• type Config
• type Service
  • func New(config Config) *Service
  • func (s *Service) BatchCreateEntry(ctx context.Context, req *entryv1.BatchCreateEntryRequest) (*entryv1.BatchCreateEntryResponse, error)
  • func (s *Service) BatchDeleteEntry(ctx context.Context, req *entryv1.BatchDeleteEntryRequest) (*entryv1.BatchDeleteEntryResponse, error)
  • func (s *Service) BatchUpdateEntry(ctx context.Context, req *entryv1.BatchUpdateEntryRequest) (*entryv1.BatchUpdateEntryResponse, error)
  • func (s *Service) CountEntries(ctx context.Context, _ *entryv1.CountEntriesRequest) (*entryv1.CountEntriesResponse, error)
  • func (s *Service) GetAuthorizedEntries(ctx context.Context, req *entryv1.GetAuthorizedEntriesRequest) (*entryv1.GetAuthorizedEntriesResponse, error)
  • func (s *Service) GetEntry(ctx context.Context, req *entryv1.GetEntryRequest) (*types.Entry, error)
  • func (s *Service) ListEntries(ctx context.Context, req *entryv1.ListEntriesRequest) (*entryv1.ListEntriesResponse, error)
  • func (s *Service) SyncAuthorizedEntries(stream entryv1.Entry_SyncAuthorizedEntriesServer) (err error)

Functions

func RegisterService

func RegisterService(s *grpc.Server, service *Service)

RegisterService registers the entry service on the gRPC server.

func SyncAuthorizedEntries

func SyncAuthorizedEntries(stream entryv1.Entry_SyncAuthorizedEntriesServer, entries []*types.Entry, entryPageSize int) (err error)

Types

type Config

type Config struct {
	TrustDomain   spiffeid.TrustDomain
	EntryFetcher  api.AuthorizedEntryFetcher
	DataStore     datastore.DataStore
	EntryPageSize int
}

Config defines the service configuration.

type Service

type Service struct {
	entryv1.UnsafeEntryServer
	// contains filtered or unexported fields
}

Service defines the v1 entry service.

func New

func New(config Config) *Service

New creates a new v1 entry service.

func (*Service) BatchCreateEntry

func (s *Service) BatchCreateEntry(ctx context.Context, req *entryv1.BatchCreateEntryRequest) (*entryv1.BatchCreateEntryResponse, error)

BatchCreateEntry adds one or more entries to the server.

func (*Service) BatchDeleteEntry

func (s *Service) BatchDeleteEntry(ctx context.Context, req *entryv1.BatchDeleteEntryRequest) (*entryv1.BatchDeleteEntryResponse, error)

BatchDeleteEntry removes one or more entries from the server.

func (*Service) BatchUpdateEntry

func (s *Service) BatchUpdateEntry(ctx context.Context, req *entryv1.BatchUpdateEntryRequest) (*entryv1.BatchUpdateEntryResponse, error)

BatchUpdateEntry updates one or more entries in the server.

func (*Service) CountEntries

func (s *Service) CountEntries(ctx context.Context, _ *entryv1.CountEntriesRequest) (*entryv1.CountEntriesResponse, error)

CountEntries returns the total number of entries.

func (*Service) GetAuthorizedEntries

func (s *Service) GetAuthorizedEntries(ctx context.Context, req *entryv1.GetAuthorizedEntriesRequest) (*entryv1.GetAuthorizedEntriesResponse, error)

GetAuthorizedEntries returns the list of entries authorized for the caller ID in the context.

func (*Service) GetEntry

func (s *Service) GetEntry(ctx context.Context, req *entryv1.GetEntryRequest) (*types.Entry, error)

GetEntry returns the registration entry associated with the given SpiffeID

func (*Service) ListEntries

func (s *Service) ListEntries(ctx context.Context, req *entryv1.ListEntriesRequest) (*entryv1.ListEntriesResponse, error)

ListEntries returns the optionally filtered and/or paginated list of entries.

func (*Service) SyncAuthorizedEntries

func (s *Service) SyncAuthorizedEntries(stream entryv1.Entry_SyncAuthorizedEntriesServer) (err error)

SyncAuthorizedEntries returns the list of entries authorized for the caller ID in the context.