smadapter

Documentation

Index

• func NewCallChannelExecutor(ctx context.Context, bufMax int, requestCancel bool, parallelReaders int) (smachine.AdapterExecutor, chan smachine.AdapterCall)
• func NewComponent(ctx context.Context, cfg Config, runArg interface{}, ...) (smachine.AdapterExecutor, managed.Component)
• func NewComponentExt(ctx context.Context, runArg interface{}, initFn func(managed.Holder), ...) ([]smachine.AdapterExecutor, managed.Component)
• func NewExecutor(ctx context.Context, cfg Config, runArg interface{}) (exec smachine.AdapterExecutor, startFn func())
• func StartExecutorFor(ctx context.Context, cfg Config, runArg interface{}) smachine.AdapterExecutor
• type Config
• type OverflowBufferCallChannel
  • func WrapCallChannel(ctx context.Context, bufMax int, requestCancel bool, ...) *OverflowBufferCallChannel
  • func WrapCallChannelNoLimit(ctx context.Context, requestCancel bool, output chan smachine.AdapterCall) *OverflowBufferCallChannel
  • func (p *OverflowBufferCallChannel) Channel() chan channelRecord
  • func (p *OverflowBufferCallChannel) Context() context.Context
  • func (p *OverflowBufferCallChannel) SendNotify(ctx context.Context, fn smachine.AdapterNotifyFunc)
  • func (p *OverflowBufferCallChannel) StartCall(ctx context.Context, fn smachine.AdapterCallFunc, ...) context.CancelFunc
  • func (p *OverflowBufferCallChannel) TrySyncCall(context.Context, smachine.AdapterCallFunc) (bool, smachine.AsyncResultFunc)
• type OverflowPanicCallChannel
  • func WrapCallChannelNoBuffer(requestCancel bool, output chan smachine.AdapterCall) OverflowPanicCallChannel
  • func (v OverflowPanicCallChannel) Channel() chan channelRecord
  • func (v OverflowPanicCallChannel) SendNotify(ctx context.Context, fn smachine.AdapterNotifyFunc)
  • func (v OverflowPanicCallChannel) StartCall(ctx context.Context, fn smachine.AdapterCallFunc, ...) context.CancelFunc
  • func (v OverflowPanicCallChannel) TrySyncCall(context.Context, smachine.AdapterCallFunc) (bool, smachine.AsyncResultFunc)

Functions

func NewCallChannelExecutor

func NewCallChannelExecutor(ctx context.Context, bufMax int, requestCancel bool, parallelReaders int) (smachine.AdapterExecutor, chan smachine.AdapterCall)

func NewComponent

func NewComponent(ctx context.Context, cfg Config, runArg interface{}, initFn func(managed.Holder)) (smachine.AdapterExecutor, managed.Component)

func NewComponentExt

func NewComponentExt(ctx context.Context, runArg interface{}, initFn func(managed.Holder), cfg ...Config) ([]smachine.AdapterExecutor, managed.Component)

func NewExecutor

func NewExecutor(ctx context.Context, cfg Config, runArg interface{}) (exec smachine.AdapterExecutor, startFn func())

func StartExecutorFor

func StartExecutorFor(ctx context.Context, cfg Config, runArg interface{}) smachine.AdapterExecutor

Types

type Config

type Config struct {
	MaxBufferCapacity       int
	ExpectedParallelReaders int
	ProvideCancel           bool
}

type OverflowBufferCallChannel

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

This wrapper doesn't allocate a buffer unless the channel is full

func WrapCallChannel

func WrapCallChannel(ctx context.Context, bufMax int, requestCancel bool, output chan smachine.AdapterCall) *OverflowBufferCallChannel

func WrapCallChannelNoLimit

func WrapCallChannelNoLimit(ctx context.Context, requestCancel bool, output chan smachine.AdapterCall) *OverflowBufferCallChannel

func (*OverflowBufferCallChannel) Channel

func (p *OverflowBufferCallChannel) Channel() chan channelRecord

func (*OverflowBufferCallChannel) Context

func (p *OverflowBufferCallChannel) Context() context.Context

func (*OverflowBufferCallChannel) SendNotify

func (p *OverflowBufferCallChannel) SendNotify(ctx context.Context, fn smachine.AdapterNotifyFunc)

func (*OverflowBufferCallChannel) StartCall

func (p *OverflowBufferCallChannel) StartCall(ctx context.Context, fn smachine.AdapterCallFunc, callback *smachine.AdapterCallback, needCancel bool) context.CancelFunc

func (*OverflowBufferCallChannel) TrySyncCall

func (p *OverflowBufferCallChannel) TrySyncCall(context.Context, smachine.AdapterCallFunc) (bool, smachine.AsyncResultFunc)

type OverflowPanicCallChannel

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

func WrapCallChannelNoBuffer

func WrapCallChannelNoBuffer(requestCancel bool, output chan smachine.AdapterCall) OverflowPanicCallChannel

func (OverflowPanicCallChannel) Channel

func (v OverflowPanicCallChannel) Channel() chan channelRecord

func (OverflowPanicCallChannel) SendNotify

func (v OverflowPanicCallChannel) SendNotify(ctx context.Context, fn smachine.AdapterNotifyFunc)

func (OverflowPanicCallChannel) StartCall

func (v OverflowPanicCallChannel) StartCall(ctx context.Context, fn smachine.AdapterCallFunc, callback *smachine.AdapterCallback, needCancel bool) context.CancelFunc

func (OverflowPanicCallChannel) TrySyncCall

func (v OverflowPanicCallChannel) TrySyncCall(context.Context, smachine.AdapterCallFunc) (bool, smachine.AsyncResultFunc)