storage

Documentation

Index

• Variables
• func AddSiloEventNotification(s Provider, state EventType, callback EventCallback) bool
• func Equals(sp1 Provider, sp2 Provider, blockSize int) (bool, error)
• func MapOverBlocks(offset int64, length int32, blockSize int, f func(b int, complete bool))
• type BlockInfo
• type BlockOrder
• type EventCallback
• type EventData
• type EventReturnData
  • func SendSiloEvent(s Provider, eventType EventType, eventData EventData) []EventReturnData
• type EventType
• type ExposedStorage
• type LockableProvider
• type Provider
• type ProviderWithEvents
  • func (spl *ProviderWithEvents) AddSiloEventNotification(eventType EventType, callback EventCallback)
  • func (spl *ProviderWithEvents) SendSiloEvent(eventType EventType, eventData EventData) []EventReturnData
• type ProviderWithEventsIfc
• type SyncStartConfig
• type TrackingProvider

Variables

var BlockInfoFinish = &BlockInfo{Block: -1}

var BlockTypeAny = -1

var BlockTypeDirty = 1

var BlockTypePriority = 2

var BlockTypeStandard = 0

Functions

func AddSiloEventNotification

func AddSiloEventNotification(s Provider, state EventType, callback EventCallback) bool

Try to add an event notification on a StorageProvider

func Equals

func Equals(sp1 Provider, sp2 Provider, blockSize int) (bool, error)

*

• Check if two storageProviders hold the same data. *

func MapOverBlocks

func MapOverBlocks(offset int64, length int32, blockSize int, f func(b int, complete bool))

*

• Map a function over blocks within the range. *

Types

type BlockInfo

type BlockInfo struct {
	Block int
	Type  int
}

type BlockOrder

type BlockOrder interface {
	AddAll()
	Add(block int)
	Remove(block int)
	GetNext() *BlockInfo
}

type EventCallback

type EventCallback func(event EventType, data EventData) EventReturnData

type EventData

type EventData interface{}

type EventReturnData

type EventReturnData interface{}

func SendSiloEvent

func SendSiloEvent(s Provider, eventType EventType, eventData EventData) []EventReturnData

Try to send an event for a given StorageProvider

type EventType

type EventType string

*

• A StorageProvider can simply embed StorageProviderWithEvents to support events *

type ExposedStorage

type ExposedStorage interface {
	Init() error
	Shutdown() error
	Device() string
	SetProvider(prov Provider)
}

type LockableProvider

type LockableProvider interface {
	Provider
	Lock()
	Unlock()
}

type Provider

type Provider interface {
	io.ReaderAt
	io.WriterAt
	Size() uint64
	Flush() error
	Close() error
	CancelWrites(offset int64, length int64)
}

type ProviderWithEvents

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

func (*ProviderWithEvents) AddSiloEventNotification

func (spl *ProviderWithEvents) AddSiloEventNotification(eventType EventType, callback EventCallback)

Add a new callback for the given state.

func (*ProviderWithEvents) SendSiloEvent

func (spl *ProviderWithEvents) SendSiloEvent(eventType EventType, eventData EventData) []EventReturnData

Send an event, and notify any callbacks

type ProviderWithEventsIfc

type ProviderWithEventsIfc interface {
	Provider
	SendSiloEvent(EventType, EventData) []EventReturnData
	AddSiloEventNotification(EventType, EventCallback)
}

type SyncStartConfig

type SyncStartConfig struct {
	AlternateSources []packets.AlternateSource
	Destination      Provider
}

type TrackingProvider

type TrackingProvider interface {
	Provider
	Sync() *util.Bitfield
}