schemas

Documentation

Overview

Package schemas handles streaming schema updates and changes.

Index

• func SetupWatcher(ctx context.Context, schemas *types.APISchemas, ...)
• type Store
  • func (s *Store) Watch(apiOp *types.APIRequest, _ *types.APISchema, _ types.WatchRequest) (chan types.APIEvent, error)

Functions

func SetupWatcher

func SetupWatcher(ctx context.Context, schemas *types.APISchemas, asl accesscontrol.AccessSetLookup, factory schema.Factory)

SetupWatcher create a new schema.Store for tracking schema changes

Types

type Store

type Store struct {
	types.Store
	// contains filtered or unexported fields
}

Store hold information for watching updates to schemas

func (*Store) Watch

func (s *Store) Watch(apiOp *types.APIRequest, _ *types.APISchema, _ types.WatchRequest) (chan types.APIEvent, error)

Watch will return a APIevent channel that tracks changes to schemas for a user in a given APIRequest. Changes will be returned until Done is closed on the context in the given APIRequest.