runtime

Jul 27, 2026

Changes in this version

+ const AuthJWTLogin

+ const AuthNone

+ const AuthOAuth2ClientCreds

+ const AuthOAuth2Password

+ const AuthStatic

+ const DefaultPollMaxBytes

+ const DefaultPollMaxFrames

+ const DefaultStreamIdleTTL

+ const DefaultStreamMaxBytes

+ const DefaultStreamMaxFrames

+ const DefaultStreamMaxLifetime

+ const DefaultStreamMaxSessions

+ func ApplyJQ(data []byte, filter string) (string, error)

+ func DeriveWSURL(httpURL string) string

+ func InjectAuth(req *http.Request, schemes []ir.AuthScheme, cred Credential)

+ func RenderPoll(id string, res *PollResult) string

+ func WithBearer(ctx context.Context, token string) context.Context

+ type AuthConfig struct

+ AccessTokenEnv string

+ AccessTokenField string

+ ClientIDEnv string

+ ClientSecretEnv string

+ ContentType string

+ ExpiresInField string

+ ExpiryMargin string

+ Header string

+ PasswordEnv string

+ RefreshTokenEnv string

+ RefreshTokenField string

+ RefreshURL string

+ Scheme string

+ Scope string

+ TokenURL string

+ Type string

+ UsernameEnv string

+ func (c AuthConfig) IsTokenFlow() bool

+ type Credential struct

+ APIKey string

+ Password string

+ Username string

+ type GraphQLExecutor struct

+ func NewGraphQLExecutor(endpoint string, auth []ir.AuthScheme, cred Credential, opts Options) *GraphQLExecutor

+ func (e *GraphQLExecutor) Endpoint() string

+ func (e *GraphQLExecutor) Query(ctx context.Context, query string, variables map[string]any, jqFilter string) (string, error)

+ func (e *GraphQLExecutor) SetWSEndpoint(u string)

+ func (e *GraphQLExecutor) Subscribe(sm *StreamManager, query string, variables map[string]any) (string, error)

+ func (e *GraphQLExecutor) WSEndpoint() string

+ type HTTPExecutor struct

+ func NewHTTPExecutor(baseURL string, auth []ir.AuthScheme, cred Credential, opts Options) *HTTPExecutor

+ func (e *HTTPExecutor) Call(ctx context.Context, op *ir.Operation, args map[string]any, jqFilter string) (string, error)

+ func (e *HTTPExecutor) StartServerStream(sm *StreamManager, op *ir.Operation, args map[string]any) (string, error)

+ type Options struct

+ AuthHeader string

+ AuthScheme string

+ ExtraHeaders map[string]string

+ MaxBody int64

+ MaxRetries int

+ Redact func(string) string

+ Timeout time.Duration

+ TokenProvider func(context.Context) (string, error)

+ TokenRefresher func(context.Context) (string, error)

+ type PollResult struct

+ Done bool

+ Dropped int

+ Frames []string

+ Pending int

+ Reason string

+ type StreamInfo struct

+ Done bool

+ EndReason string

+ Frames uint64

+ ID string

+ Kind string

+ Label string

+ Pending uint64

+ StartedAt time.Time

+ type StreamManager struct

+ func NewStreamManager(opts StreamOptions) *StreamManager

+ func (m *StreamManager) CloseAll()

+ func (m *StreamManager) List() []StreamInfo

+ func (m *StreamManager) Poll(id string, maxFrames int) (*PollResult, error)

+ func (m *StreamManager) Start(kind, label string, ...) (string, error)

+ func (m *StreamManager) Stop(id string) (*PollResult, error)

+ func (m *StreamManager) Sweep()

+ type StreamOptions struct

+ IdleTTL time.Duration

+ MaxBytes int64

+ MaxFrameBytes int64

+ MaxFrames int

+ MaxLifetime time.Duration

+ MaxSessions int

+ NoSweeper bool

+ Now func() time.Time

+ type StreamSession struct

+ ID string

+ Kind string

+ Label string

+ type TokenManager interface

+ Refresh func(ctx context.Context) (string, error)

+ Token func(ctx context.Context) (string, error)

+ func NewTokenManager(cfg AuthConfig, client *http.Client) (TokenManager, error)