volumecontrol

func CreateGrpcAllowedExecutables(
	allowedExecutablesList []*lifetimesapi.AllowedExecutable) (
	map[string]*volumecontrolapi.Executable, error)

func CreateGrpcExecutablesDiffs(
	oldLifetimeSpec *lifetimesapi.LifetimeSpec,
	newLifetimeSpec *lifetimesapi.LifetimeSpec) (
	map[string]*volumecontrolapi.ExecutablesDiffs, error)

func CreateGrpcMessageQueue(
	dataClient coreclientset.Interface, kubeClient kubernetes.Interface,
	messageQueueSpec *lifetimesapi.PublishMessageQueueSpec, topic string,
	messageQueuePublisherOptions *mqpub.MessageQueuePublisherOptions) (
	*volumecontrolapi.MessageQueue, error)

func CreateGrpcMessageQueueDiffs(
	dataClient coreclientset.Interface, kubeClient kubernetes.Interface,
	messageQueuePublisherOptions *mqpub.MessageQueuePublisherOptions,
	oldOutputDataSpec []lifetimesapi.OutputDataSpec,
	newOutputDataSpec []lifetimesapi.OutputDataSpec) (
	map[string]*volumecontrolapi.MessageQueue, error)