manifest

Documentation

Index

• func DeleteManifestDevice(ctx context.Context, etcdClient *etcd.Client, descriptor string) error
• func DeleteMultipleManifestDevices(ctx context.Context, etcdClient *etcd.Client, descprefix string) (int64, error)
• func GetLockTable(ctx context.Context, etcdClient *etcd.Client) (map[string][]string, error)
• func ObtainDeviceLock(ctx context.Context, etcdClient *etcd.Client, md *ManifestDevice, myid string) (bool, error)
• func SetEtcdKeyPrefix(prefix string)
• func UpsertManifestDevice(ctx context.Context, etcdClient *etcd.Client, md *ManifestDevice) error
• func UpsertManifestDeviceAtomically(ctx context.Context, etcdClient *etcd.Client, md *ManifestDevice) (bool, error)
• type ManifestDevice
  • func RetrieveManifestDevice(ctx context.Context, etcdClient *etcd.Client, descriptor string) (md *ManifestDevice, err error)
  • func RetrieveMultipleManifestDevices(ctx context.Context, etcdClient *etcd.Client, descprefix string) ([]*ManifestDevice, error)
  • func (md *ManifestDevice) GetRetrievedRevision() int64
  • func (md *ManifestDevice) SetRetrievedRevision(rev int64)
• type ManifestDeviceStream

Functions

func DeleteManifestDevice

func DeleteManifestDevice(ctx context.Context, etcdClient *etcd.Client, descriptor string) error

func DeleteMultipleManifestDevices

func DeleteMultipleManifestDevices(ctx context.Context, etcdClient *etcd.Client, descprefix string) (int64, error)

func GetLockTable

func GetLockTable(ctx context.Context, etcdClient *etcd.Client) (map[string][]string, error)

func ObtainDeviceLock

func ObtainDeviceLock(ctx context.Context, etcdClient *etcd.Client, md *ManifestDevice, myid string) (bool, error)

func SetEtcdKeyPrefix

func SetEtcdKeyPrefix(prefix string)

func UpsertManifestDevice

func UpsertManifestDevice(ctx context.Context, etcdClient *etcd.Client, md *ManifestDevice) error

func UpsertManifestDeviceAtomically

func UpsertManifestDeviceAtomically(ctx context.Context, etcdClient *etcd.Client, md *ManifestDevice) (bool, error)

Types

type ManifestDevice

type ManifestDevice struct {
	Descriptor string                           `codec:"-" yaml:"-"`
	Metadata   map[string]string                `codec:"metadata,omitempty" yaml:"metadata"`
	Streams    map[string]*ManifestDeviceStream `codec:"streams" yaml:"streams"`
	// contains filtered or unexported fields
}

func RetrieveManifestDevice

func RetrieveManifestDevice(ctx context.Context, etcdClient *etcd.Client, descriptor string) (md *ManifestDevice, err error)

func RetrieveMultipleManifestDevices

func RetrieveMultipleManifestDevices(ctx context.Context, etcdClient *etcd.Client, descprefix string) ([]*ManifestDevice, error)

func (*ManifestDevice) GetRetrievedRevision

func (md *ManifestDevice) GetRetrievedRevision() int64

func (*ManifestDevice) SetRetrievedRevision

func (md *ManifestDevice) SetRetrievedRevision(rev int64)

type ManifestDeviceStream

type ManifestDeviceStream struct {
	CanonicalName string            `codec:"-" yaml:"-"`
	Metadata      map[string]string `codec:"metadata,omitempty" yaml:"metadata"`
}