builtin

Documentation

Index

• Constants
• type CloudBucket
  • func NewCloudBucket(nodeID string, storageDriver StorageDriver, merkleDepth uint8, mode int) (*CloudBucket, error)
  • func (cloudBucket *CloudBucket) Name() string
  • func (cloudBucket *CloudBucket) ShouldAcceptReads(clientID string) bool
  • func (cloudBucket *CloudBucket) ShouldAcceptWrites(clientID string) bool
  • func (cloudBucket *CloudBucket) ShouldReplicateIncoming(peerID string) bool
  • func (cloudBucket *CloudBucket) ShouldReplicateOutgoing(peerID string) bool
• type DefaultBucket
  • func NewDefaultBucket(nodeID string, storageDriver StorageDriver, merkleDepth uint8) (*DefaultBucket, error)
  • func (defaultBucket *DefaultBucket) Name() string
  • func (defaultBucket *DefaultBucket) ShouldAcceptReads(clientID string) bool
  • func (defaultBucket *DefaultBucket) ShouldAcceptWrites(clientID string) bool
  • func (defaultBucket *DefaultBucket) ShouldReplicateIncoming(peerID string) bool
  • func (defaultBucket *DefaultBucket) ShouldReplicateOutgoing(peerID string) bool
• type LWWBucket
  • func NewLWWBucket(nodeID string, storageDriver StorageDriver, merkleDepth uint8) (*LWWBucket, error)
  • func (lwwBucket *LWWBucket) Name() string
  • func (lwwBucket *LWWBucket) ShouldAcceptReads(clientID string) bool
  • func (lwwBucket *LWWBucket) ShouldAcceptWrites(clientID string) bool
  • func (lwwBucket *LWWBucket) ShouldReplicateIncoming(peerID string) bool
  • func (lwwBucket *LWWBucket) ShouldReplicateOutgoing(peerID string) bool
• type LocalBucket
  • func NewLocalBucket(nodeID string, storageDriver StorageDriver, merkleDepth uint8) (*LocalBucket, error)
  • func (localBucket *LocalBucket) Name() string
  • func (localBucket *LocalBucket) ShouldAcceptReads(clientID string) bool
  • func (localBucket *LocalBucket) ShouldAcceptWrites(clientID string) bool
  • func (localBucket *LocalBucket) ShouldReplicateIncoming(peerID string) bool
  • func (localBucket *LocalBucket) ShouldReplicateOutgoing(peerID string) bool

Constants

const (
	CloudMode   = iota
	RelayMode   = iota
	CloudPeerID = "cloud"
)

Types

type CloudBucket

type CloudBucket struct {
	Store
	// contains filtered or unexported fields
}

func NewCloudBucket

func NewCloudBucket(nodeID string, storageDriver StorageDriver, merkleDepth uint8, mode int) (*CloudBucket, error)

func (*CloudBucket) Name

func (cloudBucket *CloudBucket) Name() string

func (*CloudBucket) ShouldAcceptReads

func (cloudBucket *CloudBucket) ShouldAcceptReads(clientID string) bool

func (*CloudBucket) ShouldAcceptWrites

func (cloudBucket *CloudBucket) ShouldAcceptWrites(clientID string) bool

func (*CloudBucket) ShouldReplicateIncoming

func (cloudBucket *CloudBucket) ShouldReplicateIncoming(peerID string) bool

func (*CloudBucket) ShouldReplicateOutgoing

func (cloudBucket *CloudBucket) ShouldReplicateOutgoing(peerID string) bool

type DefaultBucket

type DefaultBucket struct {
	Store
}

func NewDefaultBucket

func NewDefaultBucket(nodeID string, storageDriver StorageDriver, merkleDepth uint8) (*DefaultBucket, error)

func (*DefaultBucket) Name

func (defaultBucket *DefaultBucket) Name() string

func (*DefaultBucket) ShouldAcceptReads

func (defaultBucket *DefaultBucket) ShouldAcceptReads(clientID string) bool

func (*DefaultBucket) ShouldAcceptWrites

func (defaultBucket *DefaultBucket) ShouldAcceptWrites(clientID string) bool

func (*DefaultBucket) ShouldReplicateIncoming

func (defaultBucket *DefaultBucket) ShouldReplicateIncoming(peerID string) bool

func (*DefaultBucket) ShouldReplicateOutgoing

func (defaultBucket *DefaultBucket) ShouldReplicateOutgoing(peerID string) bool

type LWWBucket

type LWWBucket struct {
	Store
}

func NewLWWBucket

func NewLWWBucket(nodeID string, storageDriver StorageDriver, merkleDepth uint8) (*LWWBucket, error)

func (*LWWBucket) Name

func (lwwBucket *LWWBucket) Name() string

func (*LWWBucket) ShouldAcceptReads

func (lwwBucket *LWWBucket) ShouldAcceptReads(clientID string) bool

func (*LWWBucket) ShouldAcceptWrites

func (lwwBucket *LWWBucket) ShouldAcceptWrites(clientID string) bool

func (*LWWBucket) ShouldReplicateIncoming

func (lwwBucket *LWWBucket) ShouldReplicateIncoming(peerID string) bool

func (*LWWBucket) ShouldReplicateOutgoing

func (lwwBucket *LWWBucket) ShouldReplicateOutgoing(peerID string) bool

type LocalBucket

type LocalBucket struct {
	Store
}

func NewLocalBucket

func NewLocalBucket(nodeID string, storageDriver StorageDriver, merkleDepth uint8) (*LocalBucket, error)

func (*LocalBucket) Name

func (localBucket *LocalBucket) Name() string

func (*LocalBucket) ShouldAcceptReads

func (localBucket *LocalBucket) ShouldAcceptReads(clientID string) bool

func (*LocalBucket) ShouldAcceptWrites

func (localBucket *LocalBucket) ShouldAcceptWrites(clientID string) bool

func (*LocalBucket) ShouldReplicateIncoming

func (localBucket *LocalBucket) ShouldReplicateIncoming(peerID string) bool

func (*LocalBucket) ShouldReplicateOutgoing

func (localBucket *LocalBucket) ShouldReplicateOutgoing(peerID string) bool