inngestgo

Apr 17, 2024

Changes in this version

type HandlerOpts

+ SigningKeyFallback *string

+ func (h HandlerOpts) GetSigningKeyFallback() string

Apr 16, 2024

Changes in this version

type FunctionOpts

+ Throttle *Throttle

+ Timeouts *Timeouts

+ type Throttle struct

+ Burst uint

+ Key *string

+ Limit uint

+ Period time.Duration

+ type Timeouts struct

+ Finish time.Duration

+ Start time.Duration

Mar 11, 2024

Changes in this version

+ const HeaderKeyExpectedServerKind

+ const HeaderKeyServerKind

Jan 25, 2024

Changes in this version

type Debounce

+ Timeout *time.Duration

+ type StepError = errors.StepError

Nov 29, 2023

Changes in this version

+ const HeaderKeyAuthorization

+ const HeaderKeyContentType

+ const HeaderKeyEnv

+ const HeaderKeyNoRetry

+ const HeaderKeyRetryAfter

+ const HeaderKeySDK

+ const HeaderKeySignature

+ const HeaderKeyUserAgent

+ const SDKLanguage

+ const SDKVersion

+ var HeaderValueSDK = fmt.Sprintf("%s:v%s", SDKLanguage, SDKVersion)

+ func SetBasicRequestHeaders(req *http.Request)

+ func SetBasicResponseHeaders(w http.ResponseWriter)

Nov 2, 2023

Changes in this version

+ func NowMillis() int64

Nov 2, 2023

Changes in this version

+ var DefaultHandler Handler = NewHandler("Go app", HandlerOpts{})

+ var DefaultMaxBodySize = 1024 * 1024 * 100

+ var ErrExpiredSignature = fmt.Errorf("expired signature")

+ var ErrInvalidSignature = fmt.Errorf("invalid signature")

+ var ErrInvalidTimestamp = fmt.Errorf("invalid timestamp")

+ var ErrTypeMismatch = fmt.Errorf("cannot invoke function with mismatched types")

+ func CronTrigger(cron string) inngest.Trigger

+ func DevServerURL() string

+ func EventTrigger(name string, expression *string) inngest.Trigger

+ func GetRetryAtTime(err error) *time.Time

+ func IntPtr(i int) *int

+ func IsDev() bool

+ func IsNoRetryError(err error) bool

+ func IsRetryAtError(err error) bool

+ func NoRetryError(err error) error

+ func Register(funcs ...ServableFunction)

+ func RetryAtError(err error, at time.Time) error

+ func SendMany(ctx context.Context, e []any) ([]string, error)

+ func Serve(w http.ResponseWriter, r *http.Request)

+ func Sign(ctx context.Context, at time.Time, key, body []byte) string

+ func StrPtr(i string) *string

+ func ValidateSignature(ctx context.Context, sig string, key, body []byte) (bool, error)

type Client

+ SendMany func(ctx context.Context, evt []any) ([]string, error)

+ type ClientOpts struct

+ Env *string

+ EventKey *string

+ EventURL *string

+ HTTPClient *http.Client

+ type Debounce struct

+ Key string

+ Period time.Duration

type Event

+ ID *string

+ func (e Event) Map() map[string]any

+ type FunctionOpts struct

+ BatchEvents *inngest.EventBatchConfig

+ Cancel []inngest.Cancel

+ Concurrency []inngest.Concurrency

+ Debounce *Debounce

+ ID string

+ Idempotency *string

+ Name string

+ Priority *inngest.Priority

+ RateLimit *RateLimit

+ Retries *int

+ func (f FunctionOpts) GetRateLimit() *inngest.RateLimit

+ type GenericEvent struct

+ Data DATA

+ ID *string

+ Name string

+ Timestamp int64

+ User USER

+ Version string

+ func (ge GenericEvent[D, U]) Event() Event

+ func (ge GenericEvent[D, U]) Validate() error

+ type Handler interface

+ Register func(...ServableFunction)

+ SetAppName func(name string) Handler

+ SetOptions func(h HandlerOpts) Handler

+ func NewHandler(appName string, opts HandlerOpts) Handler

+ type HandlerOpts struct

+ Env *string

+ Logger *slog.Logger

+ MaxBodySize int

+ RegisterURL *string

+ SigningKey *string

+ URL *url.URL

+ UseStreaming bool

+ func (h HandlerOpts) GetEnv() string

+ func (h HandlerOpts) GetRegisterURL() string

+ func (h HandlerOpts) GetSigningKey() string

+ type Input struct

+ Event T

+ Events []T

+ InputCtx InputCtx

+ type InputCtx struct

+ Attempt int

+ Env string

+ FunctionID string

+ RunID string

+ StepID string

+ type RateLimit struct

+ Key *string

+ Limit uint

+ Period time.Duration

+ func (r RateLimit) Convert() *inngest.RateLimit

+ type SDKFunction func(ctx context.Context, input Input[T]) (any, error)

+ type ServableFunction interface

+ Config func() FunctionOpts

+ Func func() any

+ Name func() string

+ Slug func() string

+ Trigger func() inngest.Trigger

+ ZeroEvent func() any

+ func CreateFunction(fc FunctionOpts, trigger inngest.Trigger, f SDKFunction[T]) ServableFunction

+ type StreamResponse struct

+ Body any

+ Headers map[string]string

+ NoRetry bool

+ RetryAt *time.Time

+ StatusCode int

Jul 14, 2021

Changes in this version

+ const Email

+ const ExternalID

+ func Now() int64

+ func Send(ctx context.Context, e Event) error

+ func Timestamp(t time.Time) int64

+ type Client interface

+ Send func(context.Context, Event) error

+ var DefaultClient Client

+ func NewClient(ingestKey string, opts ...Modifier) Client

+ type Event struct

+ Data map[string]interface{}

+ Name string

+ Timestamp int64

+ User map[string]interface{}

+ Version string

+ func (e Event) Validate() error

+ type Modifier func(c Client)

+ func WithEndpoint(url string) Modifier

+ func WithHTTPClient(hc *http.Client) Modifier

+ func WithIngestKey(key string) Modifier