studio_topology

package
v0.0.0-...-2d9b47a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 5, 2025 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

View Source
const (
	DecommissionService_GetOne_FullMethodName           = "/arista.studio_topology.v1.DecommissionService/GetOne"
	DecommissionService_GetSome_FullMethodName          = "/arista.studio_topology.v1.DecommissionService/GetSome"
	DecommissionService_GetAll_FullMethodName           = "/arista.studio_topology.v1.DecommissionService/GetAll"
	DecommissionService_Subscribe_FullMethodName        = "/arista.studio_topology.v1.DecommissionService/Subscribe"
	DecommissionService_GetMeta_FullMethodName          = "/arista.studio_topology.v1.DecommissionService/GetMeta"
	DecommissionService_SubscribeMeta_FullMethodName    = "/arista.studio_topology.v1.DecommissionService/SubscribeMeta"
	DecommissionService_GetAllBatched_FullMethodName    = "/arista.studio_topology.v1.DecommissionService/GetAllBatched"
	DecommissionService_SubscribeBatched_FullMethodName = "/arista.studio_topology.v1.DecommissionService/SubscribeBatched"
)
View Source
const (
	DecommissionConfigService_GetOne_FullMethodName           = "/arista.studio_topology.v1.DecommissionConfigService/GetOne"
	DecommissionConfigService_GetSome_FullMethodName          = "/arista.studio_topology.v1.DecommissionConfigService/GetSome"
	DecommissionConfigService_GetAll_FullMethodName           = "/arista.studio_topology.v1.DecommissionConfigService/GetAll"
	DecommissionConfigService_Subscribe_FullMethodName        = "/arista.studio_topology.v1.DecommissionConfigService/Subscribe"
	DecommissionConfigService_GetMeta_FullMethodName          = "/arista.studio_topology.v1.DecommissionConfigService/GetMeta"
	DecommissionConfigService_SubscribeMeta_FullMethodName    = "/arista.studio_topology.v1.DecommissionConfigService/SubscribeMeta"
	DecommissionConfigService_Set_FullMethodName              = "/arista.studio_topology.v1.DecommissionConfigService/Set"
	DecommissionConfigService_SetSome_FullMethodName          = "/arista.studio_topology.v1.DecommissionConfigService/SetSome"
	DecommissionConfigService_Delete_FullMethodName           = "/arista.studio_topology.v1.DecommissionConfigService/Delete"
	DecommissionConfigService_DeleteSome_FullMethodName       = "/arista.studio_topology.v1.DecommissionConfigService/DeleteSome"
	DecommissionConfigService_DeleteAll_FullMethodName        = "/arista.studio_topology.v1.DecommissionConfigService/DeleteAll"
	DecommissionConfigService_GetAllBatched_FullMethodName    = "/arista.studio_topology.v1.DecommissionConfigService/GetAllBatched"
	DecommissionConfigService_SubscribeBatched_FullMethodName = "/arista.studio_topology.v1.DecommissionConfigService/SubscribeBatched"
)
View Source
const (
	DeviceInputConfigService_GetOne_FullMethodName           = "/arista.studio_topology.v1.DeviceInputConfigService/GetOne"
	DeviceInputConfigService_GetSome_FullMethodName          = "/arista.studio_topology.v1.DeviceInputConfigService/GetSome"
	DeviceInputConfigService_GetAll_FullMethodName           = "/arista.studio_topology.v1.DeviceInputConfigService/GetAll"
	DeviceInputConfigService_Subscribe_FullMethodName        = "/arista.studio_topology.v1.DeviceInputConfigService/Subscribe"
	DeviceInputConfigService_GetMeta_FullMethodName          = "/arista.studio_topology.v1.DeviceInputConfigService/GetMeta"
	DeviceInputConfigService_SubscribeMeta_FullMethodName    = "/arista.studio_topology.v1.DeviceInputConfigService/SubscribeMeta"
	DeviceInputConfigService_Set_FullMethodName              = "/arista.studio_topology.v1.DeviceInputConfigService/Set"
	DeviceInputConfigService_SetSome_FullMethodName          = "/arista.studio_topology.v1.DeviceInputConfigService/SetSome"
	DeviceInputConfigService_Delete_FullMethodName           = "/arista.studio_topology.v1.DeviceInputConfigService/Delete"
	DeviceInputConfigService_DeleteSome_FullMethodName       = "/arista.studio_topology.v1.DeviceInputConfigService/DeleteSome"
	DeviceInputConfigService_DeleteAll_FullMethodName        = "/arista.studio_topology.v1.DeviceInputConfigService/DeleteAll"
	DeviceInputConfigService_GetAllBatched_FullMethodName    = "/arista.studio_topology.v1.DeviceInputConfigService/GetAllBatched"
	DeviceInputConfigService_SubscribeBatched_FullMethodName = "/arista.studio_topology.v1.DeviceInputConfigService/SubscribeBatched"
)
View Source
const (
	DeviceStateService_GetOne_FullMethodName           = "/arista.studio_topology.v1.DeviceStateService/GetOne"
	DeviceStateService_GetSome_FullMethodName          = "/arista.studio_topology.v1.DeviceStateService/GetSome"
	DeviceStateService_GetAll_FullMethodName           = "/arista.studio_topology.v1.DeviceStateService/GetAll"
	DeviceStateService_Subscribe_FullMethodName        = "/arista.studio_topology.v1.DeviceStateService/Subscribe"
	DeviceStateService_GetMeta_FullMethodName          = "/arista.studio_topology.v1.DeviceStateService/GetMeta"
	DeviceStateService_SubscribeMeta_FullMethodName    = "/arista.studio_topology.v1.DeviceStateService/SubscribeMeta"
	DeviceStateService_GetAllBatched_FullMethodName    = "/arista.studio_topology.v1.DeviceStateService/GetAllBatched"
	DeviceStateService_SubscribeBatched_FullMethodName = "/arista.studio_topology.v1.DeviceStateService/SubscribeBatched"
)
View Source
const (
	InterfaceInputConfigService_GetOne_FullMethodName           = "/arista.studio_topology.v1.InterfaceInputConfigService/GetOne"
	InterfaceInputConfigService_GetSome_FullMethodName          = "/arista.studio_topology.v1.InterfaceInputConfigService/GetSome"
	InterfaceInputConfigService_GetAll_FullMethodName           = "/arista.studio_topology.v1.InterfaceInputConfigService/GetAll"
	InterfaceInputConfigService_Subscribe_FullMethodName        = "/arista.studio_topology.v1.InterfaceInputConfigService/Subscribe"
	InterfaceInputConfigService_GetMeta_FullMethodName          = "/arista.studio_topology.v1.InterfaceInputConfigService/GetMeta"
	InterfaceInputConfigService_SubscribeMeta_FullMethodName    = "/arista.studio_topology.v1.InterfaceInputConfigService/SubscribeMeta"
	InterfaceInputConfigService_Set_FullMethodName              = "/arista.studio_topology.v1.InterfaceInputConfigService/Set"
	InterfaceInputConfigService_SetSome_FullMethodName          = "/arista.studio_topology.v1.InterfaceInputConfigService/SetSome"
	InterfaceInputConfigService_Delete_FullMethodName           = "/arista.studio_topology.v1.InterfaceInputConfigService/Delete"
	InterfaceInputConfigService_DeleteSome_FullMethodName       = "/arista.studio_topology.v1.InterfaceInputConfigService/DeleteSome"
	InterfaceInputConfigService_DeleteAll_FullMethodName        = "/arista.studio_topology.v1.InterfaceInputConfigService/DeleteAll"
	InterfaceInputConfigService_GetAllBatched_FullMethodName    = "/arista.studio_topology.v1.InterfaceInputConfigService/GetAllBatched"
	InterfaceInputConfigService_SubscribeBatched_FullMethodName = "/arista.studio_topology.v1.InterfaceInputConfigService/SubscribeBatched"
)
View Source
const (
	ReplaceService_GetOne_FullMethodName           = "/arista.studio_topology.v1.ReplaceService/GetOne"
	ReplaceService_GetSome_FullMethodName          = "/arista.studio_topology.v1.ReplaceService/GetSome"
	ReplaceService_GetAll_FullMethodName           = "/arista.studio_topology.v1.ReplaceService/GetAll"
	ReplaceService_Subscribe_FullMethodName        = "/arista.studio_topology.v1.ReplaceService/Subscribe"
	ReplaceService_GetMeta_FullMethodName          = "/arista.studio_topology.v1.ReplaceService/GetMeta"
	ReplaceService_SubscribeMeta_FullMethodName    = "/arista.studio_topology.v1.ReplaceService/SubscribeMeta"
	ReplaceService_GetAllBatched_FullMethodName    = "/arista.studio_topology.v1.ReplaceService/GetAllBatched"
	ReplaceService_SubscribeBatched_FullMethodName = "/arista.studio_topology.v1.ReplaceService/SubscribeBatched"
)
View Source
const (
	ReplaceConfigService_GetOne_FullMethodName           = "/arista.studio_topology.v1.ReplaceConfigService/GetOne"
	ReplaceConfigService_GetSome_FullMethodName          = "/arista.studio_topology.v1.ReplaceConfigService/GetSome"
	ReplaceConfigService_GetAll_FullMethodName           = "/arista.studio_topology.v1.ReplaceConfigService/GetAll"
	ReplaceConfigService_Subscribe_FullMethodName        = "/arista.studio_topology.v1.ReplaceConfigService/Subscribe"
	ReplaceConfigService_GetMeta_FullMethodName          = "/arista.studio_topology.v1.ReplaceConfigService/GetMeta"
	ReplaceConfigService_SubscribeMeta_FullMethodName    = "/arista.studio_topology.v1.ReplaceConfigService/SubscribeMeta"
	ReplaceConfigService_Set_FullMethodName              = "/arista.studio_topology.v1.ReplaceConfigService/Set"
	ReplaceConfigService_SetSome_FullMethodName          = "/arista.studio_topology.v1.ReplaceConfigService/SetSome"
	ReplaceConfigService_Delete_FullMethodName           = "/arista.studio_topology.v1.ReplaceConfigService/Delete"
	ReplaceConfigService_DeleteSome_FullMethodName       = "/arista.studio_topology.v1.ReplaceConfigService/DeleteSome"
	ReplaceConfigService_DeleteAll_FullMethodName        = "/arista.studio_topology.v1.ReplaceConfigService/DeleteAll"
	ReplaceConfigService_GetAllBatched_FullMethodName    = "/arista.studio_topology.v1.ReplaceConfigService/GetAllBatched"
	ReplaceConfigService_SubscribeBatched_FullMethodName = "/arista.studio_topology.v1.ReplaceConfigService/SubscribeBatched"
)
View Source
const (
	RevertConfigService_GetOne_FullMethodName           = "/arista.studio_topology.v1.RevertConfigService/GetOne"
	RevertConfigService_GetSome_FullMethodName          = "/arista.studio_topology.v1.RevertConfigService/GetSome"
	RevertConfigService_GetAll_FullMethodName           = "/arista.studio_topology.v1.RevertConfigService/GetAll"
	RevertConfigService_Subscribe_FullMethodName        = "/arista.studio_topology.v1.RevertConfigService/Subscribe"
	RevertConfigService_GetMeta_FullMethodName          = "/arista.studio_topology.v1.RevertConfigService/GetMeta"
	RevertConfigService_SubscribeMeta_FullMethodName    = "/arista.studio_topology.v1.RevertConfigService/SubscribeMeta"
	RevertConfigService_Set_FullMethodName              = "/arista.studio_topology.v1.RevertConfigService/Set"
	RevertConfigService_SetSome_FullMethodName          = "/arista.studio_topology.v1.RevertConfigService/SetSome"
	RevertConfigService_Delete_FullMethodName           = "/arista.studio_topology.v1.RevertConfigService/Delete"
	RevertConfigService_DeleteSome_FullMethodName       = "/arista.studio_topology.v1.RevertConfigService/DeleteSome"
	RevertConfigService_DeleteAll_FullMethodName        = "/arista.studio_topology.v1.RevertConfigService/DeleteAll"
	RevertConfigService_GetAllBatched_FullMethodName    = "/arista.studio_topology.v1.RevertConfigService/GetAllBatched"
	RevertConfigService_SubscribeBatched_FullMethodName = "/arista.studio_topology.v1.RevertConfigService/SubscribeBatched"
)
View Source
const (
	UpdateService_GetOne_FullMethodName           = "/arista.studio_topology.v1.UpdateService/GetOne"
	UpdateService_GetSome_FullMethodName          = "/arista.studio_topology.v1.UpdateService/GetSome"
	UpdateService_GetAll_FullMethodName           = "/arista.studio_topology.v1.UpdateService/GetAll"
	UpdateService_Subscribe_FullMethodName        = "/arista.studio_topology.v1.UpdateService/Subscribe"
	UpdateService_GetMeta_FullMethodName          = "/arista.studio_topology.v1.UpdateService/GetMeta"
	UpdateService_SubscribeMeta_FullMethodName    = "/arista.studio_topology.v1.UpdateService/SubscribeMeta"
	UpdateService_GetAllBatched_FullMethodName    = "/arista.studio_topology.v1.UpdateService/GetAllBatched"
	UpdateService_SubscribeBatched_FullMethodName = "/arista.studio_topology.v1.UpdateService/SubscribeBatched"
)
View Source
const (
	UpdateConfigService_GetOne_FullMethodName           = "/arista.studio_topology.v1.UpdateConfigService/GetOne"
	UpdateConfigService_GetSome_FullMethodName          = "/arista.studio_topology.v1.UpdateConfigService/GetSome"
	UpdateConfigService_GetAll_FullMethodName           = "/arista.studio_topology.v1.UpdateConfigService/GetAll"
	UpdateConfigService_Subscribe_FullMethodName        = "/arista.studio_topology.v1.UpdateConfigService/Subscribe"
	UpdateConfigService_GetMeta_FullMethodName          = "/arista.studio_topology.v1.UpdateConfigService/GetMeta"
	UpdateConfigService_SubscribeMeta_FullMethodName    = "/arista.studio_topology.v1.UpdateConfigService/SubscribeMeta"
	UpdateConfigService_Set_FullMethodName              = "/arista.studio_topology.v1.UpdateConfigService/Set"
	UpdateConfigService_SetSome_FullMethodName          = "/arista.studio_topology.v1.UpdateConfigService/SetSome"
	UpdateConfigService_Delete_FullMethodName           = "/arista.studio_topology.v1.UpdateConfigService/Delete"
	UpdateConfigService_DeleteSome_FullMethodName       = "/arista.studio_topology.v1.UpdateConfigService/DeleteSome"
	UpdateConfigService_DeleteAll_FullMethodName        = "/arista.studio_topology.v1.UpdateConfigService/DeleteAll"
	UpdateConfigService_GetAllBatched_FullMethodName    = "/arista.studio_topology.v1.UpdateConfigService/GetAllBatched"
	UpdateConfigService_SubscribeBatched_FullMethodName = "/arista.studio_topology.v1.UpdateConfigService/SubscribeBatched"
)
View Source
const (
	UpdateSyncConfigService_GetOne_FullMethodName           = "/arista.studio_topology.v1.UpdateSyncConfigService/GetOne"
	UpdateSyncConfigService_GetSome_FullMethodName          = "/arista.studio_topology.v1.UpdateSyncConfigService/GetSome"
	UpdateSyncConfigService_GetAll_FullMethodName           = "/arista.studio_topology.v1.UpdateSyncConfigService/GetAll"
	UpdateSyncConfigService_Subscribe_FullMethodName        = "/arista.studio_topology.v1.UpdateSyncConfigService/Subscribe"
	UpdateSyncConfigService_GetMeta_FullMethodName          = "/arista.studio_topology.v1.UpdateSyncConfigService/GetMeta"
	UpdateSyncConfigService_SubscribeMeta_FullMethodName    = "/arista.studio_topology.v1.UpdateSyncConfigService/SubscribeMeta"
	UpdateSyncConfigService_Set_FullMethodName              = "/arista.studio_topology.v1.UpdateSyncConfigService/Set"
	UpdateSyncConfigService_SetSome_FullMethodName          = "/arista.studio_topology.v1.UpdateSyncConfigService/SetSome"
	UpdateSyncConfigService_Delete_FullMethodName           = "/arista.studio_topology.v1.UpdateSyncConfigService/Delete"
	UpdateSyncConfigService_DeleteSome_FullMethodName       = "/arista.studio_topology.v1.UpdateSyncConfigService/DeleteSome"
	UpdateSyncConfigService_DeleteAll_FullMethodName        = "/arista.studio_topology.v1.UpdateSyncConfigService/DeleteAll"
	UpdateSyncConfigService_GetAllBatched_FullMethodName    = "/arista.studio_topology.v1.UpdateSyncConfigService/GetAllBatched"
	UpdateSyncConfigService_SubscribeBatched_FullMethodName = "/arista.studio_topology.v1.UpdateSyncConfigService/SubscribeBatched"
)

Variables

View Source
var (
	Element_name = map[int32]string{
		0: "ELEMENT_UNSPECIFIED",
		1: "ELEMENT_DEVICE",
		2: "ELEMENT_INTERFACE",
		3: "ELEMENT_CONNECTION",
	}
	Element_value = map[string]int32{
		"ELEMENT_UNSPECIFIED": 0,
		"ELEMENT_DEVICE":      1,
		"ELEMENT_INTERFACE":   2,
		"ELEMENT_CONNECTION":  3,
	}
)

Enum value maps for Element.

View Source
var (
	Operation_name = map[int32]string{
		0: "OPERATION_UNSPECIFIED",
		1: "OPERATION_ADDED",
		2: "OPERATION_MODIFIED",
		3: "OPERATION_REMOVED",
	}
	Operation_value = map[string]int32{
		"OPERATION_UNSPECIFIED": 0,
		"OPERATION_ADDED":       1,
		"OPERATION_MODIFIED":    2,
		"OPERATION_REMOVED":     3,
	}
)

Enum value maps for Operation.

View Source
var (
	UpdateStatus_name = map[int32]string{
		0: "UPDATE_STATUS_UNSPECIFIED",
		1: "UPDATE_STATUS_NEW",
		2: "UPDATE_STATUS_ACCEPTED",
		3: "UPDATE_STATUS_IGNORED",
	}
	UpdateStatus_value = map[string]int32{
		"UPDATE_STATUS_UNSPECIFIED": 0,
		"UPDATE_STATUS_NEW":         1,
		"UPDATE_STATUS_ACCEPTED":    2,
		"UPDATE_STATUS_IGNORED":     3,
	}
)

Enum value maps for UpdateStatus.

View Source
var (
	DecommissionStatus_name = map[int32]string{
		0: "DECOMMISSION_STATUS_UNSPECIFIED",
		1: "DECOMMISSION_STATUS_SUCCESS",
		2: "DECOMMISSION_STATUS_FAILURE",
	}
	DecommissionStatus_value = map[string]int32{
		"DECOMMISSION_STATUS_UNSPECIFIED": 0,
		"DECOMMISSION_STATUS_SUCCESS":     1,
		"DECOMMISSION_STATUS_FAILURE":     2,
	}
)

Enum value maps for DecommissionStatus.

View Source
var (
	ReplaceStatus_name = map[int32]string{
		0: "REPLACE_STATUS_UNSPECIFIED",
		1: "REPLACE_STATUS_SUCCESS",
		2: "REPLACE_STATUS_FAILURE",
	}
	ReplaceStatus_value = map[string]int32{
		"REPLACE_STATUS_UNSPECIFIED": 0,
		"REPLACE_STATUS_SUCCESS":     1,
		"REPLACE_STATUS_FAILURE":     2,
	}
)

Enum value maps for ReplaceStatus.

View Source
var DecommissionConfigService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arista.studio_topology.v1.DecommissionConfigService",
	HandlerType: (*DecommissionConfigServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOne",
			Handler:    _DecommissionConfigService_GetOne_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _DecommissionConfigService_GetMeta_Handler,
		},
		{
			MethodName: "Set",
			Handler:    _DecommissionConfigService_Set_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _DecommissionConfigService_Delete_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSome",
			Handler:       _DecommissionConfigService_GetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAll",
			Handler:       _DecommissionConfigService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _DecommissionConfigService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMeta",
			Handler:       _DecommissionConfigService_SubscribeMeta_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SetSome",
			Handler:       _DecommissionConfigService_SetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeleteSome",
			Handler:       _DecommissionConfigService_DeleteSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeleteAll",
			Handler:       _DecommissionConfigService_DeleteAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAllBatched",
			Handler:       _DecommissionConfigService_GetAllBatched_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeBatched",
			Handler:       _DecommissionConfigService_SubscribeBatched_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arista/studio_topology.v1/services.gen.proto",
}

DecommissionConfigService_ServiceDesc is the grpc.ServiceDesc for DecommissionConfigService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var DecommissionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arista.studio_topology.v1.DecommissionService",
	HandlerType: (*DecommissionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOne",
			Handler:    _DecommissionService_GetOne_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _DecommissionService_GetMeta_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSome",
			Handler:       _DecommissionService_GetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAll",
			Handler:       _DecommissionService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _DecommissionService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMeta",
			Handler:       _DecommissionService_SubscribeMeta_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAllBatched",
			Handler:       _DecommissionService_GetAllBatched_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeBatched",
			Handler:       _DecommissionService_SubscribeBatched_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arista/studio_topology.v1/services.gen.proto",
}

DecommissionService_ServiceDesc is the grpc.ServiceDesc for DecommissionService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var DeviceInputConfigService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arista.studio_topology.v1.DeviceInputConfigService",
	HandlerType: (*DeviceInputConfigServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOne",
			Handler:    _DeviceInputConfigService_GetOne_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _DeviceInputConfigService_GetMeta_Handler,
		},
		{
			MethodName: "Set",
			Handler:    _DeviceInputConfigService_Set_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _DeviceInputConfigService_Delete_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSome",
			Handler:       _DeviceInputConfigService_GetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAll",
			Handler:       _DeviceInputConfigService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _DeviceInputConfigService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMeta",
			Handler:       _DeviceInputConfigService_SubscribeMeta_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SetSome",
			Handler:       _DeviceInputConfigService_SetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeleteSome",
			Handler:       _DeviceInputConfigService_DeleteSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeleteAll",
			Handler:       _DeviceInputConfigService_DeleteAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAllBatched",
			Handler:       _DeviceInputConfigService_GetAllBatched_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeBatched",
			Handler:       _DeviceInputConfigService_SubscribeBatched_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arista/studio_topology.v1/services.gen.proto",
}

DeviceInputConfigService_ServiceDesc is the grpc.ServiceDesc for DeviceInputConfigService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var DeviceStateService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arista.studio_topology.v1.DeviceStateService",
	HandlerType: (*DeviceStateServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOne",
			Handler:    _DeviceStateService_GetOne_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _DeviceStateService_GetMeta_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSome",
			Handler:       _DeviceStateService_GetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAll",
			Handler:       _DeviceStateService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _DeviceStateService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMeta",
			Handler:       _DeviceStateService_SubscribeMeta_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAllBatched",
			Handler:       _DeviceStateService_GetAllBatched_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeBatched",
			Handler:       _DeviceStateService_SubscribeBatched_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arista/studio_topology.v1/services.gen.proto",
}

DeviceStateService_ServiceDesc is the grpc.ServiceDesc for DeviceStateService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var File_arista_studio_topology_v1_services_gen_proto protoreflect.FileDescriptor
View Source
var File_arista_studio_topology_v1_studio_topology_proto protoreflect.FileDescriptor
View Source
var InterfaceInputConfigService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arista.studio_topology.v1.InterfaceInputConfigService",
	HandlerType: (*InterfaceInputConfigServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOne",
			Handler:    _InterfaceInputConfigService_GetOne_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _InterfaceInputConfigService_GetMeta_Handler,
		},
		{
			MethodName: "Set",
			Handler:    _InterfaceInputConfigService_Set_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _InterfaceInputConfigService_Delete_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSome",
			Handler:       _InterfaceInputConfigService_GetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAll",
			Handler:       _InterfaceInputConfigService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _InterfaceInputConfigService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMeta",
			Handler:       _InterfaceInputConfigService_SubscribeMeta_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SetSome",
			Handler:       _InterfaceInputConfigService_SetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeleteSome",
			Handler:       _InterfaceInputConfigService_DeleteSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeleteAll",
			Handler:       _InterfaceInputConfigService_DeleteAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAllBatched",
			Handler:       _InterfaceInputConfigService_GetAllBatched_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeBatched",
			Handler:       _InterfaceInputConfigService_SubscribeBatched_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arista/studio_topology.v1/services.gen.proto",
}

InterfaceInputConfigService_ServiceDesc is the grpc.ServiceDesc for InterfaceInputConfigService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var ReplaceConfigService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arista.studio_topology.v1.ReplaceConfigService",
	HandlerType: (*ReplaceConfigServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOne",
			Handler:    _ReplaceConfigService_GetOne_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _ReplaceConfigService_GetMeta_Handler,
		},
		{
			MethodName: "Set",
			Handler:    _ReplaceConfigService_Set_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _ReplaceConfigService_Delete_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSome",
			Handler:       _ReplaceConfigService_GetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAll",
			Handler:       _ReplaceConfigService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _ReplaceConfigService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMeta",
			Handler:       _ReplaceConfigService_SubscribeMeta_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SetSome",
			Handler:       _ReplaceConfigService_SetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeleteSome",
			Handler:       _ReplaceConfigService_DeleteSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeleteAll",
			Handler:       _ReplaceConfigService_DeleteAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAllBatched",
			Handler:       _ReplaceConfigService_GetAllBatched_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeBatched",
			Handler:       _ReplaceConfigService_SubscribeBatched_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arista/studio_topology.v1/services.gen.proto",
}

ReplaceConfigService_ServiceDesc is the grpc.ServiceDesc for ReplaceConfigService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var ReplaceService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arista.studio_topology.v1.ReplaceService",
	HandlerType: (*ReplaceServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOne",
			Handler:    _ReplaceService_GetOne_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _ReplaceService_GetMeta_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSome",
			Handler:       _ReplaceService_GetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAll",
			Handler:       _ReplaceService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _ReplaceService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMeta",
			Handler:       _ReplaceService_SubscribeMeta_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAllBatched",
			Handler:       _ReplaceService_GetAllBatched_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeBatched",
			Handler:       _ReplaceService_SubscribeBatched_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arista/studio_topology.v1/services.gen.proto",
}

ReplaceService_ServiceDesc is the grpc.ServiceDesc for ReplaceService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var RevertConfigService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arista.studio_topology.v1.RevertConfigService",
	HandlerType: (*RevertConfigServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOne",
			Handler:    _RevertConfigService_GetOne_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _RevertConfigService_GetMeta_Handler,
		},
		{
			MethodName: "Set",
			Handler:    _RevertConfigService_Set_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _RevertConfigService_Delete_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSome",
			Handler:       _RevertConfigService_GetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAll",
			Handler:       _RevertConfigService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _RevertConfigService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMeta",
			Handler:       _RevertConfigService_SubscribeMeta_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SetSome",
			Handler:       _RevertConfigService_SetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeleteSome",
			Handler:       _RevertConfigService_DeleteSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeleteAll",
			Handler:       _RevertConfigService_DeleteAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAllBatched",
			Handler:       _RevertConfigService_GetAllBatched_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeBatched",
			Handler:       _RevertConfigService_SubscribeBatched_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arista/studio_topology.v1/services.gen.proto",
}

RevertConfigService_ServiceDesc is the grpc.ServiceDesc for RevertConfigService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var UpdateConfigService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arista.studio_topology.v1.UpdateConfigService",
	HandlerType: (*UpdateConfigServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOne",
			Handler:    _UpdateConfigService_GetOne_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _UpdateConfigService_GetMeta_Handler,
		},
		{
			MethodName: "Set",
			Handler:    _UpdateConfigService_Set_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _UpdateConfigService_Delete_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSome",
			Handler:       _UpdateConfigService_GetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAll",
			Handler:       _UpdateConfigService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _UpdateConfigService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMeta",
			Handler:       _UpdateConfigService_SubscribeMeta_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SetSome",
			Handler:       _UpdateConfigService_SetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeleteSome",
			Handler:       _UpdateConfigService_DeleteSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeleteAll",
			Handler:       _UpdateConfigService_DeleteAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAllBatched",
			Handler:       _UpdateConfigService_GetAllBatched_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeBatched",
			Handler:       _UpdateConfigService_SubscribeBatched_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arista/studio_topology.v1/services.gen.proto",
}

UpdateConfigService_ServiceDesc is the grpc.ServiceDesc for UpdateConfigService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var UpdateService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arista.studio_topology.v1.UpdateService",
	HandlerType: (*UpdateServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOne",
			Handler:    _UpdateService_GetOne_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _UpdateService_GetMeta_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSome",
			Handler:       _UpdateService_GetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAll",
			Handler:       _UpdateService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _UpdateService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMeta",
			Handler:       _UpdateService_SubscribeMeta_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAllBatched",
			Handler:       _UpdateService_GetAllBatched_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeBatched",
			Handler:       _UpdateService_SubscribeBatched_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arista/studio_topology.v1/services.gen.proto",
}

UpdateService_ServiceDesc is the grpc.ServiceDesc for UpdateService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source
var UpdateSyncConfigService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arista.studio_topology.v1.UpdateSyncConfigService",
	HandlerType: (*UpdateSyncConfigServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOne",
			Handler:    _UpdateSyncConfigService_GetOne_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _UpdateSyncConfigService_GetMeta_Handler,
		},
		{
			MethodName: "Set",
			Handler:    _UpdateSyncConfigService_Set_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _UpdateSyncConfigService_Delete_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSome",
			Handler:       _UpdateSyncConfigService_GetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAll",
			Handler:       _UpdateSyncConfigService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _UpdateSyncConfigService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMeta",
			Handler:       _UpdateSyncConfigService_SubscribeMeta_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SetSome",
			Handler:       _UpdateSyncConfigService_SetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeleteSome",
			Handler:       _UpdateSyncConfigService_DeleteSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeleteAll",
			Handler:       _UpdateSyncConfigService_DeleteAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAllBatched",
			Handler:       _UpdateSyncConfigService_GetAllBatched_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeBatched",
			Handler:       _UpdateSyncConfigService_SubscribeBatched_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arista/studio_topology.v1/services.gen.proto",
}

UpdateSyncConfigService_ServiceDesc is the grpc.ServiceDesc for UpdateSyncConfigService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterDecommissionConfigServiceServer

func RegisterDecommissionConfigServiceServer(s grpc.ServiceRegistrar, srv DecommissionConfigServiceServer)

func RegisterDecommissionServiceServer

func RegisterDecommissionServiceServer(s grpc.ServiceRegistrar, srv DecommissionServiceServer)

func RegisterDeviceInputConfigServiceServer

func RegisterDeviceInputConfigServiceServer(s grpc.ServiceRegistrar, srv DeviceInputConfigServiceServer)

func RegisterDeviceStateServiceServer

func RegisterDeviceStateServiceServer(s grpc.ServiceRegistrar, srv DeviceStateServiceServer)

func RegisterInterfaceInputConfigServiceServer

func RegisterInterfaceInputConfigServiceServer(s grpc.ServiceRegistrar, srv InterfaceInputConfigServiceServer)

func RegisterReplaceConfigServiceServer

func RegisterReplaceConfigServiceServer(s grpc.ServiceRegistrar, srv ReplaceConfigServiceServer)

func RegisterReplaceServiceServer

func RegisterReplaceServiceServer(s grpc.ServiceRegistrar, srv ReplaceServiceServer)

func RegisterRevertConfigServiceServer

func RegisterRevertConfigServiceServer(s grpc.ServiceRegistrar, srv RevertConfigServiceServer)

func RegisterUpdateConfigServiceServer

func RegisterUpdateConfigServiceServer(s grpc.ServiceRegistrar, srv UpdateConfigServiceServer)

func RegisterUpdateServiceServer

func RegisterUpdateServiceServer(s grpc.ServiceRegistrar, srv UpdateServiceServer)

func RegisterUpdateSyncConfigServiceServer

func RegisterUpdateSyncConfigServiceServer(s grpc.ServiceRegistrar, srv UpdateSyncConfigServiceServer)

Types

type Decommission

type Decommission struct {

	// key uniquely identifies the device in a given workspace.
	Key *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// created_at is the time at which decommissioning was first initiated.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// created_by is the name of the user who first initiated decommissioning.
	CreatedBy *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=created_by,json=createdBy,proto3" json:"created_by,omitempty"`
	// last_modified_at is the time at which the decommissioning was last modified.
	LastModifiedAt *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=last_modified_at,json=lastModifiedAt,proto3" json:"last_modified_at,omitempty"`
	// last_modified_by is the name of the user that last modified the status.
	LastModifiedBy *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=last_modified_by,json=lastModifiedBy,proto3" json:"last_modified_by,omitempty"`
	// status of the decommissioning operation
	Status DecommissionStatus `protobuf:"varint,6,opt,name=status,proto3,enum=arista.studio_topology.v1.DecommissionStatus" json:"status,omitempty"`
	// error indicates if there is a failure in decommissioning
	Error *wrapperspb.StringValue `protobuf:"bytes,7,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

Decommission is the resource that holds the decommissioning state of a device.

func (*Decommission) Descriptor deprecated

func (*Decommission) Descriptor() ([]byte, []int)

Deprecated: Use Decommission.ProtoReflect.Descriptor instead.

func (*Decommission) GetCreatedAt

func (x *Decommission) GetCreatedAt() *timestamppb.Timestamp

func (*Decommission) GetCreatedBy

func (x *Decommission) GetCreatedBy() *wrapperspb.StringValue

func (*Decommission) GetError

func (x *Decommission) GetError() *wrapperspb.StringValue

func (*Decommission) GetKey

func (x *Decommission) GetKey() *DeviceKey

func (*Decommission) GetLastModifiedAt

func (x *Decommission) GetLastModifiedAt() *timestamppb.Timestamp

func (*Decommission) GetLastModifiedBy

func (x *Decommission) GetLastModifiedBy() *wrapperspb.StringValue

func (*Decommission) GetStatus

func (x *Decommission) GetStatus() DecommissionStatus

func (*Decommission) ProtoMessage

func (*Decommission) ProtoMessage()

func (*Decommission) ProtoReflect

func (x *Decommission) ProtoReflect() protoreflect.Message

func (*Decommission) Reset

func (x *Decommission) Reset()

func (*Decommission) String

func (x *Decommission) String() string

type DecommissionBatchedStreamRequest

type DecommissionBatchedStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*Decommission `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each Decommission at end.
	//   - Each Decommission response is fully-specified (all fields set).
	//   - start: Returns the state of each Decommission at start, followed by updates until now.
	//   - Each Decommission response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each Decommission at start, followed by updates
	//     until end.
	//   - Each Decommission response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// MaxMessages limits the maximum number of messages that can be contained in one batch.
	// MaxMessages is required to be at least 1.
	// The maximum number of messages in a batch is min(max_messages, INTERNAL_BATCH_LIMIT)
	// INTERNAL_BATCH_LIMIT is set based on the maximum message size.
	MaxMessages *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionBatchedStreamRequest) Descriptor deprecated

func (*DecommissionBatchedStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionBatchedStreamRequest.ProtoReflect.Descriptor instead.

func (*DecommissionBatchedStreamRequest) GetMaxMessages

func (*DecommissionBatchedStreamRequest) GetPartialEqFilter

func (x *DecommissionBatchedStreamRequest) GetPartialEqFilter() []*Decommission

func (*DecommissionBatchedStreamRequest) GetTime

func (*DecommissionBatchedStreamRequest) ProtoMessage

func (*DecommissionBatchedStreamRequest) ProtoMessage()

func (*DecommissionBatchedStreamRequest) ProtoReflect

func (*DecommissionBatchedStreamRequest) Reset

func (*DecommissionBatchedStreamRequest) String

type DecommissionBatchedStreamResponse

type DecommissionBatchedStreamResponse struct {

	// Values are the values deemed relevant to the initiating request.
	// The length of this structure is guaranteed to be between (inclusive) 1 and
	// min(req.max_messages, INTERNAL_BATCH_LIMIT).
	Responses []*DecommissionStreamResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionBatchedStreamResponse) Descriptor deprecated

func (*DecommissionBatchedStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionBatchedStreamResponse.ProtoReflect.Descriptor instead.

func (*DecommissionBatchedStreamResponse) GetResponses

func (*DecommissionBatchedStreamResponse) ProtoMessage

func (*DecommissionBatchedStreamResponse) ProtoMessage()

func (*DecommissionBatchedStreamResponse) ProtoReflect

func (*DecommissionBatchedStreamResponse) Reset

func (*DecommissionBatchedStreamResponse) String

type DecommissionConfig

type DecommissionConfig struct {

	// key uniquely identifies the device for a given workspace.
	Key *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

DecommissionConfig is the resource for decommissioning the device from the studio.

func (*DecommissionConfig) Descriptor deprecated

func (*DecommissionConfig) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionConfig.ProtoReflect.Descriptor instead.

func (*DecommissionConfig) GetKey

func (x *DecommissionConfig) GetKey() *DeviceKey

func (*DecommissionConfig) ProtoMessage

func (*DecommissionConfig) ProtoMessage()

func (*DecommissionConfig) ProtoReflect

func (x *DecommissionConfig) ProtoReflect() protoreflect.Message

func (*DecommissionConfig) Reset

func (x *DecommissionConfig) Reset()

func (*DecommissionConfig) String

func (x *DecommissionConfig) String() string

type DecommissionConfigBatchedStreamRequest

type DecommissionConfigBatchedStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*DecommissionConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each DecommissionConfig at end.
	//   - Each DecommissionConfig response is fully-specified (all fields set).
	//   - start: Returns the state of each DecommissionConfig at start, followed by updates until now.
	//   - Each DecommissionConfig response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each DecommissionConfig at start, followed by updates
	//     until end.
	//   - Each DecommissionConfig response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// MaxMessages limits the maximum number of messages that can be contained in one batch.
	// MaxMessages is required to be at least 1.
	// The maximum number of messages in a batch is min(max_messages, INTERNAL_BATCH_LIMIT)
	// INTERNAL_BATCH_LIMIT is set based on the maximum message size.
	MaxMessages *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionConfigBatchedStreamRequest) Descriptor deprecated

func (*DecommissionConfigBatchedStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionConfigBatchedStreamRequest.ProtoReflect.Descriptor instead.

func (*DecommissionConfigBatchedStreamRequest) GetMaxMessages

func (*DecommissionConfigBatchedStreamRequest) GetPartialEqFilter

func (*DecommissionConfigBatchedStreamRequest) GetTime

func (*DecommissionConfigBatchedStreamRequest) ProtoMessage

func (*DecommissionConfigBatchedStreamRequest) ProtoReflect

func (*DecommissionConfigBatchedStreamRequest) Reset

func (*DecommissionConfigBatchedStreamRequest) String

type DecommissionConfigBatchedStreamResponse

type DecommissionConfigBatchedStreamResponse struct {

	// Values are the values deemed relevant to the initiating request.
	// The length of this structure is guaranteed to be between (inclusive) 1 and
	// min(req.max_messages, INTERNAL_BATCH_LIMIT).
	Responses []*DecommissionConfigStreamResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionConfigBatchedStreamResponse) Descriptor deprecated

func (*DecommissionConfigBatchedStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionConfigBatchedStreamResponse.ProtoReflect.Descriptor instead.

func (*DecommissionConfigBatchedStreamResponse) GetResponses

func (*DecommissionConfigBatchedStreamResponse) ProtoMessage

func (*DecommissionConfigBatchedStreamResponse) ProtoReflect

func (*DecommissionConfigBatchedStreamResponse) Reset

func (*DecommissionConfigBatchedStreamResponse) String

type DecommissionConfigDeleteAllRequest

type DecommissionConfigDeleteAllRequest struct {

	// PartialEqFilter provides a way to server-side filter a DeleteAll.
	// This requires all provided fields to be equal to the response.
	// A filtered DeleteAll will use GetAll with filter to find things to delete.
	PartialEqFilter []*DecommissionConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionConfigDeleteAllRequest) Descriptor deprecated

func (*DecommissionConfigDeleteAllRequest) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionConfigDeleteAllRequest.ProtoReflect.Descriptor instead.

func (*DecommissionConfigDeleteAllRequest) GetPartialEqFilter

func (x *DecommissionConfigDeleteAllRequest) GetPartialEqFilter() []*DecommissionConfig

func (*DecommissionConfigDeleteAllRequest) ProtoMessage

func (*DecommissionConfigDeleteAllRequest) ProtoMessage()

func (*DecommissionConfigDeleteAllRequest) ProtoReflect

func (*DecommissionConfigDeleteAllRequest) Reset

func (*DecommissionConfigDeleteAllRequest) String

type DecommissionConfigDeleteAllResponse

type DecommissionConfigDeleteAllResponse struct {

	// This describes the class of delete error.
	// A DeleteAllResponse is only sent when there is an error.
	Type fmp.DeleteError `protobuf:"varint,1,opt,name=type,proto3,enum=fmp.DeleteError" json:"type,omitempty"`
	// This indicates the error message from the delete failure.
	Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// This is the key of the DecommissionConfig instance that failed to be deleted.
	Key *DeviceKey `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the (UTC) timestamp when the key was being deleted.
	Time *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionConfigDeleteAllResponse) Descriptor deprecated

func (*DecommissionConfigDeleteAllResponse) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionConfigDeleteAllResponse.ProtoReflect.Descriptor instead.

func (*DecommissionConfigDeleteAllResponse) GetError

func (*DecommissionConfigDeleteAllResponse) GetKey

func (*DecommissionConfigDeleteAllResponse) GetTime

func (*DecommissionConfigDeleteAllResponse) GetType

func (*DecommissionConfigDeleteAllResponse) ProtoMessage

func (*DecommissionConfigDeleteAllResponse) ProtoMessage()

func (*DecommissionConfigDeleteAllResponse) ProtoReflect

func (*DecommissionConfigDeleteAllResponse) Reset

func (*DecommissionConfigDeleteAllResponse) String

type DecommissionConfigDeleteRequest

type DecommissionConfigDeleteRequest struct {

	// Key indicates which DecommissionConfig instance to remove.
	// This field must always be set.
	Key *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionConfigDeleteRequest) Descriptor deprecated

func (*DecommissionConfigDeleteRequest) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionConfigDeleteRequest.ProtoReflect.Descriptor instead.

func (*DecommissionConfigDeleteRequest) GetKey

func (*DecommissionConfigDeleteRequest) ProtoMessage

func (*DecommissionConfigDeleteRequest) ProtoMessage()

func (*DecommissionConfigDeleteRequest) ProtoReflect

func (*DecommissionConfigDeleteRequest) Reset

func (*DecommissionConfigDeleteRequest) String

type DecommissionConfigDeleteResponse

type DecommissionConfigDeleteResponse struct {

	// Key echoes back the key of the deleted DecommissionConfig instance.
	Key *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the (UTC) timestamp at which the system recognizes the
	// deletion. The only guarantees made about this timestamp are:
	//
	//   - it is after the time the request was received
	//   - a time-ranged query with StartTime==DeletedAt will not include this instance.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionConfigDeleteResponse) Descriptor deprecated

func (*DecommissionConfigDeleteResponse) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionConfigDeleteResponse.ProtoReflect.Descriptor instead.

func (*DecommissionConfigDeleteResponse) GetKey

func (*DecommissionConfigDeleteResponse) GetTime

func (*DecommissionConfigDeleteResponse) ProtoMessage

func (*DecommissionConfigDeleteResponse) ProtoMessage()

func (*DecommissionConfigDeleteResponse) ProtoReflect

func (*DecommissionConfigDeleteResponse) Reset

func (*DecommissionConfigDeleteResponse) String

type DecommissionConfigDeleteSomeRequest

type DecommissionConfigDeleteSomeRequest struct {

	// key contains a list of DecommissionConfig keys to delete
	Keys []*DeviceKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionConfigDeleteSomeRequest) Descriptor deprecated

func (*DecommissionConfigDeleteSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionConfigDeleteSomeRequest.ProtoReflect.Descriptor instead.

func (*DecommissionConfigDeleteSomeRequest) GetKeys

func (*DecommissionConfigDeleteSomeRequest) ProtoMessage

func (*DecommissionConfigDeleteSomeRequest) ProtoMessage()

func (*DecommissionConfigDeleteSomeRequest) ProtoReflect

func (*DecommissionConfigDeleteSomeRequest) Reset

func (*DecommissionConfigDeleteSomeRequest) String

type DecommissionConfigDeleteSomeResponse

type DecommissionConfigDeleteSomeResponse struct {
	Key   *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Error string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

DecommissionConfigDeleteSomeResponse is only sent when there is an error.

func (*DecommissionConfigDeleteSomeResponse) Descriptor deprecated

func (*DecommissionConfigDeleteSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionConfigDeleteSomeResponse.ProtoReflect.Descriptor instead.

func (*DecommissionConfigDeleteSomeResponse) GetError

func (*DecommissionConfigDeleteSomeResponse) GetKey

func (*DecommissionConfigDeleteSomeResponse) ProtoMessage

func (*DecommissionConfigDeleteSomeResponse) ProtoMessage()

func (*DecommissionConfigDeleteSomeResponse) ProtoReflect

func (*DecommissionConfigDeleteSomeResponse) Reset

func (*DecommissionConfigDeleteSomeResponse) String

type DecommissionConfigRequest

type DecommissionConfigRequest struct {

	// Key uniquely identifies a DecommissionConfig instance to retrieve.
	// This value must be populated.
	Key *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionConfigRequest) Descriptor deprecated

func (*DecommissionConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionConfigRequest.ProtoReflect.Descriptor instead.

func (*DecommissionConfigRequest) GetKey

func (x *DecommissionConfigRequest) GetKey() *DeviceKey

func (*DecommissionConfigRequest) GetTime

func (*DecommissionConfigRequest) ProtoMessage

func (*DecommissionConfigRequest) ProtoMessage()

func (*DecommissionConfigRequest) ProtoReflect

func (*DecommissionConfigRequest) Reset

func (x *DecommissionConfigRequest) Reset()

func (*DecommissionConfigRequest) String

func (x *DecommissionConfigRequest) String() string

type DecommissionConfigResponse

type DecommissionConfigResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *DecommissionConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time carries the (UTC) timestamp of the last-modification of the
	// DecommissionConfig instance in this response.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionConfigResponse) Descriptor deprecated

func (*DecommissionConfigResponse) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionConfigResponse.ProtoReflect.Descriptor instead.

func (*DecommissionConfigResponse) GetTime

func (*DecommissionConfigResponse) GetValue

func (*DecommissionConfigResponse) ProtoMessage

func (*DecommissionConfigResponse) ProtoMessage()

func (*DecommissionConfigResponse) ProtoReflect

func (*DecommissionConfigResponse) Reset

func (x *DecommissionConfigResponse) Reset()

func (*DecommissionConfigResponse) String

func (x *DecommissionConfigResponse) String() string

type DecommissionConfigServiceClient

type DecommissionConfigServiceClient interface {
	GetOne(ctx context.Context, in *DecommissionConfigRequest, opts ...grpc.CallOption) (*DecommissionConfigResponse, error)
	GetSome(ctx context.Context, in *DecommissionConfigSomeRequest, opts ...grpc.CallOption) (DecommissionConfigService_GetSomeClient, error)
	GetAll(ctx context.Context, in *DecommissionConfigStreamRequest, opts ...grpc.CallOption) (DecommissionConfigService_GetAllClient, error)
	Subscribe(ctx context.Context, in *DecommissionConfigStreamRequest, opts ...grpc.CallOption) (DecommissionConfigService_SubscribeClient, error)
	GetMeta(ctx context.Context, in *DecommissionConfigStreamRequest, opts ...grpc.CallOption) (*MetaResponse, error)
	SubscribeMeta(ctx context.Context, in *DecommissionConfigStreamRequest, opts ...grpc.CallOption) (DecommissionConfigService_SubscribeMetaClient, error)
	Set(ctx context.Context, in *DecommissionConfigSetRequest, opts ...grpc.CallOption) (*DecommissionConfigSetResponse, error)
	SetSome(ctx context.Context, in *DecommissionConfigSetSomeRequest, opts ...grpc.CallOption) (DecommissionConfigService_SetSomeClient, error)
	Delete(ctx context.Context, in *DecommissionConfigDeleteRequest, opts ...grpc.CallOption) (*DecommissionConfigDeleteResponse, error)
	DeleteSome(ctx context.Context, in *DecommissionConfigDeleteSomeRequest, opts ...grpc.CallOption) (DecommissionConfigService_DeleteSomeClient, error)
	DeleteAll(ctx context.Context, in *DecommissionConfigDeleteAllRequest, opts ...grpc.CallOption) (DecommissionConfigService_DeleteAllClient, error)
	GetAllBatched(ctx context.Context, in *DecommissionConfigBatchedStreamRequest, opts ...grpc.CallOption) (DecommissionConfigService_GetAllBatchedClient, error)
	SubscribeBatched(ctx context.Context, in *DecommissionConfigBatchedStreamRequest, opts ...grpc.CallOption) (DecommissionConfigService_SubscribeBatchedClient, error)
}

DecommissionConfigServiceClient is the client API for DecommissionConfigService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type DecommissionConfigServiceServer

DecommissionConfigServiceServer is the server API for DecommissionConfigService service. All implementations must embed UnimplementedDecommissionConfigServiceServer for forward compatibility

type DecommissionConfigService_DeleteAllClient

type DecommissionConfigService_DeleteAllClient interface {
	Recv() (*DecommissionConfigDeleteAllResponse, error)
	grpc.ClientStream
}

type DecommissionConfigService_DeleteAllServer

type DecommissionConfigService_DeleteAllServer interface {
	Send(*DecommissionConfigDeleteAllResponse) error
	grpc.ServerStream
}

type DecommissionConfigService_DeleteSomeClient

type DecommissionConfigService_DeleteSomeClient interface {
	Recv() (*DecommissionConfigDeleteSomeResponse, error)
	grpc.ClientStream
}

type DecommissionConfigService_DeleteSomeServer

type DecommissionConfigService_DeleteSomeServer interface {
	Send(*DecommissionConfigDeleteSomeResponse) error
	grpc.ServerStream
}

type DecommissionConfigService_GetAllBatchedClient

type DecommissionConfigService_GetAllBatchedClient interface {
	Recv() (*DecommissionConfigBatchedStreamResponse, error)
	grpc.ClientStream
}

type DecommissionConfigService_GetAllBatchedServer

type DecommissionConfigService_GetAllBatchedServer interface {
	Send(*DecommissionConfigBatchedStreamResponse) error
	grpc.ServerStream
}

type DecommissionConfigService_GetAllClient

type DecommissionConfigService_GetAllClient interface {
	Recv() (*DecommissionConfigStreamResponse, error)
	grpc.ClientStream
}

type DecommissionConfigService_GetAllServer

type DecommissionConfigService_GetAllServer interface {
	Send(*DecommissionConfigStreamResponse) error
	grpc.ServerStream
}

type DecommissionConfigService_GetSomeClient

type DecommissionConfigService_GetSomeClient interface {
	Recv() (*DecommissionConfigSomeResponse, error)
	grpc.ClientStream
}

type DecommissionConfigService_GetSomeServer

type DecommissionConfigService_GetSomeServer interface {
	Send(*DecommissionConfigSomeResponse) error
	grpc.ServerStream
}

type DecommissionConfigService_SetSomeClient

type DecommissionConfigService_SetSomeClient interface {
	Recv() (*DecommissionConfigSetSomeResponse, error)
	grpc.ClientStream
}

type DecommissionConfigService_SetSomeServer

type DecommissionConfigService_SetSomeServer interface {
	Send(*DecommissionConfigSetSomeResponse) error
	grpc.ServerStream
}

type DecommissionConfigService_SubscribeBatchedClient

type DecommissionConfigService_SubscribeBatchedClient interface {
	Recv() (*DecommissionConfigBatchedStreamResponse, error)
	grpc.ClientStream
}

type DecommissionConfigService_SubscribeBatchedServer

type DecommissionConfigService_SubscribeBatchedServer interface {
	Send(*DecommissionConfigBatchedStreamResponse) error
	grpc.ServerStream
}

type DecommissionConfigService_SubscribeClient

type DecommissionConfigService_SubscribeClient interface {
	Recv() (*DecommissionConfigStreamResponse, error)
	grpc.ClientStream
}

type DecommissionConfigService_SubscribeMetaClient

type DecommissionConfigService_SubscribeMetaClient interface {
	Recv() (*MetaResponse, error)
	grpc.ClientStream
}

type DecommissionConfigService_SubscribeMetaServer

type DecommissionConfigService_SubscribeMetaServer interface {
	Send(*MetaResponse) error
	grpc.ServerStream
}

type DecommissionConfigService_SubscribeServer

type DecommissionConfigService_SubscribeServer interface {
	Send(*DecommissionConfigStreamResponse) error
	grpc.ServerStream
}

type DecommissionConfigSetRequest

type DecommissionConfigSetRequest struct {

	// DecommissionConfig carries the value to set into the datastore.
	// See the documentation on the DecommissionConfig struct for which fields are required.
	Value *DecommissionConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionConfigSetRequest) Descriptor deprecated

func (*DecommissionConfigSetRequest) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionConfigSetRequest.ProtoReflect.Descriptor instead.

func (*DecommissionConfigSetRequest) GetValue

func (*DecommissionConfigSetRequest) ProtoMessage

func (*DecommissionConfigSetRequest) ProtoMessage()

func (*DecommissionConfigSetRequest) ProtoReflect

func (*DecommissionConfigSetRequest) Reset

func (x *DecommissionConfigSetRequest) Reset()

func (*DecommissionConfigSetRequest) String

type DecommissionConfigSetResponse

type DecommissionConfigSetResponse struct {

	// Value carries all the values given in the DecommissionConfigSetRequest as well
	// as any server-generated values.
	Value *DecommissionConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time indicates the (UTC) timestamp at which the system recognizes the
	// creation. The only guarantees made about this timestamp are:
	//
	//   - it is after the time the request was received
	//   - a time-ranged query with StartTime==CreatedAt will include this instance.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionConfigSetResponse) Descriptor deprecated

func (*DecommissionConfigSetResponse) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionConfigSetResponse.ProtoReflect.Descriptor instead.

func (*DecommissionConfigSetResponse) GetTime

func (*DecommissionConfigSetResponse) GetValue

func (*DecommissionConfigSetResponse) ProtoMessage

func (*DecommissionConfigSetResponse) ProtoMessage()

func (*DecommissionConfigSetResponse) ProtoReflect

func (*DecommissionConfigSetResponse) Reset

func (x *DecommissionConfigSetResponse) Reset()

func (*DecommissionConfigSetResponse) String

type DecommissionConfigSetSomeRequest

type DecommissionConfigSetSomeRequest struct {

	// value contains a list of DecommissionConfig values to write.
	// It is possible to provide more values than can fit within either:
	//   - the maxiumum send size of the client
	//   - the maximum receive size of the server
	//
	// If this error occurs you must reduce the number of values sent.
	// See gRPC "maximum message size" documentation for more information.
	Values []*DecommissionConfig `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionConfigSetSomeRequest) Descriptor deprecated

func (*DecommissionConfigSetSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionConfigSetSomeRequest.ProtoReflect.Descriptor instead.

func (*DecommissionConfigSetSomeRequest) GetValues

func (*DecommissionConfigSetSomeRequest) ProtoMessage

func (*DecommissionConfigSetSomeRequest) ProtoMessage()

func (*DecommissionConfigSetSomeRequest) ProtoReflect

func (*DecommissionConfigSetSomeRequest) Reset

func (*DecommissionConfigSetSomeRequest) String

type DecommissionConfigSetSomeResponse

type DecommissionConfigSetSomeResponse struct {
	Key   *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Error string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionConfigSetSomeResponse) Descriptor deprecated

func (*DecommissionConfigSetSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionConfigSetSomeResponse.ProtoReflect.Descriptor instead.

func (*DecommissionConfigSetSomeResponse) GetError

func (*DecommissionConfigSetSomeResponse) GetKey

func (*DecommissionConfigSetSomeResponse) ProtoMessage

func (*DecommissionConfigSetSomeResponse) ProtoMessage()

func (*DecommissionConfigSetSomeResponse) ProtoReflect

func (*DecommissionConfigSetSomeResponse) Reset

func (*DecommissionConfigSetSomeResponse) String

type DecommissionConfigSomeRequest

type DecommissionConfigSomeRequest struct {
	Keys []*DeviceKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionConfigSomeRequest) Descriptor deprecated

func (*DecommissionConfigSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionConfigSomeRequest.ProtoReflect.Descriptor instead.

func (*DecommissionConfigSomeRequest) GetKeys

func (x *DecommissionConfigSomeRequest) GetKeys() []*DeviceKey

func (*DecommissionConfigSomeRequest) GetTime

func (*DecommissionConfigSomeRequest) ProtoMessage

func (*DecommissionConfigSomeRequest) ProtoMessage()

func (*DecommissionConfigSomeRequest) ProtoReflect

func (*DecommissionConfigSomeRequest) Reset

func (x *DecommissionConfigSomeRequest) Reset()

func (*DecommissionConfigSomeRequest) String

type DecommissionConfigSomeResponse

type DecommissionConfigSomeResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *DecommissionConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Error is an optional field.
	// It should be filled when there is an error in the GetSome process.
	Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Time  *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionConfigSomeResponse) Descriptor deprecated

func (*DecommissionConfigSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionConfigSomeResponse.ProtoReflect.Descriptor instead.

func (*DecommissionConfigSomeResponse) GetError

func (*DecommissionConfigSomeResponse) GetTime

func (*DecommissionConfigSomeResponse) GetValue

func (*DecommissionConfigSomeResponse) ProtoMessage

func (*DecommissionConfigSomeResponse) ProtoMessage()

func (*DecommissionConfigSomeResponse) ProtoReflect

func (*DecommissionConfigSomeResponse) Reset

func (x *DecommissionConfigSomeResponse) Reset()

func (*DecommissionConfigSomeResponse) String

type DecommissionConfigStreamRequest

type DecommissionConfigStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*DecommissionConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each DecommissionConfig at end.
	//   - Each DecommissionConfig response is fully-specified (all fields set).
	//   - start: Returns the state of each DecommissionConfig at start, followed by updates until now.
	//   - Each DecommissionConfig response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each DecommissionConfig at start, followed by updates
	//     until end.
	//   - Each DecommissionConfig response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionConfigStreamRequest) Descriptor deprecated

func (*DecommissionConfigStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionConfigStreamRequest.ProtoReflect.Descriptor instead.

func (*DecommissionConfigStreamRequest) GetPartialEqFilter

func (x *DecommissionConfigStreamRequest) GetPartialEqFilter() []*DecommissionConfig

func (*DecommissionConfigStreamRequest) GetTime

func (*DecommissionConfigStreamRequest) ProtoMessage

func (*DecommissionConfigStreamRequest) ProtoMessage()

func (*DecommissionConfigStreamRequest) ProtoReflect

func (*DecommissionConfigStreamRequest) Reset

func (*DecommissionConfigStreamRequest) String

type DecommissionConfigStreamResponse

type DecommissionConfigStreamResponse struct {

	// Value is a value deemed relevant to the initiating request.
	// This structure will always have its key-field populated. Which other fields are
	// populated, and why, depends on the value of Operation and what triggered this notification.
	Value *DecommissionConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time holds the timestamp of this DecommissionConfig's last modification.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// Operation indicates how the DecommissionConfig value in this response should be considered.
	// Under non-subscribe requests, this value should always be INITIAL. In a subscription,
	// once all initial data is streamed and the client begins to receive modification updates,
	// you should not see INITIAL again.
	Type subscriptions.Operation `protobuf:"varint,3,opt,name=type,proto3,enum=arista.subscriptions.Operation" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionConfigStreamResponse) Descriptor deprecated

func (*DecommissionConfigStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionConfigStreamResponse.ProtoReflect.Descriptor instead.

func (*DecommissionConfigStreamResponse) GetTime

func (*DecommissionConfigStreamResponse) GetType

func (*DecommissionConfigStreamResponse) GetValue

func (*DecommissionConfigStreamResponse) ProtoMessage

func (*DecommissionConfigStreamResponse) ProtoMessage()

func (*DecommissionConfigStreamResponse) ProtoReflect

func (*DecommissionConfigStreamResponse) Reset

func (*DecommissionConfigStreamResponse) String

type DecommissionRequest

type DecommissionRequest struct {

	// Key uniquely identifies a Decommission instance to retrieve.
	// This value must be populated.
	Key *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionRequest) Descriptor deprecated

func (*DecommissionRequest) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionRequest.ProtoReflect.Descriptor instead.

func (*DecommissionRequest) GetKey

func (x *DecommissionRequest) GetKey() *DeviceKey

func (*DecommissionRequest) GetTime

func (*DecommissionRequest) ProtoMessage

func (*DecommissionRequest) ProtoMessage()

func (*DecommissionRequest) ProtoReflect

func (x *DecommissionRequest) ProtoReflect() protoreflect.Message

func (*DecommissionRequest) Reset

func (x *DecommissionRequest) Reset()

func (*DecommissionRequest) String

func (x *DecommissionRequest) String() string

type DecommissionResponse

type DecommissionResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *Decommission `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time carries the (UTC) timestamp of the last-modification of the
	// Decommission instance in this response.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionResponse) Descriptor deprecated

func (*DecommissionResponse) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionResponse.ProtoReflect.Descriptor instead.

func (*DecommissionResponse) GetTime

func (*DecommissionResponse) GetValue

func (x *DecommissionResponse) GetValue() *Decommission

func (*DecommissionResponse) ProtoMessage

func (*DecommissionResponse) ProtoMessage()

func (*DecommissionResponse) ProtoReflect

func (x *DecommissionResponse) ProtoReflect() protoreflect.Message

func (*DecommissionResponse) Reset

func (x *DecommissionResponse) Reset()

func (*DecommissionResponse) String

func (x *DecommissionResponse) String() string

type DecommissionServiceServer

DecommissionServiceServer is the server API for DecommissionService service. All implementations must embed UnimplementedDecommissionServiceServer for forward compatibility

type DecommissionService_GetAllBatchedClient

type DecommissionService_GetAllBatchedClient interface {
	Recv() (*DecommissionBatchedStreamResponse, error)
	grpc.ClientStream
}

type DecommissionService_GetAllBatchedServer

type DecommissionService_GetAllBatchedServer interface {
	Send(*DecommissionBatchedStreamResponse) error
	grpc.ServerStream
}

type DecommissionService_GetAllClient

type DecommissionService_GetAllClient interface {
	Recv() (*DecommissionStreamResponse, error)
	grpc.ClientStream
}

type DecommissionService_GetAllServer

type DecommissionService_GetAllServer interface {
	Send(*DecommissionStreamResponse) error
	grpc.ServerStream
}

type DecommissionService_GetSomeClient

type DecommissionService_GetSomeClient interface {
	Recv() (*DecommissionSomeResponse, error)
	grpc.ClientStream
}

type DecommissionService_GetSomeServer

type DecommissionService_GetSomeServer interface {
	Send(*DecommissionSomeResponse) error
	grpc.ServerStream
}

type DecommissionService_SubscribeBatchedClient

type DecommissionService_SubscribeBatchedClient interface {
	Recv() (*DecommissionBatchedStreamResponse, error)
	grpc.ClientStream
}

type DecommissionService_SubscribeBatchedServer

type DecommissionService_SubscribeBatchedServer interface {
	Send(*DecommissionBatchedStreamResponse) error
	grpc.ServerStream
}

type DecommissionService_SubscribeClient

type DecommissionService_SubscribeClient interface {
	Recv() (*DecommissionStreamResponse, error)
	grpc.ClientStream
}

type DecommissionService_SubscribeMetaClient

type DecommissionService_SubscribeMetaClient interface {
	Recv() (*MetaResponse, error)
	grpc.ClientStream
}

type DecommissionService_SubscribeMetaServer

type DecommissionService_SubscribeMetaServer interface {
	Send(*MetaResponse) error
	grpc.ServerStream
}

type DecommissionService_SubscribeServer

type DecommissionService_SubscribeServer interface {
	Send(*DecommissionStreamResponse) error
	grpc.ServerStream
}

type DecommissionSomeRequest

type DecommissionSomeRequest struct {
	Keys []*DeviceKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionSomeRequest) Descriptor deprecated

func (*DecommissionSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionSomeRequest.ProtoReflect.Descriptor instead.

func (*DecommissionSomeRequest) GetKeys

func (x *DecommissionSomeRequest) GetKeys() []*DeviceKey

func (*DecommissionSomeRequest) GetTime

func (*DecommissionSomeRequest) ProtoMessage

func (*DecommissionSomeRequest) ProtoMessage()

func (*DecommissionSomeRequest) ProtoReflect

func (x *DecommissionSomeRequest) ProtoReflect() protoreflect.Message

func (*DecommissionSomeRequest) Reset

func (x *DecommissionSomeRequest) Reset()

func (*DecommissionSomeRequest) String

func (x *DecommissionSomeRequest) String() string

type DecommissionSomeResponse

type DecommissionSomeResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *Decommission `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Error is an optional field.
	// It should be filled when there is an error in the GetSome process.
	Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Time  *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionSomeResponse) Descriptor deprecated

func (*DecommissionSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionSomeResponse.ProtoReflect.Descriptor instead.

func (*DecommissionSomeResponse) GetError

func (*DecommissionSomeResponse) GetTime

func (*DecommissionSomeResponse) GetValue

func (x *DecommissionSomeResponse) GetValue() *Decommission

func (*DecommissionSomeResponse) ProtoMessage

func (*DecommissionSomeResponse) ProtoMessage()

func (*DecommissionSomeResponse) ProtoReflect

func (x *DecommissionSomeResponse) ProtoReflect() protoreflect.Message

func (*DecommissionSomeResponse) Reset

func (x *DecommissionSomeResponse) Reset()

func (*DecommissionSomeResponse) String

func (x *DecommissionSomeResponse) String() string

type DecommissionStatus

type DecommissionStatus int32

DecommissionStatus enumerates the status of decommissioning a device.

const (
	// DECOMMISSION_STATUS_UNSPECIFIED indicates that the device was decommissioned with
	// an unspecified state.
	DecommissionStatus_DECOMMISSION_STATUS_UNSPECIFIED DecommissionStatus = 0
	// DECOMMISSION_STATUS_SUCCESS indicates that the device was successfully decommissioned.
	DecommissionStatus_DECOMMISSION_STATUS_SUCCESS DecommissionStatus = 1
	// DECOMMISSION_STATUS_FAILURE indicates an error with decommissioning the device.
	DecommissionStatus_DECOMMISSION_STATUS_FAILURE DecommissionStatus = 2
)

func (DecommissionStatus) Descriptor

func (DecommissionStatus) Enum

func (DecommissionStatus) EnumDescriptor deprecated

func (DecommissionStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use DecommissionStatus.Descriptor instead.

func (DecommissionStatus) Number

func (DecommissionStatus) String

func (x DecommissionStatus) String() string

func (DecommissionStatus) Type

type DecommissionStreamRequest

type DecommissionStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*Decommission `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each Decommission at end.
	//   - Each Decommission response is fully-specified (all fields set).
	//   - start: Returns the state of each Decommission at start, followed by updates until now.
	//   - Each Decommission response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each Decommission at start, followed by updates
	//     until end.
	//   - Each Decommission response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionStreamRequest) Descriptor deprecated

func (*DecommissionStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionStreamRequest.ProtoReflect.Descriptor instead.

func (*DecommissionStreamRequest) GetPartialEqFilter

func (x *DecommissionStreamRequest) GetPartialEqFilter() []*Decommission

func (*DecommissionStreamRequest) GetTime

func (*DecommissionStreamRequest) ProtoMessage

func (*DecommissionStreamRequest) ProtoMessage()

func (*DecommissionStreamRequest) ProtoReflect

func (*DecommissionStreamRequest) Reset

func (x *DecommissionStreamRequest) Reset()

func (*DecommissionStreamRequest) String

func (x *DecommissionStreamRequest) String() string

type DecommissionStreamResponse

type DecommissionStreamResponse struct {

	// Value is a value deemed relevant to the initiating request.
	// This structure will always have its key-field populated. Which other fields are
	// populated, and why, depends on the value of Operation and what triggered this notification.
	Value *Decommission `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time holds the timestamp of this Decommission's last modification.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// Operation indicates how the Decommission value in this response should be considered.
	// Under non-subscribe requests, this value should always be INITIAL. In a subscription,
	// once all initial data is streamed and the client begins to receive modification updates,
	// you should not see INITIAL again.
	Type subscriptions.Operation `protobuf:"varint,3,opt,name=type,proto3,enum=arista.subscriptions.Operation" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*DecommissionStreamResponse) Descriptor deprecated

func (*DecommissionStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use DecommissionStreamResponse.ProtoReflect.Descriptor instead.

func (*DecommissionStreamResponse) GetTime

func (*DecommissionStreamResponse) GetType

func (*DecommissionStreamResponse) GetValue

func (*DecommissionStreamResponse) ProtoMessage

func (*DecommissionStreamResponse) ProtoMessage()

func (*DecommissionStreamResponse) ProtoReflect

func (*DecommissionStreamResponse) Reset

func (x *DecommissionStreamResponse) Reset()

func (*DecommissionStreamResponse) String

func (x *DecommissionStreamResponse) String() string

type DeviceInfo

type DeviceInfo struct {

	// device_id identifies the device uniquely.
	DeviceId *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	// model_name indicates the model of the device.
	ModelName *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=model_name,json=modelName,proto3" json:"model_name,omitempty"`
	// mac_address indicates the MAC address of the device.
	MacAddress *fmp.MACAddress `protobuf:"bytes,3,opt,name=mac_address,json=macAddress,proto3" json:"mac_address,omitempty"`
	// hostname indicates the hostname of the device.
	Hostname *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=hostname,proto3" json:"hostname,omitempty"`
	// contains filtered or unexported fields
}

DeviceInfo contains device properties.

func (*DeviceInfo) Descriptor deprecated

func (*DeviceInfo) Descriptor() ([]byte, []int)

Deprecated: Use DeviceInfo.ProtoReflect.Descriptor instead.

func (*DeviceInfo) GetDeviceId

func (x *DeviceInfo) GetDeviceId() *wrapperspb.StringValue

func (*DeviceInfo) GetHostname

func (x *DeviceInfo) GetHostname() *wrapperspb.StringValue

func (*DeviceInfo) GetMacAddress

func (x *DeviceInfo) GetMacAddress() *fmp.MACAddress

func (*DeviceInfo) GetModelName

func (x *DeviceInfo) GetModelName() *wrapperspb.StringValue

func (*DeviceInfo) ProtoMessage

func (*DeviceInfo) ProtoMessage()

func (*DeviceInfo) ProtoReflect

func (x *DeviceInfo) ProtoReflect() protoreflect.Message

func (*DeviceInfo) Reset

func (x *DeviceInfo) Reset()

func (*DeviceInfo) String

func (x *DeviceInfo) String() string

type DeviceInputConfig

type DeviceInputConfig struct {

	// key uniquely identifies the device ID for a given workspace.
	Key *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// device_info contains device properties.
	DeviceInfo *DeviceInfo `protobuf:"bytes,2,opt,name=device_info,json=deviceInfo,proto3" json:"device_info,omitempty"`
	// remove if set to true will remove the device from mainline
	// post workspace merge
	Remove *wrapperspb.BoolValue `protobuf:"bytes,3,opt,name=remove,proto3" json:"remove,omitempty"`
	// contains filtered or unexported fields
}

DeviceInputConfig is the desired topology input for a device.

func (*DeviceInputConfig) Descriptor deprecated

func (*DeviceInputConfig) Descriptor() ([]byte, []int)

Deprecated: Use DeviceInputConfig.ProtoReflect.Descriptor instead.

func (*DeviceInputConfig) GetDeviceInfo

func (x *DeviceInputConfig) GetDeviceInfo() *DeviceInfo

func (*DeviceInputConfig) GetKey

func (x *DeviceInputConfig) GetKey() *DeviceKey

func (*DeviceInputConfig) GetRemove

func (x *DeviceInputConfig) GetRemove() *wrapperspb.BoolValue

func (*DeviceInputConfig) ProtoMessage

func (*DeviceInputConfig) ProtoMessage()

func (*DeviceInputConfig) ProtoReflect

func (x *DeviceInputConfig) ProtoReflect() protoreflect.Message

func (*DeviceInputConfig) Reset

func (x *DeviceInputConfig) Reset()

func (*DeviceInputConfig) String

func (x *DeviceInputConfig) String() string

type DeviceInputConfigBatchedStreamRequest

type DeviceInputConfigBatchedStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*DeviceInputConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each DeviceInputConfig at end.
	//   - Each DeviceInputConfig response is fully-specified (all fields set).
	//   - start: Returns the state of each DeviceInputConfig at start, followed by updates until now.
	//   - Each DeviceInputConfig response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each DeviceInputConfig at start, followed by updates
	//     until end.
	//   - Each DeviceInputConfig response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// MaxMessages limits the maximum number of messages that can be contained in one batch.
	// MaxMessages is required to be at least 1.
	// The maximum number of messages in a batch is min(max_messages, INTERNAL_BATCH_LIMIT)
	// INTERNAL_BATCH_LIMIT is set based on the maximum message size.
	MaxMessages *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceInputConfigBatchedStreamRequest) Descriptor deprecated

func (*DeviceInputConfigBatchedStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeviceInputConfigBatchedStreamRequest.ProtoReflect.Descriptor instead.

func (*DeviceInputConfigBatchedStreamRequest) GetMaxMessages

func (*DeviceInputConfigBatchedStreamRequest) GetPartialEqFilter

func (x *DeviceInputConfigBatchedStreamRequest) GetPartialEqFilter() []*DeviceInputConfig

func (*DeviceInputConfigBatchedStreamRequest) GetTime

func (*DeviceInputConfigBatchedStreamRequest) ProtoMessage

func (*DeviceInputConfigBatchedStreamRequest) ProtoMessage()

func (*DeviceInputConfigBatchedStreamRequest) ProtoReflect

func (*DeviceInputConfigBatchedStreamRequest) Reset

func (*DeviceInputConfigBatchedStreamRequest) String

type DeviceInputConfigBatchedStreamResponse

type DeviceInputConfigBatchedStreamResponse struct {

	// Values are the values deemed relevant to the initiating request.
	// The length of this structure is guaranteed to be between (inclusive) 1 and
	// min(req.max_messages, INTERNAL_BATCH_LIMIT).
	Responses []*DeviceInputConfigStreamResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceInputConfigBatchedStreamResponse) Descriptor deprecated

func (*DeviceInputConfigBatchedStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeviceInputConfigBatchedStreamResponse.ProtoReflect.Descriptor instead.

func (*DeviceInputConfigBatchedStreamResponse) GetResponses

func (*DeviceInputConfigBatchedStreamResponse) ProtoMessage

func (*DeviceInputConfigBatchedStreamResponse) ProtoReflect

func (*DeviceInputConfigBatchedStreamResponse) Reset

func (*DeviceInputConfigBatchedStreamResponse) String

type DeviceInputConfigDeleteAllRequest

type DeviceInputConfigDeleteAllRequest struct {

	// PartialEqFilter provides a way to server-side filter a DeleteAll.
	// This requires all provided fields to be equal to the response.
	// A filtered DeleteAll will use GetAll with filter to find things to delete.
	PartialEqFilter []*DeviceInputConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceInputConfigDeleteAllRequest) Descriptor deprecated

func (*DeviceInputConfigDeleteAllRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeviceInputConfigDeleteAllRequest.ProtoReflect.Descriptor instead.

func (*DeviceInputConfigDeleteAllRequest) GetPartialEqFilter

func (x *DeviceInputConfigDeleteAllRequest) GetPartialEqFilter() []*DeviceInputConfig

func (*DeviceInputConfigDeleteAllRequest) ProtoMessage

func (*DeviceInputConfigDeleteAllRequest) ProtoMessage()

func (*DeviceInputConfigDeleteAllRequest) ProtoReflect

func (*DeviceInputConfigDeleteAllRequest) Reset

func (*DeviceInputConfigDeleteAllRequest) String

type DeviceInputConfigDeleteAllResponse

type DeviceInputConfigDeleteAllResponse struct {

	// This describes the class of delete error.
	// A DeleteAllResponse is only sent when there is an error.
	Type fmp.DeleteError `protobuf:"varint,1,opt,name=type,proto3,enum=fmp.DeleteError" json:"type,omitempty"`
	// This indicates the error message from the delete failure.
	Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// This is the key of the DeviceInputConfig instance that failed to be deleted.
	Key *DeviceKey `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the (UTC) timestamp when the key was being deleted.
	Time *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceInputConfigDeleteAllResponse) Descriptor deprecated

func (*DeviceInputConfigDeleteAllResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeviceInputConfigDeleteAllResponse.ProtoReflect.Descriptor instead.

func (*DeviceInputConfigDeleteAllResponse) GetError

func (*DeviceInputConfigDeleteAllResponse) GetKey

func (*DeviceInputConfigDeleteAllResponse) GetTime

func (*DeviceInputConfigDeleteAllResponse) GetType

func (*DeviceInputConfigDeleteAllResponse) ProtoMessage

func (*DeviceInputConfigDeleteAllResponse) ProtoMessage()

func (*DeviceInputConfigDeleteAllResponse) ProtoReflect

func (*DeviceInputConfigDeleteAllResponse) Reset

func (*DeviceInputConfigDeleteAllResponse) String

type DeviceInputConfigDeleteRequest

type DeviceInputConfigDeleteRequest struct {

	// Key indicates which DeviceInputConfig instance to remove.
	// This field must always be set.
	Key *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceInputConfigDeleteRequest) Descriptor deprecated

func (*DeviceInputConfigDeleteRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeviceInputConfigDeleteRequest.ProtoReflect.Descriptor instead.

func (*DeviceInputConfigDeleteRequest) GetKey

func (*DeviceInputConfigDeleteRequest) ProtoMessage

func (*DeviceInputConfigDeleteRequest) ProtoMessage()

func (*DeviceInputConfigDeleteRequest) ProtoReflect

func (*DeviceInputConfigDeleteRequest) Reset

func (x *DeviceInputConfigDeleteRequest) Reset()

func (*DeviceInputConfigDeleteRequest) String

type DeviceInputConfigDeleteResponse

type DeviceInputConfigDeleteResponse struct {

	// Key echoes back the key of the deleted DeviceInputConfig instance.
	Key *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the (UTC) timestamp at which the system recognizes the
	// deletion. The only guarantees made about this timestamp are:
	//
	//   - it is after the time the request was received
	//   - a time-ranged query with StartTime==DeletedAt will not include this instance.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceInputConfigDeleteResponse) Descriptor deprecated

func (*DeviceInputConfigDeleteResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeviceInputConfigDeleteResponse.ProtoReflect.Descriptor instead.

func (*DeviceInputConfigDeleteResponse) GetKey

func (*DeviceInputConfigDeleteResponse) GetTime

func (*DeviceInputConfigDeleteResponse) ProtoMessage

func (*DeviceInputConfigDeleteResponse) ProtoMessage()

func (*DeviceInputConfigDeleteResponse) ProtoReflect

func (*DeviceInputConfigDeleteResponse) Reset

func (*DeviceInputConfigDeleteResponse) String

type DeviceInputConfigDeleteSomeRequest

type DeviceInputConfigDeleteSomeRequest struct {

	// key contains a list of DeviceInputConfig keys to delete
	Keys []*DeviceKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceInputConfigDeleteSomeRequest) Descriptor deprecated

func (*DeviceInputConfigDeleteSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeviceInputConfigDeleteSomeRequest.ProtoReflect.Descriptor instead.

func (*DeviceInputConfigDeleteSomeRequest) GetKeys

func (*DeviceInputConfigDeleteSomeRequest) ProtoMessage

func (*DeviceInputConfigDeleteSomeRequest) ProtoMessage()

func (*DeviceInputConfigDeleteSomeRequest) ProtoReflect

func (*DeviceInputConfigDeleteSomeRequest) Reset

func (*DeviceInputConfigDeleteSomeRequest) String

type DeviceInputConfigDeleteSomeResponse

type DeviceInputConfigDeleteSomeResponse struct {
	Key   *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Error string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

DeviceInputConfigDeleteSomeResponse is only sent when there is an error.

func (*DeviceInputConfigDeleteSomeResponse) Descriptor deprecated

func (*DeviceInputConfigDeleteSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeviceInputConfigDeleteSomeResponse.ProtoReflect.Descriptor instead.

func (*DeviceInputConfigDeleteSomeResponse) GetError

func (*DeviceInputConfigDeleteSomeResponse) GetKey

func (*DeviceInputConfigDeleteSomeResponse) ProtoMessage

func (*DeviceInputConfigDeleteSomeResponse) ProtoMessage()

func (*DeviceInputConfigDeleteSomeResponse) ProtoReflect

func (*DeviceInputConfigDeleteSomeResponse) Reset

func (*DeviceInputConfigDeleteSomeResponse) String

type DeviceInputConfigRequest

type DeviceInputConfigRequest struct {

	// Key uniquely identifies a DeviceInputConfig instance to retrieve.
	// This value must be populated.
	Key *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceInputConfigRequest) Descriptor deprecated

func (*DeviceInputConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeviceInputConfigRequest.ProtoReflect.Descriptor instead.

func (*DeviceInputConfigRequest) GetKey

func (x *DeviceInputConfigRequest) GetKey() *DeviceKey

func (*DeviceInputConfigRequest) GetTime

func (*DeviceInputConfigRequest) ProtoMessage

func (*DeviceInputConfigRequest) ProtoMessage()

func (*DeviceInputConfigRequest) ProtoReflect

func (x *DeviceInputConfigRequest) ProtoReflect() protoreflect.Message

func (*DeviceInputConfigRequest) Reset

func (x *DeviceInputConfigRequest) Reset()

func (*DeviceInputConfigRequest) String

func (x *DeviceInputConfigRequest) String() string

type DeviceInputConfigResponse

type DeviceInputConfigResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *DeviceInputConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time carries the (UTC) timestamp of the last-modification of the
	// DeviceInputConfig instance in this response.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceInputConfigResponse) Descriptor deprecated

func (*DeviceInputConfigResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeviceInputConfigResponse.ProtoReflect.Descriptor instead.

func (*DeviceInputConfigResponse) GetTime

func (*DeviceInputConfigResponse) GetValue

func (*DeviceInputConfigResponse) ProtoMessage

func (*DeviceInputConfigResponse) ProtoMessage()

func (*DeviceInputConfigResponse) ProtoReflect

func (*DeviceInputConfigResponse) Reset

func (x *DeviceInputConfigResponse) Reset()

func (*DeviceInputConfigResponse) String

func (x *DeviceInputConfigResponse) String() string

type DeviceInputConfigServiceClient

type DeviceInputConfigServiceClient interface {
	GetOne(ctx context.Context, in *DeviceInputConfigRequest, opts ...grpc.CallOption) (*DeviceInputConfigResponse, error)
	GetSome(ctx context.Context, in *DeviceInputConfigSomeRequest, opts ...grpc.CallOption) (DeviceInputConfigService_GetSomeClient, error)
	GetAll(ctx context.Context, in *DeviceInputConfigStreamRequest, opts ...grpc.CallOption) (DeviceInputConfigService_GetAllClient, error)
	Subscribe(ctx context.Context, in *DeviceInputConfigStreamRequest, opts ...grpc.CallOption) (DeviceInputConfigService_SubscribeClient, error)
	GetMeta(ctx context.Context, in *DeviceInputConfigStreamRequest, opts ...grpc.CallOption) (*MetaResponse, error)
	SubscribeMeta(ctx context.Context, in *DeviceInputConfigStreamRequest, opts ...grpc.CallOption) (DeviceInputConfigService_SubscribeMetaClient, error)
	Set(ctx context.Context, in *DeviceInputConfigSetRequest, opts ...grpc.CallOption) (*DeviceInputConfigSetResponse, error)
	SetSome(ctx context.Context, in *DeviceInputConfigSetSomeRequest, opts ...grpc.CallOption) (DeviceInputConfigService_SetSomeClient, error)
	Delete(ctx context.Context, in *DeviceInputConfigDeleteRequest, opts ...grpc.CallOption) (*DeviceInputConfigDeleteResponse, error)
	DeleteSome(ctx context.Context, in *DeviceInputConfigDeleteSomeRequest, opts ...grpc.CallOption) (DeviceInputConfigService_DeleteSomeClient, error)
	DeleteAll(ctx context.Context, in *DeviceInputConfigDeleteAllRequest, opts ...grpc.CallOption) (DeviceInputConfigService_DeleteAllClient, error)
	GetAllBatched(ctx context.Context, in *DeviceInputConfigBatchedStreamRequest, opts ...grpc.CallOption) (DeviceInputConfigService_GetAllBatchedClient, error)
	SubscribeBatched(ctx context.Context, in *DeviceInputConfigBatchedStreamRequest, opts ...grpc.CallOption) (DeviceInputConfigService_SubscribeBatchedClient, error)
}

DeviceInputConfigServiceClient is the client API for DeviceInputConfigService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type DeviceInputConfigServiceServer

DeviceInputConfigServiceServer is the server API for DeviceInputConfigService service. All implementations must embed UnimplementedDeviceInputConfigServiceServer for forward compatibility

type DeviceInputConfigService_DeleteAllClient

type DeviceInputConfigService_DeleteAllClient interface {
	Recv() (*DeviceInputConfigDeleteAllResponse, error)
	grpc.ClientStream
}

type DeviceInputConfigService_DeleteAllServer

type DeviceInputConfigService_DeleteAllServer interface {
	Send(*DeviceInputConfigDeleteAllResponse) error
	grpc.ServerStream
}

type DeviceInputConfigService_DeleteSomeClient

type DeviceInputConfigService_DeleteSomeClient interface {
	Recv() (*DeviceInputConfigDeleteSomeResponse, error)
	grpc.ClientStream
}

type DeviceInputConfigService_DeleteSomeServer

type DeviceInputConfigService_DeleteSomeServer interface {
	Send(*DeviceInputConfigDeleteSomeResponse) error
	grpc.ServerStream
}

type DeviceInputConfigService_GetAllBatchedClient

type DeviceInputConfigService_GetAllBatchedClient interface {
	Recv() (*DeviceInputConfigBatchedStreamResponse, error)
	grpc.ClientStream
}

type DeviceInputConfigService_GetAllBatchedServer

type DeviceInputConfigService_GetAllBatchedServer interface {
	Send(*DeviceInputConfigBatchedStreamResponse) error
	grpc.ServerStream
}

type DeviceInputConfigService_GetAllClient

type DeviceInputConfigService_GetAllClient interface {
	Recv() (*DeviceInputConfigStreamResponse, error)
	grpc.ClientStream
}

type DeviceInputConfigService_GetAllServer

type DeviceInputConfigService_GetAllServer interface {
	Send(*DeviceInputConfigStreamResponse) error
	grpc.ServerStream
}

type DeviceInputConfigService_GetSomeClient

type DeviceInputConfigService_GetSomeClient interface {
	Recv() (*DeviceInputConfigSomeResponse, error)
	grpc.ClientStream
}

type DeviceInputConfigService_GetSomeServer

type DeviceInputConfigService_GetSomeServer interface {
	Send(*DeviceInputConfigSomeResponse) error
	grpc.ServerStream
}

type DeviceInputConfigService_SetSomeClient

type DeviceInputConfigService_SetSomeClient interface {
	Recv() (*DeviceInputConfigSetSomeResponse, error)
	grpc.ClientStream
}

type DeviceInputConfigService_SetSomeServer

type DeviceInputConfigService_SetSomeServer interface {
	Send(*DeviceInputConfigSetSomeResponse) error
	grpc.ServerStream
}

type DeviceInputConfigService_SubscribeBatchedClient

type DeviceInputConfigService_SubscribeBatchedClient interface {
	Recv() (*DeviceInputConfigBatchedStreamResponse, error)
	grpc.ClientStream
}

type DeviceInputConfigService_SubscribeBatchedServer

type DeviceInputConfigService_SubscribeBatchedServer interface {
	Send(*DeviceInputConfigBatchedStreamResponse) error
	grpc.ServerStream
}

type DeviceInputConfigService_SubscribeClient

type DeviceInputConfigService_SubscribeClient interface {
	Recv() (*DeviceInputConfigStreamResponse, error)
	grpc.ClientStream
}

type DeviceInputConfigService_SubscribeMetaClient

type DeviceInputConfigService_SubscribeMetaClient interface {
	Recv() (*MetaResponse, error)
	grpc.ClientStream
}

type DeviceInputConfigService_SubscribeMetaServer

type DeviceInputConfigService_SubscribeMetaServer interface {
	Send(*MetaResponse) error
	grpc.ServerStream
}

type DeviceInputConfigService_SubscribeServer

type DeviceInputConfigService_SubscribeServer interface {
	Send(*DeviceInputConfigStreamResponse) error
	grpc.ServerStream
}

type DeviceInputConfigSetRequest

type DeviceInputConfigSetRequest struct {

	// DeviceInputConfig carries the value to set into the datastore.
	// See the documentation on the DeviceInputConfig struct for which fields are required.
	Value *DeviceInputConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceInputConfigSetRequest) Descriptor deprecated

func (*DeviceInputConfigSetRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeviceInputConfigSetRequest.ProtoReflect.Descriptor instead.

func (*DeviceInputConfigSetRequest) GetValue

func (*DeviceInputConfigSetRequest) ProtoMessage

func (*DeviceInputConfigSetRequest) ProtoMessage()

func (*DeviceInputConfigSetRequest) ProtoReflect

func (*DeviceInputConfigSetRequest) Reset

func (x *DeviceInputConfigSetRequest) Reset()

func (*DeviceInputConfigSetRequest) String

func (x *DeviceInputConfigSetRequest) String() string

type DeviceInputConfigSetResponse

type DeviceInputConfigSetResponse struct {

	// Value carries all the values given in the DeviceInputConfigSetRequest as well
	// as any server-generated values.
	Value *DeviceInputConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time indicates the (UTC) timestamp at which the system recognizes the
	// creation. The only guarantees made about this timestamp are:
	//
	//   - it is after the time the request was received
	//   - a time-ranged query with StartTime==CreatedAt will include this instance.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceInputConfigSetResponse) Descriptor deprecated

func (*DeviceInputConfigSetResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeviceInputConfigSetResponse.ProtoReflect.Descriptor instead.

func (*DeviceInputConfigSetResponse) GetTime

func (*DeviceInputConfigSetResponse) GetValue

func (*DeviceInputConfigSetResponse) ProtoMessage

func (*DeviceInputConfigSetResponse) ProtoMessage()

func (*DeviceInputConfigSetResponse) ProtoReflect

func (*DeviceInputConfigSetResponse) Reset

func (x *DeviceInputConfigSetResponse) Reset()

func (*DeviceInputConfigSetResponse) String

type DeviceInputConfigSetSomeRequest

type DeviceInputConfigSetSomeRequest struct {

	// value contains a list of DeviceInputConfig values to write.
	// It is possible to provide more values than can fit within either:
	//   - the maxiumum send size of the client
	//   - the maximum receive size of the server
	//
	// If this error occurs you must reduce the number of values sent.
	// See gRPC "maximum message size" documentation for more information.
	Values []*DeviceInputConfig `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceInputConfigSetSomeRequest) Descriptor deprecated

func (*DeviceInputConfigSetSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeviceInputConfigSetSomeRequest.ProtoReflect.Descriptor instead.

func (*DeviceInputConfigSetSomeRequest) GetValues

func (*DeviceInputConfigSetSomeRequest) ProtoMessage

func (*DeviceInputConfigSetSomeRequest) ProtoMessage()

func (*DeviceInputConfigSetSomeRequest) ProtoReflect

func (*DeviceInputConfigSetSomeRequest) Reset

func (*DeviceInputConfigSetSomeRequest) String

type DeviceInputConfigSetSomeResponse

type DeviceInputConfigSetSomeResponse struct {
	Key   *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Error string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceInputConfigSetSomeResponse) Descriptor deprecated

func (*DeviceInputConfigSetSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeviceInputConfigSetSomeResponse.ProtoReflect.Descriptor instead.

func (*DeviceInputConfigSetSomeResponse) GetError

func (*DeviceInputConfigSetSomeResponse) GetKey

func (*DeviceInputConfigSetSomeResponse) ProtoMessage

func (*DeviceInputConfigSetSomeResponse) ProtoMessage()

func (*DeviceInputConfigSetSomeResponse) ProtoReflect

func (*DeviceInputConfigSetSomeResponse) Reset

func (*DeviceInputConfigSetSomeResponse) String

type DeviceInputConfigSomeRequest

type DeviceInputConfigSomeRequest struct {
	Keys []*DeviceKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceInputConfigSomeRequest) Descriptor deprecated

func (*DeviceInputConfigSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeviceInputConfigSomeRequest.ProtoReflect.Descriptor instead.

func (*DeviceInputConfigSomeRequest) GetKeys

func (x *DeviceInputConfigSomeRequest) GetKeys() []*DeviceKey

func (*DeviceInputConfigSomeRequest) GetTime

func (*DeviceInputConfigSomeRequest) ProtoMessage

func (*DeviceInputConfigSomeRequest) ProtoMessage()

func (*DeviceInputConfigSomeRequest) ProtoReflect

func (*DeviceInputConfigSomeRequest) Reset

func (x *DeviceInputConfigSomeRequest) Reset()

func (*DeviceInputConfigSomeRequest) String

type DeviceInputConfigSomeResponse

type DeviceInputConfigSomeResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *DeviceInputConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Error is an optional field.
	// It should be filled when there is an error in the GetSome process.
	Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Time  *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceInputConfigSomeResponse) Descriptor deprecated

func (*DeviceInputConfigSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeviceInputConfigSomeResponse.ProtoReflect.Descriptor instead.

func (*DeviceInputConfigSomeResponse) GetError

func (*DeviceInputConfigSomeResponse) GetTime

func (*DeviceInputConfigSomeResponse) GetValue

func (*DeviceInputConfigSomeResponse) ProtoMessage

func (*DeviceInputConfigSomeResponse) ProtoMessage()

func (*DeviceInputConfigSomeResponse) ProtoReflect

func (*DeviceInputConfigSomeResponse) Reset

func (x *DeviceInputConfigSomeResponse) Reset()

func (*DeviceInputConfigSomeResponse) String

type DeviceInputConfigStreamRequest

type DeviceInputConfigStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*DeviceInputConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each DeviceInputConfig at end.
	//   - Each DeviceInputConfig response is fully-specified (all fields set).
	//   - start: Returns the state of each DeviceInputConfig at start, followed by updates until now.
	//   - Each DeviceInputConfig response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each DeviceInputConfig at start, followed by updates
	//     until end.
	//   - Each DeviceInputConfig response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceInputConfigStreamRequest) Descriptor deprecated

func (*DeviceInputConfigStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeviceInputConfigStreamRequest.ProtoReflect.Descriptor instead.

func (*DeviceInputConfigStreamRequest) GetPartialEqFilter

func (x *DeviceInputConfigStreamRequest) GetPartialEqFilter() []*DeviceInputConfig

func (*DeviceInputConfigStreamRequest) GetTime

func (*DeviceInputConfigStreamRequest) ProtoMessage

func (*DeviceInputConfigStreamRequest) ProtoMessage()

func (*DeviceInputConfigStreamRequest) ProtoReflect

func (*DeviceInputConfigStreamRequest) Reset

func (x *DeviceInputConfigStreamRequest) Reset()

func (*DeviceInputConfigStreamRequest) String

type DeviceInputConfigStreamResponse

type DeviceInputConfigStreamResponse struct {

	// Value is a value deemed relevant to the initiating request.
	// This structure will always have its key-field populated. Which other fields are
	// populated, and why, depends on the value of Operation and what triggered this notification.
	Value *DeviceInputConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time holds the timestamp of this DeviceInputConfig's last modification.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// Operation indicates how the DeviceInputConfig value in this response should be considered.
	// Under non-subscribe requests, this value should always be INITIAL. In a subscription,
	// once all initial data is streamed and the client begins to receive modification updates,
	// you should not see INITIAL again.
	Type subscriptions.Operation `protobuf:"varint,3,opt,name=type,proto3,enum=arista.subscriptions.Operation" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceInputConfigStreamResponse) Descriptor deprecated

func (*DeviceInputConfigStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeviceInputConfigStreamResponse.ProtoReflect.Descriptor instead.

func (*DeviceInputConfigStreamResponse) GetTime

func (*DeviceInputConfigStreamResponse) GetType

func (*DeviceInputConfigStreamResponse) GetValue

func (*DeviceInputConfigStreamResponse) ProtoMessage

func (*DeviceInputConfigStreamResponse) ProtoMessage()

func (*DeviceInputConfigStreamResponse) ProtoReflect

func (*DeviceInputConfigStreamResponse) Reset

func (*DeviceInputConfigStreamResponse) String

type DeviceKey

type DeviceKey struct {

	// workspace_id identifies the workspace uniquely.
	WorkspaceId *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	// device_id identifies the device uniquely.
	DeviceId *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	// contains filtered or unexported fields
}

DeviceKey uniquely identifies the device for a workspace.

func (*DeviceKey) Descriptor deprecated

func (*DeviceKey) Descriptor() ([]byte, []int)

Deprecated: Use DeviceKey.ProtoReflect.Descriptor instead.

func (*DeviceKey) GetDeviceId

func (x *DeviceKey) GetDeviceId() *wrapperspb.StringValue

func (*DeviceKey) GetWorkspaceId

func (x *DeviceKey) GetWorkspaceId() *wrapperspb.StringValue

func (*DeviceKey) ProtoMessage

func (*DeviceKey) ProtoMessage()

func (*DeviceKey) ProtoReflect

func (x *DeviceKey) ProtoReflect() protoreflect.Message

func (*DeviceKey) Reset

func (x *DeviceKey) Reset()

func (*DeviceKey) String

func (x *DeviceKey) String() string

type DeviceState

type DeviceState struct {

	// key uniquely identifies the device for a given workspace.
	Key *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// device_info contains device properties
	DeviceInfo *DeviceInfo `protobuf:"bytes,2,opt,name=device_info,json=deviceInfo,proto3" json:"device_info,omitempty"`
	// interface_infos contains interface properties of all the interfaces
	// belonging to the device
	InterfaceInfos *InterfaceInfos `protobuf:"bytes,3,opt,name=interface_infos,json=interfaceInfos,proto3" json:"interface_infos,omitempty"`
	// contains filtered or unexported fields
}

DeviceState is the state of a device written by InterfaceInputConfig, DeviceInputConfig and UpdateConfig resources

func (*DeviceState) Descriptor deprecated

func (*DeviceState) Descriptor() ([]byte, []int)

Deprecated: Use DeviceState.ProtoReflect.Descriptor instead.

func (*DeviceState) GetDeviceInfo

func (x *DeviceState) GetDeviceInfo() *DeviceInfo

func (*DeviceState) GetInterfaceInfos

func (x *DeviceState) GetInterfaceInfos() *InterfaceInfos

func (*DeviceState) GetKey

func (x *DeviceState) GetKey() *DeviceKey

func (*DeviceState) ProtoMessage

func (*DeviceState) ProtoMessage()

func (*DeviceState) ProtoReflect

func (x *DeviceState) ProtoReflect() protoreflect.Message

func (*DeviceState) Reset

func (x *DeviceState) Reset()

func (*DeviceState) String

func (x *DeviceState) String() string

type DeviceStateBatchedStreamRequest

type DeviceStateBatchedStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*DeviceState `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each DeviceState at end.
	//   - Each DeviceState response is fully-specified (all fields set).
	//   - start: Returns the state of each DeviceState at start, followed by updates until now.
	//   - Each DeviceState response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each DeviceState at start, followed by updates
	//     until end.
	//   - Each DeviceState response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// MaxMessages limits the maximum number of messages that can be contained in one batch.
	// MaxMessages is required to be at least 1.
	// The maximum number of messages in a batch is min(max_messages, INTERNAL_BATCH_LIMIT)
	// INTERNAL_BATCH_LIMIT is set based on the maximum message size.
	MaxMessages *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceStateBatchedStreamRequest) Descriptor deprecated

func (*DeviceStateBatchedStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeviceStateBatchedStreamRequest.ProtoReflect.Descriptor instead.

func (*DeviceStateBatchedStreamRequest) GetMaxMessages

func (*DeviceStateBatchedStreamRequest) GetPartialEqFilter

func (x *DeviceStateBatchedStreamRequest) GetPartialEqFilter() []*DeviceState

func (*DeviceStateBatchedStreamRequest) GetTime

func (*DeviceStateBatchedStreamRequest) ProtoMessage

func (*DeviceStateBatchedStreamRequest) ProtoMessage()

func (*DeviceStateBatchedStreamRequest) ProtoReflect

func (*DeviceStateBatchedStreamRequest) Reset

func (*DeviceStateBatchedStreamRequest) String

type DeviceStateBatchedStreamResponse

type DeviceStateBatchedStreamResponse struct {

	// Values are the values deemed relevant to the initiating request.
	// The length of this structure is guaranteed to be between (inclusive) 1 and
	// min(req.max_messages, INTERNAL_BATCH_LIMIT).
	Responses []*DeviceStateStreamResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceStateBatchedStreamResponse) Descriptor deprecated

func (*DeviceStateBatchedStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeviceStateBatchedStreamResponse.ProtoReflect.Descriptor instead.

func (*DeviceStateBatchedStreamResponse) GetResponses

func (*DeviceStateBatchedStreamResponse) ProtoMessage

func (*DeviceStateBatchedStreamResponse) ProtoMessage()

func (*DeviceStateBatchedStreamResponse) ProtoReflect

func (*DeviceStateBatchedStreamResponse) Reset

func (*DeviceStateBatchedStreamResponse) String

type DeviceStateRequest

type DeviceStateRequest struct {

	// Key uniquely identifies a DeviceState instance to retrieve.
	// This value must be populated.
	Key *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceStateRequest) Descriptor deprecated

func (*DeviceStateRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeviceStateRequest.ProtoReflect.Descriptor instead.

func (*DeviceStateRequest) GetKey

func (x *DeviceStateRequest) GetKey() *DeviceKey

func (*DeviceStateRequest) GetTime

func (*DeviceStateRequest) ProtoMessage

func (*DeviceStateRequest) ProtoMessage()

func (*DeviceStateRequest) ProtoReflect

func (x *DeviceStateRequest) ProtoReflect() protoreflect.Message

func (*DeviceStateRequest) Reset

func (x *DeviceStateRequest) Reset()

func (*DeviceStateRequest) String

func (x *DeviceStateRequest) String() string

type DeviceStateResponse

type DeviceStateResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *DeviceState `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time carries the (UTC) timestamp of the last-modification of the
	// DeviceState instance in this response.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceStateResponse) Descriptor deprecated

func (*DeviceStateResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeviceStateResponse.ProtoReflect.Descriptor instead.

func (*DeviceStateResponse) GetTime

func (*DeviceStateResponse) GetValue

func (x *DeviceStateResponse) GetValue() *DeviceState

func (*DeviceStateResponse) ProtoMessage

func (*DeviceStateResponse) ProtoMessage()

func (*DeviceStateResponse) ProtoReflect

func (x *DeviceStateResponse) ProtoReflect() protoreflect.Message

func (*DeviceStateResponse) Reset

func (x *DeviceStateResponse) Reset()

func (*DeviceStateResponse) String

func (x *DeviceStateResponse) String() string

type DeviceStateServiceServer

DeviceStateServiceServer is the server API for DeviceStateService service. All implementations must embed UnimplementedDeviceStateServiceServer for forward compatibility

type DeviceStateService_GetAllBatchedClient

type DeviceStateService_GetAllBatchedClient interface {
	Recv() (*DeviceStateBatchedStreamResponse, error)
	grpc.ClientStream
}

type DeviceStateService_GetAllBatchedServer

type DeviceStateService_GetAllBatchedServer interface {
	Send(*DeviceStateBatchedStreamResponse) error
	grpc.ServerStream
}

type DeviceStateService_GetAllClient

type DeviceStateService_GetAllClient interface {
	Recv() (*DeviceStateStreamResponse, error)
	grpc.ClientStream
}

type DeviceStateService_GetAllServer

type DeviceStateService_GetAllServer interface {
	Send(*DeviceStateStreamResponse) error
	grpc.ServerStream
}

type DeviceStateService_GetSomeClient

type DeviceStateService_GetSomeClient interface {
	Recv() (*DeviceStateSomeResponse, error)
	grpc.ClientStream
}

type DeviceStateService_GetSomeServer

type DeviceStateService_GetSomeServer interface {
	Send(*DeviceStateSomeResponse) error
	grpc.ServerStream
}

type DeviceStateService_SubscribeBatchedClient

type DeviceStateService_SubscribeBatchedClient interface {
	Recv() (*DeviceStateBatchedStreamResponse, error)
	grpc.ClientStream
}

type DeviceStateService_SubscribeBatchedServer

type DeviceStateService_SubscribeBatchedServer interface {
	Send(*DeviceStateBatchedStreamResponse) error
	grpc.ServerStream
}

type DeviceStateService_SubscribeClient

type DeviceStateService_SubscribeClient interface {
	Recv() (*DeviceStateStreamResponse, error)
	grpc.ClientStream
}

type DeviceStateService_SubscribeMetaClient

type DeviceStateService_SubscribeMetaClient interface {
	Recv() (*MetaResponse, error)
	grpc.ClientStream
}

type DeviceStateService_SubscribeMetaServer

type DeviceStateService_SubscribeMetaServer interface {
	Send(*MetaResponse) error
	grpc.ServerStream
}

type DeviceStateService_SubscribeServer

type DeviceStateService_SubscribeServer interface {
	Send(*DeviceStateStreamResponse) error
	grpc.ServerStream
}

type DeviceStateSomeRequest

type DeviceStateSomeRequest struct {
	Keys []*DeviceKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceStateSomeRequest) Descriptor deprecated

func (*DeviceStateSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeviceStateSomeRequest.ProtoReflect.Descriptor instead.

func (*DeviceStateSomeRequest) GetKeys

func (x *DeviceStateSomeRequest) GetKeys() []*DeviceKey

func (*DeviceStateSomeRequest) GetTime

func (*DeviceStateSomeRequest) ProtoMessage

func (*DeviceStateSomeRequest) ProtoMessage()

func (*DeviceStateSomeRequest) ProtoReflect

func (x *DeviceStateSomeRequest) ProtoReflect() protoreflect.Message

func (*DeviceStateSomeRequest) Reset

func (x *DeviceStateSomeRequest) Reset()

func (*DeviceStateSomeRequest) String

func (x *DeviceStateSomeRequest) String() string

type DeviceStateSomeResponse

type DeviceStateSomeResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *DeviceState `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Error is an optional field.
	// It should be filled when there is an error in the GetSome process.
	Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Time  *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceStateSomeResponse) Descriptor deprecated

func (*DeviceStateSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeviceStateSomeResponse.ProtoReflect.Descriptor instead.

func (*DeviceStateSomeResponse) GetError

func (*DeviceStateSomeResponse) GetTime

func (*DeviceStateSomeResponse) GetValue

func (x *DeviceStateSomeResponse) GetValue() *DeviceState

func (*DeviceStateSomeResponse) ProtoMessage

func (*DeviceStateSomeResponse) ProtoMessage()

func (*DeviceStateSomeResponse) ProtoReflect

func (x *DeviceStateSomeResponse) ProtoReflect() protoreflect.Message

func (*DeviceStateSomeResponse) Reset

func (x *DeviceStateSomeResponse) Reset()

func (*DeviceStateSomeResponse) String

func (x *DeviceStateSomeResponse) String() string

type DeviceStateStreamRequest

type DeviceStateStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*DeviceState `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each DeviceState at end.
	//   - Each DeviceState response is fully-specified (all fields set).
	//   - start: Returns the state of each DeviceState at start, followed by updates until now.
	//   - Each DeviceState response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each DeviceState at start, followed by updates
	//     until end.
	//   - Each DeviceState response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceStateStreamRequest) Descriptor deprecated

func (*DeviceStateStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use DeviceStateStreamRequest.ProtoReflect.Descriptor instead.

func (*DeviceStateStreamRequest) GetPartialEqFilter

func (x *DeviceStateStreamRequest) GetPartialEqFilter() []*DeviceState

func (*DeviceStateStreamRequest) GetTime

func (*DeviceStateStreamRequest) ProtoMessage

func (*DeviceStateStreamRequest) ProtoMessage()

func (*DeviceStateStreamRequest) ProtoReflect

func (x *DeviceStateStreamRequest) ProtoReflect() protoreflect.Message

func (*DeviceStateStreamRequest) Reset

func (x *DeviceStateStreamRequest) Reset()

func (*DeviceStateStreamRequest) String

func (x *DeviceStateStreamRequest) String() string

type DeviceStateStreamResponse

type DeviceStateStreamResponse struct {

	// Value is a value deemed relevant to the initiating request.
	// This structure will always have its key-field populated. Which other fields are
	// populated, and why, depends on the value of Operation and what triggered this notification.
	Value *DeviceState `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time holds the timestamp of this DeviceState's last modification.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// Operation indicates how the DeviceState value in this response should be considered.
	// Under non-subscribe requests, this value should always be INITIAL. In a subscription,
	// once all initial data is streamed and the client begins to receive modification updates,
	// you should not see INITIAL again.
	Type subscriptions.Operation `protobuf:"varint,3,opt,name=type,proto3,enum=arista.subscriptions.Operation" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*DeviceStateStreamResponse) Descriptor deprecated

func (*DeviceStateStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use DeviceStateStreamResponse.ProtoReflect.Descriptor instead.

func (*DeviceStateStreamResponse) GetTime

func (*DeviceStateStreamResponse) GetType

func (*DeviceStateStreamResponse) GetValue

func (x *DeviceStateStreamResponse) GetValue() *DeviceState

func (*DeviceStateStreamResponse) ProtoMessage

func (*DeviceStateStreamResponse) ProtoMessage()

func (*DeviceStateStreamResponse) ProtoReflect

func (*DeviceStateStreamResponse) Reset

func (x *DeviceStateStreamResponse) Reset()

func (*DeviceStateStreamResponse) String

func (x *DeviceStateStreamResponse) String() string

type Element

type Element int32

Element defines the fundamental types of elements in topology.

const (
	// ELEMENT_UNSPECIFIED indicates an unspecified element type.
	Element_ELEMENT_UNSPECIFIED Element = 0
	// ELEMENT_DEVICE indicates a device.
	Element_ELEMENT_DEVICE Element = 1
	// ELEMENT_INTERFACE indicates an interface.
	Element_ELEMENT_INTERFACE Element = 2
	// ELEMENT_CONNECTION indicates a connection.
	Element_ELEMENT_CONNECTION Element = 3
)

func (Element) Descriptor

func (Element) Descriptor() protoreflect.EnumDescriptor

func (Element) Enum

func (x Element) Enum() *Element

func (Element) EnumDescriptor deprecated

func (Element) EnumDescriptor() ([]byte, []int)

Deprecated: Use Element.Descriptor instead.

func (Element) Number

func (x Element) Number() protoreflect.EnumNumber

func (Element) String

func (x Element) String() string

func (Element) Type

func (Element) Type() protoreflect.EnumType

type InterfaceInfo

type InterfaceInfo struct {

	// name is the name of an interface.
	Name *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// neighbor_device_id indicates the device ID of the neighbor to which
	// this interface is connected.
	NeighborDeviceId *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=neighbor_device_id,json=neighborDeviceId,proto3" json:"neighbor_device_id,omitempty"`
	// neighbor_interface_name indicates the interface on the neighbor to which
	// this interface is connected.
	NeighborInterfaceName *wrapperspb.StringValue `` /* 126-byte string literal not displayed */
	// contains filtered or unexported fields
}

InterfaceInfo contains interface properties.

func (*InterfaceInfo) Descriptor deprecated

func (*InterfaceInfo) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceInfo.ProtoReflect.Descriptor instead.

func (*InterfaceInfo) GetName

func (x *InterfaceInfo) GetName() *wrapperspb.StringValue

func (*InterfaceInfo) GetNeighborDeviceId

func (x *InterfaceInfo) GetNeighborDeviceId() *wrapperspb.StringValue

func (*InterfaceInfo) GetNeighborInterfaceName

func (x *InterfaceInfo) GetNeighborInterfaceName() *wrapperspb.StringValue

func (*InterfaceInfo) ProtoMessage

func (*InterfaceInfo) ProtoMessage()

func (*InterfaceInfo) ProtoReflect

func (x *InterfaceInfo) ProtoReflect() protoreflect.Message

func (*InterfaceInfo) Reset

func (x *InterfaceInfo) Reset()

func (*InterfaceInfo) String

func (x *InterfaceInfo) String() string

type InterfaceInfos

type InterfaceInfos struct {

	// values is a list of InterfaceInfo.
	Values []*InterfaceInfo `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

InterfaceInfos is a list of InterfaceInfo.

func (*InterfaceInfos) Descriptor deprecated

func (*InterfaceInfos) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceInfos.ProtoReflect.Descriptor instead.

func (*InterfaceInfos) GetValues

func (x *InterfaceInfos) GetValues() []*InterfaceInfo

func (*InterfaceInfos) ProtoMessage

func (*InterfaceInfos) ProtoMessage()

func (*InterfaceInfos) ProtoReflect

func (x *InterfaceInfos) ProtoReflect() protoreflect.Message

func (*InterfaceInfos) Reset

func (x *InterfaceInfos) Reset()

func (*InterfaceInfos) String

func (x *InterfaceInfos) String() string

type InterfaceInputConfig

type InterfaceInputConfig struct {

	// key uniquely identifies the interface for a given workspace.
	Key *InterfaceInputKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// interface_info contains interface properties.
	InterfaceInfo *InterfaceInfo `protobuf:"bytes,2,opt,name=interface_info,json=interfaceInfo,proto3" json:"interface_info,omitempty"`
	// remove if set to true will remove the interface from mainline
	// post workspace merge
	Remove *wrapperspb.BoolValue `protobuf:"bytes,3,opt,name=remove,proto3" json:"remove,omitempty"`
	// contains filtered or unexported fields
}

InterfaceInputConfig is the resource for manually adding an interface in I&T studios

func (*InterfaceInputConfig) Descriptor deprecated

func (*InterfaceInputConfig) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceInputConfig.ProtoReflect.Descriptor instead.

func (*InterfaceInputConfig) GetInterfaceInfo

func (x *InterfaceInputConfig) GetInterfaceInfo() *InterfaceInfo

func (*InterfaceInputConfig) GetKey

func (*InterfaceInputConfig) GetRemove

func (x *InterfaceInputConfig) GetRemove() *wrapperspb.BoolValue

func (*InterfaceInputConfig) ProtoMessage

func (*InterfaceInputConfig) ProtoMessage()

func (*InterfaceInputConfig) ProtoReflect

func (x *InterfaceInputConfig) ProtoReflect() protoreflect.Message

func (*InterfaceInputConfig) Reset

func (x *InterfaceInputConfig) Reset()

func (*InterfaceInputConfig) String

func (x *InterfaceInputConfig) String() string

type InterfaceInputConfigBatchedStreamRequest

type InterfaceInputConfigBatchedStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*InterfaceInputConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each InterfaceInputConfig at end.
	//   - Each InterfaceInputConfig response is fully-specified (all fields set).
	//   - start: Returns the state of each InterfaceInputConfig at start, followed by updates until now.
	//   - Each InterfaceInputConfig response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each InterfaceInputConfig at start, followed by updates
	//     until end.
	//   - Each InterfaceInputConfig response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// MaxMessages limits the maximum number of messages that can be contained in one batch.
	// MaxMessages is required to be at least 1.
	// The maximum number of messages in a batch is min(max_messages, INTERNAL_BATCH_LIMIT)
	// INTERNAL_BATCH_LIMIT is set based on the maximum message size.
	MaxMessages *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"`
	// contains filtered or unexported fields
}

func (*InterfaceInputConfigBatchedStreamRequest) Descriptor deprecated

func (*InterfaceInputConfigBatchedStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceInputConfigBatchedStreamRequest.ProtoReflect.Descriptor instead.

func (*InterfaceInputConfigBatchedStreamRequest) GetMaxMessages

func (*InterfaceInputConfigBatchedStreamRequest) GetPartialEqFilter

func (*InterfaceInputConfigBatchedStreamRequest) GetTime

func (*InterfaceInputConfigBatchedStreamRequest) ProtoMessage

func (*InterfaceInputConfigBatchedStreamRequest) ProtoReflect

func (*InterfaceInputConfigBatchedStreamRequest) Reset

func (*InterfaceInputConfigBatchedStreamRequest) String

type InterfaceInputConfigBatchedStreamResponse

type InterfaceInputConfigBatchedStreamResponse struct {

	// Values are the values deemed relevant to the initiating request.
	// The length of this structure is guaranteed to be between (inclusive) 1 and
	// min(req.max_messages, INTERNAL_BATCH_LIMIT).
	Responses []*InterfaceInputConfigStreamResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*InterfaceInputConfigBatchedStreamResponse) Descriptor deprecated

func (*InterfaceInputConfigBatchedStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceInputConfigBatchedStreamResponse.ProtoReflect.Descriptor instead.

func (*InterfaceInputConfigBatchedStreamResponse) GetResponses

func (*InterfaceInputConfigBatchedStreamResponse) ProtoMessage

func (*InterfaceInputConfigBatchedStreamResponse) ProtoReflect

func (*InterfaceInputConfigBatchedStreamResponse) Reset

func (*InterfaceInputConfigBatchedStreamResponse) String

type InterfaceInputConfigDeleteAllRequest

type InterfaceInputConfigDeleteAllRequest struct {

	// PartialEqFilter provides a way to server-side filter a DeleteAll.
	// This requires all provided fields to be equal to the response.
	// A filtered DeleteAll will use GetAll with filter to find things to delete.
	PartialEqFilter []*InterfaceInputConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*InterfaceInputConfigDeleteAllRequest) Descriptor deprecated

func (*InterfaceInputConfigDeleteAllRequest) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceInputConfigDeleteAllRequest.ProtoReflect.Descriptor instead.

func (*InterfaceInputConfigDeleteAllRequest) GetPartialEqFilter

func (*InterfaceInputConfigDeleteAllRequest) ProtoMessage

func (*InterfaceInputConfigDeleteAllRequest) ProtoMessage()

func (*InterfaceInputConfigDeleteAllRequest) ProtoReflect

func (*InterfaceInputConfigDeleteAllRequest) Reset

func (*InterfaceInputConfigDeleteAllRequest) String

type InterfaceInputConfigDeleteAllResponse

type InterfaceInputConfigDeleteAllResponse struct {

	// This describes the class of delete error.
	// A DeleteAllResponse is only sent when there is an error.
	Type fmp.DeleteError `protobuf:"varint,1,opt,name=type,proto3,enum=fmp.DeleteError" json:"type,omitempty"`
	// This indicates the error message from the delete failure.
	Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// This is the key of the InterfaceInputConfig instance that failed to be deleted.
	Key *InterfaceInputKey `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the (UTC) timestamp when the key was being deleted.
	Time *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*InterfaceInputConfigDeleteAllResponse) Descriptor deprecated

func (*InterfaceInputConfigDeleteAllResponse) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceInputConfigDeleteAllResponse.ProtoReflect.Descriptor instead.

func (*InterfaceInputConfigDeleteAllResponse) GetError

func (*InterfaceInputConfigDeleteAllResponse) GetKey

func (*InterfaceInputConfigDeleteAllResponse) GetTime

func (*InterfaceInputConfigDeleteAllResponse) GetType

func (*InterfaceInputConfigDeleteAllResponse) ProtoMessage

func (*InterfaceInputConfigDeleteAllResponse) ProtoMessage()

func (*InterfaceInputConfigDeleteAllResponse) ProtoReflect

func (*InterfaceInputConfigDeleteAllResponse) Reset

func (*InterfaceInputConfigDeleteAllResponse) String

type InterfaceInputConfigDeleteRequest

type InterfaceInputConfigDeleteRequest struct {

	// Key indicates which InterfaceInputConfig instance to remove.
	// This field must always be set.
	Key *InterfaceInputKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*InterfaceInputConfigDeleteRequest) Descriptor deprecated

func (*InterfaceInputConfigDeleteRequest) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceInputConfigDeleteRequest.ProtoReflect.Descriptor instead.

func (*InterfaceInputConfigDeleteRequest) GetKey

func (*InterfaceInputConfigDeleteRequest) ProtoMessage

func (*InterfaceInputConfigDeleteRequest) ProtoMessage()

func (*InterfaceInputConfigDeleteRequest) ProtoReflect

func (*InterfaceInputConfigDeleteRequest) Reset

func (*InterfaceInputConfigDeleteRequest) String

type InterfaceInputConfigDeleteResponse

type InterfaceInputConfigDeleteResponse struct {

	// Key echoes back the key of the deleted InterfaceInputConfig instance.
	Key *InterfaceInputKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the (UTC) timestamp at which the system recognizes the
	// deletion. The only guarantees made about this timestamp are:
	//
	//   - it is after the time the request was received
	//   - a time-ranged query with StartTime==DeletedAt will not include this instance.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*InterfaceInputConfigDeleteResponse) Descriptor deprecated

func (*InterfaceInputConfigDeleteResponse) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceInputConfigDeleteResponse.ProtoReflect.Descriptor instead.

func (*InterfaceInputConfigDeleteResponse) GetKey

func (*InterfaceInputConfigDeleteResponse) GetTime

func (*InterfaceInputConfigDeleteResponse) ProtoMessage

func (*InterfaceInputConfigDeleteResponse) ProtoMessage()

func (*InterfaceInputConfigDeleteResponse) ProtoReflect

func (*InterfaceInputConfigDeleteResponse) Reset

func (*InterfaceInputConfigDeleteResponse) String

type InterfaceInputConfigDeleteSomeRequest

type InterfaceInputConfigDeleteSomeRequest struct {

	// key contains a list of InterfaceInputConfig keys to delete
	Keys []*InterfaceInputKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*InterfaceInputConfigDeleteSomeRequest) Descriptor deprecated

func (*InterfaceInputConfigDeleteSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceInputConfigDeleteSomeRequest.ProtoReflect.Descriptor instead.

func (*InterfaceInputConfigDeleteSomeRequest) GetKeys

func (*InterfaceInputConfigDeleteSomeRequest) ProtoMessage

func (*InterfaceInputConfigDeleteSomeRequest) ProtoMessage()

func (*InterfaceInputConfigDeleteSomeRequest) ProtoReflect

func (*InterfaceInputConfigDeleteSomeRequest) Reset

func (*InterfaceInputConfigDeleteSomeRequest) String

type InterfaceInputConfigDeleteSomeResponse

type InterfaceInputConfigDeleteSomeResponse struct {
	Key   *InterfaceInputKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Error string             `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

InterfaceInputConfigDeleteSomeResponse is only sent when there is an error.

func (*InterfaceInputConfigDeleteSomeResponse) Descriptor deprecated

func (*InterfaceInputConfigDeleteSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceInputConfigDeleteSomeResponse.ProtoReflect.Descriptor instead.

func (*InterfaceInputConfigDeleteSomeResponse) GetError

func (*InterfaceInputConfigDeleteSomeResponse) GetKey

func (*InterfaceInputConfigDeleteSomeResponse) ProtoMessage

func (*InterfaceInputConfigDeleteSomeResponse) ProtoReflect

func (*InterfaceInputConfigDeleteSomeResponse) Reset

func (*InterfaceInputConfigDeleteSomeResponse) String

type InterfaceInputConfigRequest

type InterfaceInputConfigRequest struct {

	// Key uniquely identifies a InterfaceInputConfig instance to retrieve.
	// This value must be populated.
	Key *InterfaceInputKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*InterfaceInputConfigRequest) Descriptor deprecated

func (*InterfaceInputConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceInputConfigRequest.ProtoReflect.Descriptor instead.

func (*InterfaceInputConfigRequest) GetKey

func (*InterfaceInputConfigRequest) GetTime

func (*InterfaceInputConfigRequest) ProtoMessage

func (*InterfaceInputConfigRequest) ProtoMessage()

func (*InterfaceInputConfigRequest) ProtoReflect

func (*InterfaceInputConfigRequest) Reset

func (x *InterfaceInputConfigRequest) Reset()

func (*InterfaceInputConfigRequest) String

func (x *InterfaceInputConfigRequest) String() string

type InterfaceInputConfigResponse

type InterfaceInputConfigResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *InterfaceInputConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time carries the (UTC) timestamp of the last-modification of the
	// InterfaceInputConfig instance in this response.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*InterfaceInputConfigResponse) Descriptor deprecated

func (*InterfaceInputConfigResponse) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceInputConfigResponse.ProtoReflect.Descriptor instead.

func (*InterfaceInputConfigResponse) GetTime

func (*InterfaceInputConfigResponse) GetValue

func (*InterfaceInputConfigResponse) ProtoMessage

func (*InterfaceInputConfigResponse) ProtoMessage()

func (*InterfaceInputConfigResponse) ProtoReflect

func (*InterfaceInputConfigResponse) Reset

func (x *InterfaceInputConfigResponse) Reset()

func (*InterfaceInputConfigResponse) String

type InterfaceInputConfigServiceClient

type InterfaceInputConfigServiceClient interface {
	GetOne(ctx context.Context, in *InterfaceInputConfigRequest, opts ...grpc.CallOption) (*InterfaceInputConfigResponse, error)
	GetSome(ctx context.Context, in *InterfaceInputConfigSomeRequest, opts ...grpc.CallOption) (InterfaceInputConfigService_GetSomeClient, error)
	GetAll(ctx context.Context, in *InterfaceInputConfigStreamRequest, opts ...grpc.CallOption) (InterfaceInputConfigService_GetAllClient, error)
	Subscribe(ctx context.Context, in *InterfaceInputConfigStreamRequest, opts ...grpc.CallOption) (InterfaceInputConfigService_SubscribeClient, error)
	GetMeta(ctx context.Context, in *InterfaceInputConfigStreamRequest, opts ...grpc.CallOption) (*MetaResponse, error)
	SubscribeMeta(ctx context.Context, in *InterfaceInputConfigStreamRequest, opts ...grpc.CallOption) (InterfaceInputConfigService_SubscribeMetaClient, error)
	Set(ctx context.Context, in *InterfaceInputConfigSetRequest, opts ...grpc.CallOption) (*InterfaceInputConfigSetResponse, error)
	SetSome(ctx context.Context, in *InterfaceInputConfigSetSomeRequest, opts ...grpc.CallOption) (InterfaceInputConfigService_SetSomeClient, error)
	Delete(ctx context.Context, in *InterfaceInputConfigDeleteRequest, opts ...grpc.CallOption) (*InterfaceInputConfigDeleteResponse, error)
	DeleteSome(ctx context.Context, in *InterfaceInputConfigDeleteSomeRequest, opts ...grpc.CallOption) (InterfaceInputConfigService_DeleteSomeClient, error)
	DeleteAll(ctx context.Context, in *InterfaceInputConfigDeleteAllRequest, opts ...grpc.CallOption) (InterfaceInputConfigService_DeleteAllClient, error)
	GetAllBatched(ctx context.Context, in *InterfaceInputConfigBatchedStreamRequest, opts ...grpc.CallOption) (InterfaceInputConfigService_GetAllBatchedClient, error)
	SubscribeBatched(ctx context.Context, in *InterfaceInputConfigBatchedStreamRequest, opts ...grpc.CallOption) (InterfaceInputConfigService_SubscribeBatchedClient, error)
}

InterfaceInputConfigServiceClient is the client API for InterfaceInputConfigService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type InterfaceInputConfigServiceServer

InterfaceInputConfigServiceServer is the server API for InterfaceInputConfigService service. All implementations must embed UnimplementedInterfaceInputConfigServiceServer for forward compatibility

type InterfaceInputConfigService_DeleteAllClient

type InterfaceInputConfigService_DeleteAllClient interface {
	Recv() (*InterfaceInputConfigDeleteAllResponse, error)
	grpc.ClientStream
}

type InterfaceInputConfigService_DeleteAllServer

type InterfaceInputConfigService_DeleteAllServer interface {
	Send(*InterfaceInputConfigDeleteAllResponse) error
	grpc.ServerStream
}

type InterfaceInputConfigService_DeleteSomeClient

type InterfaceInputConfigService_DeleteSomeClient interface {
	Recv() (*InterfaceInputConfigDeleteSomeResponse, error)
	grpc.ClientStream
}

type InterfaceInputConfigService_DeleteSomeServer

type InterfaceInputConfigService_DeleteSomeServer interface {
	Send(*InterfaceInputConfigDeleteSomeResponse) error
	grpc.ServerStream
}

type InterfaceInputConfigService_GetAllBatchedClient

type InterfaceInputConfigService_GetAllBatchedClient interface {
	Recv() (*InterfaceInputConfigBatchedStreamResponse, error)
	grpc.ClientStream
}

type InterfaceInputConfigService_GetAllBatchedServer

type InterfaceInputConfigService_GetAllBatchedServer interface {
	Send(*InterfaceInputConfigBatchedStreamResponse) error
	grpc.ServerStream
}

type InterfaceInputConfigService_GetAllClient

type InterfaceInputConfigService_GetAllClient interface {
	Recv() (*InterfaceInputConfigStreamResponse, error)
	grpc.ClientStream
}

type InterfaceInputConfigService_GetAllServer

type InterfaceInputConfigService_GetAllServer interface {
	Send(*InterfaceInputConfigStreamResponse) error
	grpc.ServerStream
}

type InterfaceInputConfigService_GetSomeClient

type InterfaceInputConfigService_GetSomeClient interface {
	Recv() (*InterfaceInputConfigSomeResponse, error)
	grpc.ClientStream
}

type InterfaceInputConfigService_GetSomeServer

type InterfaceInputConfigService_GetSomeServer interface {
	Send(*InterfaceInputConfigSomeResponse) error
	grpc.ServerStream
}

type InterfaceInputConfigService_SetSomeClient

type InterfaceInputConfigService_SetSomeClient interface {
	Recv() (*InterfaceInputConfigSetSomeResponse, error)
	grpc.ClientStream
}

type InterfaceInputConfigService_SetSomeServer

type InterfaceInputConfigService_SetSomeServer interface {
	Send(*InterfaceInputConfigSetSomeResponse) error
	grpc.ServerStream
}

type InterfaceInputConfigService_SubscribeBatchedClient

type InterfaceInputConfigService_SubscribeBatchedClient interface {
	Recv() (*InterfaceInputConfigBatchedStreamResponse, error)
	grpc.ClientStream
}

type InterfaceInputConfigService_SubscribeBatchedServer

type InterfaceInputConfigService_SubscribeBatchedServer interface {
	Send(*InterfaceInputConfigBatchedStreamResponse) error
	grpc.ServerStream
}

type InterfaceInputConfigService_SubscribeClient

type InterfaceInputConfigService_SubscribeClient interface {
	Recv() (*InterfaceInputConfigStreamResponse, error)
	grpc.ClientStream
}

type InterfaceInputConfigService_SubscribeMetaClient

type InterfaceInputConfigService_SubscribeMetaClient interface {
	Recv() (*MetaResponse, error)
	grpc.ClientStream
}

type InterfaceInputConfigService_SubscribeMetaServer

type InterfaceInputConfigService_SubscribeMetaServer interface {
	Send(*MetaResponse) error
	grpc.ServerStream
}

type InterfaceInputConfigService_SubscribeServer

type InterfaceInputConfigService_SubscribeServer interface {
	Send(*InterfaceInputConfigStreamResponse) error
	grpc.ServerStream
}

type InterfaceInputConfigSetRequest

type InterfaceInputConfigSetRequest struct {

	// InterfaceInputConfig carries the value to set into the datastore.
	// See the documentation on the InterfaceInputConfig struct for which fields are required.
	Value *InterfaceInputConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*InterfaceInputConfigSetRequest) Descriptor deprecated

func (*InterfaceInputConfigSetRequest) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceInputConfigSetRequest.ProtoReflect.Descriptor instead.

func (*InterfaceInputConfigSetRequest) GetValue

func (*InterfaceInputConfigSetRequest) ProtoMessage

func (*InterfaceInputConfigSetRequest) ProtoMessage()

func (*InterfaceInputConfigSetRequest) ProtoReflect

func (*InterfaceInputConfigSetRequest) Reset

func (x *InterfaceInputConfigSetRequest) Reset()

func (*InterfaceInputConfigSetRequest) String

type InterfaceInputConfigSetResponse

type InterfaceInputConfigSetResponse struct {

	// Value carries all the values given in the InterfaceInputConfigSetRequest as well
	// as any server-generated values.
	Value *InterfaceInputConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time indicates the (UTC) timestamp at which the system recognizes the
	// creation. The only guarantees made about this timestamp are:
	//
	//   - it is after the time the request was received
	//   - a time-ranged query with StartTime==CreatedAt will include this instance.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*InterfaceInputConfigSetResponse) Descriptor deprecated

func (*InterfaceInputConfigSetResponse) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceInputConfigSetResponse.ProtoReflect.Descriptor instead.

func (*InterfaceInputConfigSetResponse) GetTime

func (*InterfaceInputConfigSetResponse) GetValue

func (*InterfaceInputConfigSetResponse) ProtoMessage

func (*InterfaceInputConfigSetResponse) ProtoMessage()

func (*InterfaceInputConfigSetResponse) ProtoReflect

func (*InterfaceInputConfigSetResponse) Reset

func (*InterfaceInputConfigSetResponse) String

type InterfaceInputConfigSetSomeRequest

type InterfaceInputConfigSetSomeRequest struct {

	// value contains a list of InterfaceInputConfig values to write.
	// It is possible to provide more values than can fit within either:
	//   - the maxiumum send size of the client
	//   - the maximum receive size of the server
	//
	// If this error occurs you must reduce the number of values sent.
	// See gRPC "maximum message size" documentation for more information.
	Values []*InterfaceInputConfig `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*InterfaceInputConfigSetSomeRequest) Descriptor deprecated

func (*InterfaceInputConfigSetSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceInputConfigSetSomeRequest.ProtoReflect.Descriptor instead.

func (*InterfaceInputConfigSetSomeRequest) GetValues

func (*InterfaceInputConfigSetSomeRequest) ProtoMessage

func (*InterfaceInputConfigSetSomeRequest) ProtoMessage()

func (*InterfaceInputConfigSetSomeRequest) ProtoReflect

func (*InterfaceInputConfigSetSomeRequest) Reset

func (*InterfaceInputConfigSetSomeRequest) String

type InterfaceInputConfigSetSomeResponse

type InterfaceInputConfigSetSomeResponse struct {
	Key   *InterfaceInputKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Error string             `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*InterfaceInputConfigSetSomeResponse) Descriptor deprecated

func (*InterfaceInputConfigSetSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceInputConfigSetSomeResponse.ProtoReflect.Descriptor instead.

func (*InterfaceInputConfigSetSomeResponse) GetError

func (*InterfaceInputConfigSetSomeResponse) GetKey

func (*InterfaceInputConfigSetSomeResponse) ProtoMessage

func (*InterfaceInputConfigSetSomeResponse) ProtoMessage()

func (*InterfaceInputConfigSetSomeResponse) ProtoReflect

func (*InterfaceInputConfigSetSomeResponse) Reset

func (*InterfaceInputConfigSetSomeResponse) String

type InterfaceInputConfigSomeRequest

type InterfaceInputConfigSomeRequest struct {
	Keys []*InterfaceInputKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*InterfaceInputConfigSomeRequest) Descriptor deprecated

func (*InterfaceInputConfigSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceInputConfigSomeRequest.ProtoReflect.Descriptor instead.

func (*InterfaceInputConfigSomeRequest) GetKeys

func (*InterfaceInputConfigSomeRequest) GetTime

func (*InterfaceInputConfigSomeRequest) ProtoMessage

func (*InterfaceInputConfigSomeRequest) ProtoMessage()

func (*InterfaceInputConfigSomeRequest) ProtoReflect

func (*InterfaceInputConfigSomeRequest) Reset

func (*InterfaceInputConfigSomeRequest) String

type InterfaceInputConfigSomeResponse

type InterfaceInputConfigSomeResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *InterfaceInputConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Error is an optional field.
	// It should be filled when there is an error in the GetSome process.
	Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Time  *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*InterfaceInputConfigSomeResponse) Descriptor deprecated

func (*InterfaceInputConfigSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceInputConfigSomeResponse.ProtoReflect.Descriptor instead.

func (*InterfaceInputConfigSomeResponse) GetError

func (*InterfaceInputConfigSomeResponse) GetTime

func (*InterfaceInputConfigSomeResponse) GetValue

func (*InterfaceInputConfigSomeResponse) ProtoMessage

func (*InterfaceInputConfigSomeResponse) ProtoMessage()

func (*InterfaceInputConfigSomeResponse) ProtoReflect

func (*InterfaceInputConfigSomeResponse) Reset

func (*InterfaceInputConfigSomeResponse) String

type InterfaceInputConfigStreamRequest

type InterfaceInputConfigStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*InterfaceInputConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each InterfaceInputConfig at end.
	//   - Each InterfaceInputConfig response is fully-specified (all fields set).
	//   - start: Returns the state of each InterfaceInputConfig at start, followed by updates until now.
	//   - Each InterfaceInputConfig response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each InterfaceInputConfig at start, followed by updates
	//     until end.
	//   - Each InterfaceInputConfig response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*InterfaceInputConfigStreamRequest) Descriptor deprecated

func (*InterfaceInputConfigStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceInputConfigStreamRequest.ProtoReflect.Descriptor instead.

func (*InterfaceInputConfigStreamRequest) GetPartialEqFilter

func (x *InterfaceInputConfigStreamRequest) GetPartialEqFilter() []*InterfaceInputConfig

func (*InterfaceInputConfigStreamRequest) GetTime

func (*InterfaceInputConfigStreamRequest) ProtoMessage

func (*InterfaceInputConfigStreamRequest) ProtoMessage()

func (*InterfaceInputConfigStreamRequest) ProtoReflect

func (*InterfaceInputConfigStreamRequest) Reset

func (*InterfaceInputConfigStreamRequest) String

type InterfaceInputConfigStreamResponse

type InterfaceInputConfigStreamResponse struct {

	// Value is a value deemed relevant to the initiating request.
	// This structure will always have its key-field populated. Which other fields are
	// populated, and why, depends on the value of Operation and what triggered this notification.
	Value *InterfaceInputConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time holds the timestamp of this InterfaceInputConfig's last modification.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// Operation indicates how the InterfaceInputConfig value in this response should be considered.
	// Under non-subscribe requests, this value should always be INITIAL. In a subscription,
	// once all initial data is streamed and the client begins to receive modification updates,
	// you should not see INITIAL again.
	Type subscriptions.Operation `protobuf:"varint,3,opt,name=type,proto3,enum=arista.subscriptions.Operation" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*InterfaceInputConfigStreamResponse) Descriptor deprecated

func (*InterfaceInputConfigStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceInputConfigStreamResponse.ProtoReflect.Descriptor instead.

func (*InterfaceInputConfigStreamResponse) GetTime

func (*InterfaceInputConfigStreamResponse) GetType

func (*InterfaceInputConfigStreamResponse) GetValue

func (*InterfaceInputConfigStreamResponse) ProtoMessage

func (*InterfaceInputConfigStreamResponse) ProtoMessage()

func (*InterfaceInputConfigStreamResponse) ProtoReflect

func (*InterfaceInputConfigStreamResponse) Reset

func (*InterfaceInputConfigStreamResponse) String

type InterfaceInputKey

type InterfaceInputKey struct {

	// workspace_id identifies the workspace uniquely.
	WorkspaceId *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	// device_id identifies the device uniquely.
	DeviceId *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	// interface_id along with device_id identifies the interface uniquely.
	InterfaceId *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=interface_id,json=interfaceId,proto3" json:"interface_id,omitempty"`
	// contains filtered or unexported fields
}

InterfaceInputKey is the set of inputs that uniquely identify the interface for a workspace.

func (*InterfaceInputKey) Descriptor deprecated

func (*InterfaceInputKey) Descriptor() ([]byte, []int)

Deprecated: Use InterfaceInputKey.ProtoReflect.Descriptor instead.

func (*InterfaceInputKey) GetDeviceId

func (x *InterfaceInputKey) GetDeviceId() *wrapperspb.StringValue

func (*InterfaceInputKey) GetInterfaceId

func (x *InterfaceInputKey) GetInterfaceId() *wrapperspb.StringValue

func (*InterfaceInputKey) GetWorkspaceId

func (x *InterfaceInputKey) GetWorkspaceId() *wrapperspb.StringValue

func (*InterfaceInputKey) ProtoMessage

func (*InterfaceInputKey) ProtoMessage()

func (*InterfaceInputKey) ProtoReflect

func (x *InterfaceInputKey) ProtoReflect() protoreflect.Message

func (*InterfaceInputKey) Reset

func (x *InterfaceInputKey) Reset()

func (*InterfaceInputKey) String

func (x *InterfaceInputKey) String() string

type MetaResponse

type MetaResponse struct {

	// Time holds the timestamp of the last item included in the metadata calculation.
	Time *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	// Operation indicates how the value in this response should be considered.
	// Under non-subscribe requests, this value should always be INITIAL. In a subscription,
	// once all initial data is streamed and the client begins to receive modification updates,
	// you should not see INITIAL again.
	Type subscriptions.Operation `protobuf:"varint,2,opt,name=type,proto3,enum=arista.subscriptions.Operation" json:"type,omitempty"`
	// Count is the number of items present under the conditions of the request.
	Count *wrapperspb.UInt32Value `protobuf:"bytes,3,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*MetaResponse) Descriptor deprecated

func (*MetaResponse) Descriptor() ([]byte, []int)

Deprecated: Use MetaResponse.ProtoReflect.Descriptor instead.

func (*MetaResponse) GetCount

func (x *MetaResponse) GetCount() *wrapperspb.UInt32Value

func (*MetaResponse) GetTime

func (x *MetaResponse) GetTime() *timestamppb.Timestamp

func (*MetaResponse) GetType

func (x *MetaResponse) GetType() subscriptions.Operation

func (*MetaResponse) ProtoMessage

func (*MetaResponse) ProtoMessage()

func (*MetaResponse) ProtoReflect

func (x *MetaResponse) ProtoReflect() protoreflect.Message

func (*MetaResponse) Reset

func (x *MetaResponse) Reset()

func (*MetaResponse) String

func (x *MetaResponse) String() string

type Operation

type Operation int32

Operation defines the operations that may be performed on the topology.

const (
	// OPERATION_UNSPECIFIED indicates an unspecified operation.
	Operation_OPERATION_UNSPECIFIED Operation = 0
	// OPERATION_ADDED indicates addition of an Element.
	Operation_OPERATION_ADDED Operation = 1
	// OPERATION_MODIFIED indicates modification of an Element.
	Operation_OPERATION_MODIFIED Operation = 2
	// OPERATION_REMOVED indicates removal of an Element.
	Operation_OPERATION_REMOVED Operation = 3
)

func (Operation) Descriptor

func (Operation) Descriptor() protoreflect.EnumDescriptor

func (Operation) Enum

func (x Operation) Enum() *Operation

func (Operation) EnumDescriptor deprecated

func (Operation) EnumDescriptor() ([]byte, []int)

Deprecated: Use Operation.Descriptor instead.

func (Operation) Number

func (x Operation) Number() protoreflect.EnumNumber

func (Operation) String

func (x Operation) String() string

func (Operation) Type

type Replace

type Replace struct {

	// key uniquely identifies the original device for a given workspace.
	Key *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// replacement_device_id is the device to replace the original device with.
	ReplacementDeviceId *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=replacement_device_id,json=replacementDeviceId,proto3" json:"replacement_device_id,omitempty"`
	// created_at is the time at which the status was first set.
	CreatedAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// created_by is the name of the user that first set the status.
	CreatedBy *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=created_by,json=createdBy,proto3" json:"created_by,omitempty"`
	// last_modified_at is the time at which the status was last modified.
	LastModifiedAt *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=last_modified_at,json=lastModifiedAt,proto3" json:"last_modified_at,omitempty"`
	// last_modified_by is the name of the user that last modified the status.
	LastModifiedBy *wrapperspb.StringValue `protobuf:"bytes,6,opt,name=last_modified_by,json=lastModifiedBy,proto3" json:"last_modified_by,omitempty"`
	// status indicates the status of the replace operation.
	Status ReplaceStatus `protobuf:"varint,7,opt,name=status,proto3,enum=arista.studio_topology.v1.ReplaceStatus" json:"status,omitempty"`
	// error provides the reason if there is a failure in replace.
	Error *wrapperspb.StringValue `protobuf:"bytes,8,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

Replace is the resource that holds the status of the replace operation.

func (*Replace) Descriptor deprecated

func (*Replace) Descriptor() ([]byte, []int)

Deprecated: Use Replace.ProtoReflect.Descriptor instead.

func (*Replace) GetCreatedAt

func (x *Replace) GetCreatedAt() *timestamppb.Timestamp

func (*Replace) GetCreatedBy

func (x *Replace) GetCreatedBy() *wrapperspb.StringValue

func (*Replace) GetError

func (x *Replace) GetError() *wrapperspb.StringValue

func (*Replace) GetKey

func (x *Replace) GetKey() *DeviceKey

func (*Replace) GetLastModifiedAt

func (x *Replace) GetLastModifiedAt() *timestamppb.Timestamp

func (*Replace) GetLastModifiedBy

func (x *Replace) GetLastModifiedBy() *wrapperspb.StringValue

func (*Replace) GetReplacementDeviceId

func (x *Replace) GetReplacementDeviceId() *wrapperspb.StringValue

func (*Replace) GetStatus

func (x *Replace) GetStatus() ReplaceStatus

func (*Replace) ProtoMessage

func (*Replace) ProtoMessage()

func (*Replace) ProtoReflect

func (x *Replace) ProtoReflect() protoreflect.Message

func (*Replace) Reset

func (x *Replace) Reset()

func (*Replace) String

func (x *Replace) String() string

type ReplaceBatchedStreamRequest

type ReplaceBatchedStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*Replace `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each Replace at end.
	//   - Each Replace response is fully-specified (all fields set).
	//   - start: Returns the state of each Replace at start, followed by updates until now.
	//   - Each Replace response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each Replace at start, followed by updates
	//     until end.
	//   - Each Replace response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// MaxMessages limits the maximum number of messages that can be contained in one batch.
	// MaxMessages is required to be at least 1.
	// The maximum number of messages in a batch is min(max_messages, INTERNAL_BATCH_LIMIT)
	// INTERNAL_BATCH_LIMIT is set based on the maximum message size.
	MaxMessages *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceBatchedStreamRequest) Descriptor deprecated

func (*ReplaceBatchedStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceBatchedStreamRequest.ProtoReflect.Descriptor instead.

func (*ReplaceBatchedStreamRequest) GetMaxMessages

func (x *ReplaceBatchedStreamRequest) GetMaxMessages() *wrapperspb.UInt32Value

func (*ReplaceBatchedStreamRequest) GetPartialEqFilter

func (x *ReplaceBatchedStreamRequest) GetPartialEqFilter() []*Replace

func (*ReplaceBatchedStreamRequest) GetTime

func (*ReplaceBatchedStreamRequest) ProtoMessage

func (*ReplaceBatchedStreamRequest) ProtoMessage()

func (*ReplaceBatchedStreamRequest) ProtoReflect

func (*ReplaceBatchedStreamRequest) Reset

func (x *ReplaceBatchedStreamRequest) Reset()

func (*ReplaceBatchedStreamRequest) String

func (x *ReplaceBatchedStreamRequest) String() string

type ReplaceBatchedStreamResponse

type ReplaceBatchedStreamResponse struct {

	// Values are the values deemed relevant to the initiating request.
	// The length of this structure is guaranteed to be between (inclusive) 1 and
	// min(req.max_messages, INTERNAL_BATCH_LIMIT).
	Responses []*ReplaceStreamResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceBatchedStreamResponse) Descriptor deprecated

func (*ReplaceBatchedStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceBatchedStreamResponse.ProtoReflect.Descriptor instead.

func (*ReplaceBatchedStreamResponse) GetResponses

func (*ReplaceBatchedStreamResponse) ProtoMessage

func (*ReplaceBatchedStreamResponse) ProtoMessage()

func (*ReplaceBatchedStreamResponse) ProtoReflect

func (*ReplaceBatchedStreamResponse) Reset

func (x *ReplaceBatchedStreamResponse) Reset()

func (*ReplaceBatchedStreamResponse) String

type ReplaceConfig

type ReplaceConfig struct {

	// key uniquely identifies the original device to be replaced in a given workspace.
	Key *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// replacement_device_id is the device to replace the original device with.
	// All references to the original device in Studios and tags will be replaced with this device.
	ReplacementDeviceId *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=replacement_device_id,json=replacementDeviceId,proto3" json:"replacement_device_id,omitempty"`
	// contains filtered or unexported fields
}

ReplaceConfig is the resource for replacing a device with another device in Studios.

func (*ReplaceConfig) Descriptor deprecated

func (*ReplaceConfig) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceConfig.ProtoReflect.Descriptor instead.

func (*ReplaceConfig) GetKey

func (x *ReplaceConfig) GetKey() *DeviceKey

func (*ReplaceConfig) GetReplacementDeviceId

func (x *ReplaceConfig) GetReplacementDeviceId() *wrapperspb.StringValue

func (*ReplaceConfig) ProtoMessage

func (*ReplaceConfig) ProtoMessage()

func (*ReplaceConfig) ProtoReflect

func (x *ReplaceConfig) ProtoReflect() protoreflect.Message

func (*ReplaceConfig) Reset

func (x *ReplaceConfig) Reset()

func (*ReplaceConfig) String

func (x *ReplaceConfig) String() string

type ReplaceConfigBatchedStreamRequest

type ReplaceConfigBatchedStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*ReplaceConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each ReplaceConfig at end.
	//   - Each ReplaceConfig response is fully-specified (all fields set).
	//   - start: Returns the state of each ReplaceConfig at start, followed by updates until now.
	//   - Each ReplaceConfig response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each ReplaceConfig at start, followed by updates
	//     until end.
	//   - Each ReplaceConfig response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// MaxMessages limits the maximum number of messages that can be contained in one batch.
	// MaxMessages is required to be at least 1.
	// The maximum number of messages in a batch is min(max_messages, INTERNAL_BATCH_LIMIT)
	// INTERNAL_BATCH_LIMIT is set based on the maximum message size.
	MaxMessages *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceConfigBatchedStreamRequest) Descriptor deprecated

func (*ReplaceConfigBatchedStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceConfigBatchedStreamRequest.ProtoReflect.Descriptor instead.

func (*ReplaceConfigBatchedStreamRequest) GetMaxMessages

func (*ReplaceConfigBatchedStreamRequest) GetPartialEqFilter

func (x *ReplaceConfigBatchedStreamRequest) GetPartialEqFilter() []*ReplaceConfig

func (*ReplaceConfigBatchedStreamRequest) GetTime

func (*ReplaceConfigBatchedStreamRequest) ProtoMessage

func (*ReplaceConfigBatchedStreamRequest) ProtoMessage()

func (*ReplaceConfigBatchedStreamRequest) ProtoReflect

func (*ReplaceConfigBatchedStreamRequest) Reset

func (*ReplaceConfigBatchedStreamRequest) String

type ReplaceConfigBatchedStreamResponse

type ReplaceConfigBatchedStreamResponse struct {

	// Values are the values deemed relevant to the initiating request.
	// The length of this structure is guaranteed to be between (inclusive) 1 and
	// min(req.max_messages, INTERNAL_BATCH_LIMIT).
	Responses []*ReplaceConfigStreamResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceConfigBatchedStreamResponse) Descriptor deprecated

func (*ReplaceConfigBatchedStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceConfigBatchedStreamResponse.ProtoReflect.Descriptor instead.

func (*ReplaceConfigBatchedStreamResponse) GetResponses

func (*ReplaceConfigBatchedStreamResponse) ProtoMessage

func (*ReplaceConfigBatchedStreamResponse) ProtoMessage()

func (*ReplaceConfigBatchedStreamResponse) ProtoReflect

func (*ReplaceConfigBatchedStreamResponse) Reset

func (*ReplaceConfigBatchedStreamResponse) String

type ReplaceConfigDeleteAllRequest

type ReplaceConfigDeleteAllRequest struct {

	// PartialEqFilter provides a way to server-side filter a DeleteAll.
	// This requires all provided fields to be equal to the response.
	// A filtered DeleteAll will use GetAll with filter to find things to delete.
	PartialEqFilter []*ReplaceConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceConfigDeleteAllRequest) Descriptor deprecated

func (*ReplaceConfigDeleteAllRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceConfigDeleteAllRequest.ProtoReflect.Descriptor instead.

func (*ReplaceConfigDeleteAllRequest) GetPartialEqFilter

func (x *ReplaceConfigDeleteAllRequest) GetPartialEqFilter() []*ReplaceConfig

func (*ReplaceConfigDeleteAllRequest) ProtoMessage

func (*ReplaceConfigDeleteAllRequest) ProtoMessage()

func (*ReplaceConfigDeleteAllRequest) ProtoReflect

func (*ReplaceConfigDeleteAllRequest) Reset

func (x *ReplaceConfigDeleteAllRequest) Reset()

func (*ReplaceConfigDeleteAllRequest) String

type ReplaceConfigDeleteAllResponse

type ReplaceConfigDeleteAllResponse struct {

	// This describes the class of delete error.
	// A DeleteAllResponse is only sent when there is an error.
	Type fmp.DeleteError `protobuf:"varint,1,opt,name=type,proto3,enum=fmp.DeleteError" json:"type,omitempty"`
	// This indicates the error message from the delete failure.
	Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// This is the key of the ReplaceConfig instance that failed to be deleted.
	Key *DeviceKey `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the (UTC) timestamp when the key was being deleted.
	Time *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceConfigDeleteAllResponse) Descriptor deprecated

func (*ReplaceConfigDeleteAllResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceConfigDeleteAllResponse.ProtoReflect.Descriptor instead.

func (*ReplaceConfigDeleteAllResponse) GetError

func (*ReplaceConfigDeleteAllResponse) GetKey

func (*ReplaceConfigDeleteAllResponse) GetTime

func (*ReplaceConfigDeleteAllResponse) GetType

func (*ReplaceConfigDeleteAllResponse) ProtoMessage

func (*ReplaceConfigDeleteAllResponse) ProtoMessage()

func (*ReplaceConfigDeleteAllResponse) ProtoReflect

func (*ReplaceConfigDeleteAllResponse) Reset

func (x *ReplaceConfigDeleteAllResponse) Reset()

func (*ReplaceConfigDeleteAllResponse) String

type ReplaceConfigDeleteRequest

type ReplaceConfigDeleteRequest struct {

	// Key indicates which ReplaceConfig instance to remove.
	// This field must always be set.
	Key *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceConfigDeleteRequest) Descriptor deprecated

func (*ReplaceConfigDeleteRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceConfigDeleteRequest.ProtoReflect.Descriptor instead.

func (*ReplaceConfigDeleteRequest) GetKey

func (*ReplaceConfigDeleteRequest) ProtoMessage

func (*ReplaceConfigDeleteRequest) ProtoMessage()

func (*ReplaceConfigDeleteRequest) ProtoReflect

func (*ReplaceConfigDeleteRequest) Reset

func (x *ReplaceConfigDeleteRequest) Reset()

func (*ReplaceConfigDeleteRequest) String

func (x *ReplaceConfigDeleteRequest) String() string

type ReplaceConfigDeleteResponse

type ReplaceConfigDeleteResponse struct {

	// Key echoes back the key of the deleted ReplaceConfig instance.
	Key *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the (UTC) timestamp at which the system recognizes the
	// deletion. The only guarantees made about this timestamp are:
	//
	//   - it is after the time the request was received
	//   - a time-ranged query with StartTime==DeletedAt will not include this instance.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceConfigDeleteResponse) Descriptor deprecated

func (*ReplaceConfigDeleteResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceConfigDeleteResponse.ProtoReflect.Descriptor instead.

func (*ReplaceConfigDeleteResponse) GetKey

func (*ReplaceConfigDeleteResponse) GetTime

func (*ReplaceConfigDeleteResponse) ProtoMessage

func (*ReplaceConfigDeleteResponse) ProtoMessage()

func (*ReplaceConfigDeleteResponse) ProtoReflect

func (*ReplaceConfigDeleteResponse) Reset

func (x *ReplaceConfigDeleteResponse) Reset()

func (*ReplaceConfigDeleteResponse) String

func (x *ReplaceConfigDeleteResponse) String() string

type ReplaceConfigDeleteSomeRequest

type ReplaceConfigDeleteSomeRequest struct {

	// key contains a list of ReplaceConfig keys to delete
	Keys []*DeviceKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceConfigDeleteSomeRequest) Descriptor deprecated

func (*ReplaceConfigDeleteSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceConfigDeleteSomeRequest.ProtoReflect.Descriptor instead.

func (*ReplaceConfigDeleteSomeRequest) GetKeys

func (x *ReplaceConfigDeleteSomeRequest) GetKeys() []*DeviceKey

func (*ReplaceConfigDeleteSomeRequest) ProtoMessage

func (*ReplaceConfigDeleteSomeRequest) ProtoMessage()

func (*ReplaceConfigDeleteSomeRequest) ProtoReflect

func (*ReplaceConfigDeleteSomeRequest) Reset

func (x *ReplaceConfigDeleteSomeRequest) Reset()

func (*ReplaceConfigDeleteSomeRequest) String

type ReplaceConfigDeleteSomeResponse

type ReplaceConfigDeleteSomeResponse struct {
	Key   *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Error string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

ReplaceConfigDeleteSomeResponse is only sent when there is an error.

func (*ReplaceConfigDeleteSomeResponse) Descriptor deprecated

func (*ReplaceConfigDeleteSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceConfigDeleteSomeResponse.ProtoReflect.Descriptor instead.

func (*ReplaceConfigDeleteSomeResponse) GetError

func (*ReplaceConfigDeleteSomeResponse) GetKey

func (*ReplaceConfigDeleteSomeResponse) ProtoMessage

func (*ReplaceConfigDeleteSomeResponse) ProtoMessage()

func (*ReplaceConfigDeleteSomeResponse) ProtoReflect

func (*ReplaceConfigDeleteSomeResponse) Reset

func (*ReplaceConfigDeleteSomeResponse) String

type ReplaceConfigRequest

type ReplaceConfigRequest struct {

	// Key uniquely identifies a ReplaceConfig instance to retrieve.
	// This value must be populated.
	Key *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceConfigRequest) Descriptor deprecated

func (*ReplaceConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceConfigRequest.ProtoReflect.Descriptor instead.

func (*ReplaceConfigRequest) GetKey

func (x *ReplaceConfigRequest) GetKey() *DeviceKey

func (*ReplaceConfigRequest) GetTime

func (*ReplaceConfigRequest) ProtoMessage

func (*ReplaceConfigRequest) ProtoMessage()

func (*ReplaceConfigRequest) ProtoReflect

func (x *ReplaceConfigRequest) ProtoReflect() protoreflect.Message

func (*ReplaceConfigRequest) Reset

func (x *ReplaceConfigRequest) Reset()

func (*ReplaceConfigRequest) String

func (x *ReplaceConfigRequest) String() string

type ReplaceConfigResponse

type ReplaceConfigResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *ReplaceConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time carries the (UTC) timestamp of the last-modification of the
	// ReplaceConfig instance in this response.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceConfigResponse) Descriptor deprecated

func (*ReplaceConfigResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceConfigResponse.ProtoReflect.Descriptor instead.

func (*ReplaceConfigResponse) GetTime

func (*ReplaceConfigResponse) GetValue

func (x *ReplaceConfigResponse) GetValue() *ReplaceConfig

func (*ReplaceConfigResponse) ProtoMessage

func (*ReplaceConfigResponse) ProtoMessage()

func (*ReplaceConfigResponse) ProtoReflect

func (x *ReplaceConfigResponse) ProtoReflect() protoreflect.Message

func (*ReplaceConfigResponse) Reset

func (x *ReplaceConfigResponse) Reset()

func (*ReplaceConfigResponse) String

func (x *ReplaceConfigResponse) String() string

type ReplaceConfigServiceClient

type ReplaceConfigServiceClient interface {
	GetOne(ctx context.Context, in *ReplaceConfigRequest, opts ...grpc.CallOption) (*ReplaceConfigResponse, error)
	GetSome(ctx context.Context, in *ReplaceConfigSomeRequest, opts ...grpc.CallOption) (ReplaceConfigService_GetSomeClient, error)
	GetAll(ctx context.Context, in *ReplaceConfigStreamRequest, opts ...grpc.CallOption) (ReplaceConfigService_GetAllClient, error)
	Subscribe(ctx context.Context, in *ReplaceConfigStreamRequest, opts ...grpc.CallOption) (ReplaceConfigService_SubscribeClient, error)
	GetMeta(ctx context.Context, in *ReplaceConfigStreamRequest, opts ...grpc.CallOption) (*MetaResponse, error)
	SubscribeMeta(ctx context.Context, in *ReplaceConfigStreamRequest, opts ...grpc.CallOption) (ReplaceConfigService_SubscribeMetaClient, error)
	Set(ctx context.Context, in *ReplaceConfigSetRequest, opts ...grpc.CallOption) (*ReplaceConfigSetResponse, error)
	SetSome(ctx context.Context, in *ReplaceConfigSetSomeRequest, opts ...grpc.CallOption) (ReplaceConfigService_SetSomeClient, error)
	Delete(ctx context.Context, in *ReplaceConfigDeleteRequest, opts ...grpc.CallOption) (*ReplaceConfigDeleteResponse, error)
	DeleteSome(ctx context.Context, in *ReplaceConfigDeleteSomeRequest, opts ...grpc.CallOption) (ReplaceConfigService_DeleteSomeClient, error)
	DeleteAll(ctx context.Context, in *ReplaceConfigDeleteAllRequest, opts ...grpc.CallOption) (ReplaceConfigService_DeleteAllClient, error)
	GetAllBatched(ctx context.Context, in *ReplaceConfigBatchedStreamRequest, opts ...grpc.CallOption) (ReplaceConfigService_GetAllBatchedClient, error)
	SubscribeBatched(ctx context.Context, in *ReplaceConfigBatchedStreamRequest, opts ...grpc.CallOption) (ReplaceConfigService_SubscribeBatchedClient, error)
}

ReplaceConfigServiceClient is the client API for ReplaceConfigService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type ReplaceConfigService_DeleteAllClient

type ReplaceConfigService_DeleteAllClient interface {
	Recv() (*ReplaceConfigDeleteAllResponse, error)
	grpc.ClientStream
}

type ReplaceConfigService_DeleteAllServer

type ReplaceConfigService_DeleteAllServer interface {
	Send(*ReplaceConfigDeleteAllResponse) error
	grpc.ServerStream
}

type ReplaceConfigService_DeleteSomeClient

type ReplaceConfigService_DeleteSomeClient interface {
	Recv() (*ReplaceConfigDeleteSomeResponse, error)
	grpc.ClientStream
}

type ReplaceConfigService_DeleteSomeServer

type ReplaceConfigService_DeleteSomeServer interface {
	Send(*ReplaceConfigDeleteSomeResponse) error
	grpc.ServerStream
}

type ReplaceConfigService_GetAllBatchedClient

type ReplaceConfigService_GetAllBatchedClient interface {
	Recv() (*ReplaceConfigBatchedStreamResponse, error)
	grpc.ClientStream
}

type ReplaceConfigService_GetAllBatchedServer

type ReplaceConfigService_GetAllBatchedServer interface {
	Send(*ReplaceConfigBatchedStreamResponse) error
	grpc.ServerStream
}

type ReplaceConfigService_GetAllClient

type ReplaceConfigService_GetAllClient interface {
	Recv() (*ReplaceConfigStreamResponse, error)
	grpc.ClientStream
}

type ReplaceConfigService_GetAllServer

type ReplaceConfigService_GetAllServer interface {
	Send(*ReplaceConfigStreamResponse) error
	grpc.ServerStream
}

type ReplaceConfigService_GetSomeClient

type ReplaceConfigService_GetSomeClient interface {
	Recv() (*ReplaceConfigSomeResponse, error)
	grpc.ClientStream
}

type ReplaceConfigService_GetSomeServer

type ReplaceConfigService_GetSomeServer interface {
	Send(*ReplaceConfigSomeResponse) error
	grpc.ServerStream
}

type ReplaceConfigService_SetSomeClient

type ReplaceConfigService_SetSomeClient interface {
	Recv() (*ReplaceConfigSetSomeResponse, error)
	grpc.ClientStream
}

type ReplaceConfigService_SetSomeServer

type ReplaceConfigService_SetSomeServer interface {
	Send(*ReplaceConfigSetSomeResponse) error
	grpc.ServerStream
}

type ReplaceConfigService_SubscribeBatchedClient

type ReplaceConfigService_SubscribeBatchedClient interface {
	Recv() (*ReplaceConfigBatchedStreamResponse, error)
	grpc.ClientStream
}

type ReplaceConfigService_SubscribeBatchedServer

type ReplaceConfigService_SubscribeBatchedServer interface {
	Send(*ReplaceConfigBatchedStreamResponse) error
	grpc.ServerStream
}

type ReplaceConfigService_SubscribeClient

type ReplaceConfigService_SubscribeClient interface {
	Recv() (*ReplaceConfigStreamResponse, error)
	grpc.ClientStream
}

type ReplaceConfigService_SubscribeMetaClient

type ReplaceConfigService_SubscribeMetaClient interface {
	Recv() (*MetaResponse, error)
	grpc.ClientStream
}

type ReplaceConfigService_SubscribeMetaServer

type ReplaceConfigService_SubscribeMetaServer interface {
	Send(*MetaResponse) error
	grpc.ServerStream
}

type ReplaceConfigService_SubscribeServer

type ReplaceConfigService_SubscribeServer interface {
	Send(*ReplaceConfigStreamResponse) error
	grpc.ServerStream
}

type ReplaceConfigSetRequest

type ReplaceConfigSetRequest struct {

	// ReplaceConfig carries the value to set into the datastore.
	// See the documentation on the ReplaceConfig struct for which fields are required.
	Value *ReplaceConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceConfigSetRequest) Descriptor deprecated

func (*ReplaceConfigSetRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceConfigSetRequest.ProtoReflect.Descriptor instead.

func (*ReplaceConfigSetRequest) GetValue

func (x *ReplaceConfigSetRequest) GetValue() *ReplaceConfig

func (*ReplaceConfigSetRequest) ProtoMessage

func (*ReplaceConfigSetRequest) ProtoMessage()

func (*ReplaceConfigSetRequest) ProtoReflect

func (x *ReplaceConfigSetRequest) ProtoReflect() protoreflect.Message

func (*ReplaceConfigSetRequest) Reset

func (x *ReplaceConfigSetRequest) Reset()

func (*ReplaceConfigSetRequest) String

func (x *ReplaceConfigSetRequest) String() string

type ReplaceConfigSetResponse

type ReplaceConfigSetResponse struct {

	// Value carries all the values given in the ReplaceConfigSetRequest as well
	// as any server-generated values.
	Value *ReplaceConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time indicates the (UTC) timestamp at which the system recognizes the
	// creation. The only guarantees made about this timestamp are:
	//
	//   - it is after the time the request was received
	//   - a time-ranged query with StartTime==CreatedAt will include this instance.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceConfigSetResponse) Descriptor deprecated

func (*ReplaceConfigSetResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceConfigSetResponse.ProtoReflect.Descriptor instead.

func (*ReplaceConfigSetResponse) GetTime

func (*ReplaceConfigSetResponse) GetValue

func (x *ReplaceConfigSetResponse) GetValue() *ReplaceConfig

func (*ReplaceConfigSetResponse) ProtoMessage

func (*ReplaceConfigSetResponse) ProtoMessage()

func (*ReplaceConfigSetResponse) ProtoReflect

func (x *ReplaceConfigSetResponse) ProtoReflect() protoreflect.Message

func (*ReplaceConfigSetResponse) Reset

func (x *ReplaceConfigSetResponse) Reset()

func (*ReplaceConfigSetResponse) String

func (x *ReplaceConfigSetResponse) String() string

type ReplaceConfigSetSomeRequest

type ReplaceConfigSetSomeRequest struct {

	// value contains a list of ReplaceConfig values to write.
	// It is possible to provide more values than can fit within either:
	//   - the maxiumum send size of the client
	//   - the maximum receive size of the server
	//
	// If this error occurs you must reduce the number of values sent.
	// See gRPC "maximum message size" documentation for more information.
	Values []*ReplaceConfig `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceConfigSetSomeRequest) Descriptor deprecated

func (*ReplaceConfigSetSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceConfigSetSomeRequest.ProtoReflect.Descriptor instead.

func (*ReplaceConfigSetSomeRequest) GetValues

func (x *ReplaceConfigSetSomeRequest) GetValues() []*ReplaceConfig

func (*ReplaceConfigSetSomeRequest) ProtoMessage

func (*ReplaceConfigSetSomeRequest) ProtoMessage()

func (*ReplaceConfigSetSomeRequest) ProtoReflect

func (*ReplaceConfigSetSomeRequest) Reset

func (x *ReplaceConfigSetSomeRequest) Reset()

func (*ReplaceConfigSetSomeRequest) String

func (x *ReplaceConfigSetSomeRequest) String() string

type ReplaceConfigSetSomeResponse

type ReplaceConfigSetSomeResponse struct {
	Key   *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Error string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceConfigSetSomeResponse) Descriptor deprecated

func (*ReplaceConfigSetSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceConfigSetSomeResponse.ProtoReflect.Descriptor instead.

func (*ReplaceConfigSetSomeResponse) GetError

func (x *ReplaceConfigSetSomeResponse) GetError() string

func (*ReplaceConfigSetSomeResponse) GetKey

func (*ReplaceConfigSetSomeResponse) ProtoMessage

func (*ReplaceConfigSetSomeResponse) ProtoMessage()

func (*ReplaceConfigSetSomeResponse) ProtoReflect

func (*ReplaceConfigSetSomeResponse) Reset

func (x *ReplaceConfigSetSomeResponse) Reset()

func (*ReplaceConfigSetSomeResponse) String

type ReplaceConfigSomeRequest

type ReplaceConfigSomeRequest struct {
	Keys []*DeviceKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceConfigSomeRequest) Descriptor deprecated

func (*ReplaceConfigSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceConfigSomeRequest.ProtoReflect.Descriptor instead.

func (*ReplaceConfigSomeRequest) GetKeys

func (x *ReplaceConfigSomeRequest) GetKeys() []*DeviceKey

func (*ReplaceConfigSomeRequest) GetTime

func (*ReplaceConfigSomeRequest) ProtoMessage

func (*ReplaceConfigSomeRequest) ProtoMessage()

func (*ReplaceConfigSomeRequest) ProtoReflect

func (x *ReplaceConfigSomeRequest) ProtoReflect() protoreflect.Message

func (*ReplaceConfigSomeRequest) Reset

func (x *ReplaceConfigSomeRequest) Reset()

func (*ReplaceConfigSomeRequest) String

func (x *ReplaceConfigSomeRequest) String() string

type ReplaceConfigSomeResponse

type ReplaceConfigSomeResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *ReplaceConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Error is an optional field.
	// It should be filled when there is an error in the GetSome process.
	Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Time  *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceConfigSomeResponse) Descriptor deprecated

func (*ReplaceConfigSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceConfigSomeResponse.ProtoReflect.Descriptor instead.

func (*ReplaceConfigSomeResponse) GetError

func (*ReplaceConfigSomeResponse) GetTime

func (*ReplaceConfigSomeResponse) GetValue

func (*ReplaceConfigSomeResponse) ProtoMessage

func (*ReplaceConfigSomeResponse) ProtoMessage()

func (*ReplaceConfigSomeResponse) ProtoReflect

func (*ReplaceConfigSomeResponse) Reset

func (x *ReplaceConfigSomeResponse) Reset()

func (*ReplaceConfigSomeResponse) String

func (x *ReplaceConfigSomeResponse) String() string

type ReplaceConfigStreamRequest

type ReplaceConfigStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*ReplaceConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each ReplaceConfig at end.
	//   - Each ReplaceConfig response is fully-specified (all fields set).
	//   - start: Returns the state of each ReplaceConfig at start, followed by updates until now.
	//   - Each ReplaceConfig response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each ReplaceConfig at start, followed by updates
	//     until end.
	//   - Each ReplaceConfig response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceConfigStreamRequest) Descriptor deprecated

func (*ReplaceConfigStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceConfigStreamRequest.ProtoReflect.Descriptor instead.

func (*ReplaceConfigStreamRequest) GetPartialEqFilter

func (x *ReplaceConfigStreamRequest) GetPartialEqFilter() []*ReplaceConfig

func (*ReplaceConfigStreamRequest) GetTime

func (*ReplaceConfigStreamRequest) ProtoMessage

func (*ReplaceConfigStreamRequest) ProtoMessage()

func (*ReplaceConfigStreamRequest) ProtoReflect

func (*ReplaceConfigStreamRequest) Reset

func (x *ReplaceConfigStreamRequest) Reset()

func (*ReplaceConfigStreamRequest) String

func (x *ReplaceConfigStreamRequest) String() string

type ReplaceConfigStreamResponse

type ReplaceConfigStreamResponse struct {

	// Value is a value deemed relevant to the initiating request.
	// This structure will always have its key-field populated. Which other fields are
	// populated, and why, depends on the value of Operation and what triggered this notification.
	Value *ReplaceConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time holds the timestamp of this ReplaceConfig's last modification.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// Operation indicates how the ReplaceConfig value in this response should be considered.
	// Under non-subscribe requests, this value should always be INITIAL. In a subscription,
	// once all initial data is streamed and the client begins to receive modification updates,
	// you should not see INITIAL again.
	Type subscriptions.Operation `protobuf:"varint,3,opt,name=type,proto3,enum=arista.subscriptions.Operation" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceConfigStreamResponse) Descriptor deprecated

func (*ReplaceConfigStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceConfigStreamResponse.ProtoReflect.Descriptor instead.

func (*ReplaceConfigStreamResponse) GetTime

func (*ReplaceConfigStreamResponse) GetType

func (*ReplaceConfigStreamResponse) GetValue

func (*ReplaceConfigStreamResponse) ProtoMessage

func (*ReplaceConfigStreamResponse) ProtoMessage()

func (*ReplaceConfigStreamResponse) ProtoReflect

func (*ReplaceConfigStreamResponse) Reset

func (x *ReplaceConfigStreamResponse) Reset()

func (*ReplaceConfigStreamResponse) String

func (x *ReplaceConfigStreamResponse) String() string

type ReplaceRequest

type ReplaceRequest struct {

	// Key uniquely identifies a Replace instance to retrieve.
	// This value must be populated.
	Key *DeviceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceRequest) Descriptor deprecated

func (*ReplaceRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceRequest.ProtoReflect.Descriptor instead.

func (*ReplaceRequest) GetKey

func (x *ReplaceRequest) GetKey() *DeviceKey

func (*ReplaceRequest) GetTime

func (x *ReplaceRequest) GetTime() *timestamppb.Timestamp

func (*ReplaceRequest) ProtoMessage

func (*ReplaceRequest) ProtoMessage()

func (*ReplaceRequest) ProtoReflect

func (x *ReplaceRequest) ProtoReflect() protoreflect.Message

func (*ReplaceRequest) Reset

func (x *ReplaceRequest) Reset()

func (*ReplaceRequest) String

func (x *ReplaceRequest) String() string

type ReplaceResponse

type ReplaceResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *Replace `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time carries the (UTC) timestamp of the last-modification of the
	// Replace instance in this response.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceResponse) Descriptor deprecated

func (*ReplaceResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceResponse.ProtoReflect.Descriptor instead.

func (*ReplaceResponse) GetTime

func (x *ReplaceResponse) GetTime() *timestamppb.Timestamp

func (*ReplaceResponse) GetValue

func (x *ReplaceResponse) GetValue() *Replace

func (*ReplaceResponse) ProtoMessage

func (*ReplaceResponse) ProtoMessage()

func (*ReplaceResponse) ProtoReflect

func (x *ReplaceResponse) ProtoReflect() protoreflect.Message

func (*ReplaceResponse) Reset

func (x *ReplaceResponse) Reset()

func (*ReplaceResponse) String

func (x *ReplaceResponse) String() string

type ReplaceServiceClient

ReplaceServiceClient is the client API for ReplaceService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type ReplaceServiceServer

ReplaceServiceServer is the server API for ReplaceService service. All implementations must embed UnimplementedReplaceServiceServer for forward compatibility

type ReplaceService_GetAllBatchedClient

type ReplaceService_GetAllBatchedClient interface {
	Recv() (*ReplaceBatchedStreamResponse, error)
	grpc.ClientStream
}

type ReplaceService_GetAllBatchedServer

type ReplaceService_GetAllBatchedServer interface {
	Send(*ReplaceBatchedStreamResponse) error
	grpc.ServerStream
}

type ReplaceService_GetAllClient

type ReplaceService_GetAllClient interface {
	Recv() (*ReplaceStreamResponse, error)
	grpc.ClientStream
}

type ReplaceService_GetAllServer

type ReplaceService_GetAllServer interface {
	Send(*ReplaceStreamResponse) error
	grpc.ServerStream
}

type ReplaceService_GetSomeClient

type ReplaceService_GetSomeClient interface {
	Recv() (*ReplaceSomeResponse, error)
	grpc.ClientStream
}

type ReplaceService_GetSomeServer

type ReplaceService_GetSomeServer interface {
	Send(*ReplaceSomeResponse) error
	grpc.ServerStream
}

type ReplaceService_SubscribeBatchedClient

type ReplaceService_SubscribeBatchedClient interface {
	Recv() (*ReplaceBatchedStreamResponse, error)
	grpc.ClientStream
}

type ReplaceService_SubscribeBatchedServer

type ReplaceService_SubscribeBatchedServer interface {
	Send(*ReplaceBatchedStreamResponse) error
	grpc.ServerStream
}

type ReplaceService_SubscribeClient

type ReplaceService_SubscribeClient interface {
	Recv() (*ReplaceStreamResponse, error)
	grpc.ClientStream
}

type ReplaceService_SubscribeMetaClient

type ReplaceService_SubscribeMetaClient interface {
	Recv() (*MetaResponse, error)
	grpc.ClientStream
}

type ReplaceService_SubscribeMetaServer

type ReplaceService_SubscribeMetaServer interface {
	Send(*MetaResponse) error
	grpc.ServerStream
}

type ReplaceService_SubscribeServer

type ReplaceService_SubscribeServer interface {
	Send(*ReplaceStreamResponse) error
	grpc.ServerStream
}

type ReplaceSomeRequest

type ReplaceSomeRequest struct {
	Keys []*DeviceKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceSomeRequest) Descriptor deprecated

func (*ReplaceSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceSomeRequest.ProtoReflect.Descriptor instead.

func (*ReplaceSomeRequest) GetKeys

func (x *ReplaceSomeRequest) GetKeys() []*DeviceKey

func (*ReplaceSomeRequest) GetTime

func (*ReplaceSomeRequest) ProtoMessage

func (*ReplaceSomeRequest) ProtoMessage()

func (*ReplaceSomeRequest) ProtoReflect

func (x *ReplaceSomeRequest) ProtoReflect() protoreflect.Message

func (*ReplaceSomeRequest) Reset

func (x *ReplaceSomeRequest) Reset()

func (*ReplaceSomeRequest) String

func (x *ReplaceSomeRequest) String() string

type ReplaceSomeResponse

type ReplaceSomeResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *Replace `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Error is an optional field.
	// It should be filled when there is an error in the GetSome process.
	Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Time  *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceSomeResponse) Descriptor deprecated

func (*ReplaceSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceSomeResponse.ProtoReflect.Descriptor instead.

func (*ReplaceSomeResponse) GetError

func (*ReplaceSomeResponse) GetTime

func (*ReplaceSomeResponse) GetValue

func (x *ReplaceSomeResponse) GetValue() *Replace

func (*ReplaceSomeResponse) ProtoMessage

func (*ReplaceSomeResponse) ProtoMessage()

func (*ReplaceSomeResponse) ProtoReflect

func (x *ReplaceSomeResponse) ProtoReflect() protoreflect.Message

func (*ReplaceSomeResponse) Reset

func (x *ReplaceSomeResponse) Reset()

func (*ReplaceSomeResponse) String

func (x *ReplaceSomeResponse) String() string

type ReplaceStatus

type ReplaceStatus int32

ReplaceStatus enumerates the status of the device.

const (
	// REPLACE_STATUS_UNSPECIFIED indicates that the device was replaced with
	// an unspecified state.
	ReplaceStatus_REPLACE_STATUS_UNSPECIFIED ReplaceStatus = 0
	// REPLACE_STATUS_SUCCESS indicates that the device was successfully replaced.
	ReplaceStatus_REPLACE_STATUS_SUCCESS ReplaceStatus = 1
	// REPLACE_STATUS_FAILURE indicates an error with replace.
	ReplaceStatus_REPLACE_STATUS_FAILURE ReplaceStatus = 2
)

func (ReplaceStatus) Descriptor

func (ReplaceStatus) Enum

func (x ReplaceStatus) Enum() *ReplaceStatus

func (ReplaceStatus) EnumDescriptor deprecated

func (ReplaceStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use ReplaceStatus.Descriptor instead.

func (ReplaceStatus) Number

func (ReplaceStatus) String

func (x ReplaceStatus) String() string

func (ReplaceStatus) Type

type ReplaceStreamRequest

type ReplaceStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*Replace `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each Replace at end.
	//   - Each Replace response is fully-specified (all fields set).
	//   - start: Returns the state of each Replace at start, followed by updates until now.
	//   - Each Replace response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each Replace at start, followed by updates
	//     until end.
	//   - Each Replace response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceStreamRequest) Descriptor deprecated

func (*ReplaceStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceStreamRequest.ProtoReflect.Descriptor instead.

func (*ReplaceStreamRequest) GetPartialEqFilter

func (x *ReplaceStreamRequest) GetPartialEqFilter() []*Replace

func (*ReplaceStreamRequest) GetTime

func (x *ReplaceStreamRequest) GetTime() *time.TimeBounds

func (*ReplaceStreamRequest) ProtoMessage

func (*ReplaceStreamRequest) ProtoMessage()

func (*ReplaceStreamRequest) ProtoReflect

func (x *ReplaceStreamRequest) ProtoReflect() protoreflect.Message

func (*ReplaceStreamRequest) Reset

func (x *ReplaceStreamRequest) Reset()

func (*ReplaceStreamRequest) String

func (x *ReplaceStreamRequest) String() string

type ReplaceStreamResponse

type ReplaceStreamResponse struct {

	// Value is a value deemed relevant to the initiating request.
	// This structure will always have its key-field populated. Which other fields are
	// populated, and why, depends on the value of Operation and what triggered this notification.
	Value *Replace `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time holds the timestamp of this Replace's last modification.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// Operation indicates how the Replace value in this response should be considered.
	// Under non-subscribe requests, this value should always be INITIAL. In a subscription,
	// once all initial data is streamed and the client begins to receive modification updates,
	// you should not see INITIAL again.
	Type subscriptions.Operation `protobuf:"varint,3,opt,name=type,proto3,enum=arista.subscriptions.Operation" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplaceStreamResponse) Descriptor deprecated

func (*ReplaceStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReplaceStreamResponse.ProtoReflect.Descriptor instead.

func (*ReplaceStreamResponse) GetTime

func (*ReplaceStreamResponse) GetType

func (*ReplaceStreamResponse) GetValue

func (x *ReplaceStreamResponse) GetValue() *Replace

func (*ReplaceStreamResponse) ProtoMessage

func (*ReplaceStreamResponse) ProtoMessage()

func (*ReplaceStreamResponse) ProtoReflect

func (x *ReplaceStreamResponse) ProtoReflect() protoreflect.Message

func (*ReplaceStreamResponse) Reset

func (x *ReplaceStreamResponse) Reset()

func (*ReplaceStreamResponse) String

func (x *ReplaceStreamResponse) String() string

type RevertConfig

type RevertConfig struct {

	// key uniquely identifies the workspace.
	Key *workspace_v1.WorkspaceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

RevertConfig is the model provided to revert a workspace.

func (*RevertConfig) Descriptor deprecated

func (*RevertConfig) Descriptor() ([]byte, []int)

Deprecated: Use RevertConfig.ProtoReflect.Descriptor instead.

func (*RevertConfig) GetKey

func (x *RevertConfig) GetKey() *workspace_v1.WorkspaceKey

func (*RevertConfig) ProtoMessage

func (*RevertConfig) ProtoMessage()

func (*RevertConfig) ProtoReflect

func (x *RevertConfig) ProtoReflect() protoreflect.Message

func (*RevertConfig) Reset

func (x *RevertConfig) Reset()

func (*RevertConfig) String

func (x *RevertConfig) String() string

type RevertConfigBatchedStreamRequest

type RevertConfigBatchedStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*RevertConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each RevertConfig at end.
	//   - Each RevertConfig response is fully-specified (all fields set).
	//   - start: Returns the state of each RevertConfig at start, followed by updates until now.
	//   - Each RevertConfig response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each RevertConfig at start, followed by updates
	//     until end.
	//   - Each RevertConfig response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// MaxMessages limits the maximum number of messages that can be contained in one batch.
	// MaxMessages is required to be at least 1.
	// The maximum number of messages in a batch is min(max_messages, INTERNAL_BATCH_LIMIT)
	// INTERNAL_BATCH_LIMIT is set based on the maximum message size.
	MaxMessages *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"`
	// contains filtered or unexported fields
}

func (*RevertConfigBatchedStreamRequest) Descriptor deprecated

func (*RevertConfigBatchedStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use RevertConfigBatchedStreamRequest.ProtoReflect.Descriptor instead.

func (*RevertConfigBatchedStreamRequest) GetMaxMessages

func (*RevertConfigBatchedStreamRequest) GetPartialEqFilter

func (x *RevertConfigBatchedStreamRequest) GetPartialEqFilter() []*RevertConfig

func (*RevertConfigBatchedStreamRequest) GetTime

func (*RevertConfigBatchedStreamRequest) ProtoMessage

func (*RevertConfigBatchedStreamRequest) ProtoMessage()

func (*RevertConfigBatchedStreamRequest) ProtoReflect

func (*RevertConfigBatchedStreamRequest) Reset

func (*RevertConfigBatchedStreamRequest) String

type RevertConfigBatchedStreamResponse

type RevertConfigBatchedStreamResponse struct {

	// Values are the values deemed relevant to the initiating request.
	// The length of this structure is guaranteed to be between (inclusive) 1 and
	// min(req.max_messages, INTERNAL_BATCH_LIMIT).
	Responses []*RevertConfigStreamResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*RevertConfigBatchedStreamResponse) Descriptor deprecated

func (*RevertConfigBatchedStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use RevertConfigBatchedStreamResponse.ProtoReflect.Descriptor instead.

func (*RevertConfigBatchedStreamResponse) GetResponses

func (*RevertConfigBatchedStreamResponse) ProtoMessage

func (*RevertConfigBatchedStreamResponse) ProtoMessage()

func (*RevertConfigBatchedStreamResponse) ProtoReflect

func (*RevertConfigBatchedStreamResponse) Reset

func (*RevertConfigBatchedStreamResponse) String

type RevertConfigDeleteAllRequest

type RevertConfigDeleteAllRequest struct {

	// PartialEqFilter provides a way to server-side filter a DeleteAll.
	// This requires all provided fields to be equal to the response.
	// A filtered DeleteAll will use GetAll with filter to find things to delete.
	PartialEqFilter []*RevertConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*RevertConfigDeleteAllRequest) Descriptor deprecated

func (*RevertConfigDeleteAllRequest) Descriptor() ([]byte, []int)

Deprecated: Use RevertConfigDeleteAllRequest.ProtoReflect.Descriptor instead.

func (*RevertConfigDeleteAllRequest) GetPartialEqFilter

func (x *RevertConfigDeleteAllRequest) GetPartialEqFilter() []*RevertConfig

func (*RevertConfigDeleteAllRequest) ProtoMessage

func (*RevertConfigDeleteAllRequest) ProtoMessage()

func (*RevertConfigDeleteAllRequest) ProtoReflect

func (*RevertConfigDeleteAllRequest) Reset

func (x *RevertConfigDeleteAllRequest) Reset()

func (*RevertConfigDeleteAllRequest) String

type RevertConfigDeleteAllResponse

type RevertConfigDeleteAllResponse struct {

	// This describes the class of delete error.
	// A DeleteAllResponse is only sent when there is an error.
	Type fmp.DeleteError `protobuf:"varint,1,opt,name=type,proto3,enum=fmp.DeleteError" json:"type,omitempty"`
	// This indicates the error message from the delete failure.
	Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// This is the key of the RevertConfig instance that failed to be deleted.
	Key *workspace_v1.WorkspaceKey `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the (UTC) timestamp when the key was being deleted.
	Time *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*RevertConfigDeleteAllResponse) Descriptor deprecated

func (*RevertConfigDeleteAllResponse) Descriptor() ([]byte, []int)

Deprecated: Use RevertConfigDeleteAllResponse.ProtoReflect.Descriptor instead.

func (*RevertConfigDeleteAllResponse) GetError

func (*RevertConfigDeleteAllResponse) GetKey

func (*RevertConfigDeleteAllResponse) GetTime

func (*RevertConfigDeleteAllResponse) GetType

func (*RevertConfigDeleteAllResponse) ProtoMessage

func (*RevertConfigDeleteAllResponse) ProtoMessage()

func (*RevertConfigDeleteAllResponse) ProtoReflect

func (*RevertConfigDeleteAllResponse) Reset

func (x *RevertConfigDeleteAllResponse) Reset()

func (*RevertConfigDeleteAllResponse) String

type RevertConfigDeleteRequest

type RevertConfigDeleteRequest struct {

	// Key indicates which RevertConfig instance to remove.
	// This field must always be set.
	Key *workspace_v1.WorkspaceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*RevertConfigDeleteRequest) Descriptor deprecated

func (*RevertConfigDeleteRequest) Descriptor() ([]byte, []int)

Deprecated: Use RevertConfigDeleteRequest.ProtoReflect.Descriptor instead.

func (*RevertConfigDeleteRequest) GetKey

func (*RevertConfigDeleteRequest) ProtoMessage

func (*RevertConfigDeleteRequest) ProtoMessage()

func (*RevertConfigDeleteRequest) ProtoReflect

func (*RevertConfigDeleteRequest) Reset

func (x *RevertConfigDeleteRequest) Reset()

func (*RevertConfigDeleteRequest) String

func (x *RevertConfigDeleteRequest) String() string

type RevertConfigDeleteResponse

type RevertConfigDeleteResponse struct {

	// Key echoes back the key of the deleted RevertConfig instance.
	Key *workspace_v1.WorkspaceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the (UTC) timestamp at which the system recognizes the
	// deletion. The only guarantees made about this timestamp are:
	//
	//   - it is after the time the request was received
	//   - a time-ranged query with StartTime==DeletedAt will not include this instance.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*RevertConfigDeleteResponse) Descriptor deprecated

func (*RevertConfigDeleteResponse) Descriptor() ([]byte, []int)

Deprecated: Use RevertConfigDeleteResponse.ProtoReflect.Descriptor instead.

func (*RevertConfigDeleteResponse) GetKey

func (*RevertConfigDeleteResponse) GetTime

func (*RevertConfigDeleteResponse) ProtoMessage

func (*RevertConfigDeleteResponse) ProtoMessage()

func (*RevertConfigDeleteResponse) ProtoReflect

func (*RevertConfigDeleteResponse) Reset

func (x *RevertConfigDeleteResponse) Reset()

func (*RevertConfigDeleteResponse) String

func (x *RevertConfigDeleteResponse) String() string

type RevertConfigDeleteSomeRequest

type RevertConfigDeleteSomeRequest struct {

	// key contains a list of RevertConfig keys to delete
	Keys []*workspace_v1.WorkspaceKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*RevertConfigDeleteSomeRequest) Descriptor deprecated

func (*RevertConfigDeleteSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use RevertConfigDeleteSomeRequest.ProtoReflect.Descriptor instead.

func (*RevertConfigDeleteSomeRequest) GetKeys

func (*RevertConfigDeleteSomeRequest) ProtoMessage

func (*RevertConfigDeleteSomeRequest) ProtoMessage()

func (*RevertConfigDeleteSomeRequest) ProtoReflect

func (*RevertConfigDeleteSomeRequest) Reset

func (x *RevertConfigDeleteSomeRequest) Reset()

func (*RevertConfigDeleteSomeRequest) String

type RevertConfigDeleteSomeResponse

type RevertConfigDeleteSomeResponse struct {
	Key   *workspace_v1.WorkspaceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Error string                     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

RevertConfigDeleteSomeResponse is only sent when there is an error.

func (*RevertConfigDeleteSomeResponse) Descriptor deprecated

func (*RevertConfigDeleteSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use RevertConfigDeleteSomeResponse.ProtoReflect.Descriptor instead.

func (*RevertConfigDeleteSomeResponse) GetError

func (x *RevertConfigDeleteSomeResponse) GetError() string

func (*RevertConfigDeleteSomeResponse) GetKey

func (*RevertConfigDeleteSomeResponse) ProtoMessage

func (*RevertConfigDeleteSomeResponse) ProtoMessage()

func (*RevertConfigDeleteSomeResponse) ProtoReflect

func (*RevertConfigDeleteSomeResponse) Reset

func (x *RevertConfigDeleteSomeResponse) Reset()

func (*RevertConfigDeleteSomeResponse) String

type RevertConfigRequest

type RevertConfigRequest struct {

	// Key uniquely identifies a RevertConfig instance to retrieve.
	// This value must be populated.
	Key *workspace_v1.WorkspaceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*RevertConfigRequest) Descriptor deprecated

func (*RevertConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use RevertConfigRequest.ProtoReflect.Descriptor instead.

func (*RevertConfigRequest) GetKey

func (*RevertConfigRequest) GetTime

func (*RevertConfigRequest) ProtoMessage

func (*RevertConfigRequest) ProtoMessage()

func (*RevertConfigRequest) ProtoReflect

func (x *RevertConfigRequest) ProtoReflect() protoreflect.Message

func (*RevertConfigRequest) Reset

func (x *RevertConfigRequest) Reset()

func (*RevertConfigRequest) String

func (x *RevertConfigRequest) String() string

type RevertConfigResponse

type RevertConfigResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *RevertConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time carries the (UTC) timestamp of the last-modification of the
	// RevertConfig instance in this response.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*RevertConfigResponse) Descriptor deprecated

func (*RevertConfigResponse) Descriptor() ([]byte, []int)

Deprecated: Use RevertConfigResponse.ProtoReflect.Descriptor instead.

func (*RevertConfigResponse) GetTime

func (*RevertConfigResponse) GetValue

func (x *RevertConfigResponse) GetValue() *RevertConfig

func (*RevertConfigResponse) ProtoMessage

func (*RevertConfigResponse) ProtoMessage()

func (*RevertConfigResponse) ProtoReflect

func (x *RevertConfigResponse) ProtoReflect() protoreflect.Message

func (*RevertConfigResponse) Reset

func (x *RevertConfigResponse) Reset()

func (*RevertConfigResponse) String

func (x *RevertConfigResponse) String() string

type RevertConfigServiceClient

type RevertConfigServiceClient interface {
	GetOne(ctx context.Context, in *RevertConfigRequest, opts ...grpc.CallOption) (*RevertConfigResponse, error)
	GetSome(ctx context.Context, in *RevertConfigSomeRequest, opts ...grpc.CallOption) (RevertConfigService_GetSomeClient, error)
	GetAll(ctx context.Context, in *RevertConfigStreamRequest, opts ...grpc.CallOption) (RevertConfigService_GetAllClient, error)
	Subscribe(ctx context.Context, in *RevertConfigStreamRequest, opts ...grpc.CallOption) (RevertConfigService_SubscribeClient, error)
	GetMeta(ctx context.Context, in *RevertConfigStreamRequest, opts ...grpc.CallOption) (*MetaResponse, error)
	SubscribeMeta(ctx context.Context, in *RevertConfigStreamRequest, opts ...grpc.CallOption) (RevertConfigService_SubscribeMetaClient, error)
	Set(ctx context.Context, in *RevertConfigSetRequest, opts ...grpc.CallOption) (*RevertConfigSetResponse, error)
	SetSome(ctx context.Context, in *RevertConfigSetSomeRequest, opts ...grpc.CallOption) (RevertConfigService_SetSomeClient, error)
	Delete(ctx context.Context, in *RevertConfigDeleteRequest, opts ...grpc.CallOption) (*RevertConfigDeleteResponse, error)
	DeleteSome(ctx context.Context, in *RevertConfigDeleteSomeRequest, opts ...grpc.CallOption) (RevertConfigService_DeleteSomeClient, error)
	DeleteAll(ctx context.Context, in *RevertConfigDeleteAllRequest, opts ...grpc.CallOption) (RevertConfigService_DeleteAllClient, error)
	GetAllBatched(ctx context.Context, in *RevertConfigBatchedStreamRequest, opts ...grpc.CallOption) (RevertConfigService_GetAllBatchedClient, error)
	SubscribeBatched(ctx context.Context, in *RevertConfigBatchedStreamRequest, opts ...grpc.CallOption) (RevertConfigService_SubscribeBatchedClient, error)
}

RevertConfigServiceClient is the client API for RevertConfigService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type RevertConfigService_DeleteAllClient

type RevertConfigService_DeleteAllClient interface {
	Recv() (*RevertConfigDeleteAllResponse, error)
	grpc.ClientStream
}

type RevertConfigService_DeleteAllServer

type RevertConfigService_DeleteAllServer interface {
	Send(*RevertConfigDeleteAllResponse) error
	grpc.ServerStream
}

type RevertConfigService_DeleteSomeClient

type RevertConfigService_DeleteSomeClient interface {
	Recv() (*RevertConfigDeleteSomeResponse, error)
	grpc.ClientStream
}

type RevertConfigService_DeleteSomeServer

type RevertConfigService_DeleteSomeServer interface {
	Send(*RevertConfigDeleteSomeResponse) error
	grpc.ServerStream
}

type RevertConfigService_GetAllBatchedClient

type RevertConfigService_GetAllBatchedClient interface {
	Recv() (*RevertConfigBatchedStreamResponse, error)
	grpc.ClientStream
}

type RevertConfigService_GetAllBatchedServer

type RevertConfigService_GetAllBatchedServer interface {
	Send(*RevertConfigBatchedStreamResponse) error
	grpc.ServerStream
}

type RevertConfigService_GetAllClient

type RevertConfigService_GetAllClient interface {
	Recv() (*RevertConfigStreamResponse, error)
	grpc.ClientStream
}

type RevertConfigService_GetAllServer

type RevertConfigService_GetAllServer interface {
	Send(*RevertConfigStreamResponse) error
	grpc.ServerStream
}

type RevertConfigService_GetSomeClient

type RevertConfigService_GetSomeClient interface {
	Recv() (*RevertConfigSomeResponse, error)
	grpc.ClientStream
}

type RevertConfigService_GetSomeServer

type RevertConfigService_GetSomeServer interface {
	Send(*RevertConfigSomeResponse) error
	grpc.ServerStream
}

type RevertConfigService_SetSomeClient

type RevertConfigService_SetSomeClient interface {
	Recv() (*RevertConfigSetSomeResponse, error)
	grpc.ClientStream
}

type RevertConfigService_SetSomeServer

type RevertConfigService_SetSomeServer interface {
	Send(*RevertConfigSetSomeResponse) error
	grpc.ServerStream
}

type RevertConfigService_SubscribeBatchedClient

type RevertConfigService_SubscribeBatchedClient interface {
	Recv() (*RevertConfigBatchedStreamResponse, error)
	grpc.ClientStream
}

type RevertConfigService_SubscribeBatchedServer

type RevertConfigService_SubscribeBatchedServer interface {
	Send(*RevertConfigBatchedStreamResponse) error
	grpc.ServerStream
}

type RevertConfigService_SubscribeClient

type RevertConfigService_SubscribeClient interface {
	Recv() (*RevertConfigStreamResponse, error)
	grpc.ClientStream
}

type RevertConfigService_SubscribeMetaClient

type RevertConfigService_SubscribeMetaClient interface {
	Recv() (*MetaResponse, error)
	grpc.ClientStream
}

type RevertConfigService_SubscribeMetaServer

type RevertConfigService_SubscribeMetaServer interface {
	Send(*MetaResponse) error
	grpc.ServerStream
}

type RevertConfigService_SubscribeServer

type RevertConfigService_SubscribeServer interface {
	Send(*RevertConfigStreamResponse) error
	grpc.ServerStream
}

type RevertConfigSetRequest

type RevertConfigSetRequest struct {

	// RevertConfig carries the value to set into the datastore.
	// See the documentation on the RevertConfig struct for which fields are required.
	Value *RevertConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*RevertConfigSetRequest) Descriptor deprecated

func (*RevertConfigSetRequest) Descriptor() ([]byte, []int)

Deprecated: Use RevertConfigSetRequest.ProtoReflect.Descriptor instead.

func (*RevertConfigSetRequest) GetValue

func (x *RevertConfigSetRequest) GetValue() *RevertConfig

func (*RevertConfigSetRequest) ProtoMessage

func (*RevertConfigSetRequest) ProtoMessage()

func (*RevertConfigSetRequest) ProtoReflect

func (x *RevertConfigSetRequest) ProtoReflect() protoreflect.Message

func (*RevertConfigSetRequest) Reset

func (x *RevertConfigSetRequest) Reset()

func (*RevertConfigSetRequest) String

func (x *RevertConfigSetRequest) String() string

type RevertConfigSetResponse

type RevertConfigSetResponse struct {

	// Value carries all the values given in the RevertConfigSetRequest as well
	// as any server-generated values.
	Value *RevertConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time indicates the (UTC) timestamp at which the system recognizes the
	// creation. The only guarantees made about this timestamp are:
	//
	//   - it is after the time the request was received
	//   - a time-ranged query with StartTime==CreatedAt will include this instance.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*RevertConfigSetResponse) Descriptor deprecated

func (*RevertConfigSetResponse) Descriptor() ([]byte, []int)

Deprecated: Use RevertConfigSetResponse.ProtoReflect.Descriptor instead.

func (*RevertConfigSetResponse) GetTime

func (*RevertConfigSetResponse) GetValue

func (x *RevertConfigSetResponse) GetValue() *RevertConfig

func (*RevertConfigSetResponse) ProtoMessage

func (*RevertConfigSetResponse) ProtoMessage()

func (*RevertConfigSetResponse) ProtoReflect

func (x *RevertConfigSetResponse) ProtoReflect() protoreflect.Message

func (*RevertConfigSetResponse) Reset

func (x *RevertConfigSetResponse) Reset()

func (*RevertConfigSetResponse) String

func (x *RevertConfigSetResponse) String() string

type RevertConfigSetSomeRequest

type RevertConfigSetSomeRequest struct {

	// value contains a list of RevertConfig values to write.
	// It is possible to provide more values than can fit within either:
	//   - the maxiumum send size of the client
	//   - the maximum receive size of the server
	//
	// If this error occurs you must reduce the number of values sent.
	// See gRPC "maximum message size" documentation for more information.
	Values []*RevertConfig `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*RevertConfigSetSomeRequest) Descriptor deprecated

func (*RevertConfigSetSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use RevertConfigSetSomeRequest.ProtoReflect.Descriptor instead.

func (*RevertConfigSetSomeRequest) GetValues

func (x *RevertConfigSetSomeRequest) GetValues() []*RevertConfig

func (*RevertConfigSetSomeRequest) ProtoMessage

func (*RevertConfigSetSomeRequest) ProtoMessage()

func (*RevertConfigSetSomeRequest) ProtoReflect

func (*RevertConfigSetSomeRequest) Reset

func (x *RevertConfigSetSomeRequest) Reset()

func (*RevertConfigSetSomeRequest) String

func (x *RevertConfigSetSomeRequest) String() string

type RevertConfigSetSomeResponse

type RevertConfigSetSomeResponse struct {
	Key   *workspace_v1.WorkspaceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Error string                     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*RevertConfigSetSomeResponse) Descriptor deprecated

func (*RevertConfigSetSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use RevertConfigSetSomeResponse.ProtoReflect.Descriptor instead.

func (*RevertConfigSetSomeResponse) GetError

func (x *RevertConfigSetSomeResponse) GetError() string

func (*RevertConfigSetSomeResponse) GetKey

func (*RevertConfigSetSomeResponse) ProtoMessage

func (*RevertConfigSetSomeResponse) ProtoMessage()

func (*RevertConfigSetSomeResponse) ProtoReflect

func (*RevertConfigSetSomeResponse) Reset

func (x *RevertConfigSetSomeResponse) Reset()

func (*RevertConfigSetSomeResponse) String

func (x *RevertConfigSetSomeResponse) String() string

type RevertConfigSomeRequest

type RevertConfigSomeRequest struct {
	Keys []*workspace_v1.WorkspaceKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*RevertConfigSomeRequest) Descriptor deprecated

func (*RevertConfigSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use RevertConfigSomeRequest.ProtoReflect.Descriptor instead.

func (*RevertConfigSomeRequest) GetKeys

func (*RevertConfigSomeRequest) GetTime

func (*RevertConfigSomeRequest) ProtoMessage

func (*RevertConfigSomeRequest) ProtoMessage()

func (*RevertConfigSomeRequest) ProtoReflect

func (x *RevertConfigSomeRequest) ProtoReflect() protoreflect.Message

func (*RevertConfigSomeRequest) Reset

func (x *RevertConfigSomeRequest) Reset()

func (*RevertConfigSomeRequest) String

func (x *RevertConfigSomeRequest) String() string

type RevertConfigSomeResponse

type RevertConfigSomeResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *RevertConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Error is an optional field.
	// It should be filled when there is an error in the GetSome process.
	Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Time  *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*RevertConfigSomeResponse) Descriptor deprecated

func (*RevertConfigSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use RevertConfigSomeResponse.ProtoReflect.Descriptor instead.

func (*RevertConfigSomeResponse) GetError

func (*RevertConfigSomeResponse) GetTime

func (*RevertConfigSomeResponse) GetValue

func (x *RevertConfigSomeResponse) GetValue() *RevertConfig

func (*RevertConfigSomeResponse) ProtoMessage

func (*RevertConfigSomeResponse) ProtoMessage()

func (*RevertConfigSomeResponse) ProtoReflect

func (x *RevertConfigSomeResponse) ProtoReflect() protoreflect.Message

func (*RevertConfigSomeResponse) Reset

func (x *RevertConfigSomeResponse) Reset()

func (*RevertConfigSomeResponse) String

func (x *RevertConfigSomeResponse) String() string

type RevertConfigStreamRequest

type RevertConfigStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*RevertConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each RevertConfig at end.
	//   - Each RevertConfig response is fully-specified (all fields set).
	//   - start: Returns the state of each RevertConfig at start, followed by updates until now.
	//   - Each RevertConfig response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each RevertConfig at start, followed by updates
	//     until end.
	//   - Each RevertConfig response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*RevertConfigStreamRequest) Descriptor deprecated

func (*RevertConfigStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use RevertConfigStreamRequest.ProtoReflect.Descriptor instead.

func (*RevertConfigStreamRequest) GetPartialEqFilter

func (x *RevertConfigStreamRequest) GetPartialEqFilter() []*RevertConfig

func (*RevertConfigStreamRequest) GetTime

func (*RevertConfigStreamRequest) ProtoMessage

func (*RevertConfigStreamRequest) ProtoMessage()

func (*RevertConfigStreamRequest) ProtoReflect

func (*RevertConfigStreamRequest) Reset

func (x *RevertConfigStreamRequest) Reset()

func (*RevertConfigStreamRequest) String

func (x *RevertConfigStreamRequest) String() string

type RevertConfigStreamResponse

type RevertConfigStreamResponse struct {

	// Value is a value deemed relevant to the initiating request.
	// This structure will always have its key-field populated. Which other fields are
	// populated, and why, depends on the value of Operation and what triggered this notification.
	Value *RevertConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time holds the timestamp of this RevertConfig's last modification.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// Operation indicates how the RevertConfig value in this response should be considered.
	// Under non-subscribe requests, this value should always be INITIAL. In a subscription,
	// once all initial data is streamed and the client begins to receive modification updates,
	// you should not see INITIAL again.
	Type subscriptions.Operation `protobuf:"varint,3,opt,name=type,proto3,enum=arista.subscriptions.Operation" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*RevertConfigStreamResponse) Descriptor deprecated

func (*RevertConfigStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use RevertConfigStreamResponse.ProtoReflect.Descriptor instead.

func (*RevertConfigStreamResponse) GetTime

func (*RevertConfigStreamResponse) GetType

func (*RevertConfigStreamResponse) GetValue

func (*RevertConfigStreamResponse) ProtoMessage

func (*RevertConfigStreamResponse) ProtoMessage()

func (*RevertConfigStreamResponse) ProtoReflect

func (*RevertConfigStreamResponse) Reset

func (x *RevertConfigStreamResponse) Reset()

func (*RevertConfigStreamResponse) String

func (x *RevertConfigStreamResponse) String() string

type UnimplementedDecommissionConfigServiceServer

type UnimplementedDecommissionConfigServiceServer struct {
}

UnimplementedDecommissionConfigServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDecommissionConfigServiceServer) GetMeta

func (UnimplementedDecommissionConfigServiceServer) GetOne

type UnimplementedDecommissionServiceServer

type UnimplementedDecommissionServiceServer struct {
}

UnimplementedDecommissionServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDecommissionServiceServer) GetMeta

func (UnimplementedDecommissionServiceServer) GetOne

type UnimplementedDeviceInputConfigServiceServer

type UnimplementedDeviceInputConfigServiceServer struct {
}

UnimplementedDeviceInputConfigServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDeviceInputConfigServiceServer) GetMeta

func (UnimplementedDeviceInputConfigServiceServer) GetOne

type UnimplementedDeviceStateServiceServer

type UnimplementedDeviceStateServiceServer struct {
}

UnimplementedDeviceStateServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDeviceStateServiceServer) GetMeta

func (UnimplementedDeviceStateServiceServer) GetOne

func (UnimplementedDeviceStateServiceServer) GetSome

type UnimplementedInterfaceInputConfigServiceServer

type UnimplementedInterfaceInputConfigServiceServer struct {
}

UnimplementedInterfaceInputConfigServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedInterfaceInputConfigServiceServer) GetMeta

type UnimplementedReplaceConfigServiceServer

type UnimplementedReplaceConfigServiceServer struct {
}

UnimplementedReplaceConfigServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedReplaceConfigServiceServer) GetMeta

func (UnimplementedReplaceConfigServiceServer) GetOne

func (UnimplementedReplaceConfigServiceServer) Set

type UnimplementedReplaceServiceServer

type UnimplementedReplaceServiceServer struct {
}

UnimplementedReplaceServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedReplaceServiceServer) GetAll

func (UnimplementedReplaceServiceServer) GetMeta

func (UnimplementedReplaceServiceServer) GetOne

func (UnimplementedReplaceServiceServer) GetSome

func (UnimplementedReplaceServiceServer) Subscribe

func (UnimplementedReplaceServiceServer) SubscribeMeta

type UnimplementedRevertConfigServiceServer

type UnimplementedRevertConfigServiceServer struct {
}

UnimplementedRevertConfigServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRevertConfigServiceServer) GetMeta

func (UnimplementedRevertConfigServiceServer) GetOne

func (UnimplementedRevertConfigServiceServer) Set

type UnimplementedUpdateConfigServiceServer

type UnimplementedUpdateConfigServiceServer struct {
}

UnimplementedUpdateConfigServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedUpdateConfigServiceServer) GetMeta

func (UnimplementedUpdateConfigServiceServer) GetOne

func (UnimplementedUpdateConfigServiceServer) Set

type UnimplementedUpdateServiceServer

type UnimplementedUpdateServiceServer struct {
}

UnimplementedUpdateServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedUpdateServiceServer) GetAll

func (UnimplementedUpdateServiceServer) GetMeta

func (UnimplementedUpdateServiceServer) GetOne

func (UnimplementedUpdateServiceServer) GetSome

func (UnimplementedUpdateServiceServer) Subscribe

func (UnimplementedUpdateServiceServer) SubscribeMeta

type UnimplementedUpdateSyncConfigServiceServer

type UnimplementedUpdateSyncConfigServiceServer struct {
}

UnimplementedUpdateSyncConfigServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedUpdateSyncConfigServiceServer) GetMeta

func (UnimplementedUpdateSyncConfigServiceServer) GetOne

type UnsafeDecommissionConfigServiceServer

type UnsafeDecommissionConfigServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeDecommissionConfigServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DecommissionConfigServiceServer will result in compilation errors.

type UnsafeDecommissionServiceServer

type UnsafeDecommissionServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeDecommissionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DecommissionServiceServer will result in compilation errors.

type UnsafeDeviceInputConfigServiceServer

type UnsafeDeviceInputConfigServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeDeviceInputConfigServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DeviceInputConfigServiceServer will result in compilation errors.

type UnsafeDeviceStateServiceServer

type UnsafeDeviceStateServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeDeviceStateServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DeviceStateServiceServer will result in compilation errors.

type UnsafeInterfaceInputConfigServiceServer

type UnsafeInterfaceInputConfigServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeInterfaceInputConfigServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to InterfaceInputConfigServiceServer will result in compilation errors.

type UnsafeReplaceConfigServiceServer

type UnsafeReplaceConfigServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeReplaceConfigServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ReplaceConfigServiceServer will result in compilation errors.

type UnsafeReplaceServiceServer

type UnsafeReplaceServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeReplaceServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ReplaceServiceServer will result in compilation errors.

type UnsafeRevertConfigServiceServer

type UnsafeRevertConfigServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeRevertConfigServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RevertConfigServiceServer will result in compilation errors.

type UnsafeUpdateConfigServiceServer

type UnsafeUpdateConfigServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeUpdateConfigServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to UpdateConfigServiceServer will result in compilation errors.

type UnsafeUpdateServiceServer

type UnsafeUpdateServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeUpdateServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to UpdateServiceServer will result in compilation errors.

type UnsafeUpdateSyncConfigServiceServer

type UnsafeUpdateSyncConfigServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeUpdateSyncConfigServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to UpdateSyncConfigServiceServer will result in compilation errors.

type Update

type Update struct {

	// key uniquely identifies the update.
	Key *UpdateKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// element indicates the type of a network element.
	Element Element `protobuf:"varint,2,opt,name=element,proto3,enum=arista.studio_topology.v1.Element" json:"element,omitempty"`
	// operation indicates the type of operation on the topology update.
	Operation Operation `protobuf:"varint,3,opt,name=operation,proto3,enum=arista.studio_topology.v1.Operation" json:"operation,omitempty"`
	// status indicates the status of the topology update.
	Status UpdateStatus `protobuf:"varint,4,opt,name=status,proto3,enum=arista.studio_topology.v1.UpdateStatus" json:"status,omitempty"`
	// description describes the topology update in short.
	Description *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
	// device_id indicates the device associated with the update.
	DeviceId *wrapperspb.StringValue `protobuf:"bytes,6,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	// contains filtered or unexported fields
}

Update represents an update on to the workspace.

func (*Update) Descriptor deprecated

func (*Update) Descriptor() ([]byte, []int)

Deprecated: Use Update.ProtoReflect.Descriptor instead.

func (*Update) GetDescription

func (x *Update) GetDescription() *wrapperspb.StringValue

func (*Update) GetDeviceId

func (x *Update) GetDeviceId() *wrapperspb.StringValue

func (*Update) GetElement

func (x *Update) GetElement() Element

func (*Update) GetKey

func (x *Update) GetKey() *UpdateKey

func (*Update) GetOperation

func (x *Update) GetOperation() Operation

func (*Update) GetStatus

func (x *Update) GetStatus() UpdateStatus

func (*Update) ProtoMessage

func (*Update) ProtoMessage()

func (*Update) ProtoReflect

func (x *Update) ProtoReflect() protoreflect.Message

func (*Update) Reset

func (x *Update) Reset()

func (*Update) String

func (x *Update) String() string

type UpdateBatchedStreamRequest

type UpdateBatchedStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*Update `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each Update at end.
	//   - Each Update response is fully-specified (all fields set).
	//   - start: Returns the state of each Update at start, followed by updates until now.
	//   - Each Update response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each Update at start, followed by updates
	//     until end.
	//   - Each Update response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// MaxMessages limits the maximum number of messages that can be contained in one batch.
	// MaxMessages is required to be at least 1.
	// The maximum number of messages in a batch is min(max_messages, INTERNAL_BATCH_LIMIT)
	// INTERNAL_BATCH_LIMIT is set based on the maximum message size.
	MaxMessages *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateBatchedStreamRequest) Descriptor deprecated

func (*UpdateBatchedStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateBatchedStreamRequest.ProtoReflect.Descriptor instead.

func (*UpdateBatchedStreamRequest) GetMaxMessages

func (x *UpdateBatchedStreamRequest) GetMaxMessages() *wrapperspb.UInt32Value

func (*UpdateBatchedStreamRequest) GetPartialEqFilter

func (x *UpdateBatchedStreamRequest) GetPartialEqFilter() []*Update

func (*UpdateBatchedStreamRequest) GetTime

func (*UpdateBatchedStreamRequest) ProtoMessage

func (*UpdateBatchedStreamRequest) ProtoMessage()

func (*UpdateBatchedStreamRequest) ProtoReflect

func (*UpdateBatchedStreamRequest) Reset

func (x *UpdateBatchedStreamRequest) Reset()

func (*UpdateBatchedStreamRequest) String

func (x *UpdateBatchedStreamRequest) String() string

type UpdateBatchedStreamResponse

type UpdateBatchedStreamResponse struct {

	// Values are the values deemed relevant to the initiating request.
	// The length of this structure is guaranteed to be between (inclusive) 1 and
	// min(req.max_messages, INTERNAL_BATCH_LIMIT).
	Responses []*UpdateStreamResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateBatchedStreamResponse) Descriptor deprecated

func (*UpdateBatchedStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateBatchedStreamResponse.ProtoReflect.Descriptor instead.

func (*UpdateBatchedStreamResponse) GetResponses

func (*UpdateBatchedStreamResponse) ProtoMessage

func (*UpdateBatchedStreamResponse) ProtoMessage()

func (*UpdateBatchedStreamResponse) ProtoReflect

func (*UpdateBatchedStreamResponse) Reset

func (x *UpdateBatchedStreamResponse) Reset()

func (*UpdateBatchedStreamResponse) String

func (x *UpdateBatchedStreamResponse) String() string

type UpdateConfig

type UpdateConfig struct {

	// key uniquely identifies the update.
	Key *UpdateKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// status indicates the status of the topology update.
	Status UpdateStatus `protobuf:"varint,2,opt,name=status,proto3,enum=arista.studio_topology.v1.UpdateStatus" json:"status,omitempty"`
	// remove if set to true will remove the update key from mainline
	// post workspace merge. This can only be set true for ignored keys
	// since we don't carry accepted keys to mainline post workspace
	// merge
	Remove *wrapperspb.BoolValue `protobuf:"bytes,3,opt,name=remove,proto3" json:"remove,omitempty"`
	// contains filtered or unexported fields
}

UpdateConfig contains the acceptance status of an Update.

func (*UpdateConfig) Descriptor deprecated

func (*UpdateConfig) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConfig.ProtoReflect.Descriptor instead.

func (*UpdateConfig) GetKey

func (x *UpdateConfig) GetKey() *UpdateKey

func (*UpdateConfig) GetRemove

func (x *UpdateConfig) GetRemove() *wrapperspb.BoolValue

func (*UpdateConfig) GetStatus

func (x *UpdateConfig) GetStatus() UpdateStatus

func (*UpdateConfig) ProtoMessage

func (*UpdateConfig) ProtoMessage()

func (*UpdateConfig) ProtoReflect

func (x *UpdateConfig) ProtoReflect() protoreflect.Message

func (*UpdateConfig) Reset

func (x *UpdateConfig) Reset()

func (*UpdateConfig) String

func (x *UpdateConfig) String() string

type UpdateConfigBatchedStreamRequest

type UpdateConfigBatchedStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*UpdateConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each UpdateConfig at end.
	//   - Each UpdateConfig response is fully-specified (all fields set).
	//   - start: Returns the state of each UpdateConfig at start, followed by updates until now.
	//   - Each UpdateConfig response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each UpdateConfig at start, followed by updates
	//     until end.
	//   - Each UpdateConfig response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// MaxMessages limits the maximum number of messages that can be contained in one batch.
	// MaxMessages is required to be at least 1.
	// The maximum number of messages in a batch is min(max_messages, INTERNAL_BATCH_LIMIT)
	// INTERNAL_BATCH_LIMIT is set based on the maximum message size.
	MaxMessages *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConfigBatchedStreamRequest) Descriptor deprecated

func (*UpdateConfigBatchedStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConfigBatchedStreamRequest.ProtoReflect.Descriptor instead.

func (*UpdateConfigBatchedStreamRequest) GetMaxMessages

func (*UpdateConfigBatchedStreamRequest) GetPartialEqFilter

func (x *UpdateConfigBatchedStreamRequest) GetPartialEqFilter() []*UpdateConfig

func (*UpdateConfigBatchedStreamRequest) GetTime

func (*UpdateConfigBatchedStreamRequest) ProtoMessage

func (*UpdateConfigBatchedStreamRequest) ProtoMessage()

func (*UpdateConfigBatchedStreamRequest) ProtoReflect

func (*UpdateConfigBatchedStreamRequest) Reset

func (*UpdateConfigBatchedStreamRequest) String

type UpdateConfigBatchedStreamResponse

type UpdateConfigBatchedStreamResponse struct {

	// Values are the values deemed relevant to the initiating request.
	// The length of this structure is guaranteed to be between (inclusive) 1 and
	// min(req.max_messages, INTERNAL_BATCH_LIMIT).
	Responses []*UpdateConfigStreamResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConfigBatchedStreamResponse) Descriptor deprecated

func (*UpdateConfigBatchedStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConfigBatchedStreamResponse.ProtoReflect.Descriptor instead.

func (*UpdateConfigBatchedStreamResponse) GetResponses

func (*UpdateConfigBatchedStreamResponse) ProtoMessage

func (*UpdateConfigBatchedStreamResponse) ProtoMessage()

func (*UpdateConfigBatchedStreamResponse) ProtoReflect

func (*UpdateConfigBatchedStreamResponse) Reset

func (*UpdateConfigBatchedStreamResponse) String

type UpdateConfigDeleteAllRequest

type UpdateConfigDeleteAllRequest struct {

	// PartialEqFilter provides a way to server-side filter a DeleteAll.
	// This requires all provided fields to be equal to the response.
	// A filtered DeleteAll will use GetAll with filter to find things to delete.
	PartialEqFilter []*UpdateConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConfigDeleteAllRequest) Descriptor deprecated

func (*UpdateConfigDeleteAllRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConfigDeleteAllRequest.ProtoReflect.Descriptor instead.

func (*UpdateConfigDeleteAllRequest) GetPartialEqFilter

func (x *UpdateConfigDeleteAllRequest) GetPartialEqFilter() []*UpdateConfig

func (*UpdateConfigDeleteAllRequest) ProtoMessage

func (*UpdateConfigDeleteAllRequest) ProtoMessage()

func (*UpdateConfigDeleteAllRequest) ProtoReflect

func (*UpdateConfigDeleteAllRequest) Reset

func (x *UpdateConfigDeleteAllRequest) Reset()

func (*UpdateConfigDeleteAllRequest) String

type UpdateConfigDeleteAllResponse

type UpdateConfigDeleteAllResponse struct {

	// This describes the class of delete error.
	// A DeleteAllResponse is only sent when there is an error.
	Type fmp.DeleteError `protobuf:"varint,1,opt,name=type,proto3,enum=fmp.DeleteError" json:"type,omitempty"`
	// This indicates the error message from the delete failure.
	Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// This is the key of the UpdateConfig instance that failed to be deleted.
	Key *UpdateKey `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the (UTC) timestamp when the key was being deleted.
	Time *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConfigDeleteAllResponse) Descriptor deprecated

func (*UpdateConfigDeleteAllResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConfigDeleteAllResponse.ProtoReflect.Descriptor instead.

func (*UpdateConfigDeleteAllResponse) GetError

func (*UpdateConfigDeleteAllResponse) GetKey

func (*UpdateConfigDeleteAllResponse) GetTime

func (*UpdateConfigDeleteAllResponse) GetType

func (*UpdateConfigDeleteAllResponse) ProtoMessage

func (*UpdateConfigDeleteAllResponse) ProtoMessage()

func (*UpdateConfigDeleteAllResponse) ProtoReflect

func (*UpdateConfigDeleteAllResponse) Reset

func (x *UpdateConfigDeleteAllResponse) Reset()

func (*UpdateConfigDeleteAllResponse) String

type UpdateConfigDeleteRequest

type UpdateConfigDeleteRequest struct {

	// Key indicates which UpdateConfig instance to remove.
	// This field must always be set.
	Key *UpdateKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConfigDeleteRequest) Descriptor deprecated

func (*UpdateConfigDeleteRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConfigDeleteRequest.ProtoReflect.Descriptor instead.

func (*UpdateConfigDeleteRequest) GetKey

func (x *UpdateConfigDeleteRequest) GetKey() *UpdateKey

func (*UpdateConfigDeleteRequest) ProtoMessage

func (*UpdateConfigDeleteRequest) ProtoMessage()

func (*UpdateConfigDeleteRequest) ProtoReflect

func (*UpdateConfigDeleteRequest) Reset

func (x *UpdateConfigDeleteRequest) Reset()

func (*UpdateConfigDeleteRequest) String

func (x *UpdateConfigDeleteRequest) String() string

type UpdateConfigDeleteResponse

type UpdateConfigDeleteResponse struct {

	// Key echoes back the key of the deleted UpdateConfig instance.
	Key *UpdateKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the (UTC) timestamp at which the system recognizes the
	// deletion. The only guarantees made about this timestamp are:
	//
	//   - it is after the time the request was received
	//   - a time-ranged query with StartTime==DeletedAt will not include this instance.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConfigDeleteResponse) Descriptor deprecated

func (*UpdateConfigDeleteResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConfigDeleteResponse.ProtoReflect.Descriptor instead.

func (*UpdateConfigDeleteResponse) GetKey

func (*UpdateConfigDeleteResponse) GetTime

func (*UpdateConfigDeleteResponse) ProtoMessage

func (*UpdateConfigDeleteResponse) ProtoMessage()

func (*UpdateConfigDeleteResponse) ProtoReflect

func (*UpdateConfigDeleteResponse) Reset

func (x *UpdateConfigDeleteResponse) Reset()

func (*UpdateConfigDeleteResponse) String

func (x *UpdateConfigDeleteResponse) String() string

type UpdateConfigDeleteSomeRequest

type UpdateConfigDeleteSomeRequest struct {

	// key contains a list of UpdateConfig keys to delete
	Keys []*UpdateKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConfigDeleteSomeRequest) Descriptor deprecated

func (*UpdateConfigDeleteSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConfigDeleteSomeRequest.ProtoReflect.Descriptor instead.

func (*UpdateConfigDeleteSomeRequest) GetKeys

func (x *UpdateConfigDeleteSomeRequest) GetKeys() []*UpdateKey

func (*UpdateConfigDeleteSomeRequest) ProtoMessage

func (*UpdateConfigDeleteSomeRequest) ProtoMessage()

func (*UpdateConfigDeleteSomeRequest) ProtoReflect

func (*UpdateConfigDeleteSomeRequest) Reset

func (x *UpdateConfigDeleteSomeRequest) Reset()

func (*UpdateConfigDeleteSomeRequest) String

type UpdateConfigDeleteSomeResponse

type UpdateConfigDeleteSomeResponse struct {
	Key   *UpdateKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Error string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

UpdateConfigDeleteSomeResponse is only sent when there is an error.

func (*UpdateConfigDeleteSomeResponse) Descriptor deprecated

func (*UpdateConfigDeleteSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConfigDeleteSomeResponse.ProtoReflect.Descriptor instead.

func (*UpdateConfigDeleteSomeResponse) GetError

func (x *UpdateConfigDeleteSomeResponse) GetError() string

func (*UpdateConfigDeleteSomeResponse) GetKey

func (*UpdateConfigDeleteSomeResponse) ProtoMessage

func (*UpdateConfigDeleteSomeResponse) ProtoMessage()

func (*UpdateConfigDeleteSomeResponse) ProtoReflect

func (*UpdateConfigDeleteSomeResponse) Reset

func (x *UpdateConfigDeleteSomeResponse) Reset()

func (*UpdateConfigDeleteSomeResponse) String

type UpdateConfigRequest

type UpdateConfigRequest struct {

	// Key uniquely identifies a UpdateConfig instance to retrieve.
	// This value must be populated.
	Key *UpdateKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConfigRequest) Descriptor deprecated

func (*UpdateConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConfigRequest.ProtoReflect.Descriptor instead.

func (*UpdateConfigRequest) GetKey

func (x *UpdateConfigRequest) GetKey() *UpdateKey

func (*UpdateConfigRequest) GetTime

func (*UpdateConfigRequest) ProtoMessage

func (*UpdateConfigRequest) ProtoMessage()

func (*UpdateConfigRequest) ProtoReflect

func (x *UpdateConfigRequest) ProtoReflect() protoreflect.Message

func (*UpdateConfigRequest) Reset

func (x *UpdateConfigRequest) Reset()

func (*UpdateConfigRequest) String

func (x *UpdateConfigRequest) String() string

type UpdateConfigResponse

type UpdateConfigResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *UpdateConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time carries the (UTC) timestamp of the last-modification of the
	// UpdateConfig instance in this response.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConfigResponse) Descriptor deprecated

func (*UpdateConfigResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConfigResponse.ProtoReflect.Descriptor instead.

func (*UpdateConfigResponse) GetTime

func (*UpdateConfigResponse) GetValue

func (x *UpdateConfigResponse) GetValue() *UpdateConfig

func (*UpdateConfigResponse) ProtoMessage

func (*UpdateConfigResponse) ProtoMessage()

func (*UpdateConfigResponse) ProtoReflect

func (x *UpdateConfigResponse) ProtoReflect() protoreflect.Message

func (*UpdateConfigResponse) Reset

func (x *UpdateConfigResponse) Reset()

func (*UpdateConfigResponse) String

func (x *UpdateConfigResponse) String() string

type UpdateConfigServiceClient

type UpdateConfigServiceClient interface {
	GetOne(ctx context.Context, in *UpdateConfigRequest, opts ...grpc.CallOption) (*UpdateConfigResponse, error)
	GetSome(ctx context.Context, in *UpdateConfigSomeRequest, opts ...grpc.CallOption) (UpdateConfigService_GetSomeClient, error)
	GetAll(ctx context.Context, in *UpdateConfigStreamRequest, opts ...grpc.CallOption) (UpdateConfigService_GetAllClient, error)
	Subscribe(ctx context.Context, in *UpdateConfigStreamRequest, opts ...grpc.CallOption) (UpdateConfigService_SubscribeClient, error)
	GetMeta(ctx context.Context, in *UpdateConfigStreamRequest, opts ...grpc.CallOption) (*MetaResponse, error)
	SubscribeMeta(ctx context.Context, in *UpdateConfigStreamRequest, opts ...grpc.CallOption) (UpdateConfigService_SubscribeMetaClient, error)
	Set(ctx context.Context, in *UpdateConfigSetRequest, opts ...grpc.CallOption) (*UpdateConfigSetResponse, error)
	SetSome(ctx context.Context, in *UpdateConfigSetSomeRequest, opts ...grpc.CallOption) (UpdateConfigService_SetSomeClient, error)
	Delete(ctx context.Context, in *UpdateConfigDeleteRequest, opts ...grpc.CallOption) (*UpdateConfigDeleteResponse, error)
	DeleteSome(ctx context.Context, in *UpdateConfigDeleteSomeRequest, opts ...grpc.CallOption) (UpdateConfigService_DeleteSomeClient, error)
	DeleteAll(ctx context.Context, in *UpdateConfigDeleteAllRequest, opts ...grpc.CallOption) (UpdateConfigService_DeleteAllClient, error)
	GetAllBatched(ctx context.Context, in *UpdateConfigBatchedStreamRequest, opts ...grpc.CallOption) (UpdateConfigService_GetAllBatchedClient, error)
	SubscribeBatched(ctx context.Context, in *UpdateConfigBatchedStreamRequest, opts ...grpc.CallOption) (UpdateConfigService_SubscribeBatchedClient, error)
}

UpdateConfigServiceClient is the client API for UpdateConfigService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type UpdateConfigService_DeleteAllClient

type UpdateConfigService_DeleteAllClient interface {
	Recv() (*UpdateConfigDeleteAllResponse, error)
	grpc.ClientStream
}

type UpdateConfigService_DeleteAllServer

type UpdateConfigService_DeleteAllServer interface {
	Send(*UpdateConfigDeleteAllResponse) error
	grpc.ServerStream
}

type UpdateConfigService_DeleteSomeClient

type UpdateConfigService_DeleteSomeClient interface {
	Recv() (*UpdateConfigDeleteSomeResponse, error)
	grpc.ClientStream
}

type UpdateConfigService_DeleteSomeServer

type UpdateConfigService_DeleteSomeServer interface {
	Send(*UpdateConfigDeleteSomeResponse) error
	grpc.ServerStream
}

type UpdateConfigService_GetAllBatchedClient

type UpdateConfigService_GetAllBatchedClient interface {
	Recv() (*UpdateConfigBatchedStreamResponse, error)
	grpc.ClientStream
}

type UpdateConfigService_GetAllBatchedServer

type UpdateConfigService_GetAllBatchedServer interface {
	Send(*UpdateConfigBatchedStreamResponse) error
	grpc.ServerStream
}

type UpdateConfigService_GetAllClient

type UpdateConfigService_GetAllClient interface {
	Recv() (*UpdateConfigStreamResponse, error)
	grpc.ClientStream
}

type UpdateConfigService_GetAllServer

type UpdateConfigService_GetAllServer interface {
	Send(*UpdateConfigStreamResponse) error
	grpc.ServerStream
}

type UpdateConfigService_GetSomeClient

type UpdateConfigService_GetSomeClient interface {
	Recv() (*UpdateConfigSomeResponse, error)
	grpc.ClientStream
}

type UpdateConfigService_GetSomeServer

type UpdateConfigService_GetSomeServer interface {
	Send(*UpdateConfigSomeResponse) error
	grpc.ServerStream
}

type UpdateConfigService_SetSomeClient

type UpdateConfigService_SetSomeClient interface {
	Recv() (*UpdateConfigSetSomeResponse, error)
	grpc.ClientStream
}

type UpdateConfigService_SetSomeServer

type UpdateConfigService_SetSomeServer interface {
	Send(*UpdateConfigSetSomeResponse) error
	grpc.ServerStream
}

type UpdateConfigService_SubscribeBatchedClient

type UpdateConfigService_SubscribeBatchedClient interface {
	Recv() (*UpdateConfigBatchedStreamResponse, error)
	grpc.ClientStream
}

type UpdateConfigService_SubscribeBatchedServer

type UpdateConfigService_SubscribeBatchedServer interface {
	Send(*UpdateConfigBatchedStreamResponse) error
	grpc.ServerStream
}

type UpdateConfigService_SubscribeClient

type UpdateConfigService_SubscribeClient interface {
	Recv() (*UpdateConfigStreamResponse, error)
	grpc.ClientStream
}

type UpdateConfigService_SubscribeMetaClient

type UpdateConfigService_SubscribeMetaClient interface {
	Recv() (*MetaResponse, error)
	grpc.ClientStream
}

type UpdateConfigService_SubscribeMetaServer

type UpdateConfigService_SubscribeMetaServer interface {
	Send(*MetaResponse) error
	grpc.ServerStream
}

type UpdateConfigService_SubscribeServer

type UpdateConfigService_SubscribeServer interface {
	Send(*UpdateConfigStreamResponse) error
	grpc.ServerStream
}

type UpdateConfigSetRequest

type UpdateConfigSetRequest struct {

	// UpdateConfig carries the value to set into the datastore.
	// See the documentation on the UpdateConfig struct for which fields are required.
	Value *UpdateConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConfigSetRequest) Descriptor deprecated

func (*UpdateConfigSetRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConfigSetRequest.ProtoReflect.Descriptor instead.

func (*UpdateConfigSetRequest) GetValue

func (x *UpdateConfigSetRequest) GetValue() *UpdateConfig

func (*UpdateConfigSetRequest) ProtoMessage

func (*UpdateConfigSetRequest) ProtoMessage()

func (*UpdateConfigSetRequest) ProtoReflect

func (x *UpdateConfigSetRequest) ProtoReflect() protoreflect.Message

func (*UpdateConfigSetRequest) Reset

func (x *UpdateConfigSetRequest) Reset()

func (*UpdateConfigSetRequest) String

func (x *UpdateConfigSetRequest) String() string

type UpdateConfigSetResponse

type UpdateConfigSetResponse struct {

	// Value carries all the values given in the UpdateConfigSetRequest as well
	// as any server-generated values.
	Value *UpdateConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time indicates the (UTC) timestamp at which the system recognizes the
	// creation. The only guarantees made about this timestamp are:
	//
	//   - it is after the time the request was received
	//   - a time-ranged query with StartTime==CreatedAt will include this instance.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConfigSetResponse) Descriptor deprecated

func (*UpdateConfigSetResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConfigSetResponse.ProtoReflect.Descriptor instead.

func (*UpdateConfigSetResponse) GetTime

func (*UpdateConfigSetResponse) GetValue

func (x *UpdateConfigSetResponse) GetValue() *UpdateConfig

func (*UpdateConfigSetResponse) ProtoMessage

func (*UpdateConfigSetResponse) ProtoMessage()

func (*UpdateConfigSetResponse) ProtoReflect

func (x *UpdateConfigSetResponse) ProtoReflect() protoreflect.Message

func (*UpdateConfigSetResponse) Reset

func (x *UpdateConfigSetResponse) Reset()

func (*UpdateConfigSetResponse) String

func (x *UpdateConfigSetResponse) String() string

type UpdateConfigSetSomeRequest

type UpdateConfigSetSomeRequest struct {

	// value contains a list of UpdateConfig values to write.
	// It is possible to provide more values than can fit within either:
	//   - the maxiumum send size of the client
	//   - the maximum receive size of the server
	//
	// If this error occurs you must reduce the number of values sent.
	// See gRPC "maximum message size" documentation for more information.
	Values []*UpdateConfig `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConfigSetSomeRequest) Descriptor deprecated

func (*UpdateConfigSetSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConfigSetSomeRequest.ProtoReflect.Descriptor instead.

func (*UpdateConfigSetSomeRequest) GetValues

func (x *UpdateConfigSetSomeRequest) GetValues() []*UpdateConfig

func (*UpdateConfigSetSomeRequest) ProtoMessage

func (*UpdateConfigSetSomeRequest) ProtoMessage()

func (*UpdateConfigSetSomeRequest) ProtoReflect

func (*UpdateConfigSetSomeRequest) Reset

func (x *UpdateConfigSetSomeRequest) Reset()

func (*UpdateConfigSetSomeRequest) String

func (x *UpdateConfigSetSomeRequest) String() string

type UpdateConfigSetSomeResponse

type UpdateConfigSetSomeResponse struct {
	Key   *UpdateKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Error string     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConfigSetSomeResponse) Descriptor deprecated

func (*UpdateConfigSetSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConfigSetSomeResponse.ProtoReflect.Descriptor instead.

func (*UpdateConfigSetSomeResponse) GetError

func (x *UpdateConfigSetSomeResponse) GetError() string

func (*UpdateConfigSetSomeResponse) GetKey

func (*UpdateConfigSetSomeResponse) ProtoMessage

func (*UpdateConfigSetSomeResponse) ProtoMessage()

func (*UpdateConfigSetSomeResponse) ProtoReflect

func (*UpdateConfigSetSomeResponse) Reset

func (x *UpdateConfigSetSomeResponse) Reset()

func (*UpdateConfigSetSomeResponse) String

func (x *UpdateConfigSetSomeResponse) String() string

type UpdateConfigSomeRequest

type UpdateConfigSomeRequest struct {
	Keys []*UpdateKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConfigSomeRequest) Descriptor deprecated

func (*UpdateConfigSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConfigSomeRequest.ProtoReflect.Descriptor instead.

func (*UpdateConfigSomeRequest) GetKeys

func (x *UpdateConfigSomeRequest) GetKeys() []*UpdateKey

func (*UpdateConfigSomeRequest) GetTime

func (*UpdateConfigSomeRequest) ProtoMessage

func (*UpdateConfigSomeRequest) ProtoMessage()

func (*UpdateConfigSomeRequest) ProtoReflect

func (x *UpdateConfigSomeRequest) ProtoReflect() protoreflect.Message

func (*UpdateConfigSomeRequest) Reset

func (x *UpdateConfigSomeRequest) Reset()

func (*UpdateConfigSomeRequest) String

func (x *UpdateConfigSomeRequest) String() string

type UpdateConfigSomeResponse

type UpdateConfigSomeResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *UpdateConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Error is an optional field.
	// It should be filled when there is an error in the GetSome process.
	Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Time  *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConfigSomeResponse) Descriptor deprecated

func (*UpdateConfigSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConfigSomeResponse.ProtoReflect.Descriptor instead.

func (*UpdateConfigSomeResponse) GetError

func (*UpdateConfigSomeResponse) GetTime

func (*UpdateConfigSomeResponse) GetValue

func (x *UpdateConfigSomeResponse) GetValue() *UpdateConfig

func (*UpdateConfigSomeResponse) ProtoMessage

func (*UpdateConfigSomeResponse) ProtoMessage()

func (*UpdateConfigSomeResponse) ProtoReflect

func (x *UpdateConfigSomeResponse) ProtoReflect() protoreflect.Message

func (*UpdateConfigSomeResponse) Reset

func (x *UpdateConfigSomeResponse) Reset()

func (*UpdateConfigSomeResponse) String

func (x *UpdateConfigSomeResponse) String() string

type UpdateConfigStreamRequest

type UpdateConfigStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*UpdateConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each UpdateConfig at end.
	//   - Each UpdateConfig response is fully-specified (all fields set).
	//   - start: Returns the state of each UpdateConfig at start, followed by updates until now.
	//   - Each UpdateConfig response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each UpdateConfig at start, followed by updates
	//     until end.
	//   - Each UpdateConfig response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConfigStreamRequest) Descriptor deprecated

func (*UpdateConfigStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConfigStreamRequest.ProtoReflect.Descriptor instead.

func (*UpdateConfigStreamRequest) GetPartialEqFilter

func (x *UpdateConfigStreamRequest) GetPartialEqFilter() []*UpdateConfig

func (*UpdateConfigStreamRequest) GetTime

func (*UpdateConfigStreamRequest) ProtoMessage

func (*UpdateConfigStreamRequest) ProtoMessage()

func (*UpdateConfigStreamRequest) ProtoReflect

func (*UpdateConfigStreamRequest) Reset

func (x *UpdateConfigStreamRequest) Reset()

func (*UpdateConfigStreamRequest) String

func (x *UpdateConfigStreamRequest) String() string

type UpdateConfigStreamResponse

type UpdateConfigStreamResponse struct {

	// Value is a value deemed relevant to the initiating request.
	// This structure will always have its key-field populated. Which other fields are
	// populated, and why, depends on the value of Operation and what triggered this notification.
	Value *UpdateConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time holds the timestamp of this UpdateConfig's last modification.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// Operation indicates how the UpdateConfig value in this response should be considered.
	// Under non-subscribe requests, this value should always be INITIAL. In a subscription,
	// once all initial data is streamed and the client begins to receive modification updates,
	// you should not see INITIAL again.
	Type subscriptions.Operation `protobuf:"varint,3,opt,name=type,proto3,enum=arista.subscriptions.Operation" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateConfigStreamResponse) Descriptor deprecated

func (*UpdateConfigStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateConfigStreamResponse.ProtoReflect.Descriptor instead.

func (*UpdateConfigStreamResponse) GetTime

func (*UpdateConfigStreamResponse) GetType

func (*UpdateConfigStreamResponse) GetValue

func (*UpdateConfigStreamResponse) ProtoMessage

func (*UpdateConfigStreamResponse) ProtoMessage()

func (*UpdateConfigStreamResponse) ProtoReflect

func (*UpdateConfigStreamResponse) Reset

func (x *UpdateConfigStreamResponse) Reset()

func (*UpdateConfigStreamResponse) String

func (x *UpdateConfigStreamResponse) String() string

type UpdateKey

type UpdateKey struct {

	// workspace_id identifies the workspace uniquely.
	WorkspaceId *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	// update_id identifies the update uniquely.
	UpdateId *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=update_id,json=updateId,proto3" json:"update_id,omitempty"`
	// contains filtered or unexported fields
}

UpdateKey uniquely identifies a workspace topology update.

func (*UpdateKey) Descriptor deprecated

func (*UpdateKey) Descriptor() ([]byte, []int)

Deprecated: Use UpdateKey.ProtoReflect.Descriptor instead.

func (*UpdateKey) GetUpdateId

func (x *UpdateKey) GetUpdateId() *wrapperspb.StringValue

func (*UpdateKey) GetWorkspaceId

func (x *UpdateKey) GetWorkspaceId() *wrapperspb.StringValue

func (*UpdateKey) ProtoMessage

func (*UpdateKey) ProtoMessage()

func (*UpdateKey) ProtoReflect

func (x *UpdateKey) ProtoReflect() protoreflect.Message

func (*UpdateKey) Reset

func (x *UpdateKey) Reset()

func (*UpdateKey) String

func (x *UpdateKey) String() string

type UpdateRequest

type UpdateRequest struct {

	// Key uniquely identifies a Update instance to retrieve.
	// This value must be populated.
	Key *UpdateKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateRequest) Descriptor deprecated

func (*UpdateRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.

func (*UpdateRequest) GetKey

func (x *UpdateRequest) GetKey() *UpdateKey

func (*UpdateRequest) GetTime

func (x *UpdateRequest) GetTime() *timestamppb.Timestamp

func (*UpdateRequest) ProtoMessage

func (*UpdateRequest) ProtoMessage()

func (*UpdateRequest) ProtoReflect

func (x *UpdateRequest) ProtoReflect() protoreflect.Message

func (*UpdateRequest) Reset

func (x *UpdateRequest) Reset()

func (*UpdateRequest) String

func (x *UpdateRequest) String() string

type UpdateResponse

type UpdateResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *Update `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time carries the (UTC) timestamp of the last-modification of the
	// Update instance in this response.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateResponse) Descriptor deprecated

func (*UpdateResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateResponse.ProtoReflect.Descriptor instead.

func (*UpdateResponse) GetTime

func (x *UpdateResponse) GetTime() *timestamppb.Timestamp

func (*UpdateResponse) GetValue

func (x *UpdateResponse) GetValue() *Update

func (*UpdateResponse) ProtoMessage

func (*UpdateResponse) ProtoMessage()

func (*UpdateResponse) ProtoReflect

func (x *UpdateResponse) ProtoReflect() protoreflect.Message

func (*UpdateResponse) Reset

func (x *UpdateResponse) Reset()

func (*UpdateResponse) String

func (x *UpdateResponse) String() string

type UpdateServiceClient

UpdateServiceClient is the client API for UpdateService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type UpdateServiceServer

UpdateServiceServer is the server API for UpdateService service. All implementations must embed UnimplementedUpdateServiceServer for forward compatibility

type UpdateService_GetAllBatchedClient

type UpdateService_GetAllBatchedClient interface {
	Recv() (*UpdateBatchedStreamResponse, error)
	grpc.ClientStream
}

type UpdateService_GetAllBatchedServer

type UpdateService_GetAllBatchedServer interface {
	Send(*UpdateBatchedStreamResponse) error
	grpc.ServerStream
}

type UpdateService_GetAllClient

type UpdateService_GetAllClient interface {
	Recv() (*UpdateStreamResponse, error)
	grpc.ClientStream
}

type UpdateService_GetAllServer

type UpdateService_GetAllServer interface {
	Send(*UpdateStreamResponse) error
	grpc.ServerStream
}

type UpdateService_GetSomeClient

type UpdateService_GetSomeClient interface {
	Recv() (*UpdateSomeResponse, error)
	grpc.ClientStream
}

type UpdateService_GetSomeServer

type UpdateService_GetSomeServer interface {
	Send(*UpdateSomeResponse) error
	grpc.ServerStream
}

type UpdateService_SubscribeBatchedClient

type UpdateService_SubscribeBatchedClient interface {
	Recv() (*UpdateBatchedStreamResponse, error)
	grpc.ClientStream
}

type UpdateService_SubscribeBatchedServer

type UpdateService_SubscribeBatchedServer interface {
	Send(*UpdateBatchedStreamResponse) error
	grpc.ServerStream
}

type UpdateService_SubscribeClient

type UpdateService_SubscribeClient interface {
	Recv() (*UpdateStreamResponse, error)
	grpc.ClientStream
}

type UpdateService_SubscribeMetaClient

type UpdateService_SubscribeMetaClient interface {
	Recv() (*MetaResponse, error)
	grpc.ClientStream
}

type UpdateService_SubscribeMetaServer

type UpdateService_SubscribeMetaServer interface {
	Send(*MetaResponse) error
	grpc.ServerStream
}

type UpdateService_SubscribeServer

type UpdateService_SubscribeServer interface {
	Send(*UpdateStreamResponse) error
	grpc.ServerStream
}

type UpdateSomeRequest

type UpdateSomeRequest struct {
	Keys []*UpdateKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSomeRequest) Descriptor deprecated

func (*UpdateSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSomeRequest.ProtoReflect.Descriptor instead.

func (*UpdateSomeRequest) GetKeys

func (x *UpdateSomeRequest) GetKeys() []*UpdateKey

func (*UpdateSomeRequest) GetTime

func (x *UpdateSomeRequest) GetTime() *timestamppb.Timestamp

func (*UpdateSomeRequest) ProtoMessage

func (*UpdateSomeRequest) ProtoMessage()

func (*UpdateSomeRequest) ProtoReflect

func (x *UpdateSomeRequest) ProtoReflect() protoreflect.Message

func (*UpdateSomeRequest) Reset

func (x *UpdateSomeRequest) Reset()

func (*UpdateSomeRequest) String

func (x *UpdateSomeRequest) String() string

type UpdateSomeResponse

type UpdateSomeResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *Update `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Error is an optional field.
	// It should be filled when there is an error in the GetSome process.
	Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Time  *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSomeResponse) Descriptor deprecated

func (*UpdateSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSomeResponse.ProtoReflect.Descriptor instead.

func (*UpdateSomeResponse) GetError

func (x *UpdateSomeResponse) GetError() *wrapperspb.StringValue

func (*UpdateSomeResponse) GetTime

func (*UpdateSomeResponse) GetValue

func (x *UpdateSomeResponse) GetValue() *Update

func (*UpdateSomeResponse) ProtoMessage

func (*UpdateSomeResponse) ProtoMessage()

func (*UpdateSomeResponse) ProtoReflect

func (x *UpdateSomeResponse) ProtoReflect() protoreflect.Message

func (*UpdateSomeResponse) Reset

func (x *UpdateSomeResponse) Reset()

func (*UpdateSomeResponse) String

func (x *UpdateSomeResponse) String() string

type UpdateStatus

type UpdateStatus int32

UpdateStatus defines the set of statuses that apply to individual topology updates.

const (
	// UPDATE_STATUS_UNSPECIFIED indicates an unspecified update status.
	UpdateStatus_UPDATE_STATUS_UNSPECIFIED UpdateStatus = 0
	// UPDATE_STATUS_NEW indicates the update is new.
	UpdateStatus_UPDATE_STATUS_NEW UpdateStatus = 1
	// UPDATE_STATUS_ACCEPTED indicates the update is accepted.
	UpdateStatus_UPDATE_STATUS_ACCEPTED UpdateStatus = 2
	// UPDATE_STATUS_IGNORED indicates the update is ignored.
	UpdateStatus_UPDATE_STATUS_IGNORED UpdateStatus = 3
)

func (UpdateStatus) Descriptor

func (UpdateStatus) Enum

func (x UpdateStatus) Enum() *UpdateStatus

func (UpdateStatus) EnumDescriptor deprecated

func (UpdateStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use UpdateStatus.Descriptor instead.

func (UpdateStatus) Number

func (UpdateStatus) String

func (x UpdateStatus) String() string

func (UpdateStatus) Type

type UpdateStreamRequest

type UpdateStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*Update `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each Update at end.
	//   - Each Update response is fully-specified (all fields set).
	//   - start: Returns the state of each Update at start, followed by updates until now.
	//   - Each Update response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each Update at start, followed by updates
	//     until end.
	//   - Each Update response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateStreamRequest) Descriptor deprecated

func (*UpdateStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateStreamRequest.ProtoReflect.Descriptor instead.

func (*UpdateStreamRequest) GetPartialEqFilter

func (x *UpdateStreamRequest) GetPartialEqFilter() []*Update

func (*UpdateStreamRequest) GetTime

func (x *UpdateStreamRequest) GetTime() *time.TimeBounds

func (*UpdateStreamRequest) ProtoMessage

func (*UpdateStreamRequest) ProtoMessage()

func (*UpdateStreamRequest) ProtoReflect

func (x *UpdateStreamRequest) ProtoReflect() protoreflect.Message

func (*UpdateStreamRequest) Reset

func (x *UpdateStreamRequest) Reset()

func (*UpdateStreamRequest) String

func (x *UpdateStreamRequest) String() string

type UpdateStreamResponse

type UpdateStreamResponse struct {

	// Value is a value deemed relevant to the initiating request.
	// This structure will always have its key-field populated. Which other fields are
	// populated, and why, depends on the value of Operation and what triggered this notification.
	Value *Update `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time holds the timestamp of this Update's last modification.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// Operation indicates how the Update value in this response should be considered.
	// Under non-subscribe requests, this value should always be INITIAL. In a subscription,
	// once all initial data is streamed and the client begins to receive modification updates,
	// you should not see INITIAL again.
	Type subscriptions.Operation `protobuf:"varint,3,opt,name=type,proto3,enum=arista.subscriptions.Operation" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateStreamResponse) Descriptor deprecated

func (*UpdateStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateStreamResponse.ProtoReflect.Descriptor instead.

func (*UpdateStreamResponse) GetTime

func (*UpdateStreamResponse) GetType

func (*UpdateStreamResponse) GetValue

func (x *UpdateStreamResponse) GetValue() *Update

func (*UpdateStreamResponse) ProtoMessage

func (*UpdateStreamResponse) ProtoMessage()

func (*UpdateStreamResponse) ProtoReflect

func (x *UpdateStreamResponse) ProtoReflect() protoreflect.Message

func (*UpdateStreamResponse) Reset

func (x *UpdateStreamResponse) Reset()

func (*UpdateStreamResponse) String

func (x *UpdateStreamResponse) String() string

type UpdateSyncConfig

type UpdateSyncConfig struct {

	// key uniquely identifies the workspace.
	Key *workspace_v1.WorkspaceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// sync_time indicates the desired synchronization time with the live topology.
	// If the sync_time indicated in the config takes effect without error,
	// it will appear in the state model, and then all updates that occurred up to
	// and including the timestamp in the state model will be accepted.
	SyncTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=sync_time,json=syncTime,proto3" json:"sync_time,omitempty"`
	// contains filtered or unexported fields
}

UpdateSyncConfig model represents a point in time all updates are to be accepted.

func (*UpdateSyncConfig) Descriptor deprecated

func (*UpdateSyncConfig) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSyncConfig.ProtoReflect.Descriptor instead.

func (*UpdateSyncConfig) GetKey

func (*UpdateSyncConfig) GetSyncTime

func (x *UpdateSyncConfig) GetSyncTime() *timestamppb.Timestamp

func (*UpdateSyncConfig) ProtoMessage

func (*UpdateSyncConfig) ProtoMessage()

func (*UpdateSyncConfig) ProtoReflect

func (x *UpdateSyncConfig) ProtoReflect() protoreflect.Message

func (*UpdateSyncConfig) Reset

func (x *UpdateSyncConfig) Reset()

func (*UpdateSyncConfig) String

func (x *UpdateSyncConfig) String() string

type UpdateSyncConfigBatchedStreamRequest

type UpdateSyncConfigBatchedStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*UpdateSyncConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each UpdateSyncConfig at end.
	//   - Each UpdateSyncConfig response is fully-specified (all fields set).
	//   - start: Returns the state of each UpdateSyncConfig at start, followed by updates until now.
	//   - Each UpdateSyncConfig response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each UpdateSyncConfig at start, followed by updates
	//     until end.
	//   - Each UpdateSyncConfig response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// MaxMessages limits the maximum number of messages that can be contained in one batch.
	// MaxMessages is required to be at least 1.
	// The maximum number of messages in a batch is min(max_messages, INTERNAL_BATCH_LIMIT)
	// INTERNAL_BATCH_LIMIT is set based on the maximum message size.
	MaxMessages *wrapperspb.UInt32Value `protobuf:"bytes,4,opt,name=max_messages,json=maxMessages,proto3" json:"max_messages,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSyncConfigBatchedStreamRequest) Descriptor deprecated

func (*UpdateSyncConfigBatchedStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSyncConfigBatchedStreamRequest.ProtoReflect.Descriptor instead.

func (*UpdateSyncConfigBatchedStreamRequest) GetMaxMessages

func (*UpdateSyncConfigBatchedStreamRequest) GetPartialEqFilter

func (x *UpdateSyncConfigBatchedStreamRequest) GetPartialEqFilter() []*UpdateSyncConfig

func (*UpdateSyncConfigBatchedStreamRequest) GetTime

func (*UpdateSyncConfigBatchedStreamRequest) ProtoMessage

func (*UpdateSyncConfigBatchedStreamRequest) ProtoMessage()

func (*UpdateSyncConfigBatchedStreamRequest) ProtoReflect

func (*UpdateSyncConfigBatchedStreamRequest) Reset

func (*UpdateSyncConfigBatchedStreamRequest) String

type UpdateSyncConfigBatchedStreamResponse

type UpdateSyncConfigBatchedStreamResponse struct {

	// Values are the values deemed relevant to the initiating request.
	// The length of this structure is guaranteed to be between (inclusive) 1 and
	// min(req.max_messages, INTERNAL_BATCH_LIMIT).
	Responses []*UpdateSyncConfigStreamResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSyncConfigBatchedStreamResponse) Descriptor deprecated

func (*UpdateSyncConfigBatchedStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSyncConfigBatchedStreamResponse.ProtoReflect.Descriptor instead.

func (*UpdateSyncConfigBatchedStreamResponse) GetResponses

func (*UpdateSyncConfigBatchedStreamResponse) ProtoMessage

func (*UpdateSyncConfigBatchedStreamResponse) ProtoMessage()

func (*UpdateSyncConfigBatchedStreamResponse) ProtoReflect

func (*UpdateSyncConfigBatchedStreamResponse) Reset

func (*UpdateSyncConfigBatchedStreamResponse) String

type UpdateSyncConfigDeleteAllRequest

type UpdateSyncConfigDeleteAllRequest struct {

	// PartialEqFilter provides a way to server-side filter a DeleteAll.
	// This requires all provided fields to be equal to the response.
	// A filtered DeleteAll will use GetAll with filter to find things to delete.
	PartialEqFilter []*UpdateSyncConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSyncConfigDeleteAllRequest) Descriptor deprecated

func (*UpdateSyncConfigDeleteAllRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSyncConfigDeleteAllRequest.ProtoReflect.Descriptor instead.

func (*UpdateSyncConfigDeleteAllRequest) GetPartialEqFilter

func (x *UpdateSyncConfigDeleteAllRequest) GetPartialEqFilter() []*UpdateSyncConfig

func (*UpdateSyncConfigDeleteAllRequest) ProtoMessage

func (*UpdateSyncConfigDeleteAllRequest) ProtoMessage()

func (*UpdateSyncConfigDeleteAllRequest) ProtoReflect

func (*UpdateSyncConfigDeleteAllRequest) Reset

func (*UpdateSyncConfigDeleteAllRequest) String

type UpdateSyncConfigDeleteAllResponse

type UpdateSyncConfigDeleteAllResponse struct {

	// This describes the class of delete error.
	// A DeleteAllResponse is only sent when there is an error.
	Type fmp.DeleteError `protobuf:"varint,1,opt,name=type,proto3,enum=fmp.DeleteError" json:"type,omitempty"`
	// This indicates the error message from the delete failure.
	Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// This is the key of the UpdateSyncConfig instance that failed to be deleted.
	Key *workspace_v1.WorkspaceKey `protobuf:"bytes,3,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the (UTC) timestamp when the key was being deleted.
	Time *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSyncConfigDeleteAllResponse) Descriptor deprecated

func (*UpdateSyncConfigDeleteAllResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSyncConfigDeleteAllResponse.ProtoReflect.Descriptor instead.

func (*UpdateSyncConfigDeleteAllResponse) GetError

func (*UpdateSyncConfigDeleteAllResponse) GetKey

func (*UpdateSyncConfigDeleteAllResponse) GetTime

func (*UpdateSyncConfigDeleteAllResponse) GetType

func (*UpdateSyncConfigDeleteAllResponse) ProtoMessage

func (*UpdateSyncConfigDeleteAllResponse) ProtoMessage()

func (*UpdateSyncConfigDeleteAllResponse) ProtoReflect

func (*UpdateSyncConfigDeleteAllResponse) Reset

func (*UpdateSyncConfigDeleteAllResponse) String

type UpdateSyncConfigDeleteRequest

type UpdateSyncConfigDeleteRequest struct {

	// Key indicates which UpdateSyncConfig instance to remove.
	// This field must always be set.
	Key *workspace_v1.WorkspaceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSyncConfigDeleteRequest) Descriptor deprecated

func (*UpdateSyncConfigDeleteRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSyncConfigDeleteRequest.ProtoReflect.Descriptor instead.

func (*UpdateSyncConfigDeleteRequest) GetKey

func (*UpdateSyncConfigDeleteRequest) ProtoMessage

func (*UpdateSyncConfigDeleteRequest) ProtoMessage()

func (*UpdateSyncConfigDeleteRequest) ProtoReflect

func (*UpdateSyncConfigDeleteRequest) Reset

func (x *UpdateSyncConfigDeleteRequest) Reset()

func (*UpdateSyncConfigDeleteRequest) String

type UpdateSyncConfigDeleteResponse

type UpdateSyncConfigDeleteResponse struct {

	// Key echoes back the key of the deleted UpdateSyncConfig instance.
	Key *workspace_v1.WorkspaceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the (UTC) timestamp at which the system recognizes the
	// deletion. The only guarantees made about this timestamp are:
	//
	//   - it is after the time the request was received
	//   - a time-ranged query with StartTime==DeletedAt will not include this instance.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSyncConfigDeleteResponse) Descriptor deprecated

func (*UpdateSyncConfigDeleteResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSyncConfigDeleteResponse.ProtoReflect.Descriptor instead.

func (*UpdateSyncConfigDeleteResponse) GetKey

func (*UpdateSyncConfigDeleteResponse) GetTime

func (*UpdateSyncConfigDeleteResponse) ProtoMessage

func (*UpdateSyncConfigDeleteResponse) ProtoMessage()

func (*UpdateSyncConfigDeleteResponse) ProtoReflect

func (*UpdateSyncConfigDeleteResponse) Reset

func (x *UpdateSyncConfigDeleteResponse) Reset()

func (*UpdateSyncConfigDeleteResponse) String

type UpdateSyncConfigDeleteSomeRequest

type UpdateSyncConfigDeleteSomeRequest struct {

	// key contains a list of UpdateSyncConfig keys to delete
	Keys []*workspace_v1.WorkspaceKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSyncConfigDeleteSomeRequest) Descriptor deprecated

func (*UpdateSyncConfigDeleteSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSyncConfigDeleteSomeRequest.ProtoReflect.Descriptor instead.

func (*UpdateSyncConfigDeleteSomeRequest) GetKeys

func (*UpdateSyncConfigDeleteSomeRequest) ProtoMessage

func (*UpdateSyncConfigDeleteSomeRequest) ProtoMessage()

func (*UpdateSyncConfigDeleteSomeRequest) ProtoReflect

func (*UpdateSyncConfigDeleteSomeRequest) Reset

func (*UpdateSyncConfigDeleteSomeRequest) String

type UpdateSyncConfigDeleteSomeResponse

type UpdateSyncConfigDeleteSomeResponse struct {
	Key   *workspace_v1.WorkspaceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Error string                     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

UpdateSyncConfigDeleteSomeResponse is only sent when there is an error.

func (*UpdateSyncConfigDeleteSomeResponse) Descriptor deprecated

func (*UpdateSyncConfigDeleteSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSyncConfigDeleteSomeResponse.ProtoReflect.Descriptor instead.

func (*UpdateSyncConfigDeleteSomeResponse) GetError

func (*UpdateSyncConfigDeleteSomeResponse) GetKey

func (*UpdateSyncConfigDeleteSomeResponse) ProtoMessage

func (*UpdateSyncConfigDeleteSomeResponse) ProtoMessage()

func (*UpdateSyncConfigDeleteSomeResponse) ProtoReflect

func (*UpdateSyncConfigDeleteSomeResponse) Reset

func (*UpdateSyncConfigDeleteSomeResponse) String

type UpdateSyncConfigRequest

type UpdateSyncConfigRequest struct {

	// Key uniquely identifies a UpdateSyncConfig instance to retrieve.
	// This value must be populated.
	Key *workspace_v1.WorkspaceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSyncConfigRequest) Descriptor deprecated

func (*UpdateSyncConfigRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSyncConfigRequest.ProtoReflect.Descriptor instead.

func (*UpdateSyncConfigRequest) GetKey

func (*UpdateSyncConfigRequest) GetTime

func (*UpdateSyncConfigRequest) ProtoMessage

func (*UpdateSyncConfigRequest) ProtoMessage()

func (*UpdateSyncConfigRequest) ProtoReflect

func (x *UpdateSyncConfigRequest) ProtoReflect() protoreflect.Message

func (*UpdateSyncConfigRequest) Reset

func (x *UpdateSyncConfigRequest) Reset()

func (*UpdateSyncConfigRequest) String

func (x *UpdateSyncConfigRequest) String() string

type UpdateSyncConfigResponse

type UpdateSyncConfigResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *UpdateSyncConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time carries the (UTC) timestamp of the last-modification of the
	// UpdateSyncConfig instance in this response.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSyncConfigResponse) Descriptor deprecated

func (*UpdateSyncConfigResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSyncConfigResponse.ProtoReflect.Descriptor instead.

func (*UpdateSyncConfigResponse) GetTime

func (*UpdateSyncConfigResponse) GetValue

func (*UpdateSyncConfigResponse) ProtoMessage

func (*UpdateSyncConfigResponse) ProtoMessage()

func (*UpdateSyncConfigResponse) ProtoReflect

func (x *UpdateSyncConfigResponse) ProtoReflect() protoreflect.Message

func (*UpdateSyncConfigResponse) Reset

func (x *UpdateSyncConfigResponse) Reset()

func (*UpdateSyncConfigResponse) String

func (x *UpdateSyncConfigResponse) String() string

type UpdateSyncConfigServiceClient

type UpdateSyncConfigServiceClient interface {
	GetOne(ctx context.Context, in *UpdateSyncConfigRequest, opts ...grpc.CallOption) (*UpdateSyncConfigResponse, error)
	GetSome(ctx context.Context, in *UpdateSyncConfigSomeRequest, opts ...grpc.CallOption) (UpdateSyncConfigService_GetSomeClient, error)
	GetAll(ctx context.Context, in *UpdateSyncConfigStreamRequest, opts ...grpc.CallOption) (UpdateSyncConfigService_GetAllClient, error)
	Subscribe(ctx context.Context, in *UpdateSyncConfigStreamRequest, opts ...grpc.CallOption) (UpdateSyncConfigService_SubscribeClient, error)
	GetMeta(ctx context.Context, in *UpdateSyncConfigStreamRequest, opts ...grpc.CallOption) (*MetaResponse, error)
	SubscribeMeta(ctx context.Context, in *UpdateSyncConfigStreamRequest, opts ...grpc.CallOption) (UpdateSyncConfigService_SubscribeMetaClient, error)
	Set(ctx context.Context, in *UpdateSyncConfigSetRequest, opts ...grpc.CallOption) (*UpdateSyncConfigSetResponse, error)
	SetSome(ctx context.Context, in *UpdateSyncConfigSetSomeRequest, opts ...grpc.CallOption) (UpdateSyncConfigService_SetSomeClient, error)
	Delete(ctx context.Context, in *UpdateSyncConfigDeleteRequest, opts ...grpc.CallOption) (*UpdateSyncConfigDeleteResponse, error)
	DeleteSome(ctx context.Context, in *UpdateSyncConfigDeleteSomeRequest, opts ...grpc.CallOption) (UpdateSyncConfigService_DeleteSomeClient, error)
	DeleteAll(ctx context.Context, in *UpdateSyncConfigDeleteAllRequest, opts ...grpc.CallOption) (UpdateSyncConfigService_DeleteAllClient, error)
	GetAllBatched(ctx context.Context, in *UpdateSyncConfigBatchedStreamRequest, opts ...grpc.CallOption) (UpdateSyncConfigService_GetAllBatchedClient, error)
	SubscribeBatched(ctx context.Context, in *UpdateSyncConfigBatchedStreamRequest, opts ...grpc.CallOption) (UpdateSyncConfigService_SubscribeBatchedClient, error)
}

UpdateSyncConfigServiceClient is the client API for UpdateSyncConfigService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

type UpdateSyncConfigServiceServer

UpdateSyncConfigServiceServer is the server API for UpdateSyncConfigService service. All implementations must embed UnimplementedUpdateSyncConfigServiceServer for forward compatibility

type UpdateSyncConfigService_DeleteAllClient

type UpdateSyncConfigService_DeleteAllClient interface {
	Recv() (*UpdateSyncConfigDeleteAllResponse, error)
	grpc.ClientStream
}

type UpdateSyncConfigService_DeleteAllServer

type UpdateSyncConfigService_DeleteAllServer interface {
	Send(*UpdateSyncConfigDeleteAllResponse) error
	grpc.ServerStream
}

type UpdateSyncConfigService_DeleteSomeClient

type UpdateSyncConfigService_DeleteSomeClient interface {
	Recv() (*UpdateSyncConfigDeleteSomeResponse, error)
	grpc.ClientStream
}

type UpdateSyncConfigService_DeleteSomeServer

type UpdateSyncConfigService_DeleteSomeServer interface {
	Send(*UpdateSyncConfigDeleteSomeResponse) error
	grpc.ServerStream
}

type UpdateSyncConfigService_GetAllBatchedClient

type UpdateSyncConfigService_GetAllBatchedClient interface {
	Recv() (*UpdateSyncConfigBatchedStreamResponse, error)
	grpc.ClientStream
}

type UpdateSyncConfigService_GetAllBatchedServer

type UpdateSyncConfigService_GetAllBatchedServer interface {
	Send(*UpdateSyncConfigBatchedStreamResponse) error
	grpc.ServerStream
}

type UpdateSyncConfigService_GetAllClient

type UpdateSyncConfigService_GetAllClient interface {
	Recv() (*UpdateSyncConfigStreamResponse, error)
	grpc.ClientStream
}

type UpdateSyncConfigService_GetAllServer

type UpdateSyncConfigService_GetAllServer interface {
	Send(*UpdateSyncConfigStreamResponse) error
	grpc.ServerStream
}

type UpdateSyncConfigService_GetSomeClient

type UpdateSyncConfigService_GetSomeClient interface {
	Recv() (*UpdateSyncConfigSomeResponse, error)
	grpc.ClientStream
}

type UpdateSyncConfigService_GetSomeServer

type UpdateSyncConfigService_GetSomeServer interface {
	Send(*UpdateSyncConfigSomeResponse) error
	grpc.ServerStream
}

type UpdateSyncConfigService_SetSomeClient

type UpdateSyncConfigService_SetSomeClient interface {
	Recv() (*UpdateSyncConfigSetSomeResponse, error)
	grpc.ClientStream
}

type UpdateSyncConfigService_SetSomeServer

type UpdateSyncConfigService_SetSomeServer interface {
	Send(*UpdateSyncConfigSetSomeResponse) error
	grpc.ServerStream
}

type UpdateSyncConfigService_SubscribeBatchedClient

type UpdateSyncConfigService_SubscribeBatchedClient interface {
	Recv() (*UpdateSyncConfigBatchedStreamResponse, error)
	grpc.ClientStream
}

type UpdateSyncConfigService_SubscribeBatchedServer

type UpdateSyncConfigService_SubscribeBatchedServer interface {
	Send(*UpdateSyncConfigBatchedStreamResponse) error
	grpc.ServerStream
}

type UpdateSyncConfigService_SubscribeClient

type UpdateSyncConfigService_SubscribeClient interface {
	Recv() (*UpdateSyncConfigStreamResponse, error)
	grpc.ClientStream
}

type UpdateSyncConfigService_SubscribeMetaClient

type UpdateSyncConfigService_SubscribeMetaClient interface {
	Recv() (*MetaResponse, error)
	grpc.ClientStream
}

type UpdateSyncConfigService_SubscribeMetaServer

type UpdateSyncConfigService_SubscribeMetaServer interface {
	Send(*MetaResponse) error
	grpc.ServerStream
}

type UpdateSyncConfigService_SubscribeServer

type UpdateSyncConfigService_SubscribeServer interface {
	Send(*UpdateSyncConfigStreamResponse) error
	grpc.ServerStream
}

type UpdateSyncConfigSetRequest

type UpdateSyncConfigSetRequest struct {

	// UpdateSyncConfig carries the value to set into the datastore.
	// See the documentation on the UpdateSyncConfig struct for which fields are required.
	Value *UpdateSyncConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSyncConfigSetRequest) Descriptor deprecated

func (*UpdateSyncConfigSetRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSyncConfigSetRequest.ProtoReflect.Descriptor instead.

func (*UpdateSyncConfigSetRequest) GetValue

func (*UpdateSyncConfigSetRequest) ProtoMessage

func (*UpdateSyncConfigSetRequest) ProtoMessage()

func (*UpdateSyncConfigSetRequest) ProtoReflect

func (*UpdateSyncConfigSetRequest) Reset

func (x *UpdateSyncConfigSetRequest) Reset()

func (*UpdateSyncConfigSetRequest) String

func (x *UpdateSyncConfigSetRequest) String() string

type UpdateSyncConfigSetResponse

type UpdateSyncConfigSetResponse struct {

	// Value carries all the values given in the UpdateSyncConfigSetRequest as well
	// as any server-generated values.
	Value *UpdateSyncConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time indicates the (UTC) timestamp at which the system recognizes the
	// creation. The only guarantees made about this timestamp are:
	//
	//   - it is after the time the request was received
	//   - a time-ranged query with StartTime==CreatedAt will include this instance.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSyncConfigSetResponse) Descriptor deprecated

func (*UpdateSyncConfigSetResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSyncConfigSetResponse.ProtoReflect.Descriptor instead.

func (*UpdateSyncConfigSetResponse) GetTime

func (*UpdateSyncConfigSetResponse) GetValue

func (*UpdateSyncConfigSetResponse) ProtoMessage

func (*UpdateSyncConfigSetResponse) ProtoMessage()

func (*UpdateSyncConfigSetResponse) ProtoReflect

func (*UpdateSyncConfigSetResponse) Reset

func (x *UpdateSyncConfigSetResponse) Reset()

func (*UpdateSyncConfigSetResponse) String

func (x *UpdateSyncConfigSetResponse) String() string

type UpdateSyncConfigSetSomeRequest

type UpdateSyncConfigSetSomeRequest struct {

	// value contains a list of UpdateSyncConfig values to write.
	// It is possible to provide more values than can fit within either:
	//   - the maxiumum send size of the client
	//   - the maximum receive size of the server
	//
	// If this error occurs you must reduce the number of values sent.
	// See gRPC "maximum message size" documentation for more information.
	Values []*UpdateSyncConfig `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSyncConfigSetSomeRequest) Descriptor deprecated

func (*UpdateSyncConfigSetSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSyncConfigSetSomeRequest.ProtoReflect.Descriptor instead.

func (*UpdateSyncConfigSetSomeRequest) GetValues

func (*UpdateSyncConfigSetSomeRequest) ProtoMessage

func (*UpdateSyncConfigSetSomeRequest) ProtoMessage()

func (*UpdateSyncConfigSetSomeRequest) ProtoReflect

func (*UpdateSyncConfigSetSomeRequest) Reset

func (x *UpdateSyncConfigSetSomeRequest) Reset()

func (*UpdateSyncConfigSetSomeRequest) String

type UpdateSyncConfigSetSomeResponse

type UpdateSyncConfigSetSomeResponse struct {
	Key   *workspace_v1.WorkspaceKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Error string                     `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSyncConfigSetSomeResponse) Descriptor deprecated

func (*UpdateSyncConfigSetSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSyncConfigSetSomeResponse.ProtoReflect.Descriptor instead.

func (*UpdateSyncConfigSetSomeResponse) GetError

func (*UpdateSyncConfigSetSomeResponse) GetKey

func (*UpdateSyncConfigSetSomeResponse) ProtoMessage

func (*UpdateSyncConfigSetSomeResponse) ProtoMessage()

func (*UpdateSyncConfigSetSomeResponse) ProtoReflect

func (*UpdateSyncConfigSetSomeResponse) Reset

func (*UpdateSyncConfigSetSomeResponse) String

type UpdateSyncConfigSomeRequest

type UpdateSyncConfigSomeRequest struct {
	Keys []*workspace_v1.WorkspaceKey `protobuf:"bytes,1,rep,name=keys,proto3" json:"keys,omitempty"`
	// Time indicates the time for which you are interested in the data.
	// If no time is given, the server will use the time at which it makes the request.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSyncConfigSomeRequest) Descriptor deprecated

func (*UpdateSyncConfigSomeRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSyncConfigSomeRequest.ProtoReflect.Descriptor instead.

func (*UpdateSyncConfigSomeRequest) GetKeys

func (*UpdateSyncConfigSomeRequest) GetTime

func (*UpdateSyncConfigSomeRequest) ProtoMessage

func (*UpdateSyncConfigSomeRequest) ProtoMessage()

func (*UpdateSyncConfigSomeRequest) ProtoReflect

func (*UpdateSyncConfigSomeRequest) Reset

func (x *UpdateSyncConfigSomeRequest) Reset()

func (*UpdateSyncConfigSomeRequest) String

func (x *UpdateSyncConfigSomeRequest) String() string

type UpdateSyncConfigSomeResponse

type UpdateSyncConfigSomeResponse struct {

	// Value is the value requested.
	// This structure will be fully-populated as it exists in the datastore. If
	// optional fields were not given at creation, these fields will be empty or
	// set to default values.
	Value *UpdateSyncConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Error is an optional field.
	// It should be filled when there is an error in the GetSome process.
	Error *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	Time  *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSyncConfigSomeResponse) Descriptor deprecated

func (*UpdateSyncConfigSomeResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSyncConfigSomeResponse.ProtoReflect.Descriptor instead.

func (*UpdateSyncConfigSomeResponse) GetError

func (*UpdateSyncConfigSomeResponse) GetTime

func (*UpdateSyncConfigSomeResponse) GetValue

func (*UpdateSyncConfigSomeResponse) ProtoMessage

func (*UpdateSyncConfigSomeResponse) ProtoMessage()

func (*UpdateSyncConfigSomeResponse) ProtoReflect

func (*UpdateSyncConfigSomeResponse) Reset

func (x *UpdateSyncConfigSomeResponse) Reset()

func (*UpdateSyncConfigSomeResponse) String

type UpdateSyncConfigStreamRequest

type UpdateSyncConfigStreamRequest struct {

	// PartialEqFilter provides a way to server-side filter a GetAll/Subscribe.
	// This requires all provided fields to be equal to the response.
	//
	// While transparent to users, this field also allows services to optimize internal
	// subscriptions if filter(s) are sufficiently specific.
	PartialEqFilter []*UpdateSyncConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// TimeRange allows limiting response data to within a specified time window.
	// If this field is populated, at least one of the two time fields are required.
	//
	// For GetAll, the fields start and end can be used as follows:
	//
	//   - end: Returns the state of each UpdateSyncConfig at end.
	//   - Each UpdateSyncConfig response is fully-specified (all fields set).
	//   - start: Returns the state of each UpdateSyncConfig at start, followed by updates until now.
	//   - Each UpdateSyncConfig response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each UpdateSyncConfig at start, followed by updates
	//     until end.
	//   - Each UpdateSyncConfig response at start is fully-specified, but updates until end may
	//     be partial.
	//
	// This field is not allowed in the Subscribe RPC.
	Time *time.TimeBounds `protobuf:"bytes,3,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSyncConfigStreamRequest) Descriptor deprecated

func (*UpdateSyncConfigStreamRequest) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSyncConfigStreamRequest.ProtoReflect.Descriptor instead.

func (*UpdateSyncConfigStreamRequest) GetPartialEqFilter

func (x *UpdateSyncConfigStreamRequest) GetPartialEqFilter() []*UpdateSyncConfig

func (*UpdateSyncConfigStreamRequest) GetTime

func (*UpdateSyncConfigStreamRequest) ProtoMessage

func (*UpdateSyncConfigStreamRequest) ProtoMessage()

func (*UpdateSyncConfigStreamRequest) ProtoReflect

func (*UpdateSyncConfigStreamRequest) Reset

func (x *UpdateSyncConfigStreamRequest) Reset()

func (*UpdateSyncConfigStreamRequest) String

type UpdateSyncConfigStreamResponse

type UpdateSyncConfigStreamResponse struct {

	// Value is a value deemed relevant to the initiating request.
	// This structure will always have its key-field populated. Which other fields are
	// populated, and why, depends on the value of Operation and what triggered this notification.
	Value *UpdateSyncConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time holds the timestamp of this UpdateSyncConfig's last modification.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// Operation indicates how the UpdateSyncConfig value in this response should be considered.
	// Under non-subscribe requests, this value should always be INITIAL. In a subscription,
	// once all initial data is streamed and the client begins to receive modification updates,
	// you should not see INITIAL again.
	Type subscriptions.Operation `protobuf:"varint,3,opt,name=type,proto3,enum=arista.subscriptions.Operation" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateSyncConfigStreamResponse) Descriptor deprecated

func (*UpdateSyncConfigStreamResponse) Descriptor() ([]byte, []int)

Deprecated: Use UpdateSyncConfigStreamResponse.ProtoReflect.Descriptor instead.

func (*UpdateSyncConfigStreamResponse) GetTime

func (*UpdateSyncConfigStreamResponse) GetType

func (*UpdateSyncConfigStreamResponse) GetValue

func (*UpdateSyncConfigStreamResponse) ProtoMessage

func (*UpdateSyncConfigStreamResponse) ProtoMessage()

func (*UpdateSyncConfigStreamResponse) ProtoReflect

func (*UpdateSyncConfigStreamResponse) Reset

func (x *UpdateSyncConfigStreamResponse) Reset()

func (*UpdateSyncConfigStreamResponse) String

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL