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

statefun

package

Go to main page

Versions in this module

v3

v3.3.0

Sep 12, 2023

Changes in this version

type Context

+ func DeriveContext(statefunCtx Context, ctx context.Context) Context

v3.3.0-rc2

Sep 12, 2023

v3.3.0-rc1

Sep 8, 2023

v3.2.0

Jan 25, 2022

v3.1.1

Dec 17, 2021

v3.1.1-rc2

Dec 17, 2021

v3.1.0

Aug 24, 2021

Changes in this version

+ type Address struct

+ FunctionType TypeName

+ Id string

+ func (a Address) String() string

+ type AddressScopedStorage interface

+ Get func(spec ValueSpec, receiver interface{}) (exists bool)

+ Remove func(spec ValueSpec)

+ Set func(spec ValueSpec, value interface{})

+ type CancellationToken interface

+ Token func() string

+ func NewCancellationToken(t string) (CancellationToken, error)

+ type Context interface

+ Caller func() *Address

+ CancelDelayedMessage func(token CancellationToken)

+ Self func() Address

+ Send func(message MessageBuilder)

+ SendAfter func(delay time.Duration, message MessageBuilder)

+ SendAfterWithCancellationToken func(delay time.Duration, token CancellationToken, message MessageBuilder)

+ SendEgress func(egress EgressBuilder)

+ Storage func() AddressScopedStorage

+ type EgressBuilder interface

+ type Expiration struct

+ func ExpireAfterCall(duration time.Duration) Expiration

+ func ExpireAfterWrite(duration time.Duration) Expiration

+ func (e Expiration) String() string

+ type GenericEgressBuilder struct

+ Target TypeName

+ Value interface{}

+ ValueType SimpleType

+ type KafkaEgressBuilder struct

+ Key string

+ Target TypeName

+ Topic string

+ Value interface{}

+ ValueType SimpleType

+ type KinesisEgressBuilder struct

+ ExplicitHashKey string

+ PartitionKey string

+ Stream string

+ Target TypeName

+ Value interface{}

+ ValueType SimpleType

+ type Message struct

+ func (m *Message) As(t SimpleType, receiver interface{}) error

+ func (m *Message) AsBool() bool

+ func (m *Message) AsFloat32() float32

+ func (m *Message) AsFloat64() float64

+ func (m *Message) AsInt32() int32

+ func (m *Message) AsInt64() int64

+ func (m *Message) AsString() string

+ func (m *Message) Is(t SimpleType) bool

+ func (m *Message) IsBool() bool

+ func (m *Message) IsFloat32() bool

+ func (m *Message) IsFloat64() bool

+ func (m *Message) IsInt32() bool

+ func (m *Message) IsInt64() bool

+ func (m *Message) IsString() bool

+ func (m *Message) RawValue() []byte

+ func (m *Message) ValueTypeName() TypeName

+ type MessageBuilder struct

+ Target Address

+ Value interface{}

+ ValueType SimpleType

+ func (m MessageBuilder) ToMessage() (Message, error)

+ type MissingSpecs []*protocol.FromFunction_PersistedValueSpec

+ type PrimitiveType int

+ const BoolType

+ const Float32Type

+ const Float64Type

+ const Int32Type

+ const Int64Type

+ const StringType

+ func (p PrimitiveType) Deserialize(r io.Reader, receiver interface{}) error

+ func (p PrimitiveType) GetTypeName() TypeName

+ func (p PrimitiveType) Serialize(writer io.Writer, data interface{}) error

+ type RequestReplyHandler interface

+ Invoke func(ctx context.Context, payload []byte) ([]byte, error)

+ type SimpleType interface

+ Deserialize func(r io.Reader, receiver interface{}) error

+ GetTypeName func() TypeName

+ Serialize func(writer io.Writer, data interface{}) error

+ func MakeJsonType(name TypeName) SimpleType

+ func MakeProtobufType(m proto.Message) SimpleType

+ func MakeProtobufTypeWithTypeName(typeName TypeName) SimpleType

+ type StatefulFunction interface

+ Invoke func(ctx Context, message Message) error

+ type StatefulFunctionPointer func(Context, Message) error

+ func (s StatefulFunctionPointer) Invoke(ctx Context, message Message) error

+ type StatefulFunctionSpec struct

+ Function StatefulFunction

+ FunctionType TypeName

+ States []ValueSpec

+ type StatefulFunctions interface

+ AsHandler func() RequestReplyHandler

+ WithSpec func(spec StatefulFunctionSpec) error

+ func StatefulFunctionsBuilder() StatefulFunctions

+ type TypeName interface

+ GetNamespace func() string

+ GetType func() string

+ func ParseTypeName(typename string) (TypeName, error)

+ func TypeNameFrom(typename string) TypeName

+ func TypeNameFromParts(namespace, tpe string) (TypeName, error)

+ type ValueSpec struct

+ Expiration Expiration

+ Name string

+ ValueType SimpleType

+ func (v *ValueSpec) String() string

v3.1.0-rc2

Aug 24, 2021