resources

Documentation

Index

• type LocalResourcesService
  • func NewLocalResourcesService() *LocalResourcesService
  • func (l *LocalResourcesService) ClearServiceResources(serviceName string)
  • func (l *LocalResourcesService) Declare(ctx context.Context, req *resourcespb.ResourceDeclareRequest) (*resourcespb.ResourceDeclareResponse, error)
  • func (l *LocalResourcesService) LogServiceError(serviceName string, err error)
  • func (s *LocalResourcesService) SubscribeToState(fn func(lrs LocalResourcesState))
• type LocalResourcesState
• type NewServiceResourceRefresherArgs
• type ResourceName
• type ResourceRegister
• type ResourceRegistrar
  • func NewResourceRegistrar[R any]() *ResourceRegistrar[R]
  • func (r *ResourceRegistrar[R]) ClearRequestingService(requestingService string)
  • func (r *ResourceRegistrar[R]) Get(resourceName string) *R
  • func (r *ResourceRegistrar[R]) GetAll() map[ResourceName]*ResourceRegister[R]
  • func (r *ResourceRegistrar[R]) GetRequestingServices(name string) []string
  • func (r *ResourceRegistrar[R]) Register(name string, requestingService string, resource *R) error
• type ServiceResourceRefresher
  • func NewServiceResourceRefresher(serviceName string, args NewServiceResourceRefresherArgs) (*ServiceResourceRefresher, error)
• type UpdateArgs

Types

type LocalResourcesService

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

func NewLocalResourcesService

func NewLocalResourcesService() *LocalResourcesService

func (*LocalResourcesService) ClearServiceResources

func (l *LocalResourcesService) ClearServiceResources(serviceName string)

ClearServiceResources - Clear all resources registered by a service, typically done when the service terminates or is restarted

func (*LocalResourcesService) Declare

func (l *LocalResourcesService) Declare(ctx context.Context, req *resourcespb.ResourceDeclareRequest) (*resourcespb.ResourceDeclareResponse, error)

func (*LocalResourcesService) LogServiceError

func (l *LocalResourcesService) LogServiceError(serviceName string, err error)

func (*LocalResourcesService) SubscribeToState

func (s *LocalResourcesService) SubscribeToState(fn func(lrs LocalResourcesState))

type LocalResourcesState

type LocalResourcesState struct {
	Buckets                *ResourceRegistrar[resourcespb.BucketResource]
	BatchJobs              *ResourceRegistrar[resourcespb.JobResource]
	KeyValueStores         *ResourceRegistrar[resourcespb.KeyValueStoreResource]
	Policies               *ResourceRegistrar[resourcespb.PolicyResource]
	Secrets                *ResourceRegistrar[resourcespb.SecretResource]
	Topics                 *ResourceRegistrar[resourcespb.TopicResource]
	Queues                 *ResourceRegistrar[resourcespb.QueueResource]
	SqlDatabases           *ResourceRegistrar[resourcespb.SqlDatabaseResource]
	ApiSecurityDefinitions *ResourceRegistrar[resourcespb.ApiSecurityDefinitionResource]

	ServiceErrors map[string][]error
}

type NewServiceResourceRefresherArgs

type NewServiceResourceRefresherArgs struct {
	Resources *LocalResourcesService

	Apis       *apis.LocalApiGatewayService
	Schedules  *schedules.LocalSchedulesService
	Http       *http.LocalHttpProxy
	Listeners  *storage.LocalStorageService
	Websockets *websockets.LocalWebsocketService
	Topics     *topics.LocalTopicsAndSubscribersService
	Storage    *storage.LocalStorageService
	BatchJobs  *batch.LocalBatchService
}

type ResourceName

type ResourceName = string

type ResourceRegister

type ResourceRegister[R any] struct {
	RequestingServices []string
	Resource           *R
}

type ResourceRegistrar

type ResourceRegistrar[R any] struct {
	// contains filtered or unexported fields
}

func NewResourceRegistrar

func NewResourceRegistrar[R any]() *ResourceRegistrar[R]

func (*ResourceRegistrar[R]) ClearRequestingService

func (r *ResourceRegistrar[R]) ClearRequestingService(requestingService string)

ClearRequestingService - Remove a requesting service from all resources, if it was the only requestor for a resource, the resource is also removed

func (*ResourceRegistrar[R]) Get

func (r *ResourceRegistrar[R]) Get(resourceName string) *R

func (*ResourceRegistrar[R]) GetAll

func (r *ResourceRegistrar[R]) GetAll() map[ResourceName]*ResourceRegister[R]

func (*ResourceRegistrar[R]) GetRequestingServices

func (r *ResourceRegistrar[R]) GetRequestingServices(name string) []string

func (*ResourceRegistrar[R]) Register

func (r *ResourceRegistrar[R]) Register(name string, requestingService string, resource *R) error

type ServiceResourceRefresher

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

func NewServiceResourceRefresher

func NewServiceResourceRefresher(serviceName string, args NewServiceResourceRefresherArgs) (*ServiceResourceRefresher, error)

type UpdateArgs

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