statefun

package
v0.1.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 19, 2023 License: Apache-2.0 Imports: 12 Imported by: 4

Documentation

Overview

Foliage primary statefun package. Provides all everything that is needed for Foliage stateful functions and Foliage applications

Index

Constants

View Source 
const (
	MsgAckWaitTimeoutMs = 10000
	MsgChannelSize      = 64
	MsgAckChannelSize   = 64
	BalanceNeeded       = true
	MutexLifetimeSec    = 120
)
View Source 
const (
	NatsURL                      = "nats://nats:foliage@nats:4222"
	RuntimeName                  = "foliage_runtime"
	KeyValueStoreBucketName      = RuntimeName + "_kv_store"
	FunctionTypesStreamName      = RuntimeName + "_stream"
	KVMutexLifetimeSec           = 120
	KVMutexIsOldPollingInterval  = 10
	FunctionTypeIDLifetimeMs     = 5000
	IngressCallGolangSyncTimeout = 60
)

Variables

This section is empty.

Functions

func AddRequestSourceNatsCore added in v0.1.1 

func AddRequestSourceNatsCore(ft *FunctionType) error

func AddSignalSourceJetstreamQueuePushConsumer added in v0.1.1 

func AddSignalSourceJetstreamQueuePushConsumer(ft *FunctionType, streamName string) error

func ContextMutexLock 

func ContextMutexLock(ft *FunctionType, id string, errorOnLocked bool) (uint64, error)

func ContextMutexUnlock 

func ContextMutexUnlock(ft *FunctionType, id string, lockRevisionID uint64) error

func FunctionTypeMutexLock 

func FunctionTypeMutexLock(ft *FunctionType, errorOnLocked bool) (uint64, error)

func FunctionTypeMutexUnlock 

func FunctionTypeMutexUnlock(ft *FunctionType, lockRevisionID uint64) error

func KeyMutexLock 

func KeyMutexLock(runtime *Runtime, key string, errorOnLocked bool, debugCaller ...string) (uint64, error)

func KeyMutexUnlock 

func KeyMutexUnlock(runtime *Runtime, key string, lockRevisionID uint64, debugCaller ...string) error

Types

type FunctionLogicHandler added in v0.1.1 

type FunctionLogicHandler func(sfPlugins.StatefunExecutor, *sfPlugins.StatefunContextProcessor)

type FunctionType 

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

func NewFunctionType 

func NewFunctionType(runtime *Runtime, name string, logicHandler FunctionLogicHandler, config FunctionTypeConfig) *FunctionType

func (*FunctionType) SetExecutor 

func (ft *FunctionType) SetExecutor(alias string, content string, constructor func(alias string, source string) sfPlugins.StatefunExecutor) error

type FunctionTypeConfig 

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

func NewFunctionTypeConfig 

func NewFunctionTypeConfig() *FunctionTypeConfig

func (*FunctionTypeConfig) SeMsgChannelSize 

func (ftc *FunctionTypeConfig) SeMsgChannelSize(msgChannelSize int) *FunctionTypeConfig

func (*FunctionTypeConfig) SetBalanceNeeded 

func (ftc *FunctionTypeConfig) SetBalanceNeeded(balanceNeeded bool) *FunctionTypeConfig

func (*FunctionTypeConfig) SetMsgAckChannelSize 

func (ftc *FunctionTypeConfig) SetMsgAckChannelSize(msgAckChannelSize int) *FunctionTypeConfig

func (*FunctionTypeConfig) SetMsgAckWaitMs 

func (ftc *FunctionTypeConfig) SetMsgAckWaitMs(msgAckWaitMs int) *FunctionTypeConfig

func (*FunctionTypeConfig) SetMutexLifeTimeSec 

func (ftc *FunctionTypeConfig) SetMutexLifeTimeSec(mutexLifeTimeSec int) *FunctionTypeConfig

func (*FunctionTypeConfig) SetOptions 

func (ftc *FunctionTypeConfig) SetOptions(options *easyjson.JSON) *FunctionTypeConfig

func (*FunctionTypeConfig) SetServiceState added in v0.1.1 

func (ftc *FunctionTypeConfig) SetServiceState(active bool) *FunctionTypeConfig

type FunctionTypeMsg added in v0.1.1 

type FunctionTypeMsg struct {
	Caller          *sfPlugins.StatefunAddress
	Payload         *easyjson.JSON
	Options         *easyjson.JSON
	RefusalCallback RefusalCallbackAction
	RequestCallback RequestCallbackAction
	AckCallback     SignalCallbackAction
}

type HandlerMsgRefusalType added in v0.1.1 

type HandlerMsgRefusalType int

type RefusalCallbackAction added in v0.1.1 

type RefusalCallbackAction = func()

type RequestCallbackAction added in v0.1.1 

type RequestCallbackAction = func(data *easyjson.JSON)

type Runtime 

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

func NewRuntime 

func NewRuntime(config RuntimeConfig) (r *Runtime, err error)

func (*Runtime) Request added in v0.1.1 

func (r *Runtime) Request(requestProvider sfPlugins.RequestProvider, typename string, id string, payload *easyjson.JSON, options *easyjson.JSON) (*easyjson.JSON, error)

func (*Runtime) Signal added in v0.1.1 

func (r *Runtime) Signal(signalProvider sfPlugins.SignalProvider, typename string, id string, payload *easyjson.JSON, options *easyjson.JSON) error

func (*Runtime) Start 

func (r *Runtime) Start(cacheConfig *cache.Config, onAfterStart func(runtime *Runtime) error) (err error)

type RuntimeConfig 

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

func NewRuntimeConfig 

func NewRuntimeConfig() *RuntimeConfig

func NewRuntimeConfigSimple 

func NewRuntimeConfigSimple(natsURL string, runtimeName string) *RuntimeConfig

func (*RuntimeConfig) SeKeyValueStoreBucketName 

func (ro *RuntimeConfig) SeKeyValueStoreBucketName(keyValueStoreBucketName string) *RuntimeConfig

func (*RuntimeConfig) SetFunctionTypeIDLifetimeMs 

func (ro *RuntimeConfig) SetFunctionTypeIDLifetimeMs(functionTypeIDLifetimeMs int) *RuntimeConfig

func (*RuntimeConfig) SetFunctionTypesStreamName 

func (ro *RuntimeConfig) SetFunctionTypesStreamName(functionTypesStreamName string) *RuntimeConfig

func (*RuntimeConfig) SetIngressCallGoLangSyncTimeoutSec 

func (ro *RuntimeConfig) SetIngressCallGoLangSyncTimeoutSec(ingressCallGoLangSyncTimeoutSec int) *RuntimeConfig

func (*RuntimeConfig) SetKVMutexIsOldPollingIntervalSec 

func (ro *RuntimeConfig) SetKVMutexIsOldPollingIntervalSec(kvMutexIsOldPollingIntervalSec int) *RuntimeConfig

func (*RuntimeConfig) SetKVMutexLifeTimeSec 

func (ro *RuntimeConfig) SetKVMutexLifeTimeSec(kvMutexLifeTimeSec int) *RuntimeConfig

func (*RuntimeConfig) SetNatsURL 

func (ro *RuntimeConfig) SetNatsURL(natsURL string) *RuntimeConfig

type SignalCallbackAction added in v0.1.1 

type SignalCallbackAction = func(ack bool)

Source Files

View all Source files

Directories

Path Synopsis
Foliage statefun cache package.
 Foliage statefun cache package.
Foliage statefun plugins package.
 Foliage statefun plugins package.
js
Foliage primary statefun system package.
 Foliage primary statefun system package.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.