protoactor-go: github.com/AsynkronIT/protoactor-go/persistence Index | Files

package persistence

import "github.com/AsynkronIT/protoactor-go/persistence"

Index

Package Files

in_memory_provider.go messages.go persistence_provider.go plugin.go receiver.go

func Using Uses

func Using(provider Provider) func(next actor.ActorFunc) actor.ActorFunc

type InMemoryProvider Uses

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

func NewInMemoryProvider Uses

func NewInMemoryProvider(snapshotInterval int) *InMemoryProvider

func (*InMemoryProvider) GetEvents Uses

func (provider *InMemoryProvider) GetEvents(actorName string, eventIndexStart int, callback func(e interface{}))

func (*InMemoryProvider) GetSnapshot Uses

func (provider *InMemoryProvider) GetSnapshot(actorName string) (snapshot interface{}, eventIndex int, ok bool)

func (*InMemoryProvider) GetSnapshotInterval Uses

func (provider *InMemoryProvider) GetSnapshotInterval() int

func (*InMemoryProvider) PersistEvent Uses

func (provider *InMemoryProvider) PersistEvent(actorName string, eventIndex int, event proto.Message)

func (*InMemoryProvider) PersistSnapshot Uses

func (provider *InMemoryProvider) PersistSnapshot(actorName string, eventIndex int, snapshot proto.Message)

func (*InMemoryProvider) Restart Uses

func (provider *InMemoryProvider) Restart()

type Mixin Uses

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

func (*Mixin) Name Uses

func (mixin *Mixin) Name() string

func (*Mixin) PersistReceive Uses

func (mixin *Mixin) PersistReceive(message proto.Message)

func (*Mixin) PersistSnapshot Uses

func (mixin *Mixin) PersistSnapshot(snapshot proto.Message)

func (*Mixin) Recovering Uses

func (mixin *Mixin) Recovering() bool

type OfferSnapshot Uses

type OfferSnapshot struct {
    Snapshot interface{}
}

type Provider Uses

type Provider interface {
    GetState() ProviderState
}

Provider is the abstraction used for persistence

type ProviderState Uses

type ProviderState interface {
    Restart()
    GetSnapshotInterval() int
    GetSnapshot(actorName string) (snapshot interface{}, eventIndex int, ok bool)
    GetEvents(actorName string, eventIndexStart int, callback func(e interface{}))
    PersistEvent(actorName string, eventIndex int, event proto.Message)
    PersistSnapshot(actorName string, eventIndex int, snapshot proto.Message)
}

type Replay Uses

type Replay struct{}

type ReplayComplete Uses

type ReplayComplete struct{}

type RequestSnapshot Uses

type RequestSnapshot struct{}

Package persistence imports 5 packages (graph). Updated 2017-08-08. Refresh now. Tools for package owners.