daemonsetstore

Documentation

Index

• func ProtoDSToRawDS(protoDS *daemonsetstore_protos.DaemonSet) (fields.DaemonSet, error)
• func RawDSToProtoDS(rawDS fields.DaemonSet) (*daemonsetstore_protos.DaemonSet, error)
• type ConsulStore
• type Store
  • func NewServer(consulStore ConsulStore) Store
  • func (s Store) DisableDaemonSet(_ context.Context, req *daemonsetstore_protos.DisableDaemonSetRequest) (*daemonsetstore_protos.DisableDaemonSetResponse, error)
  • func (s Store) ListDaemonSets(_ context.Context, _ *daemonsetstore_protos.ListDaemonSetsRequest) (*daemonsetstore_protos.ListDaemonSetsResponse, error)
  • func (s Store) WatchDaemonSets(_ *daemonsetstore_protos.WatchDaemonSetsRequest, ...) error

Functions

func ProtoDSToRawDS

func ProtoDSToRawDS(protoDS *daemonsetstore_protos.DaemonSet) (fields.DaemonSet, error)

func RawDSToProtoDS

func RawDSToProtoDS(rawDS fields.DaemonSet) (*daemonsetstore_protos.DaemonSet, error)

Types

type ConsulStore

type ConsulStore interface {
	List() ([]fields.DaemonSet, error)
	Disable(id fields.ID) (fields.DaemonSet, error)
	Watch(quitCh <-chan struct{}) <-chan dsstore.WatchedDaemonSets
}

type Store

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

func NewServer

func NewServer(consulStore ConsulStore) Store

func (Store) DisableDaemonSet

func (s Store) DisableDaemonSet(_ context.Context, req *daemonsetstore_protos.DisableDaemonSetRequest) (*daemonsetstore_protos.DisableDaemonSetResponse, error)

func (Store) ListDaemonSets

func (s Store) ListDaemonSets(_ context.Context, _ *daemonsetstore_protos.ListDaemonSetsRequest) (*daemonsetstore_protos.ListDaemonSetsResponse, error)

func (Store) WatchDaemonSets

func (s Store) WatchDaemonSets(_ *daemonsetstore_protos.WatchDaemonSetsRequest, stream daemonsetstore_protos.P2DaemonSetStore_WatchDaemonSetsServer) error