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

chasm

package

Go to main page

Versions in this module

v1

v1.28.0-129.0

Mar 7, 2025

v1.27.1

Feb 26, 2025

v1.27.0

Feb 21, 2025

Changes in this version

+ func NewEntity[C Component, I any, O any](ctx context.Context, key EntityKey, ...) (O, []byte, error)

+ func PollComponent[C Component, R []byte | ComponentRef, I any, O any, T any](ctx context.Context, r R, predicateFn func(C, Context, I) (T, bool, error), ...) (O, []byte, error)

+ func ReadComponent[C Component, R []byte | ComponentRef, I any, O any](ctx context.Context, r R, readFn func(C, Context, I) (O, error), input I, ...) (O, error)

+ func UpdateComponent[C Component, R []byte | ComponentRef, I any, O any](ctx context.Context, r R, updateFn func(C, MutableContext, I) (O, error), ...) (O, []byte, error)

+ func UpdateWithNewEntity[C Component, I any, O1 any, O2 any](ctx context.Context, key EntityKey, ...) (O1, O2, []byte, error)

+ type BusinessIDConflictPolicy int

+ const BusinessIDConflictPolicyFail

+ const BusinessIDConflictPolicyTermiateExisting

+ const BusinessIDConflictPolicyUseExisting

+ type BusinessIDReusePolicy int

+ const BusinessIDReusePolicyAllowDuplicate

+ const BusinessIDReusePolicyRejectDuplicate

+ type Collection map[string]*Field[T]

+ type Component interface

+ LifecycleState func() LifecycleState

+ type ComponentFieldOption func(*componentFieldOptions)

+ func ComponentFieldDetached() ComponentFieldOption

+ type ComponentRef struct

+ func DeserializeComponentRef(data []byte) (ComponentRef, error)

+ func NewComponentRef(entityKey EntityKey, rootComponentType string) ComponentRef

+ func (r *ComponentRef) Serialize() []byte

+ type Context interface

+ Now func(Component) time.Time

+ Ref func(Component) (ComponentRef, bool)

+ type EntityKey struct

+ BusinessID string

+ EntityID string

+ NamespaceID string

+ type Field struct

+ Internal fieldInternal

+ func NewComponentField[C Component](ctx MutableContext, c C, options ...ComponentFieldOption) *Field[C]

+ func NewComponentPointerField[C Component](ctx MutableContext, c C) *Field[C]

+ func NewDataField[D proto.Message](ctx MutableContext, d D) *Field[D]

+ func NewDataPointerField[D proto.Message](ctx MutableContext, d D) *Field[D]

+ func (d *Field[T]) Get(Context) (T, error)

+ type Library interface

+ Components func() []*RegistrableComponent

+ Name func() string

+ Tasks func() []*RegistrableTask

+ type LifecycleState int

+ const LifecycleStateCompleted

+ const LifecycleStateCreated

+ const LifecycleStateFailed

+ const LifecycleStateRunning

+ const LifecycleStateUnspecified

+ type MockComponent struct

+ func NewMockComponent(ctrl *gomock.Controller) *MockComponent

+ func (m *MockComponent) EXPECT() *MockComponentMockRecorder

+ func (m *MockComponent) LifecycleState() LifecycleState

+ type MockComponentMockRecorder struct

+ func (mr *MockComponentMockRecorder) LifecycleState() *gomock.Call

+ type MockLibrary struct

+ func NewMockLibrary(ctrl *gomock.Controller) *MockLibrary

+ func (m *MockLibrary) Components() []*RegistrableComponent

+ func (m *MockLibrary) EXPECT() *MockLibraryMockRecorder

+ func (m *MockLibrary) Name() string

+ func (m *MockLibrary) Tasks() []*RegistrableTask

+ type MockLibraryMockRecorder struct

+ func (mr *MockLibraryMockRecorder) Components() *gomock.Call

+ func (mr *MockLibraryMockRecorder) Name() *gomock.Call

+ func (mr *MockLibraryMockRecorder) Tasks() *gomock.Call

+ type MockTaskHandler struct

+ func NewMockTaskHandler[C any, T any](ctrl *gomock.Controller) *MockTaskHandler[C, T]

+ func (m *MockTaskHandler[C, T]) EXPECT() *MockTaskHandlerMockRecorder[C, T]

+ func (m *MockTaskHandler[C, T]) Execute(arg0 context.Context, arg1 ComponentRef, arg2 T) error

+ func (m *MockTaskHandler[C, T]) Validate(arg0 Context, arg1 C, arg2 T) error

+ type MockTaskHandlerMockRecorder struct

+ func (mr *MockTaskHandlerMockRecorder[C, T]) Execute(arg0, arg1, arg2 any) *gomock.Call

+ func (mr *MockTaskHandlerMockRecorder[C, T]) Validate(arg0, arg1, arg2 any) *gomock.Call

+ type MutableContext interface

+ AddTask func(Component, TaskAttributes, any) error

+ type OperationIntent int

+ const OperationIntentObserve

+ const OperationIntentProgress

+ const OperationIntentUnspecified

+ type PollComponentRequest struct

+ Input I

+ OperationFn func(C, MutableContext, I) (O, error)

+ PredicateFn func(C, Context, I) bool

+ Ref ComponentRef

+ type RegistrableComponent struct

+ func NewRegistrableComponent[C Component](componentType string, opts ...RegistrableComponentOption) *RegistrableComponent

+ func (rc RegistrableComponent) Type() string

+ type RegistrableComponentOption func(*RegistrableComponent)

+ func WithEphemeral() RegistrableComponentOption

+ func WithShardingFn(shardingFn func(EntityKey) string) RegistrableComponentOption

+ func WithSingleCluster() RegistrableComponentOption

+ type RegistrableTask struct

+ func NewRegistrableTask[C any, T any](taskType string, handler TaskHandler[C, T], opts ...RegistrableTaskOption) *RegistrableTask

+ func (rt RegistrableTask) Type() string

+ type RegistrableTaskOption func(*RegistrableTask)

+ type Registry struct

+ func NewRegistry() *Registry

+ func (r *Registry) Register(lib Library) error

+ type TaskAttributes struct

+ Destination string

+ ScheduledTime time.Time

+ type TaskHandler interface

+ Execute func(context.Context, ComponentRef, T) error

+ Validate func(Context, C, T) error

+ type TransitionOption func(*transitionOptions)

+ func WithBusinessIDPolicy(reusePolicy BusinessIDReusePolicy, conflictPolicy BusinessIDConflictPolicy) TransitionOption

+ func WithSpeculative() TransitionOption

+ type UnimplementedComponent struct

+ func (UnimplementedComponent) LifecycleState() LifecycleState

+ type UnimplementedLibrary struct

+ func (UnimplementedLibrary) Components() []*RegistrableComponent

+ func (UnimplementedLibrary) Tasks() []*RegistrableTask

v1.27.0-rc.0

Feb 21, 2025

v1.27.0-128.6

Feb 26, 2025

v1.27.0-128.5

Feb 20, 2025

v1.27.0-128.4

Feb 14, 2025

v1.27.0-128.3

Feb 12, 2025

v1.27.0-128.2

Feb 11, 2025

v1.27.0-128.1

Feb 10, 2025

v1.27.0-128.0

Feb 7, 2025