tag

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: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	TagService_GetOne_FullMethodName           = "/arista.tag.v2.TagService/GetOne"
	TagService_GetSome_FullMethodName          = "/arista.tag.v2.TagService/GetSome"
	TagService_GetAll_FullMethodName           = "/arista.tag.v2.TagService/GetAll"
	TagService_Subscribe_FullMethodName        = "/arista.tag.v2.TagService/Subscribe"
	TagService_GetMeta_FullMethodName          = "/arista.tag.v2.TagService/GetMeta"
	TagService_SubscribeMeta_FullMethodName    = "/arista.tag.v2.TagService/SubscribeMeta"
	TagService_GetAllBatched_FullMethodName    = "/arista.tag.v2.TagService/GetAllBatched"
	TagService_SubscribeBatched_FullMethodName = "/arista.tag.v2.TagService/SubscribeBatched"
)
View Source 
const (
	TagAssignmentService_GetOne_FullMethodName           = "/arista.tag.v2.TagAssignmentService/GetOne"
	TagAssignmentService_GetSome_FullMethodName          = "/arista.tag.v2.TagAssignmentService/GetSome"
	TagAssignmentService_GetAll_FullMethodName           = "/arista.tag.v2.TagAssignmentService/GetAll"
	TagAssignmentService_Subscribe_FullMethodName        = "/arista.tag.v2.TagAssignmentService/Subscribe"
	TagAssignmentService_GetMeta_FullMethodName          = "/arista.tag.v2.TagAssignmentService/GetMeta"
	TagAssignmentService_SubscribeMeta_FullMethodName    = "/arista.tag.v2.TagAssignmentService/SubscribeMeta"
	TagAssignmentService_GetAllBatched_FullMethodName    = "/arista.tag.v2.TagAssignmentService/GetAllBatched"
	TagAssignmentService_SubscribeBatched_FullMethodName = "/arista.tag.v2.TagAssignmentService/SubscribeBatched"
)
View Source 
const (
	TagAssignmentConfigService_GetOne_FullMethodName           = "/arista.tag.v2.TagAssignmentConfigService/GetOne"
	TagAssignmentConfigService_GetSome_FullMethodName          = "/arista.tag.v2.TagAssignmentConfigService/GetSome"
	TagAssignmentConfigService_GetAll_FullMethodName           = "/arista.tag.v2.TagAssignmentConfigService/GetAll"
	TagAssignmentConfigService_Subscribe_FullMethodName        = "/arista.tag.v2.TagAssignmentConfigService/Subscribe"
	TagAssignmentConfigService_GetMeta_FullMethodName          = "/arista.tag.v2.TagAssignmentConfigService/GetMeta"
	TagAssignmentConfigService_SubscribeMeta_FullMethodName    = "/arista.tag.v2.TagAssignmentConfigService/SubscribeMeta"
	TagAssignmentConfigService_Set_FullMethodName              = "/arista.tag.v2.TagAssignmentConfigService/Set"
	TagAssignmentConfigService_SetSome_FullMethodName          = "/arista.tag.v2.TagAssignmentConfigService/SetSome"
	TagAssignmentConfigService_Delete_FullMethodName           = "/arista.tag.v2.TagAssignmentConfigService/Delete"
	TagAssignmentConfigService_DeleteSome_FullMethodName       = "/arista.tag.v2.TagAssignmentConfigService/DeleteSome"
	TagAssignmentConfigService_DeleteAll_FullMethodName        = "/arista.tag.v2.TagAssignmentConfigService/DeleteAll"
	TagAssignmentConfigService_GetAllBatched_FullMethodName    = "/arista.tag.v2.TagAssignmentConfigService/GetAllBatched"
	TagAssignmentConfigService_SubscribeBatched_FullMethodName = "/arista.tag.v2.TagAssignmentConfigService/SubscribeBatched"
)
View Source 
const (
	TagConfigService_GetOne_FullMethodName           = "/arista.tag.v2.TagConfigService/GetOne"
	TagConfigService_GetSome_FullMethodName          = "/arista.tag.v2.TagConfigService/GetSome"
	TagConfigService_GetAll_FullMethodName           = "/arista.tag.v2.TagConfigService/GetAll"
	TagConfigService_Subscribe_FullMethodName        = "/arista.tag.v2.TagConfigService/Subscribe"
	TagConfigService_GetMeta_FullMethodName          = "/arista.tag.v2.TagConfigService/GetMeta"
	TagConfigService_SubscribeMeta_FullMethodName    = "/arista.tag.v2.TagConfigService/SubscribeMeta"
	TagConfigService_Set_FullMethodName              = "/arista.tag.v2.TagConfigService/Set"
	TagConfigService_SetSome_FullMethodName          = "/arista.tag.v2.TagConfigService/SetSome"
	TagConfigService_Delete_FullMethodName           = "/arista.tag.v2.TagConfigService/Delete"
	TagConfigService_DeleteSome_FullMethodName       = "/arista.tag.v2.TagConfigService/DeleteSome"
	TagConfigService_DeleteAll_FullMethodName        = "/arista.tag.v2.TagConfigService/DeleteAll"
	TagConfigService_GetAllBatched_FullMethodName    = "/arista.tag.v2.TagConfigService/GetAllBatched"
	TagConfigService_SubscribeBatched_FullMethodName = "/arista.tag.v2.TagConfigService/SubscribeBatched"
)

Variables

View Source 
var (
	ElementType_name = map[int32]string{
		0: "ELEMENT_TYPE_UNSPECIFIED",
		1: "ELEMENT_TYPE_DEVICE",
		2: "ELEMENT_TYPE_INTERFACE",
	}
	ElementType_value = map[string]int32{
		"ELEMENT_TYPE_UNSPECIFIED": 0,
		"ELEMENT_TYPE_DEVICE":      1,
		"ELEMENT_TYPE_INTERFACE":   2,
	}
)

Enum value maps for ElementType.

View Source 
var (
	ElementSubType_name = map[int32]string{
		0: "ELEMENT_SUB_TYPE_UNSPECIFIED",
		1: "ELEMENT_SUB_TYPE_DEVICE",
		2: "ELEMENT_SUB_TYPE_VDS",
		3: "ELEMENT_SUB_TYPE_WORKLOAD_SERVER",
		4: "ELEMENT_SUB_TYPE_VM",
	}
	ElementSubType_value = map[string]int32{
		"ELEMENT_SUB_TYPE_UNSPECIFIED":     0,
		"ELEMENT_SUB_TYPE_DEVICE":          1,
		"ELEMENT_SUB_TYPE_VDS":             2,
		"ELEMENT_SUB_TYPE_WORKLOAD_SERVER": 3,
		"ELEMENT_SUB_TYPE_VM":              4,
	}
)

Enum value maps for ElementSubType.

View Source 
var (
	CreatorType_name = map[int32]string{
		0: "CREATOR_TYPE_UNSPECIFIED",
		1: "CREATOR_TYPE_SYSTEM",
		2: "CREATOR_TYPE_USER",
		3: "CREATOR_TYPE_EXTERNAL",
	}
	CreatorType_value = map[string]int32{
		"CREATOR_TYPE_UNSPECIFIED": 0,
		"CREATOR_TYPE_SYSTEM":      1,
		"CREATOR_TYPE_USER":        2,
		"CREATOR_TYPE_EXTERNAL":    3,
	}
)

Enum value maps for CreatorType.

View Source 
var File_arista_tag_v2_services_gen_proto protoreflect.FileDescriptor
View Source 
var File_arista_tag_v2_tag_proto protoreflect.FileDescriptor
View Source 
var TagAssignmentConfigService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arista.tag.v2.TagAssignmentConfigService",
	HandlerType: (*TagAssignmentConfigServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOne",
			Handler:    _TagAssignmentConfigService_GetOne_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _TagAssignmentConfigService_GetMeta_Handler,
		},
		{
			MethodName: "Set",
			Handler:    _TagAssignmentConfigService_Set_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _TagAssignmentConfigService_Delete_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSome",
			Handler:       _TagAssignmentConfigService_GetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAll",
			Handler:       _TagAssignmentConfigService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _TagAssignmentConfigService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMeta",
			Handler:       _TagAssignmentConfigService_SubscribeMeta_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SetSome",
			Handler:       _TagAssignmentConfigService_SetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeleteSome",
			Handler:       _TagAssignmentConfigService_DeleteSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeleteAll",
			Handler:       _TagAssignmentConfigService_DeleteAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAllBatched",
			Handler:       _TagAssignmentConfigService_GetAllBatched_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeBatched",
			Handler:       _TagAssignmentConfigService_SubscribeBatched_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arista/tag.v2/services.gen.proto",
}

TagAssignmentConfigService_ServiceDesc is the grpc.ServiceDesc for TagAssignmentConfigService 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 TagAssignmentService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arista.tag.v2.TagAssignmentService",
	HandlerType: (*TagAssignmentServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOne",
			Handler:    _TagAssignmentService_GetOne_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _TagAssignmentService_GetMeta_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSome",
			Handler:       _TagAssignmentService_GetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAll",
			Handler:       _TagAssignmentService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _TagAssignmentService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMeta",
			Handler:       _TagAssignmentService_SubscribeMeta_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAllBatched",
			Handler:       _TagAssignmentService_GetAllBatched_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeBatched",
			Handler:       _TagAssignmentService_SubscribeBatched_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arista/tag.v2/services.gen.proto",
}

TagAssignmentService_ServiceDesc is the grpc.ServiceDesc for TagAssignmentService 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 TagConfigService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arista.tag.v2.TagConfigService",
	HandlerType: (*TagConfigServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOne",
			Handler:    _TagConfigService_GetOne_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _TagConfigService_GetMeta_Handler,
		},
		{
			MethodName: "Set",
			Handler:    _TagConfigService_Set_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _TagConfigService_Delete_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSome",
			Handler:       _TagConfigService_GetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAll",
			Handler:       _TagConfigService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _TagConfigService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMeta",
			Handler:       _TagConfigService_SubscribeMeta_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SetSome",
			Handler:       _TagConfigService_SetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeleteSome",
			Handler:       _TagConfigService_DeleteSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeleteAll",
			Handler:       _TagConfigService_DeleteAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAllBatched",
			Handler:       _TagConfigService_GetAllBatched_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeBatched",
			Handler:       _TagConfigService_SubscribeBatched_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arista/tag.v2/services.gen.proto",
}

TagConfigService_ServiceDesc is the grpc.ServiceDesc for TagConfigService 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 TagService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arista.tag.v2.TagService",
	HandlerType: (*TagServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOne",
			Handler:    _TagService_GetOne_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _TagService_GetMeta_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSome",
			Handler:       _TagService_GetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAll",
			Handler:       _TagService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _TagService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMeta",
			Handler:       _TagService_SubscribeMeta_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAllBatched",
			Handler:       _TagService_GetAllBatched_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeBatched",
			Handler:       _TagService_SubscribeBatched_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arista/tag.v2/services.gen.proto",
}

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

Functions

func RegisterTagAssignmentConfigServiceServer 

func RegisterTagAssignmentConfigServiceServer(s grpc.ServiceRegistrar, srv TagAssignmentConfigServiceServer)

func RegisterTagAssignmentServiceServer 

func RegisterTagAssignmentServiceServer(s grpc.ServiceRegistrar, srv TagAssignmentServiceServer)

func RegisterTagConfigServiceServer 

func RegisterTagConfigServiceServer(s grpc.ServiceRegistrar, srv TagConfigServiceServer)

func RegisterTagServiceServer 

func RegisterTagServiceServer(s grpc.ServiceRegistrar, srv TagServiceServer)

Types

type CreatorType 

type CreatorType int32

CreatorType enumerates the types of entities that can create a tag. 

const (
	// CREATOR_TYPE_UNSPECIFIED is the default value.
	CreatorType_CREATOR_TYPE_UNSPECIFIED CreatorType = 0
	// CREATOR_TYPE_SYSTEM is used for system tags.
	CreatorType_CREATOR_TYPE_SYSTEM CreatorType = 1
	// CREATOR_TYPE_USER is used for user tags.
	CreatorType_CREATOR_TYPE_USER CreatorType = 2
	// CREATOR_TYPE_EXTERNAL is used for tags created from external sources.
	// For E.g., vCenter
	CreatorType_CREATOR_TYPE_EXTERNAL CreatorType = 3
)

func (CreatorType) Descriptor 

func (CreatorType) Descriptor() protoreflect.EnumDescriptor

func (CreatorType) Enum 

func (x CreatorType) Enum() *CreatorType

func (CreatorType) EnumDescriptor deprecated 

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

Deprecated: Use CreatorType.Descriptor instead.

func (CreatorType) Number 

func (x CreatorType) Number() protoreflect.EnumNumber

func (CreatorType) String 

func (x CreatorType) String() string

func (CreatorType) Type 

func (CreatorType) Type() protoreflect.EnumType

type ElementSubType 

type ElementSubType int32

ElementSubType enumerates the sub-types of network elements that can be associated with tags. 

const (
	// ELEMENT_SUB_TYPE_UNSPECIFIED is the default value.
	ElementSubType_ELEMENT_SUB_TYPE_UNSPECIFIED ElementSubType = 0
	// ELEMENT_SUB_TYPE_DEVICE is used for EOS or
	// third-party devices discovered via LLDP/SNMP.
	ElementSubType_ELEMENT_SUB_TYPE_DEVICE ElementSubType = 1
	// ELEMENT_SUB_TYPE_VDS is used for VMWare vSphere Distributed Switch (VDS) tags.
	ElementSubType_ELEMENT_SUB_TYPE_VDS ElementSubType = 2
	// ELEMENT_SUB_TYPE_WORKLOAD_SERVER is used for workload server
	// tags (such as VMWare ESXi host).
	// A workload server is a server/data storage device on which
	// the hypervisor is installed.
	ElementSubType_ELEMENT_SUB_TYPE_WORKLOAD_SERVER ElementSubType = 3
	// ELEMENT_SUB_TYPE_VM is used for VM tags.
	// A VM is a software computer that, like a physical computer,
	// runs an operating system and applications.
	ElementSubType_ELEMENT_SUB_TYPE_VM ElementSubType = 4
)

func (ElementSubType) Descriptor 

func (ElementSubType) Descriptor() protoreflect.EnumDescriptor

func (ElementSubType) Enum 

func (x ElementSubType) Enum() *ElementSubType

func (ElementSubType) EnumDescriptor deprecated 

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

Deprecated: Use ElementSubType.Descriptor instead.

func (ElementSubType) Number 

func (x ElementSubType) Number() protoreflect.EnumNumber

func (ElementSubType) String 

func (x ElementSubType) String() string

func (ElementSubType) Type 

func (ElementSubType) Type() protoreflect.EnumType

type ElementType 

type ElementType int32

ElementType enumerates the types of network elements that can be associated with tags. 

const (
	// ELEMENT_TYPE_UNSPECIFIED is the default value.
	ElementType_ELEMENT_TYPE_UNSPECIFIED ElementType = 0
	// ELEMENT_TYPE_DEVICE is used for device tags.
	ElementType_ELEMENT_TYPE_DEVICE ElementType = 1
	// ELEMENT_TYPE_INTERFACE is used for interface tags.
	ElementType_ELEMENT_TYPE_INTERFACE ElementType = 2
)

func (ElementType) Descriptor 

func (ElementType) Descriptor() protoreflect.EnumDescriptor

func (ElementType) Enum 

func (x ElementType) Enum() *ElementType

func (ElementType) EnumDescriptor deprecated 

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

Deprecated: Use ElementType.Descriptor instead.

func (ElementType) Number 

func (x ElementType) Number() protoreflect.EnumNumber

func (ElementType) String 

func (x ElementType) String() string

func (ElementType) Type 

func (ElementType) Type() protoreflect.EnumType

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 Tag 

type Tag struct {

	// key identifies a tag.
	Key *TagKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// creator_type is the creator type of the tag.
	CreatorType CreatorType `` /* 126-byte string literal not displayed */
	// assigned indicates whether the tag is assigned
	// (true) or not (false).
	Assigned *wrapperspb.BoolValue `protobuf:"bytes,3,opt,name=assigned,proto3" json:"assigned,omitempty"`
	// contains filtered or unexported fields
}

Tag holds a merge-preview or the existing merged state (if the workspace ID is "") of a tag.

func (*Tag) Descriptor deprecated 

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

Deprecated: Use Tag.ProtoReflect.Descriptor instead.

func (*Tag) GetAssigned 

func (x *Tag) GetAssigned() *wrapperspb.BoolValue

func (*Tag) GetCreatorType 

func (x *Tag) GetCreatorType() CreatorType

func (*Tag) GetKey 

func (x *Tag) GetKey() *TagKey

func (*Tag) ProtoMessage 

func (*Tag) ProtoMessage()

func (*Tag) ProtoReflect 

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

func (*Tag) Reset 

func (x *Tag) Reset()

func (*Tag) String 

func (x *Tag) String() string

type TagAssignment 

type TagAssignment struct {

	// key identifies an assignment.
	Key *TagAssignmentKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// tag_creator_type is the creator type of the tag
	// involved in the assignment.
	TagCreatorType CreatorType `` /* 137-byte string literal not displayed */
	// contains filtered or unexported fields
}

TagAssignment holds a merge-preview or the existing merged state (if the workspace ID is "") of an assignment between a tag and a network element.

func (*TagAssignment) Descriptor deprecated 

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

Deprecated: Use TagAssignment.ProtoReflect.Descriptor instead.

func (*TagAssignment) GetKey 

func (x *TagAssignment) GetKey() *TagAssignmentKey

func (*TagAssignment) GetTagCreatorType 

func (x *TagAssignment) GetTagCreatorType() CreatorType

func (*TagAssignment) ProtoMessage 

func (*TagAssignment) ProtoMessage()

func (*TagAssignment) ProtoReflect 

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

func (*TagAssignment) Reset 

func (x *TagAssignment) Reset()

func (*TagAssignment) String 

func (x *TagAssignment) String() string

type TagAssignmentBatchedStreamRequest 

type TagAssignmentBatchedStreamRequest 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 []*TagAssignment `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 TagAssignment at end.
	//   - Each TagAssignment response is fully-specified (all fields set).
	//   - start: Returns the state of each TagAssignment at start, followed by updates until now.
	//   - Each TagAssignment response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each TagAssignment at start, followed by updates
	//     until end.
	//   - Each TagAssignment 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 (*TagAssignmentBatchedStreamRequest) Descriptor deprecated 

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

Deprecated: Use TagAssignmentBatchedStreamRequest.ProtoReflect.Descriptor instead.

func (*TagAssignmentBatchedStreamRequest) GetMaxMessages 

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

func (*TagAssignmentBatchedStreamRequest) GetPartialEqFilter 

func (x *TagAssignmentBatchedStreamRequest) GetPartialEqFilter() []*TagAssignment

func (*TagAssignmentBatchedStreamRequest) GetTime 

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

func (*TagAssignmentBatchedStreamRequest) ProtoMessage 

func (*TagAssignmentBatchedStreamRequest) ProtoMessage()

func (*TagAssignmentBatchedStreamRequest) ProtoReflect 

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

func (*TagAssignmentBatchedStreamRequest) Reset 

func (x *TagAssignmentBatchedStreamRequest) Reset()

func (*TagAssignmentBatchedStreamRequest) String 

func (x *TagAssignmentBatchedStreamRequest) String() string

type TagAssignmentBatchedStreamResponse 

type TagAssignmentBatchedStreamResponse 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 []*TagAssignmentStreamResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*TagAssignmentBatchedStreamResponse) Descriptor deprecated 

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

Deprecated: Use TagAssignmentBatchedStreamResponse.ProtoReflect.Descriptor instead.

func (*TagAssignmentBatchedStreamResponse) GetResponses 

func (x *TagAssignmentBatchedStreamResponse) GetResponses() []*TagAssignmentStreamResponse

func (*TagAssignmentBatchedStreamResponse) ProtoMessage 

func (*TagAssignmentBatchedStreamResponse) ProtoMessage()

func (*TagAssignmentBatchedStreamResponse) ProtoReflect 

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

func (*TagAssignmentBatchedStreamResponse) Reset 

func (x *TagAssignmentBatchedStreamResponse) Reset()

func (*TagAssignmentBatchedStreamResponse) String 

func (x *TagAssignmentBatchedStreamResponse) String() string

type TagAssignmentConfig 

type TagAssignmentConfig struct {

	// key identifies an assignment. The special workspace ID ""
	// for merged assignments should not be set here.
	Key *TagAssignmentKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// remove indicates whether to remove (true) or add (false,
	// unset) the assignment identified by the key if the
	// encompassing workspace merges.
	Remove *wrapperspb.BoolValue `protobuf:"bytes,2,opt,name=remove,proto3" json:"remove,omitempty"`
	// contains filtered or unexported fields
}

TagAssignmentConfig holds a configuration for an assignment between a tag and a network element. The tag assignments that belong to entities other than ELEMENT_SUB_TYPE_DEVICE will always be present in mainline only.

func (*TagAssignmentConfig) Descriptor deprecated 

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

Deprecated: Use TagAssignmentConfig.ProtoReflect.Descriptor instead.

func (*TagAssignmentConfig) GetKey 

func (x *TagAssignmentConfig) GetKey() *TagAssignmentKey

func (*TagAssignmentConfig) GetRemove 

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

func (*TagAssignmentConfig) ProtoMessage 

func (*TagAssignmentConfig) ProtoMessage()

func (*TagAssignmentConfig) ProtoReflect 

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

func (*TagAssignmentConfig) Reset 

func (x *TagAssignmentConfig) Reset()

func (*TagAssignmentConfig) String 

func (x *TagAssignmentConfig) String() string

type TagAssignmentConfigBatchedStreamRequest 

type TagAssignmentConfigBatchedStreamRequest 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 []*TagAssignmentConfig `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 TagAssignmentConfig at end.
	//   - Each TagAssignmentConfig response is fully-specified (all fields set).
	//   - start: Returns the state of each TagAssignmentConfig at start, followed by updates until now.
	//   - Each TagAssignmentConfig response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each TagAssignmentConfig at start, followed by updates
	//     until end.
	//   - Each TagAssignmentConfig 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 (*TagAssignmentConfigBatchedStreamRequest) Descriptor deprecated 

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

Deprecated: Use TagAssignmentConfigBatchedStreamRequest.ProtoReflect.Descriptor instead.

func (*TagAssignmentConfigBatchedStreamRequest) GetMaxMessages 

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

func (*TagAssignmentConfigBatchedStreamRequest) GetPartialEqFilter 

func (x *TagAssignmentConfigBatchedStreamRequest) GetPartialEqFilter() []*TagAssignmentConfig

func (*TagAssignmentConfigBatchedStreamRequest) GetTime 

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

func (*TagAssignmentConfigBatchedStreamRequest) ProtoMessage 

func (*TagAssignmentConfigBatchedStreamRequest) ProtoMessage()

func (*TagAssignmentConfigBatchedStreamRequest) ProtoReflect 

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

func (*TagAssignmentConfigBatchedStreamRequest) Reset 

func (x *TagAssignmentConfigBatchedStreamRequest) Reset()

func (*TagAssignmentConfigBatchedStreamRequest) String 

func (x *TagAssignmentConfigBatchedStreamRequest) String() string

type TagAssignmentConfigBatchedStreamResponse 

type TagAssignmentConfigBatchedStreamResponse 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 []*TagAssignmentConfigStreamResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*TagAssignmentConfigBatchedStreamResponse) Descriptor deprecated 

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

Deprecated: Use TagAssignmentConfigBatchedStreamResponse.ProtoReflect.Descriptor instead.

func (*TagAssignmentConfigBatchedStreamResponse) GetResponses 

func (x *TagAssignmentConfigBatchedStreamResponse) GetResponses() []*TagAssignmentConfigStreamResponse

func (*TagAssignmentConfigBatchedStreamResponse) ProtoMessage 

func (*TagAssignmentConfigBatchedStreamResponse) ProtoMessage()

func (*TagAssignmentConfigBatchedStreamResponse) ProtoReflect 

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

func (*TagAssignmentConfigBatchedStreamResponse) Reset 

func (x *TagAssignmentConfigBatchedStreamResponse) Reset()

func (*TagAssignmentConfigBatchedStreamResponse) String 

func (x *TagAssignmentConfigBatchedStreamResponse) String() string

type TagAssignmentConfigDeleteAllRequest 

type TagAssignmentConfigDeleteAllRequest 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 []*TagAssignmentConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*TagAssignmentConfigDeleteAllRequest) Descriptor deprecated 

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

Deprecated: Use TagAssignmentConfigDeleteAllRequest.ProtoReflect.Descriptor instead.

func (*TagAssignmentConfigDeleteAllRequest) GetPartialEqFilter 

func (x *TagAssignmentConfigDeleteAllRequest) GetPartialEqFilter() []*TagAssignmentConfig

func (*TagAssignmentConfigDeleteAllRequest) ProtoMessage 

func (*TagAssignmentConfigDeleteAllRequest) ProtoMessage()

func (*TagAssignmentConfigDeleteAllRequest) ProtoReflect 

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

func (*TagAssignmentConfigDeleteAllRequest) Reset 

func (x *TagAssignmentConfigDeleteAllRequest) Reset()

func (*TagAssignmentConfigDeleteAllRequest) String 

func (x *TagAssignmentConfigDeleteAllRequest) String() string

type TagAssignmentConfigDeleteAllResponse 

type TagAssignmentConfigDeleteAllResponse 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 TagAssignmentConfig instance that failed to be deleted.
	Key *TagAssignmentKey `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 (*TagAssignmentConfigDeleteAllResponse) Descriptor deprecated 

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

Deprecated: Use TagAssignmentConfigDeleteAllResponse.ProtoReflect.Descriptor instead.

func (*TagAssignmentConfigDeleteAllResponse) GetError 

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

func (*TagAssignmentConfigDeleteAllResponse) GetKey 

func (x *TagAssignmentConfigDeleteAllResponse) GetKey() *TagAssignmentKey

func (*TagAssignmentConfigDeleteAllResponse) GetTime 

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

func (*TagAssignmentConfigDeleteAllResponse) GetType 

func (x *TagAssignmentConfigDeleteAllResponse) GetType() fmp.DeleteError

func (*TagAssignmentConfigDeleteAllResponse) ProtoMessage 

func (*TagAssignmentConfigDeleteAllResponse) ProtoMessage()

func (*TagAssignmentConfigDeleteAllResponse) ProtoReflect 

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

func (*TagAssignmentConfigDeleteAllResponse) Reset 

func (x *TagAssignmentConfigDeleteAllResponse) Reset()

func (*TagAssignmentConfigDeleteAllResponse) String 

func (x *TagAssignmentConfigDeleteAllResponse) String() string

type TagAssignmentConfigDeleteRequest 

type TagAssignmentConfigDeleteRequest struct {

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

func (*TagAssignmentConfigDeleteRequest) Descriptor deprecated 

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

Deprecated: Use TagAssignmentConfigDeleteRequest.ProtoReflect.Descriptor instead.

func (*TagAssignmentConfigDeleteRequest) GetKey 

func (x *TagAssignmentConfigDeleteRequest) GetKey() *TagAssignmentKey

func (*TagAssignmentConfigDeleteRequest) ProtoMessage 

func (*TagAssignmentConfigDeleteRequest) ProtoMessage()

func (*TagAssignmentConfigDeleteRequest) ProtoReflect 

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

func (*TagAssignmentConfigDeleteRequest) Reset 

func (x *TagAssignmentConfigDeleteRequest) Reset()

func (*TagAssignmentConfigDeleteRequest) String 

func (x *TagAssignmentConfigDeleteRequest) String() string

type TagAssignmentConfigDeleteResponse 

type TagAssignmentConfigDeleteResponse struct {

	// Key echoes back the key of the deleted TagAssignmentConfig instance.
	Key *TagAssignmentKey `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 (*TagAssignmentConfigDeleteResponse) Descriptor deprecated 

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

Deprecated: Use TagAssignmentConfigDeleteResponse.ProtoReflect.Descriptor instead.

func (*TagAssignmentConfigDeleteResponse) GetKey 

func (x *TagAssignmentConfigDeleteResponse) GetKey() *TagAssignmentKey

func (*TagAssignmentConfigDeleteResponse) GetTime 

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

func (*TagAssignmentConfigDeleteResponse) ProtoMessage 

func (*TagAssignmentConfigDeleteResponse) ProtoMessage()

func (*TagAssignmentConfigDeleteResponse) ProtoReflect 

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

func (*TagAssignmentConfigDeleteResponse) Reset 

func (x *TagAssignmentConfigDeleteResponse) Reset()

func (*TagAssignmentConfigDeleteResponse) String 

func (x *TagAssignmentConfigDeleteResponse) String() string

type TagAssignmentConfigDeleteSomeRequest 

type TagAssignmentConfigDeleteSomeRequest struct {

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

func (*TagAssignmentConfigDeleteSomeRequest) Descriptor deprecated 

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

Deprecated: Use TagAssignmentConfigDeleteSomeRequest.ProtoReflect.Descriptor instead.

func (*TagAssignmentConfigDeleteSomeRequest) GetKeys 

func (x *TagAssignmentConfigDeleteSomeRequest) GetKeys() []*TagAssignmentKey

func (*TagAssignmentConfigDeleteSomeRequest) ProtoMessage 

func (*TagAssignmentConfigDeleteSomeRequest) ProtoMessage()

func (*TagAssignmentConfigDeleteSomeRequest) ProtoReflect 

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

func (*TagAssignmentConfigDeleteSomeRequest) Reset 

func (x *TagAssignmentConfigDeleteSomeRequest) Reset()

func (*TagAssignmentConfigDeleteSomeRequest) String 

func (x *TagAssignmentConfigDeleteSomeRequest) String() string

type TagAssignmentConfigDeleteSomeResponse 

type TagAssignmentConfigDeleteSomeResponse struct {
	Key   *TagAssignmentKey `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
}

TagAssignmentConfigDeleteSomeResponse is only sent when there is an error.

func (*TagAssignmentConfigDeleteSomeResponse) Descriptor deprecated 

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

Deprecated: Use TagAssignmentConfigDeleteSomeResponse.ProtoReflect.Descriptor instead.

func (*TagAssignmentConfigDeleteSomeResponse) GetError 

func (x *TagAssignmentConfigDeleteSomeResponse) GetError() string

func (*TagAssignmentConfigDeleteSomeResponse) GetKey 

func (x *TagAssignmentConfigDeleteSomeResponse) GetKey() *TagAssignmentKey

func (*TagAssignmentConfigDeleteSomeResponse) ProtoMessage 

func (*TagAssignmentConfigDeleteSomeResponse) ProtoMessage()

func (*TagAssignmentConfigDeleteSomeResponse) ProtoReflect 

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

func (*TagAssignmentConfigDeleteSomeResponse) Reset 

func (x *TagAssignmentConfigDeleteSomeResponse) Reset()

func (*TagAssignmentConfigDeleteSomeResponse) String 

func (x *TagAssignmentConfigDeleteSomeResponse) String() string

type TagAssignmentConfigRequest 

type TagAssignmentConfigRequest struct {

	// Key uniquely identifies a TagAssignmentConfig instance to retrieve.
	// This value must be populated.
	Key *TagAssignmentKey `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 (*TagAssignmentConfigRequest) Descriptor deprecated 

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

Deprecated: Use TagAssignmentConfigRequest.ProtoReflect.Descriptor instead.

func (*TagAssignmentConfigRequest) GetKey 

func (x *TagAssignmentConfigRequest) GetKey() *TagAssignmentKey

func (*TagAssignmentConfigRequest) GetTime 

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

func (*TagAssignmentConfigRequest) ProtoMessage 

func (*TagAssignmentConfigRequest) ProtoMessage()

func (*TagAssignmentConfigRequest) ProtoReflect 

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

func (*TagAssignmentConfigRequest) Reset 

func (x *TagAssignmentConfigRequest) Reset()

func (*TagAssignmentConfigRequest) String 

func (x *TagAssignmentConfigRequest) String() string

type TagAssignmentConfigResponse 

type TagAssignmentConfigResponse 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 *TagAssignmentConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time carries the (UTC) timestamp of the last-modification of the
	// TagAssignmentConfig instance in this response.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*TagAssignmentConfigResponse) Descriptor deprecated 

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

Deprecated: Use TagAssignmentConfigResponse.ProtoReflect.Descriptor instead.

func (*TagAssignmentConfigResponse) GetTime 

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

func (*TagAssignmentConfigResponse) GetValue 

func (x *TagAssignmentConfigResponse) GetValue() *TagAssignmentConfig

func (*TagAssignmentConfigResponse) ProtoMessage 

func (*TagAssignmentConfigResponse) ProtoMessage()

func (*TagAssignmentConfigResponse) ProtoReflect 

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

func (*TagAssignmentConfigResponse) Reset 

func (x *TagAssignmentConfigResponse) Reset()

func (*TagAssignmentConfigResponse) String 

func (x *TagAssignmentConfigResponse) String() string

type TagAssignmentConfigServiceClient 

type TagAssignmentConfigServiceClient interface {
	GetOne(ctx context.Context, in *TagAssignmentConfigRequest, opts ...grpc.CallOption) (*TagAssignmentConfigResponse, error)
	GetSome(ctx context.Context, in *TagAssignmentConfigSomeRequest, opts ...grpc.CallOption) (TagAssignmentConfigService_GetSomeClient, error)
	GetAll(ctx context.Context, in *TagAssignmentConfigStreamRequest, opts ...grpc.CallOption) (TagAssignmentConfigService_GetAllClient, error)
	Subscribe(ctx context.Context, in *TagAssignmentConfigStreamRequest, opts ...grpc.CallOption) (TagAssignmentConfigService_SubscribeClient, error)
	GetMeta(ctx context.Context, in *TagAssignmentConfigStreamRequest, opts ...grpc.CallOption) (*MetaResponse, error)
	SubscribeMeta(ctx context.Context, in *TagAssignmentConfigStreamRequest, opts ...grpc.CallOption) (TagAssignmentConfigService_SubscribeMetaClient, error)
	Set(ctx context.Context, in *TagAssignmentConfigSetRequest, opts ...grpc.CallOption) (*TagAssignmentConfigSetResponse, error)
	SetSome(ctx context.Context, in *TagAssignmentConfigSetSomeRequest, opts ...grpc.CallOption) (TagAssignmentConfigService_SetSomeClient, error)
	Delete(ctx context.Context, in *TagAssignmentConfigDeleteRequest, opts ...grpc.CallOption) (*TagAssignmentConfigDeleteResponse, error)
	DeleteSome(ctx context.Context, in *TagAssignmentConfigDeleteSomeRequest, opts ...grpc.CallOption) (TagAssignmentConfigService_DeleteSomeClient, error)
	DeleteAll(ctx context.Context, in *TagAssignmentConfigDeleteAllRequest, opts ...grpc.CallOption) (TagAssignmentConfigService_DeleteAllClient, error)
	GetAllBatched(ctx context.Context, in *TagAssignmentConfigBatchedStreamRequest, opts ...grpc.CallOption) (TagAssignmentConfigService_GetAllBatchedClient, error)
	SubscribeBatched(ctx context.Context, in *TagAssignmentConfigBatchedStreamRequest, opts ...grpc.CallOption) (TagAssignmentConfigService_SubscribeBatchedClient, error)
}

TagAssignmentConfigServiceClient is the client API for TagAssignmentConfigService 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.

func NewTagAssignmentConfigServiceClient 

func NewTagAssignmentConfigServiceClient(cc grpc.ClientConnInterface) TagAssignmentConfigServiceClient

type TagAssignmentConfigServiceServer 

type TagAssignmentConfigServiceServer interface {
	GetOne(context.Context, *TagAssignmentConfigRequest) (*TagAssignmentConfigResponse, error)
	GetSome(*TagAssignmentConfigSomeRequest, TagAssignmentConfigService_GetSomeServer) error
	GetAll(*TagAssignmentConfigStreamRequest, TagAssignmentConfigService_GetAllServer) error
	Subscribe(*TagAssignmentConfigStreamRequest, TagAssignmentConfigService_SubscribeServer) error
	GetMeta(context.Context, *TagAssignmentConfigStreamRequest) (*MetaResponse, error)
	SubscribeMeta(*TagAssignmentConfigStreamRequest, TagAssignmentConfigService_SubscribeMetaServer) error
	Set(context.Context, *TagAssignmentConfigSetRequest) (*TagAssignmentConfigSetResponse, error)
	SetSome(*TagAssignmentConfigSetSomeRequest, TagAssignmentConfigService_SetSomeServer) error
	Delete(context.Context, *TagAssignmentConfigDeleteRequest) (*TagAssignmentConfigDeleteResponse, error)
	DeleteSome(*TagAssignmentConfigDeleteSomeRequest, TagAssignmentConfigService_DeleteSomeServer) error
	DeleteAll(*TagAssignmentConfigDeleteAllRequest, TagAssignmentConfigService_DeleteAllServer) error
	GetAllBatched(*TagAssignmentConfigBatchedStreamRequest, TagAssignmentConfigService_GetAllBatchedServer) error
	SubscribeBatched(*TagAssignmentConfigBatchedStreamRequest, TagAssignmentConfigService_SubscribeBatchedServer) error
	// contains filtered or unexported methods
}

TagAssignmentConfigServiceServer is the server API for TagAssignmentConfigService service. All implementations must embed UnimplementedTagAssignmentConfigServiceServer for forward compatibility

type TagAssignmentConfigService_DeleteAllClient 

type TagAssignmentConfigService_DeleteAllClient interface {
	Recv() (*TagAssignmentConfigDeleteAllResponse, error)
	grpc.ClientStream
}

type TagAssignmentConfigService_DeleteAllServer 

type TagAssignmentConfigService_DeleteAllServer interface {
	Send(*TagAssignmentConfigDeleteAllResponse) error
	grpc.ServerStream
}

type TagAssignmentConfigService_DeleteSomeClient 

type TagAssignmentConfigService_DeleteSomeClient interface {
	Recv() (*TagAssignmentConfigDeleteSomeResponse, error)
	grpc.ClientStream
}

type TagAssignmentConfigService_DeleteSomeServer 

type TagAssignmentConfigService_DeleteSomeServer interface {
	Send(*TagAssignmentConfigDeleteSomeResponse) error
	grpc.ServerStream
}

type TagAssignmentConfigService_GetAllBatchedClient 

type TagAssignmentConfigService_GetAllBatchedClient interface {
	Recv() (*TagAssignmentConfigBatchedStreamResponse, error)
	grpc.ClientStream
}

type TagAssignmentConfigService_GetAllBatchedServer 

type TagAssignmentConfigService_GetAllBatchedServer interface {
	Send(*TagAssignmentConfigBatchedStreamResponse) error
	grpc.ServerStream
}

type TagAssignmentConfigService_GetAllClient 

type TagAssignmentConfigService_GetAllClient interface {
	Recv() (*TagAssignmentConfigStreamResponse, error)
	grpc.ClientStream
}

type TagAssignmentConfigService_GetAllServer 

type TagAssignmentConfigService_GetAllServer interface {
	Send(*TagAssignmentConfigStreamResponse) error
	grpc.ServerStream
}

type TagAssignmentConfigService_GetSomeClient 

type TagAssignmentConfigService_GetSomeClient interface {
	Recv() (*TagAssignmentConfigSomeResponse, error)
	grpc.ClientStream
}

type TagAssignmentConfigService_GetSomeServer 

type TagAssignmentConfigService_GetSomeServer interface {
	Send(*TagAssignmentConfigSomeResponse) error
	grpc.ServerStream
}

type TagAssignmentConfigService_SetSomeClient 

type TagAssignmentConfigService_SetSomeClient interface {
	Recv() (*TagAssignmentConfigSetSomeResponse, error)
	grpc.ClientStream
}

type TagAssignmentConfigService_SetSomeServer 

type TagAssignmentConfigService_SetSomeServer interface {
	Send(*TagAssignmentConfigSetSomeResponse) error
	grpc.ServerStream
}

type TagAssignmentConfigService_SubscribeBatchedClient 

type TagAssignmentConfigService_SubscribeBatchedClient interface {
	Recv() (*TagAssignmentConfigBatchedStreamResponse, error)
	grpc.ClientStream
}

type TagAssignmentConfigService_SubscribeBatchedServer 

type TagAssignmentConfigService_SubscribeBatchedServer interface {
	Send(*TagAssignmentConfigBatchedStreamResponse) error
	grpc.ServerStream
}

type TagAssignmentConfigService_SubscribeClient 

type TagAssignmentConfigService_SubscribeClient interface {
	Recv() (*TagAssignmentConfigStreamResponse, error)
	grpc.ClientStream
}

type TagAssignmentConfigService_SubscribeMetaClient 

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

type TagAssignmentConfigService_SubscribeMetaServer 

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

type TagAssignmentConfigService_SubscribeServer 

type TagAssignmentConfigService_SubscribeServer interface {
	Send(*TagAssignmentConfigStreamResponse) error
	grpc.ServerStream
}

type TagAssignmentConfigSetRequest 

type TagAssignmentConfigSetRequest struct {

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

func (*TagAssignmentConfigSetRequest) Descriptor deprecated 

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

Deprecated: Use TagAssignmentConfigSetRequest.ProtoReflect.Descriptor instead.

func (*TagAssignmentConfigSetRequest) GetValue 

func (x *TagAssignmentConfigSetRequest) GetValue() *TagAssignmentConfig

func (*TagAssignmentConfigSetRequest) ProtoMessage 

func (*TagAssignmentConfigSetRequest) ProtoMessage()

func (*TagAssignmentConfigSetRequest) ProtoReflect 

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

func (*TagAssignmentConfigSetRequest) Reset 

func (x *TagAssignmentConfigSetRequest) Reset()

func (*TagAssignmentConfigSetRequest) String 

func (x *TagAssignmentConfigSetRequest) String() string

type TagAssignmentConfigSetResponse 

type TagAssignmentConfigSetResponse struct {

	// Value carries all the values given in the TagAssignmentConfigSetRequest as well
	// as any server-generated values.
	Value *TagAssignmentConfig `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 (*TagAssignmentConfigSetResponse) Descriptor deprecated 

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

Deprecated: Use TagAssignmentConfigSetResponse.ProtoReflect.Descriptor instead.

func (*TagAssignmentConfigSetResponse) GetTime 

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

func (*TagAssignmentConfigSetResponse) GetValue 

func (x *TagAssignmentConfigSetResponse) GetValue() *TagAssignmentConfig

func (*TagAssignmentConfigSetResponse) ProtoMessage 

func (*TagAssignmentConfigSetResponse) ProtoMessage()

func (*TagAssignmentConfigSetResponse) ProtoReflect 

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

func (*TagAssignmentConfigSetResponse) Reset 

func (x *TagAssignmentConfigSetResponse) Reset()

func (*TagAssignmentConfigSetResponse) String 

func (x *TagAssignmentConfigSetResponse) String() string

type TagAssignmentConfigSetSomeRequest 

type TagAssignmentConfigSetSomeRequest struct {

	// value contains a list of TagAssignmentConfig 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 []*TagAssignmentConfig `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*TagAssignmentConfigSetSomeRequest) Descriptor deprecated 

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

Deprecated: Use TagAssignmentConfigSetSomeRequest.ProtoReflect.Descriptor instead.

func (*TagAssignmentConfigSetSomeRequest) GetValues 

func (x *TagAssignmentConfigSetSomeRequest) GetValues() []*TagAssignmentConfig

func (*TagAssignmentConfigSetSomeRequest) ProtoMessage 

func (*TagAssignmentConfigSetSomeRequest) ProtoMessage()

func (*TagAssignmentConfigSetSomeRequest) ProtoReflect 

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

func (*TagAssignmentConfigSetSomeRequest) Reset 

func (x *TagAssignmentConfigSetSomeRequest) Reset()

func (*TagAssignmentConfigSetSomeRequest) String 

func (x *TagAssignmentConfigSetSomeRequest) String() string

type TagAssignmentConfigSetSomeResponse 

type TagAssignmentConfigSetSomeResponse struct {
	Key   *TagAssignmentKey `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 (*TagAssignmentConfigSetSomeResponse) Descriptor deprecated 

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

Deprecated: Use TagAssignmentConfigSetSomeResponse.ProtoReflect.Descriptor instead.

func (*TagAssignmentConfigSetSomeResponse) GetError 

func (x *TagAssignmentConfigSetSomeResponse) GetError() string

func (*TagAssignmentConfigSetSomeResponse) GetKey 

func (x *TagAssignmentConfigSetSomeResponse) GetKey() *TagAssignmentKey

func (*TagAssignmentConfigSetSomeResponse) ProtoMessage 

func (*TagAssignmentConfigSetSomeResponse) ProtoMessage()

func (*TagAssignmentConfigSetSomeResponse) ProtoReflect 

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

func (*TagAssignmentConfigSetSomeResponse) Reset 

func (x *TagAssignmentConfigSetSomeResponse) Reset()

func (*TagAssignmentConfigSetSomeResponse) String 

func (x *TagAssignmentConfigSetSomeResponse) String() string

type TagAssignmentConfigSomeRequest 

type TagAssignmentConfigSomeRequest struct {
	Keys []*TagAssignmentKey `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 (*TagAssignmentConfigSomeRequest) Descriptor deprecated 

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

Deprecated: Use TagAssignmentConfigSomeRequest.ProtoReflect.Descriptor instead.

func (*TagAssignmentConfigSomeRequest) GetKeys 

func (x *TagAssignmentConfigSomeRequest) GetKeys() []*TagAssignmentKey

func (*TagAssignmentConfigSomeRequest) GetTime 

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

func (*TagAssignmentConfigSomeRequest) ProtoMessage 

func (*TagAssignmentConfigSomeRequest) ProtoMessage()

func (*TagAssignmentConfigSomeRequest) ProtoReflect 

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

func (*TagAssignmentConfigSomeRequest) Reset 

func (x *TagAssignmentConfigSomeRequest) Reset()

func (*TagAssignmentConfigSomeRequest) String 

func (x *TagAssignmentConfigSomeRequest) String() string

type TagAssignmentConfigSomeResponse 

type TagAssignmentConfigSomeResponse 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 *TagAssignmentConfig `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 (*TagAssignmentConfigSomeResponse) Descriptor deprecated 

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

Deprecated: Use TagAssignmentConfigSomeResponse.ProtoReflect.Descriptor instead.

func (*TagAssignmentConfigSomeResponse) GetError 

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

func (*TagAssignmentConfigSomeResponse) GetTime 

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

func (*TagAssignmentConfigSomeResponse) GetValue 

func (x *TagAssignmentConfigSomeResponse) GetValue() *TagAssignmentConfig

func (*TagAssignmentConfigSomeResponse) ProtoMessage 

func (*TagAssignmentConfigSomeResponse) ProtoMessage()

func (*TagAssignmentConfigSomeResponse) ProtoReflect 

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

func (*TagAssignmentConfigSomeResponse) Reset 

func (x *TagAssignmentConfigSomeResponse) Reset()

func (*TagAssignmentConfigSomeResponse) String 

func (x *TagAssignmentConfigSomeResponse) String() string

type TagAssignmentConfigStreamRequest 

type TagAssignmentConfigStreamRequest 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 []*TagAssignmentConfig `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 TagAssignmentConfig at end.
	//   - Each TagAssignmentConfig response is fully-specified (all fields set).
	//   - start: Returns the state of each TagAssignmentConfig at start, followed by updates until now.
	//   - Each TagAssignmentConfig response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each TagAssignmentConfig at start, followed by updates
	//     until end.
	//   - Each TagAssignmentConfig 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 (*TagAssignmentConfigStreamRequest) Descriptor deprecated 

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

Deprecated: Use TagAssignmentConfigStreamRequest.ProtoReflect.Descriptor instead.

func (*TagAssignmentConfigStreamRequest) GetPartialEqFilter 

func (x *TagAssignmentConfigStreamRequest) GetPartialEqFilter() []*TagAssignmentConfig

func (*TagAssignmentConfigStreamRequest) GetTime 

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

func (*TagAssignmentConfigStreamRequest) ProtoMessage 

func (*TagAssignmentConfigStreamRequest) ProtoMessage()

func (*TagAssignmentConfigStreamRequest) ProtoReflect 

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

func (*TagAssignmentConfigStreamRequest) Reset 

func (x *TagAssignmentConfigStreamRequest) Reset()

func (*TagAssignmentConfigStreamRequest) String 

func (x *TagAssignmentConfigStreamRequest) String() string

type TagAssignmentConfigStreamResponse 

type TagAssignmentConfigStreamResponse 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 *TagAssignmentConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time holds the timestamp of this TagAssignmentConfig's last modification.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// Operation indicates how the TagAssignmentConfig 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 (*TagAssignmentConfigStreamResponse) Descriptor deprecated 

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

Deprecated: Use TagAssignmentConfigStreamResponse.ProtoReflect.Descriptor instead.

func (*TagAssignmentConfigStreamResponse) GetTime 

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

func (*TagAssignmentConfigStreamResponse) GetType 

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

func (*TagAssignmentConfigStreamResponse) GetValue 

func (x *TagAssignmentConfigStreamResponse) GetValue() *TagAssignmentConfig

func (*TagAssignmentConfigStreamResponse) ProtoMessage 

func (*TagAssignmentConfigStreamResponse) ProtoMessage()

func (*TagAssignmentConfigStreamResponse) ProtoReflect 

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

func (*TagAssignmentConfigStreamResponse) Reset 

func (x *TagAssignmentConfigStreamResponse) Reset()

func (*TagAssignmentConfigStreamResponse) String 

func (x *TagAssignmentConfigStreamResponse) String() string

type TagAssignmentKey 

type TagAssignmentKey struct {

	// workspace_id is the ID of a workspace. The special ID ""
	// identifies the location where merged assignments reside.
	WorkspaceId *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	// element_type is the element type of a tag. What should
	// be set per element type:
	//
	// ELEMENT_TYPE_DEVICE: device_id
	// ELEMENT_TYPE_INTERFACE: device_id, interface_id
	ElementType ElementType `` /* 126-byte string literal not displayed */
	// label is the label of a tag.
	Label *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=label,proto3" json:"label,omitempty"`
	// value is the value of a tag.
	Value *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// device_id identifies a device.
	DeviceId *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=device_id,json=deviceId,proto3" json:"device_id,omitempty"`
	// interface_id identifies an interface on a device.
	InterfaceId *wrapperspb.StringValue `protobuf:"bytes,6,opt,name=interface_id,json=interfaceId,proto3" json:"interface_id,omitempty"`
	// element_sub_type is the element sub-type of a tag.
	ElementSubType ElementSubType `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

TagAssignmentKey uniquely identifies an assignment between a tag and a network element.

func (*TagAssignmentKey) Descriptor deprecated 

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

Deprecated: Use TagAssignmentKey.ProtoReflect.Descriptor instead.

func (*TagAssignmentKey) GetDeviceId 

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

func (*TagAssignmentKey) GetElementSubType 

func (x *TagAssignmentKey) GetElementSubType() ElementSubType

func (*TagAssignmentKey) GetElementType 

func (x *TagAssignmentKey) GetElementType() ElementType

func (*TagAssignmentKey) GetInterfaceId 

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

func (*TagAssignmentKey) GetLabel 

func (x *TagAssignmentKey) GetLabel() *wrapperspb.StringValue

func (*TagAssignmentKey) GetValue 

func (x *TagAssignmentKey) GetValue() *wrapperspb.StringValue

func (*TagAssignmentKey) GetWorkspaceId 

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

func (*TagAssignmentKey) ProtoMessage 

func (*TagAssignmentKey) ProtoMessage()

func (*TagAssignmentKey) ProtoReflect 

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

func (*TagAssignmentKey) Reset 

func (x *TagAssignmentKey) Reset()

func (*TagAssignmentKey) String 

func (x *TagAssignmentKey) String() string

type TagAssignmentRequest 

type TagAssignmentRequest struct {

	// Key uniquely identifies a TagAssignment instance to retrieve.
	// This value must be populated.
	Key *TagAssignmentKey `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 (*TagAssignmentRequest) Descriptor deprecated 

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

Deprecated: Use TagAssignmentRequest.ProtoReflect.Descriptor instead.

func (*TagAssignmentRequest) GetKey 

func (x *TagAssignmentRequest) GetKey() *TagAssignmentKey

func (*TagAssignmentRequest) GetTime 

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

func (*TagAssignmentRequest) ProtoMessage 

func (*TagAssignmentRequest) ProtoMessage()

func (*TagAssignmentRequest) ProtoReflect 

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

func (*TagAssignmentRequest) Reset 

func (x *TagAssignmentRequest) Reset()

func (*TagAssignmentRequest) String 

func (x *TagAssignmentRequest) String() string

type TagAssignmentResponse 

type TagAssignmentResponse 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 *TagAssignment `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time carries the (UTC) timestamp of the last-modification of the
	// TagAssignment instance in this response.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*TagAssignmentResponse) Descriptor deprecated 

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

Deprecated: Use TagAssignmentResponse.ProtoReflect.Descriptor instead.

func (*TagAssignmentResponse) GetTime 

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

func (*TagAssignmentResponse) GetValue 

func (x *TagAssignmentResponse) GetValue() *TagAssignment

func (*TagAssignmentResponse) ProtoMessage 

func (*TagAssignmentResponse) ProtoMessage()

func (*TagAssignmentResponse) ProtoReflect 

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

func (*TagAssignmentResponse) Reset 

func (x *TagAssignmentResponse) Reset()

func (*TagAssignmentResponse) String 

func (x *TagAssignmentResponse) String() string

type TagAssignmentServiceClient 

type TagAssignmentServiceClient interface {
	GetOne(ctx context.Context, in *TagAssignmentRequest, opts ...grpc.CallOption) (*TagAssignmentResponse, error)
	GetSome(ctx context.Context, in *TagAssignmentSomeRequest, opts ...grpc.CallOption) (TagAssignmentService_GetSomeClient, error)
	GetAll(ctx context.Context, in *TagAssignmentStreamRequest, opts ...grpc.CallOption) (TagAssignmentService_GetAllClient, error)
	Subscribe(ctx context.Context, in *TagAssignmentStreamRequest, opts ...grpc.CallOption) (TagAssignmentService_SubscribeClient, error)
	GetMeta(ctx context.Context, in *TagAssignmentStreamRequest, opts ...grpc.CallOption) (*MetaResponse, error)
	SubscribeMeta(ctx context.Context, in *TagAssignmentStreamRequest, opts ...grpc.CallOption) (TagAssignmentService_SubscribeMetaClient, error)
	GetAllBatched(ctx context.Context, in *TagAssignmentBatchedStreamRequest, opts ...grpc.CallOption) (TagAssignmentService_GetAllBatchedClient, error)
	SubscribeBatched(ctx context.Context, in *TagAssignmentBatchedStreamRequest, opts ...grpc.CallOption) (TagAssignmentService_SubscribeBatchedClient, error)
}

TagAssignmentServiceClient is the client API for TagAssignmentService 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.

func NewTagAssignmentServiceClient 

func NewTagAssignmentServiceClient(cc grpc.ClientConnInterface) TagAssignmentServiceClient

type TagAssignmentServiceServer 

type TagAssignmentServiceServer interface {
	GetOne(context.Context, *TagAssignmentRequest) (*TagAssignmentResponse, error)
	GetSome(*TagAssignmentSomeRequest, TagAssignmentService_GetSomeServer) error
	GetAll(*TagAssignmentStreamRequest, TagAssignmentService_GetAllServer) error
	Subscribe(*TagAssignmentStreamRequest, TagAssignmentService_SubscribeServer) error
	GetMeta(context.Context, *TagAssignmentStreamRequest) (*MetaResponse, error)
	SubscribeMeta(*TagAssignmentStreamRequest, TagAssignmentService_SubscribeMetaServer) error
	GetAllBatched(*TagAssignmentBatchedStreamRequest, TagAssignmentService_GetAllBatchedServer) error
	SubscribeBatched(*TagAssignmentBatchedStreamRequest, TagAssignmentService_SubscribeBatchedServer) error
	// contains filtered or unexported methods
}

TagAssignmentServiceServer is the server API for TagAssignmentService service. All implementations must embed UnimplementedTagAssignmentServiceServer for forward compatibility

type TagAssignmentService_GetAllBatchedClient 

type TagAssignmentService_GetAllBatchedClient interface {
	Recv() (*TagAssignmentBatchedStreamResponse, error)
	grpc.ClientStream
}

type TagAssignmentService_GetAllBatchedServer 

type TagAssignmentService_GetAllBatchedServer interface {
	Send(*TagAssignmentBatchedStreamResponse) error
	grpc.ServerStream
}

type TagAssignmentService_GetAllClient 

type TagAssignmentService_GetAllClient interface {
	Recv() (*TagAssignmentStreamResponse, error)
	grpc.ClientStream
}

type TagAssignmentService_GetAllServer 

type TagAssignmentService_GetAllServer interface {
	Send(*TagAssignmentStreamResponse) error
	grpc.ServerStream
}

type TagAssignmentService_GetSomeClient 

type TagAssignmentService_GetSomeClient interface {
	Recv() (*TagAssignmentSomeResponse, error)
	grpc.ClientStream
}

type TagAssignmentService_GetSomeServer 

type TagAssignmentService_GetSomeServer interface {
	Send(*TagAssignmentSomeResponse) error
	grpc.ServerStream
}

type TagAssignmentService_SubscribeBatchedClient 

type TagAssignmentService_SubscribeBatchedClient interface {
	Recv() (*TagAssignmentBatchedStreamResponse, error)
	grpc.ClientStream
}

type TagAssignmentService_SubscribeBatchedServer 

type TagAssignmentService_SubscribeBatchedServer interface {
	Send(*TagAssignmentBatchedStreamResponse) error
	grpc.ServerStream
}

type TagAssignmentService_SubscribeClient 

type TagAssignmentService_SubscribeClient interface {
	Recv() (*TagAssignmentStreamResponse, error)
	grpc.ClientStream
}

type TagAssignmentService_SubscribeMetaClient 

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

type TagAssignmentService_SubscribeMetaServer 

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

type TagAssignmentService_SubscribeServer 

type TagAssignmentService_SubscribeServer interface {
	Send(*TagAssignmentStreamResponse) error
	grpc.ServerStream
}

type TagAssignmentSomeRequest 

type TagAssignmentSomeRequest struct {
	Keys []*TagAssignmentKey `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 (*TagAssignmentSomeRequest) Descriptor deprecated 

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

Deprecated: Use TagAssignmentSomeRequest.ProtoReflect.Descriptor instead.

func (*TagAssignmentSomeRequest) GetKeys 

func (x *TagAssignmentSomeRequest) GetKeys() []*TagAssignmentKey

func (*TagAssignmentSomeRequest) GetTime 

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

func (*TagAssignmentSomeRequest) ProtoMessage 

func (*TagAssignmentSomeRequest) ProtoMessage()

func (*TagAssignmentSomeRequest) ProtoReflect 

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

func (*TagAssignmentSomeRequest) Reset 

func (x *TagAssignmentSomeRequest) Reset()

func (*TagAssignmentSomeRequest) String 

func (x *TagAssignmentSomeRequest) String() string

type TagAssignmentSomeResponse 

type TagAssignmentSomeResponse 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 *TagAssignment `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 (*TagAssignmentSomeResponse) Descriptor deprecated 

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

Deprecated: Use TagAssignmentSomeResponse.ProtoReflect.Descriptor instead.

func (*TagAssignmentSomeResponse) GetError 

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

func (*TagAssignmentSomeResponse) GetTime 

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

func (*TagAssignmentSomeResponse) GetValue 

func (x *TagAssignmentSomeResponse) GetValue() *TagAssignment

func (*TagAssignmentSomeResponse) ProtoMessage 

func (*TagAssignmentSomeResponse) ProtoMessage()

func (*TagAssignmentSomeResponse) ProtoReflect 

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

func (*TagAssignmentSomeResponse) Reset 

func (x *TagAssignmentSomeResponse) Reset()

func (*TagAssignmentSomeResponse) String 

func (x *TagAssignmentSomeResponse) String() string

type TagAssignmentStreamRequest 

type TagAssignmentStreamRequest 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 []*TagAssignment `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 TagAssignment at end.
	//   - Each TagAssignment response is fully-specified (all fields set).
	//   - start: Returns the state of each TagAssignment at start, followed by updates until now.
	//   - Each TagAssignment response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each TagAssignment at start, followed by updates
	//     until end.
	//   - Each TagAssignment 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 (*TagAssignmentStreamRequest) Descriptor deprecated 

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

Deprecated: Use TagAssignmentStreamRequest.ProtoReflect.Descriptor instead.

func (*TagAssignmentStreamRequest) GetPartialEqFilter 

func (x *TagAssignmentStreamRequest) GetPartialEqFilter() []*TagAssignment

func (*TagAssignmentStreamRequest) GetTime 

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

func (*TagAssignmentStreamRequest) ProtoMessage 

func (*TagAssignmentStreamRequest) ProtoMessage()

func (*TagAssignmentStreamRequest) ProtoReflect 

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

func (*TagAssignmentStreamRequest) Reset 

func (x *TagAssignmentStreamRequest) Reset()

func (*TagAssignmentStreamRequest) String 

func (x *TagAssignmentStreamRequest) String() string

type TagAssignmentStreamResponse 

type TagAssignmentStreamResponse 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 *TagAssignment `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time holds the timestamp of this TagAssignment's last modification.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// Operation indicates how the TagAssignment 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 (*TagAssignmentStreamResponse) Descriptor deprecated 

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

Deprecated: Use TagAssignmentStreamResponse.ProtoReflect.Descriptor instead.

func (*TagAssignmentStreamResponse) GetTime 

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

func (*TagAssignmentStreamResponse) GetType 

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

func (*TagAssignmentStreamResponse) GetValue 

func (x *TagAssignmentStreamResponse) GetValue() *TagAssignment

func (*TagAssignmentStreamResponse) ProtoMessage 

func (*TagAssignmentStreamResponse) ProtoMessage()

func (*TagAssignmentStreamResponse) ProtoReflect 

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

func (*TagAssignmentStreamResponse) Reset 

func (x *TagAssignmentStreamResponse) Reset()

func (*TagAssignmentStreamResponse) String 

func (x *TagAssignmentStreamResponse) String() string

type TagBatchedStreamRequest 

type TagBatchedStreamRequest 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 []*Tag `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 Tag at end.
	//   - Each Tag response is fully-specified (all fields set).
	//   - start: Returns the state of each Tag at start, followed by updates until now.
	//   - Each Tag response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each Tag at start, followed by updates
	//     until end.
	//   - Each Tag 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 (*TagBatchedStreamRequest) Descriptor deprecated 

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

Deprecated: Use TagBatchedStreamRequest.ProtoReflect.Descriptor instead.

func (*TagBatchedStreamRequest) GetMaxMessages 

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

func (*TagBatchedStreamRequest) GetPartialEqFilter 

func (x *TagBatchedStreamRequest) GetPartialEqFilter() []*Tag

func (*TagBatchedStreamRequest) GetTime 

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

func (*TagBatchedStreamRequest) ProtoMessage 

func (*TagBatchedStreamRequest) ProtoMessage()

func (*TagBatchedStreamRequest) ProtoReflect 

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

func (*TagBatchedStreamRequest) Reset 

func (x *TagBatchedStreamRequest) Reset()

func (*TagBatchedStreamRequest) String 

func (x *TagBatchedStreamRequest) String() string

type TagBatchedStreamResponse 

type TagBatchedStreamResponse 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 []*TagStreamResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*TagBatchedStreamResponse) Descriptor deprecated 

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

Deprecated: Use TagBatchedStreamResponse.ProtoReflect.Descriptor instead.

func (*TagBatchedStreamResponse) GetResponses 

func (x *TagBatchedStreamResponse) GetResponses() []*TagStreamResponse

func (*TagBatchedStreamResponse) ProtoMessage 

func (*TagBatchedStreamResponse) ProtoMessage()

func (*TagBatchedStreamResponse) ProtoReflect 

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

func (*TagBatchedStreamResponse) Reset 

func (x *TagBatchedStreamResponse) Reset()

func (*TagBatchedStreamResponse) String 

func (x *TagBatchedStreamResponse) String() string

type TagConfig 

type TagConfig struct {

	// key identifies a tag. The special workspace ID "" for
	// merged tags should not be set here.
	Key *TagKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// remove indicates whether to remove (true) or add (false,
	// unset) the tag identified by the key if the encompassing
	// workspace merges.
	Remove *wrapperspb.BoolValue `protobuf:"bytes,2,opt,name=remove,proto3" json:"remove,omitempty"`
	// contains filtered or unexported fields
}

TagConfig holds a configuration for a user tag. The tags that belong to entities other than ELEMENT_SUB_TYPE_DEVICE will always be present in mainline only.

func (*TagConfig) Descriptor deprecated 

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

Deprecated: Use TagConfig.ProtoReflect.Descriptor instead.

func (*TagConfig) GetKey 

func (x *TagConfig) GetKey() *TagKey

func (*TagConfig) GetRemove 

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

func (*TagConfig) ProtoMessage 

func (*TagConfig) ProtoMessage()

func (*TagConfig) ProtoReflect 

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

func (*TagConfig) Reset 

func (x *TagConfig) Reset()

func (*TagConfig) String 

func (x *TagConfig) String() string

type TagConfigBatchedStreamRequest 

type TagConfigBatchedStreamRequest 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 []*TagConfig `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 TagConfig at end.
	//   - Each TagConfig response is fully-specified (all fields set).
	//   - start: Returns the state of each TagConfig at start, followed by updates until now.
	//   - Each TagConfig response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each TagConfig at start, followed by updates
	//     until end.
	//   - Each TagConfig 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 (*TagConfigBatchedStreamRequest) Descriptor deprecated 

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

Deprecated: Use TagConfigBatchedStreamRequest.ProtoReflect.Descriptor instead.

func (*TagConfigBatchedStreamRequest) GetMaxMessages 

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

func (*TagConfigBatchedStreamRequest) GetPartialEqFilter 

func (x *TagConfigBatchedStreamRequest) GetPartialEqFilter() []*TagConfig

func (*TagConfigBatchedStreamRequest) GetTime 

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

func (*TagConfigBatchedStreamRequest) ProtoMessage 

func (*TagConfigBatchedStreamRequest) ProtoMessage()

func (*TagConfigBatchedStreamRequest) ProtoReflect 

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

func (*TagConfigBatchedStreamRequest) Reset 

func (x *TagConfigBatchedStreamRequest) Reset()

func (*TagConfigBatchedStreamRequest) String 

func (x *TagConfigBatchedStreamRequest) String() string

type TagConfigBatchedStreamResponse 

type TagConfigBatchedStreamResponse 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 []*TagConfigStreamResponse `protobuf:"bytes,1,rep,name=responses,proto3" json:"responses,omitempty"`
	// contains filtered or unexported fields
}

func (*TagConfigBatchedStreamResponse) Descriptor deprecated 

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

Deprecated: Use TagConfigBatchedStreamResponse.ProtoReflect.Descriptor instead.

func (*TagConfigBatchedStreamResponse) GetResponses 

func (x *TagConfigBatchedStreamResponse) GetResponses() []*TagConfigStreamResponse

func (*TagConfigBatchedStreamResponse) ProtoMessage 

func (*TagConfigBatchedStreamResponse) ProtoMessage()

func (*TagConfigBatchedStreamResponse) ProtoReflect 

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

func (*TagConfigBatchedStreamResponse) Reset 

func (x *TagConfigBatchedStreamResponse) Reset()

func (*TagConfigBatchedStreamResponse) String 

func (x *TagConfigBatchedStreamResponse) String() string

type TagConfigDeleteAllRequest 

type TagConfigDeleteAllRequest 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 []*TagConfig `protobuf:"bytes,1,rep,name=partial_eq_filter,json=partialEqFilter,proto3" json:"partial_eq_filter,omitempty"`
	// contains filtered or unexported fields
}

func (*TagConfigDeleteAllRequest) Descriptor deprecated 

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

Deprecated: Use TagConfigDeleteAllRequest.ProtoReflect.Descriptor instead.

func (*TagConfigDeleteAllRequest) GetPartialEqFilter 

func (x *TagConfigDeleteAllRequest) GetPartialEqFilter() []*TagConfig

func (*TagConfigDeleteAllRequest) ProtoMessage 

func (*TagConfigDeleteAllRequest) ProtoMessage()

func (*TagConfigDeleteAllRequest) ProtoReflect 

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

func (*TagConfigDeleteAllRequest) Reset 

func (x *TagConfigDeleteAllRequest) Reset()

func (*TagConfigDeleteAllRequest) String 

func (x *TagConfigDeleteAllRequest) String() string

type TagConfigDeleteAllResponse 

type TagConfigDeleteAllResponse 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 TagConfig instance that failed to be deleted.
	Key *TagKey `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 (*TagConfigDeleteAllResponse) Descriptor deprecated 

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

Deprecated: Use TagConfigDeleteAllResponse.ProtoReflect.Descriptor instead.

func (*TagConfigDeleteAllResponse) GetError 

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

func (*TagConfigDeleteAllResponse) GetKey 

func (x *TagConfigDeleteAllResponse) GetKey() *TagKey

func (*TagConfigDeleteAllResponse) GetTime 

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

func (*TagConfigDeleteAllResponse) GetType 

func (x *TagConfigDeleteAllResponse) GetType() fmp.DeleteError

func (*TagConfigDeleteAllResponse) ProtoMessage 

func (*TagConfigDeleteAllResponse) ProtoMessage()

func (*TagConfigDeleteAllResponse) ProtoReflect 

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

func (*TagConfigDeleteAllResponse) Reset 

func (x *TagConfigDeleteAllResponse) Reset()

func (*TagConfigDeleteAllResponse) String 

func (x *TagConfigDeleteAllResponse) String() string

type TagConfigDeleteRequest 

type TagConfigDeleteRequest struct {

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

func (*TagConfigDeleteRequest) Descriptor deprecated 

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

Deprecated: Use TagConfigDeleteRequest.ProtoReflect.Descriptor instead.

func (*TagConfigDeleteRequest) GetKey 

func (x *TagConfigDeleteRequest) GetKey() *TagKey

func (*TagConfigDeleteRequest) ProtoMessage 

func (*TagConfigDeleteRequest) ProtoMessage()

func (*TagConfigDeleteRequest) ProtoReflect 

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

func (*TagConfigDeleteRequest) Reset 

func (x *TagConfigDeleteRequest) Reset()

func (*TagConfigDeleteRequest) String 

func (x *TagConfigDeleteRequest) String() string

type TagConfigDeleteResponse 

type TagConfigDeleteResponse struct {

	// Key echoes back the key of the deleted TagConfig instance.
	Key *TagKey `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 (*TagConfigDeleteResponse) Descriptor deprecated 

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

Deprecated: Use TagConfigDeleteResponse.ProtoReflect.Descriptor instead.

func (*TagConfigDeleteResponse) GetKey 

func (x *TagConfigDeleteResponse) GetKey() *TagKey

func (*TagConfigDeleteResponse) GetTime 

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

func (*TagConfigDeleteResponse) ProtoMessage 

func (*TagConfigDeleteResponse) ProtoMessage()

func (*TagConfigDeleteResponse) ProtoReflect 

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

func (*TagConfigDeleteResponse) Reset 

func (x *TagConfigDeleteResponse) Reset()

func (*TagConfigDeleteResponse) String 

func (x *TagConfigDeleteResponse) String() string

type TagConfigDeleteSomeRequest 

type TagConfigDeleteSomeRequest struct {

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

func (*TagConfigDeleteSomeRequest) Descriptor deprecated 

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

Deprecated: Use TagConfigDeleteSomeRequest.ProtoReflect.Descriptor instead.

func (*TagConfigDeleteSomeRequest) GetKeys 

func (x *TagConfigDeleteSomeRequest) GetKeys() []*TagKey

func (*TagConfigDeleteSomeRequest) ProtoMessage 

func (*TagConfigDeleteSomeRequest) ProtoMessage()

func (*TagConfigDeleteSomeRequest) ProtoReflect 

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

func (*TagConfigDeleteSomeRequest) Reset 

func (x *TagConfigDeleteSomeRequest) Reset()

func (*TagConfigDeleteSomeRequest) String 

func (x *TagConfigDeleteSomeRequest) String() string

type TagConfigDeleteSomeResponse 

type TagConfigDeleteSomeResponse struct {
	Key   *TagKey `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
}

TagConfigDeleteSomeResponse is only sent when there is an error.

func (*TagConfigDeleteSomeResponse) Descriptor deprecated 

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

Deprecated: Use TagConfigDeleteSomeResponse.ProtoReflect.Descriptor instead.

func (*TagConfigDeleteSomeResponse) GetError 

func (x *TagConfigDeleteSomeResponse) GetError() string

func (*TagConfigDeleteSomeResponse) GetKey 

func (x *TagConfigDeleteSomeResponse) GetKey() *TagKey

func (*TagConfigDeleteSomeResponse) ProtoMessage 

func (*TagConfigDeleteSomeResponse) ProtoMessage()

func (*TagConfigDeleteSomeResponse) ProtoReflect 

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

func (*TagConfigDeleteSomeResponse) Reset 

func (x *TagConfigDeleteSomeResponse) Reset()

func (*TagConfigDeleteSomeResponse) String 

func (x *TagConfigDeleteSomeResponse) String() string

type TagConfigRequest 

type TagConfigRequest struct {

	// Key uniquely identifies a TagConfig instance to retrieve.
	// This value must be populated.
	Key *TagKey `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 (*TagConfigRequest) Descriptor deprecated 

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

Deprecated: Use TagConfigRequest.ProtoReflect.Descriptor instead.

func (*TagConfigRequest) GetKey 

func (x *TagConfigRequest) GetKey() *TagKey

func (*TagConfigRequest) GetTime 

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

func (*TagConfigRequest) ProtoMessage 

func (*TagConfigRequest) ProtoMessage()

func (*TagConfigRequest) ProtoReflect 

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

func (*TagConfigRequest) Reset 

func (x *TagConfigRequest) Reset()

func (*TagConfigRequest) String 

func (x *TagConfigRequest) String() string

type TagConfigResponse 

type TagConfigResponse 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 *TagConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time carries the (UTC) timestamp of the last-modification of the
	// TagConfig instance in this response.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*TagConfigResponse) Descriptor deprecated 

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

Deprecated: Use TagConfigResponse.ProtoReflect.Descriptor instead.

func (*TagConfigResponse) GetTime 

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

func (*TagConfigResponse) GetValue 

func (x *TagConfigResponse) GetValue() *TagConfig

func (*TagConfigResponse) ProtoMessage 

func (*TagConfigResponse) ProtoMessage()

func (*TagConfigResponse) ProtoReflect 

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

func (*TagConfigResponse) Reset 

func (x *TagConfigResponse) Reset()

func (*TagConfigResponse) String 

func (x *TagConfigResponse) String() string

type TagConfigServiceClient 

type TagConfigServiceClient interface {
	GetOne(ctx context.Context, in *TagConfigRequest, opts ...grpc.CallOption) (*TagConfigResponse, error)
	GetSome(ctx context.Context, in *TagConfigSomeRequest, opts ...grpc.CallOption) (TagConfigService_GetSomeClient, error)
	GetAll(ctx context.Context, in *TagConfigStreamRequest, opts ...grpc.CallOption) (TagConfigService_GetAllClient, error)
	Subscribe(ctx context.Context, in *TagConfigStreamRequest, opts ...grpc.CallOption) (TagConfigService_SubscribeClient, error)
	GetMeta(ctx context.Context, in *TagConfigStreamRequest, opts ...grpc.CallOption) (*MetaResponse, error)
	SubscribeMeta(ctx context.Context, in *TagConfigStreamRequest, opts ...grpc.CallOption) (TagConfigService_SubscribeMetaClient, error)
	Set(ctx context.Context, in *TagConfigSetRequest, opts ...grpc.CallOption) (*TagConfigSetResponse, error)
	SetSome(ctx context.Context, in *TagConfigSetSomeRequest, opts ...grpc.CallOption) (TagConfigService_SetSomeClient, error)
	Delete(ctx context.Context, in *TagConfigDeleteRequest, opts ...grpc.CallOption) (*TagConfigDeleteResponse, error)
	DeleteSome(ctx context.Context, in *TagConfigDeleteSomeRequest, opts ...grpc.CallOption) (TagConfigService_DeleteSomeClient, error)
	DeleteAll(ctx context.Context, in *TagConfigDeleteAllRequest, opts ...grpc.CallOption) (TagConfigService_DeleteAllClient, error)
	GetAllBatched(ctx context.Context, in *TagConfigBatchedStreamRequest, opts ...grpc.CallOption) (TagConfigService_GetAllBatchedClient, error)
	SubscribeBatched(ctx context.Context, in *TagConfigBatchedStreamRequest, opts ...grpc.CallOption) (TagConfigService_SubscribeBatchedClient, error)
}

TagConfigServiceClient is the client API for TagConfigService 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.

func NewTagConfigServiceClient 

func NewTagConfigServiceClient(cc grpc.ClientConnInterface) TagConfigServiceClient

type TagConfigServiceServer 

type TagConfigServiceServer interface {
	GetOne(context.Context, *TagConfigRequest) (*TagConfigResponse, error)
	GetSome(*TagConfigSomeRequest, TagConfigService_GetSomeServer) error
	GetAll(*TagConfigStreamRequest, TagConfigService_GetAllServer) error
	Subscribe(*TagConfigStreamRequest, TagConfigService_SubscribeServer) error
	GetMeta(context.Context, *TagConfigStreamRequest) (*MetaResponse, error)
	SubscribeMeta(*TagConfigStreamRequest, TagConfigService_SubscribeMetaServer) error
	Set(context.Context, *TagConfigSetRequest) (*TagConfigSetResponse, error)
	SetSome(*TagConfigSetSomeRequest, TagConfigService_SetSomeServer) error
	Delete(context.Context, *TagConfigDeleteRequest) (*TagConfigDeleteResponse, error)
	DeleteSome(*TagConfigDeleteSomeRequest, TagConfigService_DeleteSomeServer) error
	DeleteAll(*TagConfigDeleteAllRequest, TagConfigService_DeleteAllServer) error
	GetAllBatched(*TagConfigBatchedStreamRequest, TagConfigService_GetAllBatchedServer) error
	SubscribeBatched(*TagConfigBatchedStreamRequest, TagConfigService_SubscribeBatchedServer) error
	// contains filtered or unexported methods
}

TagConfigServiceServer is the server API for TagConfigService service. All implementations must embed UnimplementedTagConfigServiceServer for forward compatibility

type TagConfigService_DeleteAllClient 

type TagConfigService_DeleteAllClient interface {
	Recv() (*TagConfigDeleteAllResponse, error)
	grpc.ClientStream
}

type TagConfigService_DeleteAllServer 

type TagConfigService_DeleteAllServer interface {
	Send(*TagConfigDeleteAllResponse) error
	grpc.ServerStream
}

type TagConfigService_DeleteSomeClient 

type TagConfigService_DeleteSomeClient interface {
	Recv() (*TagConfigDeleteSomeResponse, error)
	grpc.ClientStream
}

type TagConfigService_DeleteSomeServer 

type TagConfigService_DeleteSomeServer interface {
	Send(*TagConfigDeleteSomeResponse) error
	grpc.ServerStream
}

type TagConfigService_GetAllBatchedClient 

type TagConfigService_GetAllBatchedClient interface {
	Recv() (*TagConfigBatchedStreamResponse, error)
	grpc.ClientStream
}

type TagConfigService_GetAllBatchedServer 

type TagConfigService_GetAllBatchedServer interface {
	Send(*TagConfigBatchedStreamResponse) error
	grpc.ServerStream
}

type TagConfigService_GetAllClient 

type TagConfigService_GetAllClient interface {
	Recv() (*TagConfigStreamResponse, error)
	grpc.ClientStream
}

type TagConfigService_GetAllServer 

type TagConfigService_GetAllServer interface {
	Send(*TagConfigStreamResponse) error
	grpc.ServerStream
}

type TagConfigService_GetSomeClient 

type TagConfigService_GetSomeClient interface {
	Recv() (*TagConfigSomeResponse, error)
	grpc.ClientStream
}

type TagConfigService_GetSomeServer 

type TagConfigService_GetSomeServer interface {
	Send(*TagConfigSomeResponse) error
	grpc.ServerStream
}

type TagConfigService_SetSomeClient 

type TagConfigService_SetSomeClient interface {
	Recv() (*TagConfigSetSomeResponse, error)
	grpc.ClientStream
}

type TagConfigService_SetSomeServer 

type TagConfigService_SetSomeServer interface {
	Send(*TagConfigSetSomeResponse) error
	grpc.ServerStream
}

type TagConfigService_SubscribeBatchedClient 

type TagConfigService_SubscribeBatchedClient interface {
	Recv() (*TagConfigBatchedStreamResponse, error)
	grpc.ClientStream
}

type TagConfigService_SubscribeBatchedServer 

type TagConfigService_SubscribeBatchedServer interface {
	Send(*TagConfigBatchedStreamResponse) error
	grpc.ServerStream
}

type TagConfigService_SubscribeClient 

type TagConfigService_SubscribeClient interface {
	Recv() (*TagConfigStreamResponse, error)
	grpc.ClientStream
}

type TagConfigService_SubscribeMetaClient 

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

type TagConfigService_SubscribeMetaServer 

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

type TagConfigService_SubscribeServer 

type TagConfigService_SubscribeServer interface {
	Send(*TagConfigStreamResponse) error
	grpc.ServerStream
}

type TagConfigSetRequest 

type TagConfigSetRequest struct {

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

func (*TagConfigSetRequest) Descriptor deprecated 

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

Deprecated: Use TagConfigSetRequest.ProtoReflect.Descriptor instead.

func (*TagConfigSetRequest) GetValue 

func (x *TagConfigSetRequest) GetValue() *TagConfig

func (*TagConfigSetRequest) ProtoMessage 

func (*TagConfigSetRequest) ProtoMessage()

func (*TagConfigSetRequest) ProtoReflect 

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

func (*TagConfigSetRequest) Reset 

func (x *TagConfigSetRequest) Reset()

func (*TagConfigSetRequest) String 

func (x *TagConfigSetRequest) String() string

type TagConfigSetResponse 

type TagConfigSetResponse struct {

	// Value carries all the values given in the TagConfigSetRequest as well
	// as any server-generated values.
	Value *TagConfig `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 (*TagConfigSetResponse) Descriptor deprecated 

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

Deprecated: Use TagConfigSetResponse.ProtoReflect.Descriptor instead.

func (*TagConfigSetResponse) GetTime 

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

func (*TagConfigSetResponse) GetValue 

func (x *TagConfigSetResponse) GetValue() *TagConfig

func (*TagConfigSetResponse) ProtoMessage 

func (*TagConfigSetResponse) ProtoMessage()

func (*TagConfigSetResponse) ProtoReflect 

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

func (*TagConfigSetResponse) Reset 

func (x *TagConfigSetResponse) Reset()

func (*TagConfigSetResponse) String 

func (x *TagConfigSetResponse) String() string

type TagConfigSetSomeRequest 

type TagConfigSetSomeRequest struct {

	// value contains a list of TagConfig 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 []*TagConfig `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*TagConfigSetSomeRequest) Descriptor deprecated 

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

Deprecated: Use TagConfigSetSomeRequest.ProtoReflect.Descriptor instead.

func (*TagConfigSetSomeRequest) GetValues 

func (x *TagConfigSetSomeRequest) GetValues() []*TagConfig

func (*TagConfigSetSomeRequest) ProtoMessage 

func (*TagConfigSetSomeRequest) ProtoMessage()

func (*TagConfigSetSomeRequest) ProtoReflect 

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

func (*TagConfigSetSomeRequest) Reset 

func (x *TagConfigSetSomeRequest) Reset()

func (*TagConfigSetSomeRequest) String 

func (x *TagConfigSetSomeRequest) String() string

type TagConfigSetSomeResponse 

type TagConfigSetSomeResponse struct {
	Key   *TagKey `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 (*TagConfigSetSomeResponse) Descriptor deprecated 

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

Deprecated: Use TagConfigSetSomeResponse.ProtoReflect.Descriptor instead.

func (*TagConfigSetSomeResponse) GetError 

func (x *TagConfigSetSomeResponse) GetError() string

func (*TagConfigSetSomeResponse) GetKey 

func (x *TagConfigSetSomeResponse) GetKey() *TagKey

func (*TagConfigSetSomeResponse) ProtoMessage 

func (*TagConfigSetSomeResponse) ProtoMessage()

func (*TagConfigSetSomeResponse) ProtoReflect 

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

func (*TagConfigSetSomeResponse) Reset 

func (x *TagConfigSetSomeResponse) Reset()

func (*TagConfigSetSomeResponse) String 

func (x *TagConfigSetSomeResponse) String() string

type TagConfigSomeRequest 

type TagConfigSomeRequest struct {
	Keys []*TagKey `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 (*TagConfigSomeRequest) Descriptor deprecated 

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

Deprecated: Use TagConfigSomeRequest.ProtoReflect.Descriptor instead.

func (*TagConfigSomeRequest) GetKeys 

func (x *TagConfigSomeRequest) GetKeys() []*TagKey

func (*TagConfigSomeRequest) GetTime 

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

func (*TagConfigSomeRequest) ProtoMessage 

func (*TagConfigSomeRequest) ProtoMessage()

func (*TagConfigSomeRequest) ProtoReflect 

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

func (*TagConfigSomeRequest) Reset 

func (x *TagConfigSomeRequest) Reset()

func (*TagConfigSomeRequest) String 

func (x *TagConfigSomeRequest) String() string

type TagConfigSomeResponse 

type TagConfigSomeResponse 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 *TagConfig `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 (*TagConfigSomeResponse) Descriptor deprecated 

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

Deprecated: Use TagConfigSomeResponse.ProtoReflect.Descriptor instead.

func (*TagConfigSomeResponse) GetError 

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

func (*TagConfigSomeResponse) GetTime 

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

func (*TagConfigSomeResponse) GetValue 

func (x *TagConfigSomeResponse) GetValue() *TagConfig

func (*TagConfigSomeResponse) ProtoMessage 

func (*TagConfigSomeResponse) ProtoMessage()

func (*TagConfigSomeResponse) ProtoReflect 

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

func (*TagConfigSomeResponse) Reset 

func (x *TagConfigSomeResponse) Reset()

func (*TagConfigSomeResponse) String 

func (x *TagConfigSomeResponse) String() string

type TagConfigStreamRequest 

type TagConfigStreamRequest 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 []*TagConfig `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 TagConfig at end.
	//   - Each TagConfig response is fully-specified (all fields set).
	//   - start: Returns the state of each TagConfig at start, followed by updates until now.
	//   - Each TagConfig response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each TagConfig at start, followed by updates
	//     until end.
	//   - Each TagConfig 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 (*TagConfigStreamRequest) Descriptor deprecated 

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

Deprecated: Use TagConfigStreamRequest.ProtoReflect.Descriptor instead.

func (*TagConfigStreamRequest) GetPartialEqFilter 

func (x *TagConfigStreamRequest) GetPartialEqFilter() []*TagConfig

func (*TagConfigStreamRequest) GetTime 

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

func (*TagConfigStreamRequest) ProtoMessage 

func (*TagConfigStreamRequest) ProtoMessage()

func (*TagConfigStreamRequest) ProtoReflect 

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

func (*TagConfigStreamRequest) Reset 

func (x *TagConfigStreamRequest) Reset()

func (*TagConfigStreamRequest) String 

func (x *TagConfigStreamRequest) String() string

type TagConfigStreamResponse 

type TagConfigStreamResponse 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 *TagConfig `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time holds the timestamp of this TagConfig's last modification.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// Operation indicates how the TagConfig 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 (*TagConfigStreamResponse) Descriptor deprecated 

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

Deprecated: Use TagConfigStreamResponse.ProtoReflect.Descriptor instead.

func (*TagConfigStreamResponse) GetTime 

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

func (*TagConfigStreamResponse) GetType 

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

func (*TagConfigStreamResponse) GetValue 

func (x *TagConfigStreamResponse) GetValue() *TagConfig

func (*TagConfigStreamResponse) ProtoMessage 

func (*TagConfigStreamResponse) ProtoMessage()

func (*TagConfigStreamResponse) ProtoReflect 

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

func (*TagConfigStreamResponse) Reset 

func (x *TagConfigStreamResponse) Reset()

func (*TagConfigStreamResponse) String 

func (x *TagConfigStreamResponse) String() string

type TagKey 

type TagKey struct {

	// workspace_id is the ID of a workspace. The special ID ""
	// identifies the location where merged tags reside.
	WorkspaceId *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=workspace_id,json=workspaceId,proto3" json:"workspace_id,omitempty"`
	// element_type is the category of network element to which
	// this tag can be assigned.
	ElementType ElementType `` /* 126-byte string literal not displayed */
	// label is an arbitrary label.
	Label *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=label,proto3" json:"label,omitempty"`
	// value is an arbitrary value.
	Value *wrapperspb.StringValue `protobuf:"bytes,4,opt,name=value,proto3" json:"value,omitempty"`
	// element_sub_type is the sub-category of network element
	// to which this tag can be assigned.
	ElementSubType ElementSubType `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

TagKey uniquely identifies a tag.

func (*TagKey) Descriptor deprecated 

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

Deprecated: Use TagKey.ProtoReflect.Descriptor instead.

func (*TagKey) GetElementSubType 

func (x *TagKey) GetElementSubType() ElementSubType

func (*TagKey) GetElementType 

func (x *TagKey) GetElementType() ElementType

func (*TagKey) GetLabel 

func (x *TagKey) GetLabel() *wrapperspb.StringValue

func (*TagKey) GetValue 

func (x *TagKey) GetValue() *wrapperspb.StringValue

func (*TagKey) GetWorkspaceId 

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

func (*TagKey) ProtoMessage 

func (*TagKey) ProtoMessage()

func (*TagKey) ProtoReflect 

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

func (*TagKey) Reset 

func (x *TagKey) Reset()

func (*TagKey) String 

func (x *TagKey) String() string

type TagRequest 

type TagRequest struct {

	// Key uniquely identifies a Tag instance to retrieve.
	// This value must be populated.
	Key *TagKey `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 (*TagRequest) Descriptor deprecated 

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

Deprecated: Use TagRequest.ProtoReflect.Descriptor instead.

func (*TagRequest) GetKey 

func (x *TagRequest) GetKey() *TagKey

func (*TagRequest) GetTime 

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

func (*TagRequest) ProtoMessage 

func (*TagRequest) ProtoMessage()

func (*TagRequest) ProtoReflect 

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

func (*TagRequest) Reset 

func (x *TagRequest) Reset()

func (*TagRequest) String 

func (x *TagRequest) String() string

type TagResponse 

type TagResponse 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 *Tag `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time carries the (UTC) timestamp of the last-modification of the
	// Tag instance in this response.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// contains filtered or unexported fields
}

func (*TagResponse) Descriptor deprecated 

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

Deprecated: Use TagResponse.ProtoReflect.Descriptor instead.

func (*TagResponse) GetTime 

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

func (*TagResponse) GetValue 

func (x *TagResponse) GetValue() *Tag

func (*TagResponse) ProtoMessage 

func (*TagResponse) ProtoMessage()

func (*TagResponse) ProtoReflect 

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

func (*TagResponse) Reset 

func (x *TagResponse) Reset()

func (*TagResponse) String 

func (x *TagResponse) String() string

type TagServiceClient 

type TagServiceClient interface {
	GetOne(ctx context.Context, in *TagRequest, opts ...grpc.CallOption) (*TagResponse, error)
	GetSome(ctx context.Context, in *TagSomeRequest, opts ...grpc.CallOption) (TagService_GetSomeClient, error)
	GetAll(ctx context.Context, in *TagStreamRequest, opts ...grpc.CallOption) (TagService_GetAllClient, error)
	Subscribe(ctx context.Context, in *TagStreamRequest, opts ...grpc.CallOption) (TagService_SubscribeClient, error)
	GetMeta(ctx context.Context, in *TagStreamRequest, opts ...grpc.CallOption) (*MetaResponse, error)
	SubscribeMeta(ctx context.Context, in *TagStreamRequest, opts ...grpc.CallOption) (TagService_SubscribeMetaClient, error)
	GetAllBatched(ctx context.Context, in *TagBatchedStreamRequest, opts ...grpc.CallOption) (TagService_GetAllBatchedClient, error)
	SubscribeBatched(ctx context.Context, in *TagBatchedStreamRequest, opts ...grpc.CallOption) (TagService_SubscribeBatchedClient, error)
}

TagServiceClient is the client API for TagService 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.

func NewTagServiceClient 

func NewTagServiceClient(cc grpc.ClientConnInterface) TagServiceClient

type TagServiceServer 

type TagServiceServer interface {
	GetOne(context.Context, *TagRequest) (*TagResponse, error)
	GetSome(*TagSomeRequest, TagService_GetSomeServer) error
	GetAll(*TagStreamRequest, TagService_GetAllServer) error
	Subscribe(*TagStreamRequest, TagService_SubscribeServer) error
	GetMeta(context.Context, *TagStreamRequest) (*MetaResponse, error)
	SubscribeMeta(*TagStreamRequest, TagService_SubscribeMetaServer) error
	GetAllBatched(*TagBatchedStreamRequest, TagService_GetAllBatchedServer) error
	SubscribeBatched(*TagBatchedStreamRequest, TagService_SubscribeBatchedServer) error
	// contains filtered or unexported methods
}

TagServiceServer is the server API for TagService service. All implementations must embed UnimplementedTagServiceServer for forward compatibility

type TagService_GetAllBatchedClient 

type TagService_GetAllBatchedClient interface {
	Recv() (*TagBatchedStreamResponse, error)
	grpc.ClientStream
}

type TagService_GetAllBatchedServer 

type TagService_GetAllBatchedServer interface {
	Send(*TagBatchedStreamResponse) error
	grpc.ServerStream
}

type TagService_GetAllClient 

type TagService_GetAllClient interface {
	Recv() (*TagStreamResponse, error)
	grpc.ClientStream
}

type TagService_GetAllServer 

type TagService_GetAllServer interface {
	Send(*TagStreamResponse) error
	grpc.ServerStream
}

type TagService_GetSomeClient 

type TagService_GetSomeClient interface {
	Recv() (*TagSomeResponse, error)
	grpc.ClientStream
}

type TagService_GetSomeServer 

type TagService_GetSomeServer interface {
	Send(*TagSomeResponse) error
	grpc.ServerStream
}

type TagService_SubscribeBatchedClient 

type TagService_SubscribeBatchedClient interface {
	Recv() (*TagBatchedStreamResponse, error)
	grpc.ClientStream
}

type TagService_SubscribeBatchedServer 

type TagService_SubscribeBatchedServer interface {
	Send(*TagBatchedStreamResponse) error
	grpc.ServerStream
}

type TagService_SubscribeClient 

type TagService_SubscribeClient interface {
	Recv() (*TagStreamResponse, error)
	grpc.ClientStream
}

type TagService_SubscribeMetaClient 

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

type TagService_SubscribeMetaServer 

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

type TagService_SubscribeServer 

type TagService_SubscribeServer interface {
	Send(*TagStreamResponse) error
	grpc.ServerStream
}

type TagSomeRequest 

type TagSomeRequest struct {
	Keys []*TagKey `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 (*TagSomeRequest) Descriptor deprecated 

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

Deprecated: Use TagSomeRequest.ProtoReflect.Descriptor instead.

func (*TagSomeRequest) GetKeys 

func (x *TagSomeRequest) GetKeys() []*TagKey

func (*TagSomeRequest) GetTime 

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

func (*TagSomeRequest) ProtoMessage 

func (*TagSomeRequest) ProtoMessage()

func (*TagSomeRequest) ProtoReflect 

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

func (*TagSomeRequest) Reset 

func (x *TagSomeRequest) Reset()

func (*TagSomeRequest) String 

func (x *TagSomeRequest) String() string

type TagSomeResponse 

type TagSomeResponse 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 *Tag `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 (*TagSomeResponse) Descriptor deprecated 

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

Deprecated: Use TagSomeResponse.ProtoReflect.Descriptor instead.

func (*TagSomeResponse) GetError 

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

func (*TagSomeResponse) GetTime 

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

func (*TagSomeResponse) GetValue 

func (x *TagSomeResponse) GetValue() *Tag

func (*TagSomeResponse) ProtoMessage 

func (*TagSomeResponse) ProtoMessage()

func (*TagSomeResponse) ProtoReflect 

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

func (*TagSomeResponse) Reset 

func (x *TagSomeResponse) Reset()

func (*TagSomeResponse) String 

func (x *TagSomeResponse) String() string

type TagStreamRequest 

type TagStreamRequest 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 []*Tag `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 Tag at end.
	//   - Each Tag response is fully-specified (all fields set).
	//   - start: Returns the state of each Tag at start, followed by updates until now.
	//   - Each Tag response at start is fully-specified, but updates may be partial.
	//   - start and end: Returns the state of each Tag at start, followed by updates
	//     until end.
	//   - Each Tag 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 (*TagStreamRequest) Descriptor deprecated 

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

Deprecated: Use TagStreamRequest.ProtoReflect.Descriptor instead.

func (*TagStreamRequest) GetPartialEqFilter 

func (x *TagStreamRequest) GetPartialEqFilter() []*Tag

func (*TagStreamRequest) GetTime 

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

func (*TagStreamRequest) ProtoMessage 

func (*TagStreamRequest) ProtoMessage()

func (*TagStreamRequest) ProtoReflect 

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

func (*TagStreamRequest) Reset 

func (x *TagStreamRequest) Reset()

func (*TagStreamRequest) String 

func (x *TagStreamRequest) String() string

type TagStreamResponse 

type TagStreamResponse 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 *Tag `protobuf:"bytes,1,opt,name=value,proto3" json:"value,omitempty"`
	// Time holds the timestamp of this Tag's last modification.
	Time *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=time,proto3" json:"time,omitempty"`
	// Operation indicates how the Tag 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 (*TagStreamResponse) Descriptor deprecated 

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

Deprecated: Use TagStreamResponse.ProtoReflect.Descriptor instead.

func (*TagStreamResponse) GetTime 

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

func (*TagStreamResponse) GetType 

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

func (*TagStreamResponse) GetValue 

func (x *TagStreamResponse) GetValue() *Tag

func (*TagStreamResponse) ProtoMessage 

func (*TagStreamResponse) ProtoMessage()

func (*TagStreamResponse) ProtoReflect 

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

func (*TagStreamResponse) Reset 

func (x *TagStreamResponse) Reset()

func (*TagStreamResponse) String 

func (x *TagStreamResponse) String() string

type UnimplementedTagAssignmentConfigServiceServer 

type UnimplementedTagAssignmentConfigServiceServer struct {
}

UnimplementedTagAssignmentConfigServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTagAssignmentConfigServiceServer) Delete 

func (UnimplementedTagAssignmentConfigServiceServer) Delete(context.Context, *TagAssignmentConfigDeleteRequest) (*TagAssignmentConfigDeleteResponse, error)

func (UnimplementedTagAssignmentConfigServiceServer) DeleteAll 

func (UnimplementedTagAssignmentConfigServiceServer) DeleteAll(*TagAssignmentConfigDeleteAllRequest, TagAssignmentConfigService_DeleteAllServer) error

func (UnimplementedTagAssignmentConfigServiceServer) DeleteSome 

func (UnimplementedTagAssignmentConfigServiceServer) DeleteSome(*TagAssignmentConfigDeleteSomeRequest, TagAssignmentConfigService_DeleteSomeServer) error

func (UnimplementedTagAssignmentConfigServiceServer) GetAll 

func (UnimplementedTagAssignmentConfigServiceServer) GetAll(*TagAssignmentConfigStreamRequest, TagAssignmentConfigService_GetAllServer) error

func (UnimplementedTagAssignmentConfigServiceServer) GetAllBatched 

func (UnimplementedTagAssignmentConfigServiceServer) GetAllBatched(*TagAssignmentConfigBatchedStreamRequest, TagAssignmentConfigService_GetAllBatchedServer) error

func (UnimplementedTagAssignmentConfigServiceServer) GetMeta 

func (UnimplementedTagAssignmentConfigServiceServer) GetMeta(context.Context, *TagAssignmentConfigStreamRequest) (*MetaResponse, error)

func (UnimplementedTagAssignmentConfigServiceServer) GetOne 

func (UnimplementedTagAssignmentConfigServiceServer) GetOne(context.Context, *TagAssignmentConfigRequest) (*TagAssignmentConfigResponse, error)

func (UnimplementedTagAssignmentConfigServiceServer) GetSome 

func (UnimplementedTagAssignmentConfigServiceServer) GetSome(*TagAssignmentConfigSomeRequest, TagAssignmentConfigService_GetSomeServer) error

func (UnimplementedTagAssignmentConfigServiceServer) Set 

func (UnimplementedTagAssignmentConfigServiceServer) Set(context.Context, *TagAssignmentConfigSetRequest) (*TagAssignmentConfigSetResponse, error)

func (UnimplementedTagAssignmentConfigServiceServer) SetSome 

func (UnimplementedTagAssignmentConfigServiceServer) SetSome(*TagAssignmentConfigSetSomeRequest, TagAssignmentConfigService_SetSomeServer) error

func (UnimplementedTagAssignmentConfigServiceServer) Subscribe 

func (UnimplementedTagAssignmentConfigServiceServer) Subscribe(*TagAssignmentConfigStreamRequest, TagAssignmentConfigService_SubscribeServer) error

func (UnimplementedTagAssignmentConfigServiceServer) SubscribeBatched 

func (UnimplementedTagAssignmentConfigServiceServer) SubscribeBatched(*TagAssignmentConfigBatchedStreamRequest, TagAssignmentConfigService_SubscribeBatchedServer) error

func (UnimplementedTagAssignmentConfigServiceServer) SubscribeMeta 

func (UnimplementedTagAssignmentConfigServiceServer) SubscribeMeta(*TagAssignmentConfigStreamRequest, TagAssignmentConfigService_SubscribeMetaServer) error

type UnimplementedTagAssignmentServiceServer 

type UnimplementedTagAssignmentServiceServer struct {
}

UnimplementedTagAssignmentServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTagAssignmentServiceServer) GetAll 

func (UnimplementedTagAssignmentServiceServer) GetAll(*TagAssignmentStreamRequest, TagAssignmentService_GetAllServer) error

func (UnimplementedTagAssignmentServiceServer) GetAllBatched 

func (UnimplementedTagAssignmentServiceServer) GetAllBatched(*TagAssignmentBatchedStreamRequest, TagAssignmentService_GetAllBatchedServer) error

func (UnimplementedTagAssignmentServiceServer) GetMeta 

func (UnimplementedTagAssignmentServiceServer) GetMeta(context.Context, *TagAssignmentStreamRequest) (*MetaResponse, error)

func (UnimplementedTagAssignmentServiceServer) GetOne 

func (UnimplementedTagAssignmentServiceServer) GetOne(context.Context, *TagAssignmentRequest) (*TagAssignmentResponse, error)

func (UnimplementedTagAssignmentServiceServer) GetSome 

func (UnimplementedTagAssignmentServiceServer) GetSome(*TagAssignmentSomeRequest, TagAssignmentService_GetSomeServer) error

func (UnimplementedTagAssignmentServiceServer) Subscribe 

func (UnimplementedTagAssignmentServiceServer) Subscribe(*TagAssignmentStreamRequest, TagAssignmentService_SubscribeServer) error

func (UnimplementedTagAssignmentServiceServer) SubscribeBatched 

func (UnimplementedTagAssignmentServiceServer) SubscribeBatched(*TagAssignmentBatchedStreamRequest, TagAssignmentService_SubscribeBatchedServer) error

func (UnimplementedTagAssignmentServiceServer) SubscribeMeta 

func (UnimplementedTagAssignmentServiceServer) SubscribeMeta(*TagAssignmentStreamRequest, TagAssignmentService_SubscribeMetaServer) error

type UnimplementedTagConfigServiceServer 

type UnimplementedTagConfigServiceServer struct {
}

UnimplementedTagConfigServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTagConfigServiceServer) Delete 

func (UnimplementedTagConfigServiceServer) Delete(context.Context, *TagConfigDeleteRequest) (*TagConfigDeleteResponse, error)

func (UnimplementedTagConfigServiceServer) DeleteAll 

func (UnimplementedTagConfigServiceServer) DeleteAll(*TagConfigDeleteAllRequest, TagConfigService_DeleteAllServer) error

func (UnimplementedTagConfigServiceServer) DeleteSome 

func (UnimplementedTagConfigServiceServer) DeleteSome(*TagConfigDeleteSomeRequest, TagConfigService_DeleteSomeServer) error

func (UnimplementedTagConfigServiceServer) GetAll 

func (UnimplementedTagConfigServiceServer) GetAll(*TagConfigStreamRequest, TagConfigService_GetAllServer) error

func (UnimplementedTagConfigServiceServer) GetAllBatched 

func (UnimplementedTagConfigServiceServer) GetAllBatched(*TagConfigBatchedStreamRequest, TagConfigService_GetAllBatchedServer) error

func (UnimplementedTagConfigServiceServer) GetMeta 

func (UnimplementedTagConfigServiceServer) GetMeta(context.Context, *TagConfigStreamRequest) (*MetaResponse, error)

func (UnimplementedTagConfigServiceServer) GetOne 

func (UnimplementedTagConfigServiceServer) GetOne(context.Context, *TagConfigRequest) (*TagConfigResponse, error)

func (UnimplementedTagConfigServiceServer) GetSome 

func (UnimplementedTagConfigServiceServer) GetSome(*TagConfigSomeRequest, TagConfigService_GetSomeServer) error

func (UnimplementedTagConfigServiceServer) Set 

func (UnimplementedTagConfigServiceServer) Set(context.Context, *TagConfigSetRequest) (*TagConfigSetResponse, error)

func (UnimplementedTagConfigServiceServer) SetSome 

func (UnimplementedTagConfigServiceServer) SetSome(*TagConfigSetSomeRequest, TagConfigService_SetSomeServer) error

func (UnimplementedTagConfigServiceServer) Subscribe 

func (UnimplementedTagConfigServiceServer) Subscribe(*TagConfigStreamRequest, TagConfigService_SubscribeServer) error

func (UnimplementedTagConfigServiceServer) SubscribeBatched 

func (UnimplementedTagConfigServiceServer) SubscribeBatched(*TagConfigBatchedStreamRequest, TagConfigService_SubscribeBatchedServer) error

func (UnimplementedTagConfigServiceServer) SubscribeMeta 

func (UnimplementedTagConfigServiceServer) SubscribeMeta(*TagConfigStreamRequest, TagConfigService_SubscribeMetaServer) error

type UnimplementedTagServiceServer 

type UnimplementedTagServiceServer struct {
}

UnimplementedTagServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTagServiceServer) GetAll 

func (UnimplementedTagServiceServer) GetAll(*TagStreamRequest, TagService_GetAllServer) error

func (UnimplementedTagServiceServer) GetAllBatched 

func (UnimplementedTagServiceServer) GetAllBatched(*TagBatchedStreamRequest, TagService_GetAllBatchedServer) error

func (UnimplementedTagServiceServer) GetMeta 

func (UnimplementedTagServiceServer) GetMeta(context.Context, *TagStreamRequest) (*MetaResponse, error)

func (UnimplementedTagServiceServer) GetOne 

func (UnimplementedTagServiceServer) GetOne(context.Context, *TagRequest) (*TagResponse, error)

func (UnimplementedTagServiceServer) GetSome 

func (UnimplementedTagServiceServer) GetSome(*TagSomeRequest, TagService_GetSomeServer) error

func (UnimplementedTagServiceServer) Subscribe 

func (UnimplementedTagServiceServer) Subscribe(*TagStreamRequest, TagService_SubscribeServer) error

func (UnimplementedTagServiceServer) SubscribeBatched 

func (UnimplementedTagServiceServer) SubscribeBatched(*TagBatchedStreamRequest, TagService_SubscribeBatchedServer) error

func (UnimplementedTagServiceServer) SubscribeMeta 

func (UnimplementedTagServiceServer) SubscribeMeta(*TagStreamRequest, TagService_SubscribeMetaServer) error

type UnsafeTagAssignmentConfigServiceServer 

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

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

type UnsafeTagAssignmentServiceServer 

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

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

type UnsafeTagConfigServiceServer 

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

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

type UnsafeTagServiceServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.