transport

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

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

type HTTPTransportOptions struct {
	// PollInterval controls how often the transport polls the evaluate endpoint.
	// Defaults to 20 minutes when zero.
	PollInterval time.Duration
	// HTTPClient overrides the default HTTP client. Useful for testing.
	HTTPClient *http.Client
}

type Transport interface {
	// Connect establishes the connection with optional initial evaluation context.
	// The context is sent in the x-flagmint-context header if provided.
	// Blocks until the transport is ready to send/receive, or ctx is cancelled.
	Connect(ctx context.Context, evalCtx map[string]any) error

	// FetchFlags sends the evaluation context to the server and returns the
	// evaluated flag set. evalCtx is a map representation of the evaluation
	// context. For WebSocket this sends a context message; for HTTP this makes
	// a POST request.
	FetchFlags(ctx context.Context, evalCtx map[string]any) (map[string]any, error)

	// OnFlagsUpdated registers a callback invoked when the server pushes flag
	// updates (WebSocket broadcasts or poll results with changes).
	// Must be called before Connect(). Only one callback is supported;
	// subsequent calls replace the previous callback.
	OnFlagsUpdated(fn func(flags map[string]any))

	// Close shuts down the transport and releases resources.
	// Blocks until all internal goroutines have exited.
	// Safe to call multiple times.
	Close() error
}

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