 Documentation
      ¶
      Documentation
      ¶
    
    
  
    
  
    Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func NewExpiredUpdatesChecker ¶ added in v2.21.3
Types ¶
type APIsConfig ¶
type APIsConfig struct {
	GRPC grpcService.Config `yaml:"grpc" json:"grpc"`
	HTTP HTTPConfig         `yaml:"http" json:"http"`
}
    Config represent application configuration
func (*APIsConfig) Validate ¶
func (c *APIsConfig) Validate() error
type ClientsConfig ¶
type ClientsConfig struct {
	Storage                storeConfig.Config      `yaml:"storage" json:"storage"`
	OpenTelemetryCollector otelClient.Config       `yaml:"openTelemetryCollector" json:"openTelemetryCollector"`
	EventBus               EventBusConfig          `yaml:"eventBus" json:"eventBus"`
	ResourceAggregate      ResourceAggregateConfig `yaml:"resourceAggregate" json:"resourceAggregate"`
}
    func (*ClientsConfig) Validate ¶
func (c *ClientsConfig) Validate() error
type Config ¶
type Config struct {
	HubID   string        `yaml:"hubID" json:"hubId"`
	Log     log.Config    `yaml:"log" json:"log"`
	APIs    APIsConfig    `yaml:"apis" json:"apis"`
	Clients ClientsConfig `yaml:"clients" json:"clients"`
}
    type EventBusConfig ¶
type EventBusConfig struct {
	NATS           natsClient.ConfigSubscriber `yaml:"nats" json:"nats"`
	SubscriptionID string                      `yaml:"subscriptionID" json:"subscriptionID"`
}
    func (*EventBusConfig) Validate ¶
func (c *EventBusConfig) Validate() error
type HTTPConfig ¶
type HTTPConfig struct {
	Addr   string            `yaml:"address" json:"address"`
	Server httpServer.Config `yaml:",inline" json:",inline"`
}
    func (*HTTPConfig) Validate ¶
func (c *HTTPConfig) Validate() error
type ResourceAggregateConfig ¶ added in v2.21.3
type ResourceAggregateConfig struct {
	Connection grpcClient.Config `yaml:"grpc" json:"grpc"`
}
    func (*ResourceAggregateConfig) Validate ¶ added in v2.21.3
func (c *ResourceAggregateConfig) Validate() error
type ResourceSubscriber ¶
type ResourceSubscriber struct {
	// contains filtered or unexported fields
}
    func NewResourceSubscriber ¶
func NewResourceSubscriber(ctx context.Context, config natsClient.ConfigSubscriber, subscriptionID string, fileWatcher *fsnotify.Watcher, logger log.Logger, tracerProvider trace.TracerProvider, handler eventbus.Handler) (*ResourceSubscriber, error)
func (*ResourceSubscriber) Close ¶
func (r *ResourceSubscriber) Close() error
type Service ¶
func (*Service) CancelPendingResourceUpdates ¶
func (*Service) SnippetServiceStore ¶
       Source Files
      ¶
      Source Files
      ¶
    
   Click to show internal directories. 
   Click to hide internal directories.