sync

package

Go to main page

Versions in this module

v0

v0.3.0

Sep 24, 2021

Changes in this version

+ const EnvServiceHost

+ const EnvServicePort

type DefaultClient

+ func (c *DefaultClient) SubscribeEvents(ctx context.Context, rp *runtime.RunParams) (chan *runtime.Event, error)

v0.2.7

Jan 26, 2021

v0.2.6

Oct 16, 2020

Changes in this version

type Client

+ SignalEvent func(context.Context, *runtime.Event) error

type DefaultClient

+ func NewGenericClientWithRedis(ctx context.Context, rclient *redis.Client, log *zap.SugaredLogger) (*DefaultClient, error)

+ func (c *DefaultClient) SignalEvent(ctx context.Context, event *runtime.Event) (err error)

+ type WatchClient struct

+ func NewWatchClient(ctx context.Context, log *zap.SugaredLogger) (*WatchClient, error)

+ func (w *WatchClient) FetchAllEvents(rp *runtime.RunParams) ([]*runtime.Event, error)

+ func (w *WatchClient) SubscribeEvents(ctx context.Context, rp *runtime.RunParams) (chan *runtime.Event, error)

v0.2.5

Sep 2, 2020

v0.2.4

Jul 27, 2020

v0.2.3

Jul 21, 2020

Changes in this version

+ type DefaultClient struct

+ func (c *DefaultClient) Barrier(ctx context.Context, state State, target int) (*Barrier, error)

+ func (c *DefaultClient) Close() error

+ func (c *DefaultClient) EnableBackgroundGC(notifyCh chan error)

+ func (c *DefaultClient) MustSubscribe(ctx context.Context, topic *Topic, ch interface{}) (sub *Subscription)

+ func (c *DefaultClient) Publish(ctx context.Context, topic *Topic, payload interface{}) (seq int64, err error)

+ func (c *DefaultClient) RunGC() error

+ func (c *DefaultClient) SignalEntry(ctx context.Context, state State) (after int64, err error)

+ func (c *DefaultClient) Subscribe(ctx context.Context, topic *Topic, ch interface{}) (*Subscription, error)

+ func (c DefaultClient) MustBarrier(ctx context.Context, state State, required int) *Barrier

+ func (c DefaultClient) MustPublish(ctx context.Context, topic *Topic, payload interface{}) (seq int64)

+ func (c DefaultClient) MustPublishAndWait(ctx context.Context, topic *Topic, payload interface{}, state State, ...) (seq int64)

+ func (c DefaultClient) MustPublishSubscribe(ctx context.Context, topic *Topic, payload interface{}, ch interface{}) (seq int64, sub *Subscription)

+ func (c DefaultClient) MustSignalAndWait(ctx context.Context, state State, target int) (seq int64)

+ func (c DefaultClient) MustSignalEntry(ctx context.Context, state State) (current int64)

+ func (c DefaultClient) PublishAndWait(ctx context.Context, topic *Topic, payload interface{}, state State, ...) (seq int64, err error)

+ func (c DefaultClient) PublishSubscribe(ctx context.Context, topic *Topic, payload interface{}, ch interface{}) (seq int64, sub *Subscription, err error)

+ func (c DefaultClient) SignalAndWait(ctx context.Context, state State, target int) (seq int64, err error)

v0.2.2

May 28, 2020

Changes in this version

+ func NewInmemClient() *inmemClient

+ type Interface interface

+ Barrier func(ctx context.Context, state State, target int) (*Barrier, error)

+ MustBarrier func(ctx context.Context, state State, target int) *Barrier

+ MustSignalEntry func(ctx context.Context, state State) int64

+ MustSubscribe func(ctx context.Context, topic *Topic, ch interface{}) *Subscription

+ Publish func(ctx context.Context, topic *Topic, payload interface{}) (seq int64, err error)

+ PublishAndWait func(ctx context.Context, topic *Topic, payload interface{}, state State, ...) (seq int64, err error)

+ PublishSubscribe func(ctx context.Context, topic *Topic, payload interface{}, ch interface{}) (seq int64, sub *Subscription, err error)

+ SignalAndWait func(ctx context.Context, state State, target int) (seq int64, err error)

+ SignalEntry func(ctx context.Context, state State) (after int64, err error)

+ Subscribe func(ctx context.Context, topic *Topic, ch interface{}) (*Subscription, error)

v0.2.1

May 3, 2020

v0.2.0

Apr 30, 2020

v0.1.1

Apr 22, 2020

Changes in this version

+ const EnvRedisHost

+ const EnvRedisPort

+ const HostHostname

+ const NetworkInitialisationFailed

+ const NetworkInitialisationSuccessful

+ const RedisHostname

+ const RedisPayloadKey

+ const StateInterrupting

+ const StateRunning

+ const StateStopped

+ var DefaultRedisOpts = redis.Options

+ var ErrNoRunParameters = fmt.Errorf("no run parameters provided")

+ var GCFrequency = 30 * time.Minute

+ var GCLastAccessThreshold = 30 * time.Minute

+ func GetRunParams(ctx context.Context) *runtime.RunParams

+ func WithRunParams(ctx context.Context, rp *runtime.RunParams) context.Context

+ type Barrier struct

+ C chan error

+ type Client struct

+ func MustBoundClient(ctx context.Context, runenv *runtime.RunEnv) *Client

+ func MustGenericClient(ctx context.Context, log *zap.SugaredLogger) *Client

+ func NewBoundClient(ctx context.Context, runenv *runtime.RunEnv) (*Client, error)

+ func NewGenericClient(ctx context.Context, log *zap.SugaredLogger) (*Client, error)

+ func (c *Client) Barrier(ctx context.Context, state State, target int) (*Barrier, error)

+ func (c *Client) Close() error

+ func (c *Client) EnableBackgroundGC(notifyCh chan error)

+ func (c *Client) MustBarrier(ctx context.Context, state State, required int) *Barrier

+ func (c *Client) MustPublish(ctx context.Context, topic *Topic, payload interface{}) (seq int64)

+ func (c *Client) MustPublishAndWait(ctx context.Context, topic *Topic, payload interface{}, state State, ...) (seq int64)

+ func (c *Client) MustPublishSubscribe(ctx context.Context, topic *Topic, payload interface{}, ch interface{}) (seq int64, sub *Subscription)

+ func (c *Client) MustSignalAndWait(ctx context.Context, state State, target int) (seq int64)

+ func (c *Client) MustSignalEntry(ctx context.Context, state State) (current int64)

+ func (c *Client) MustSubscribe(ctx context.Context, topic *Topic, ch interface{}) (sub *Subscription)

+ func (c *Client) Publish(ctx context.Context, topic *Topic, payload interface{}) (seq int64, err error)

+ func (c *Client) PublishAndWait(ctx context.Context, topic *Topic, payload interface{}, state State, ...) (seq int64, err error)

+ func (c *Client) PublishSubscribe(ctx context.Context, topic *Topic, payload interface{}, ch interface{}) (seq int64, sub *Subscription, err error)

+ func (c *Client) RunGC() error

+ func (c *Client) SignalAndWait(ctx context.Context, state State, target int) (seq int64, err error)

+ func (c *Client) SignalEntry(ctx context.Context, state State) (after int64, err error)

+ func (c *Client) Subscribe(ctx context.Context, topic *Topic, ch interface{}) (*Subscription, error)

+ func (c *Client) WaitNetworkInitialized(ctx context.Context, runenv *runtime.RunEnv) error

+ type FilterAction int

+ const Accept

+ const Drop

+ const Reject

+ type LinkRule struct

+ Subnet net.IPNet

+ type LinkShape struct

+ Bandwidth uint64

+ Corrupt float32

+ CorruptCorr float32

+ Duplicate float32

+ DuplicateCorr float32

+ Filter FilterAction

+ Jitter time.Duration

+ Latency time.Duration

+ Loss float32

+ Reorder float32

+ ReorderCorr float32

+ type NetworkConfig struct

+ Default LinkShape

+ Enable bool

+ IPv4 *net.IPNet

+ IPv6 *net.IPNet

+ Network string

+ Rules []LinkRule

+ State State

+ type State string

+ func (s State) Key(rp *runtime.RunParams) string

+ type Subscription struct

+ func (s *Subscription) Done() <-chan error

+ type Topic struct

+ func NetworkTopic(container string) *Topic

+ func NewTopic(name string, typ interface{}) *Topic

+ func (t Topic) Key(rp *runtime.RunParams) string

v0.1.0

Apr 22, 2020

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL