Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

generic

package

Go to main page

Versions in this module

v0

v0.15.0

Oct 14, 2024

Changes in this version

+ func RegisterResourceResyncMetrics()

+ func ResetResourceResyncMetricsCollectors()

+ func UnregisterResourceResyncMetrics()

v0.14.0

Jun 18, 2024

Changes in this version

+ var DelayFn = ...(&clock.RealClock{}, 10 * time.Minute)

+ func BuildCloudEventsAgentOptions(config any, clusterName, clientId string) (*options.CloudEventsAgentOptions, error)

+ func BuildCloudEventsSourceOptions(config any, clientId, sourceId string) (*options.CloudEventsSourceOptions, error)

type CloudEventAgentClient

+ func (c *CloudEventAgentClient[T]) ReconnectedChan() <-chan struct{}

type CloudEventSourceClient

+ func (c *CloudEventSourceClient[T]) ReconnectedChan() <-chan struct{}

type CloudEventsClient

+ ReconnectedChan func() <-chan struct{}

+ type ConfigLoader struct

+ func NewConfigLoader(configType, configPath string) *ConfigLoader

+ func (l *ConfigLoader) LoadConfig() (string, any, error)

v0.13.0

Feb 21, 2024

Changes in this version

+ const DefaultBurst

+ const DefaultQPS

+ func NewRateLimiter(limit options.EventRateLimit) flowcontrol.RateLimiter

+ type CloudEventAgentClient struct

+ func NewCloudEventAgentClient[T ResourceObject](ctx context.Context, agentOptions *options.CloudEventsAgentOptions, ...) (*CloudEventAgentClient[T], error)

+ func (c *CloudEventAgentClient[T]) Publish(ctx context.Context, eventType types.CloudEventsType, obj T) error

+ func (c *CloudEventAgentClient[T]) Resync(ctx context.Context, source string) error

+ func (c *CloudEventAgentClient[T]) Subscribe(ctx context.Context, handlers ...ResourceHandler[T])

+ type CloudEventSourceClient struct

+ func NewCloudEventSourceClient[T ResourceObject](ctx context.Context, sourceOptions *options.CloudEventsSourceOptions, ...) (*CloudEventSourceClient[T], error)

+ func (c *CloudEventSourceClient[T]) Publish(ctx context.Context, eventType types.CloudEventsType, obj T) error

+ func (c *CloudEventSourceClient[T]) Resync(ctx context.Context, clusterName string) error

+ func (c *CloudEventSourceClient[T]) Subscribe(ctx context.Context, handlers ...ResourceHandler[T])

+ type CloudEventsClient interface

+ Publish func(ctx context.Context, eventType types.CloudEventsType, obj T) error

+ Resync func(context.Context, string) error

+ Subscribe func(ctx context.Context, handlers ...ResourceHandler[T])

+ type Codec interface

+ Decode func(event *cloudevents.Event) (T, error)

+ Encode func(source string, eventType types.CloudEventsType, obj T) (*cloudevents.Event, error)

+ EventDataType func() types.CloudEventsDataType

+ type Lister interface

+ List func(options types.ListOptions) ([]T, error)

+ type ResourceHandler func(action types.ResourceAction, obj T) error

+ type ResourceObject interface

+ GetDeletionTimestamp func() *metav1.Time

+ GetResourceVersion func() string

+ GetUID func() kubetypes.UID

+ type StatusHashGetter func(obj T) (string, error)