model

package

v1.1.1 Latest Latest Go to latest Published: Mar 5, 2020 License: MIT Imports: 3 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

type SyncModel struct {
	*sb.Scuttlebutt
	// contains filtered or unexported fields
}

MemoryModel 的操作不考虑“同步” 同步由 MemoryModel 间 Stream 负责即业务和 IO 分离

func NewSyncModel(opts ...sb.Option) *SyncModel

func (s *SyncModel) ApplyUpdates(update *sb.Update) bool

func (s *SyncModel) CreateReadStream(opts ...duplex.Option) *duplex.Duplex

func (s *SyncModel) CreateSinkStream(opts ...duplex.Option) *duplex.Duplex

func (s *SyncModel) CreateSourceStream(opts ...duplex.Option) *duplex.Duplex

func (s *SyncModel) CreateStream(opts ...duplex.Option) *duplex.Duplex

func (s *SyncModel) CreateWriteStream(opts ...duplex.Option) *duplex.Duplex

func (s *SyncModel) Get(k string, withClock bool) interface{}

func (s *SyncModel) History(peerSources sb.Sources, accept *sb.ModelAccept) []*sb.Update

func (s *SyncModel) IsAccepted(peerAccept *sb.ModelAccept, update *sb.Update) bool

func (s *SyncModel) Keys() []string

func (s *SyncModel) Set(k string, v interface{}) *SyncModel

type ValueModel struct {
	K string
	V interface{}
}

type ValueModelFrom struct {
	*ValueModel
	From sb.SourceId
}