Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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
- API
  
  Reference documentation for the pkg.go.dev API
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

cohorly

package module

Go to main page

Versions in this module

v0

v0.2.0

Aug 10, 2026

Changes in this version

+ const DefaultFlagPollInterval

type Client

+ func (c *Client) Close() error

+ func (c *Client) GetAllFlags(ctx context.Context, distinctID string) (map[string]FlagResult, error)

+ func (c *Client) GetFeatureFlag(ctx context.Context, key string, distinctID string, opts ...FlagOption) (variant string, enabled bool, err error)

+ func (c *Client) GetFeatureFlagPayload(ctx context.Context, key string, distinctID string, opts ...FlagOption) (json.RawMessage, error)

+ func (c *Client) IsFeatureEnabled(ctx context.Context, key string, distinctID string, opts ...FlagOption) (bool, error)

+ type FlagDefinition struct

+ Active bool

+ Key string

+ LocalEvaluable bool

+ Name string

+ Rules []FlagRule

+ Variants []FlagVariant

+ type FlagOption func(*flagCallOptions)

+ func WithExposureEvent() FlagOption

+ type FlagResult struct

+ Enabled bool

+ Payload json.RawMessage

+ Reason string

+ Variant string

+ type FlagRule struct

+ CohortID *int

+ DistinctIDs []string

+ RolloutPct float64

+ Variant string

+ type FlagVariant struct

+ Key string

+ Payload json.RawMessage

+ RolloutPct float64

type Option

+ func WithFlagPollInterval(d time.Duration) Option

+ func WithFlagSecret(secret string) Option

v0.1.0

Jul 5, 2026

Changes in this version

+ const DefaultAPIHost

+ const DefaultFlushBatchSize

+ const DefaultFlushInterval

+ const DefaultQueueCapacity

+ const EmptyDistinctID

+ const MaxTrackBatch

+ const Version

+ var ErrInvalidToken = errors.New("cohorly: invalid token")

+ type BufferedClient struct

+ func NewBufferedClient(client *Client, opts ...BufferedOption) *BufferedClient

+ func (b *BufferedClient) Close(ctx context.Context) error

+ func (b *BufferedClient) Enqueue(events ...*Event)

+ func (b *BufferedClient) Flush(ctx context.Context) error

+ func (b *BufferedClient) Len() int

+ type BufferedOption func(*BufferedClient)

+ func WithFlushBatchSize(n int) BufferedOption

+ func WithFlushInterval(d time.Duration) BufferedOption

+ func WithQueueCapacity(n int) BufferedOption

+ type Client struct

+ func NewClient(token string, opts ...Option) *Client

+ func (c *Client) Alias(ctx context.Context, alias string, distinctID string) error

+ func (c *Client) NewEvent(name string, distinctID string, properties map[string]any) *Event

+ func (c *Client) PeopleDelete(ctx context.Context, distinctID string) error

+ func (c *Client) PeopleIncrement(ctx context.Context, distinctID string, add map[string]float64) error

+ func (c *Client) PeopleSet(ctx context.Context, people []*PeopleProperties) error

+ func (c *Client) PeopleSetOnce(ctx context.Context, people []*PeopleProperties) error

+ func (c *Client) PeopleUnset(ctx context.Context, distinctID string, unset []string) error

+ func (c *Client) Track(ctx context.Context, events []*Event) error

+ type Event struct

+ Name string

+ Properties map[string]any

+ func (e *Event) AddInsertID(insertID string)

+ func (e *Event) AddTime(t time.Time)

+ type HTTPError struct

+ Body string

+ RetryAfter time.Duration

+ Status int

+ func (e *HTTPError) Error() string

+ func (e *HTTPError) Unwrap() error

+ type Option func(*Client)

+ func WithAPIHost(host string) Option

+ func WithHTTPClient(httpClient *http.Client) Option

+ type PeopleProperties struct

+ DistinctID string

+ Properties map[string]any

+ func NewPeopleProperties(distinctID string, properties map[string]any) *PeopleProperties