serviceaccount

package
v0.0.0-...-1768917 Latest Latest
Warning

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

 Go to latest Published: Apr 25, 2024 License: Apache-2.0 Imports: 14 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	AccountStatus_name = map[int32]string{
		0: "ACCOUNT_STATUS_UNSPECIFIED",
		1: "ACCOUNT_STATUS_ENABLED",
		2: "ACCOUNT_STATUS_DISABLED",
	}
	AccountStatus_value = map[string]int32{
		"ACCOUNT_STATUS_UNSPECIFIED": 0,
		"ACCOUNT_STATUS_ENABLED":     1,
		"ACCOUNT_STATUS_DISABLED":    2,
	}
)

Enum value maps for AccountStatus.

View Source 
var AccountConfigService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arista.serviceaccount.v1.AccountConfigService",
	HandlerType: (*AccountConfigServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOne",
			Handler:    _AccountConfigService_GetOne_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _AccountConfigService_GetMeta_Handler,
		},
		{
			MethodName: "Set",
			Handler:    _AccountConfigService_Set_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _AccountConfigService_Delete_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSome",
			Handler:       _AccountConfigService_GetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAll",
			Handler:       _AccountConfigService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _AccountConfigService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMeta",
			Handler:       _AccountConfigService_SubscribeMeta_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SetSome",
			Handler:       _AccountConfigService_SetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeleteSome",
			Handler:       _AccountConfigService_DeleteSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeleteAll",
			Handler:       _AccountConfigService_DeleteAll_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arista/serviceaccount.v1/services.gen.proto",
}

AccountConfigService_ServiceDesc is the grpc.ServiceDesc for AccountConfigService 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 AccountService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arista.serviceaccount.v1.AccountService",
	HandlerType: (*AccountServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOne",
			Handler:    _AccountService_GetOne_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _AccountService_GetMeta_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSome",
			Handler:       _AccountService_GetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAll",
			Handler:       _AccountService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _AccountService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMeta",
			Handler:       _AccountService_SubscribeMeta_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arista/serviceaccount.v1/services.gen.proto",
}

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

View Source 
var File_arista_serviceaccount_v1_serviceaccount_proto protoreflect.FileDescriptor
View Source 
var File_arista_serviceaccount_v1_services_gen_proto protoreflect.FileDescriptor
View Source 
var TokenConfigService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arista.serviceaccount.v1.TokenConfigService",
	HandlerType: (*TokenConfigServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOne",
			Handler:    _TokenConfigService_GetOne_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _TokenConfigService_GetMeta_Handler,
		},
		{
			MethodName: "Set",
			Handler:    _TokenConfigService_Set_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _TokenConfigService_Delete_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSome",
			Handler:       _TokenConfigService_GetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAll",
			Handler:       _TokenConfigService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _TokenConfigService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMeta",
			Handler:       _TokenConfigService_SubscribeMeta_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SetSome",
			Handler:       _TokenConfigService_SetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeleteSome",
			Handler:       _TokenConfigService_DeleteSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "DeleteAll",
			Handler:       _TokenConfigService_DeleteAll_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arista/serviceaccount.v1/services.gen.proto",
}

TokenConfigService_ServiceDesc is the grpc.ServiceDesc for TokenConfigService 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 TokenService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "arista.serviceaccount.v1.TokenService",
	HandlerType: (*TokenServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetOne",
			Handler:    _TokenService_GetOne_Handler,
		},
		{
			MethodName: "GetMeta",
			Handler:    _TokenService_GetMeta_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetSome",
			Handler:       _TokenService_GetSome_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetAll",
			Handler:       _TokenService_GetAll_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "Subscribe",
			Handler:       _TokenService_Subscribe_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "SubscribeMeta",
			Handler:       _TokenService_SubscribeMeta_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "arista/serviceaccount.v1/services.gen.proto",
}

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

Functions

func RegisterAccountConfigServiceServer 

func RegisterAccountConfigServiceServer(s grpc.ServiceRegistrar, srv AccountConfigServiceServer)

func RegisterAccountServiceServer 

func RegisterAccountServiceServer(s grpc.ServiceRegistrar, srv AccountServiceServer)

func RegisterTokenConfigServiceServer 

func RegisterTokenConfigServiceServer(s grpc.ServiceRegistrar, srv TokenConfigServiceServer)

func RegisterTokenServiceServer 

func RegisterTokenServiceServer(s grpc.ServiceRegistrar, srv TokenServiceServer)

Types

type Account 

type Account struct {

	// key uniquely identifies the service account.
	Key *AccountKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// status determines whether the service account is enabled or disabled.
	Status AccountStatus `protobuf:"varint,2,opt,name=status,proto3,enum=arista.serviceaccount.v1.AccountStatus" json:"status,omitempty"`
	// description is a comment describing the service account.
	Description *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// groups is a list of roles that the service account inherits permissions from.
	Groups *fmp.RepeatedString `protobuf:"bytes,4,opt,name=groups,proto3" json:"groups,omitempty"`
	// created_by is the name of the entity that created the service account.
	CreatedBy *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=created_by,json=createdBy,proto3" json:"created_by,omitempty"`
	// last_access is the time when the service account was last fetched.
	LastAccess *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=last_access,json=lastAccess,proto3" json:"last_access,omitempty"`
	// contains filtered or unexported fields
}

Account describes a service account.

func (*Account) Descriptor deprecated 

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

Deprecated: Use Account.ProtoReflect.Descriptor instead.

func (*Account) GetCreatedBy 

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

func (*Account) GetDescription 

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

func (*Account) GetGroups 

func (x *Account) GetGroups() *fmp.RepeatedString

func (*Account) GetKey 

func (x *Account) GetKey() *AccountKey

func (*Account) GetLastAccess 

func (x *Account) GetLastAccess() *timestamppb.Timestamp

func (*Account) GetStatus 

func (x *Account) GetStatus() AccountStatus

func (*Account) ProtoMessage 

func (*Account) ProtoMessage()

func (*Account) ProtoReflect 

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

func (*Account) Reset 

func (x *Account) Reset()

func (*Account) String 

func (x *Account) String() string

type AccountConfig 

type AccountConfig struct {

	// key contains the name of the service account.
	Key *AccountKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// status determines if the service account is enabled or disabled. New service accounts are
	// enabled by default.
	Status AccountStatus `protobuf:"varint,2,opt,name=status,proto3,enum=arista.serviceaccount.v1.AccountStatus" json:"status,omitempty"`
	// description is a comment describing the service account.
	Description *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// groups is a list of roles that the service account inherits permissions from.
	Groups *fmp.RepeatedString `protobuf:"bytes,4,opt,name=groups,proto3" json:"groups,omitempty"`
	// contains filtered or unexported fields
}

AccountConfig holds the configuration for a service account.

func (*AccountConfig) Descriptor deprecated 

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

Deprecated: Use AccountConfig.ProtoReflect.Descriptor instead.

func (*AccountConfig) GetDescription 

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

func (*AccountConfig) GetGroups 

func (x *AccountConfig) GetGroups() *fmp.RepeatedString

func (*AccountConfig) GetKey 

func (x *AccountConfig) GetKey() *AccountKey

func (*AccountConfig) GetStatus 

func (x *AccountConfig) GetStatus() AccountStatus

func (*AccountConfig) ProtoMessage 

func (*AccountConfig) ProtoMessage()

func (*AccountConfig) ProtoReflect 

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

func (*AccountConfig) Reset 

func (x *AccountConfig) Reset()

func (*AccountConfig) String 

func (x *AccountConfig) String() string

type AccountConfigDeleteAllRequest 

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

func (*AccountConfigDeleteAllRequest) Descriptor deprecated 

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

Deprecated: Use AccountConfigDeleteAllRequest.ProtoReflect.Descriptor instead.

func (*AccountConfigDeleteAllRequest) ProtoMessage 

func (*AccountConfigDeleteAllRequest) ProtoMessage()

func (*AccountConfigDeleteAllRequest) ProtoReflect 

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

func (*AccountConfigDeleteAllRequest) Reset 

func (x *AccountConfigDeleteAllRequest) Reset()

func (*AccountConfigDeleteAllRequest) String 

func (x *AccountConfigDeleteAllRequest) String() string

type AccountConfigDeleteAllResponse 

type AccountConfigDeleteAllResponse struct {

	// This describes the class of delete 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 AccountConfig instance that failed to be deleted.
	Key *AccountKey `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 (*AccountConfigDeleteAllResponse) Descriptor deprecated 

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

Deprecated: Use AccountConfigDeleteAllResponse.ProtoReflect.Descriptor instead.

func (*AccountConfigDeleteAllResponse) GetError 

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

func (*AccountConfigDeleteAllResponse) GetKey 

func (x *AccountConfigDeleteAllResponse) GetKey() *AccountKey

func (*AccountConfigDeleteAllResponse) GetTime 

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

func (*AccountConfigDeleteAllResponse) GetType 

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

func (*AccountConfigDeleteAllResponse) ProtoMessage 

func (*AccountConfigDeleteAllResponse) ProtoMessage()

func (*AccountConfigDeleteAllResponse) ProtoReflect 

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

func (*AccountConfigDeleteAllResponse) Reset 

func (x *AccountConfigDeleteAllResponse) Reset()

func (*AccountConfigDeleteAllResponse) String 

func (x *AccountConfigDeleteAllResponse) String() string

type AccountConfigDeleteRequest 

type AccountConfigDeleteRequest struct {

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

func (*AccountConfigDeleteRequest) Descriptor deprecated 

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

Deprecated: Use AccountConfigDeleteRequest.ProtoReflect.Descriptor instead.

func (*AccountConfigDeleteRequest) GetKey 

func (x *AccountConfigDeleteRequest) GetKey() *AccountKey

func (*AccountConfigDeleteRequest) ProtoMessage 

func (*AccountConfigDeleteRequest) ProtoMessage()

func (*AccountConfigDeleteRequest) ProtoReflect 

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

func (*AccountConfigDeleteRequest) Reset 

func (x *AccountConfigDeleteRequest) Reset()

func (*AccountConfigDeleteRequest) String 

func (x *AccountConfigDeleteRequest) String() string

type AccountConfigDeleteResponse 

type AccountConfigDeleteResponse struct {

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

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

Deprecated: Use AccountConfigDeleteResponse.ProtoReflect.Descriptor instead.

func (*AccountConfigDeleteResponse) GetKey 

func (x *AccountConfigDeleteResponse) GetKey() *AccountKey

func (*AccountConfigDeleteResponse) GetTime 

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

func (*AccountConfigDeleteResponse) ProtoMessage 

func (*AccountConfigDeleteResponse) ProtoMessage()

func (*AccountConfigDeleteResponse) ProtoReflect 

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

func (*AccountConfigDeleteResponse) Reset 

func (x *AccountConfigDeleteResponse) Reset()

func (*AccountConfigDeleteResponse) String 

func (x *AccountConfigDeleteResponse) String() string

type AccountConfigDeleteSomeRequest 

type AccountConfigDeleteSomeRequest struct {

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

func (*AccountConfigDeleteSomeRequest) Descriptor deprecated 

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

Deprecated: Use AccountConfigDeleteSomeRequest.ProtoReflect.Descriptor instead.

func (*AccountConfigDeleteSomeRequest) GetKeys 

func (x *AccountConfigDeleteSomeRequest) GetKeys() []*AccountKey

func (*AccountConfigDeleteSomeRequest) ProtoMessage 

func (*AccountConfigDeleteSomeRequest) ProtoMessage()

func (*AccountConfigDeleteSomeRequest) ProtoReflect 

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

func (*AccountConfigDeleteSomeRequest) Reset 

func (x *AccountConfigDeleteSomeRequest) Reset()

func (*AccountConfigDeleteSomeRequest) String 

func (x *AccountConfigDeleteSomeRequest) String() string

type AccountConfigDeleteSomeResponse 

type AccountConfigDeleteSomeResponse struct {
	Key   *AccountKey `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
}

AccountConfigDeleteSomeResponse is only sent when there is an error.

func (*AccountConfigDeleteSomeResponse) Descriptor deprecated 

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

Deprecated: Use AccountConfigDeleteSomeResponse.ProtoReflect.Descriptor instead.

func (*AccountConfigDeleteSomeResponse) GetError 

func (x *AccountConfigDeleteSomeResponse) GetError() string

func (*AccountConfigDeleteSomeResponse) GetKey 

func (x *AccountConfigDeleteSomeResponse) GetKey() *AccountKey

func (*AccountConfigDeleteSomeResponse) ProtoMessage 

func (*AccountConfigDeleteSomeResponse) ProtoMessage()

func (*AccountConfigDeleteSomeResponse) ProtoReflect 

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

func (*AccountConfigDeleteSomeResponse) Reset 

func (x *AccountConfigDeleteSomeResponse) Reset()

func (*AccountConfigDeleteSomeResponse) String 

func (x *AccountConfigDeleteSomeResponse) String() string

type AccountConfigRequest 

type AccountConfigRequest struct {

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

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

Deprecated: Use AccountConfigRequest.ProtoReflect.Descriptor instead.

func (*AccountConfigRequest) GetKey 

func (x *AccountConfigRequest) GetKey() *AccountKey

func (*AccountConfigRequest) GetTime 

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

func (*AccountConfigRequest) ProtoMessage 

func (*AccountConfigRequest) ProtoMessage()

func (*AccountConfigRequest) ProtoReflect 

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

func (*AccountConfigRequest) Reset 

func (x *AccountConfigRequest) Reset()

func (*AccountConfigRequest) String 

func (x *AccountConfigRequest) String() string

type AccountConfigResponse 

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

func (*AccountConfigResponse) Descriptor deprecated 

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

Deprecated: Use AccountConfigResponse.ProtoReflect.Descriptor instead.

func (*AccountConfigResponse) GetTime 

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

func (*AccountConfigResponse) GetValue 

func (x *AccountConfigResponse) GetValue() *AccountConfig

func (*AccountConfigResponse) ProtoMessage 

func (*AccountConfigResponse) ProtoMessage()

func (*AccountConfigResponse) ProtoReflect 

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

func (*AccountConfigResponse) Reset 

func (x *AccountConfigResponse) Reset()

func (*AccountConfigResponse) String 

func (x *AccountConfigResponse) String() string

type AccountConfigServiceClient 

type AccountConfigServiceClient interface {
	GetOne(ctx context.Context, in *AccountConfigRequest, opts ...grpc.CallOption) (*AccountConfigResponse, error)
	GetSome(ctx context.Context, in *AccountConfigSomeRequest, opts ...grpc.CallOption) (AccountConfigService_GetSomeClient, error)
	GetAll(ctx context.Context, in *AccountConfigStreamRequest, opts ...grpc.CallOption) (AccountConfigService_GetAllClient, error)
	Subscribe(ctx context.Context, in *AccountConfigStreamRequest, opts ...grpc.CallOption) (AccountConfigService_SubscribeClient, error)
	GetMeta(ctx context.Context, in *AccountConfigStreamRequest, opts ...grpc.CallOption) (*MetaResponse, error)
	SubscribeMeta(ctx context.Context, in *AccountConfigStreamRequest, opts ...grpc.CallOption) (AccountConfigService_SubscribeMetaClient, error)
	Set(ctx context.Context, in *AccountConfigSetRequest, opts ...grpc.CallOption) (*AccountConfigSetResponse, error)
	SetSome(ctx context.Context, in *AccountConfigSetSomeRequest, opts ...grpc.CallOption) (AccountConfigService_SetSomeClient, error)
	Delete(ctx context.Context, in *AccountConfigDeleteRequest, opts ...grpc.CallOption) (*AccountConfigDeleteResponse, error)
	DeleteSome(ctx context.Context, in *AccountConfigDeleteSomeRequest, opts ...grpc.CallOption) (AccountConfigService_DeleteSomeClient, error)
	DeleteAll(ctx context.Context, in *AccountConfigDeleteAllRequest, opts ...grpc.CallOption) (AccountConfigService_DeleteAllClient, error)
}

AccountConfigServiceClient is the client API for AccountConfigService 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 NewAccountConfigServiceClient 

func NewAccountConfigServiceClient(cc grpc.ClientConnInterface) AccountConfigServiceClient

type AccountConfigServiceServer 

type AccountConfigServiceServer interface {
	GetOne(context.Context, *AccountConfigRequest) (*AccountConfigResponse, error)
	GetSome(*AccountConfigSomeRequest, AccountConfigService_GetSomeServer) error
	GetAll(*AccountConfigStreamRequest, AccountConfigService_GetAllServer) error
	Subscribe(*AccountConfigStreamRequest, AccountConfigService_SubscribeServer) error
	GetMeta(context.Context, *AccountConfigStreamRequest) (*MetaResponse, error)
	SubscribeMeta(*AccountConfigStreamRequest, AccountConfigService_SubscribeMetaServer) error
	Set(context.Context, *AccountConfigSetRequest) (*AccountConfigSetResponse, error)
	SetSome(*AccountConfigSetSomeRequest, AccountConfigService_SetSomeServer) error
	Delete(context.Context, *AccountConfigDeleteRequest) (*AccountConfigDeleteResponse, error)
	DeleteSome(*AccountConfigDeleteSomeRequest, AccountConfigService_DeleteSomeServer) error
	DeleteAll(*AccountConfigDeleteAllRequest, AccountConfigService_DeleteAllServer) error
	// contains filtered or unexported methods
}

AccountConfigServiceServer is the server API for AccountConfigService service. All implementations must embed UnimplementedAccountConfigServiceServer for forward compatibility

type AccountConfigService_DeleteAllClient 

type AccountConfigService_DeleteAllClient interface {
	Recv() (*AccountConfigDeleteAllResponse, error)
	grpc.ClientStream
}

type AccountConfigService_DeleteAllServer 

type AccountConfigService_DeleteAllServer interface {
	Send(*AccountConfigDeleteAllResponse) error
	grpc.ServerStream
}

type AccountConfigService_DeleteSomeClient 

type AccountConfigService_DeleteSomeClient interface {
	Recv() (*AccountConfigDeleteSomeResponse, error)
	grpc.ClientStream
}

type AccountConfigService_DeleteSomeServer 

type AccountConfigService_DeleteSomeServer interface {
	Send(*AccountConfigDeleteSomeResponse) error
	grpc.ServerStream
}

type AccountConfigService_GetAllClient 

type AccountConfigService_GetAllClient interface {
	Recv() (*AccountConfigStreamResponse, error)
	grpc.ClientStream
}

type AccountConfigService_GetAllServer 

type AccountConfigService_GetAllServer interface {
	Send(*AccountConfigStreamResponse) error
	grpc.ServerStream
}

type AccountConfigService_GetSomeClient 

type AccountConfigService_GetSomeClient interface {
	Recv() (*AccountConfigSomeResponse, error)
	grpc.ClientStream
}

type AccountConfigService_GetSomeServer 

type AccountConfigService_GetSomeServer interface {
	Send(*AccountConfigSomeResponse) error
	grpc.ServerStream
}

type AccountConfigService_SetSomeClient 

type AccountConfigService_SetSomeClient interface {
	Recv() (*AccountConfigSetSomeResponse, error)
	grpc.ClientStream
}

type AccountConfigService_SetSomeServer 

type AccountConfigService_SetSomeServer interface {
	Send(*AccountConfigSetSomeResponse) error
	grpc.ServerStream
}

type AccountConfigService_SubscribeClient 

type AccountConfigService_SubscribeClient interface {
	Recv() (*AccountConfigStreamResponse, error)
	grpc.ClientStream
}

type AccountConfigService_SubscribeMetaClient 

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

type AccountConfigService_SubscribeMetaServer 

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

type AccountConfigService_SubscribeServer 

type AccountConfigService_SubscribeServer interface {
	Send(*AccountConfigStreamResponse) error
	grpc.ServerStream
}

type AccountConfigSetRequest 

type AccountConfigSetRequest struct {

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

func (*AccountConfigSetRequest) Descriptor deprecated 

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

Deprecated: Use AccountConfigSetRequest.ProtoReflect.Descriptor instead.

func (*AccountConfigSetRequest) GetValue 

func (x *AccountConfigSetRequest) GetValue() *AccountConfig

func (*AccountConfigSetRequest) ProtoMessage 

func (*AccountConfigSetRequest) ProtoMessage()

func (*AccountConfigSetRequest) ProtoReflect 

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

func (*AccountConfigSetRequest) Reset 

func (x *AccountConfigSetRequest) Reset()

func (*AccountConfigSetRequest) String 

func (x *AccountConfigSetRequest) String() string

type AccountConfigSetResponse 

type AccountConfigSetResponse struct {

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

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

Deprecated: Use AccountConfigSetResponse.ProtoReflect.Descriptor instead.

func (*AccountConfigSetResponse) GetTime 

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

func (*AccountConfigSetResponse) GetValue 

func (x *AccountConfigSetResponse) GetValue() *AccountConfig

func (*AccountConfigSetResponse) ProtoMessage 

func (*AccountConfigSetResponse) ProtoMessage()

func (*AccountConfigSetResponse) ProtoReflect 

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

func (*AccountConfigSetResponse) Reset 

func (x *AccountConfigSetResponse) Reset()

func (*AccountConfigSetResponse) String 

func (x *AccountConfigSetResponse) String() string

type AccountConfigSetSomeRequest 

type AccountConfigSetSomeRequest struct {

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

func (*AccountConfigSetSomeRequest) Descriptor deprecated 

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

Deprecated: Use AccountConfigSetSomeRequest.ProtoReflect.Descriptor instead.

func (*AccountConfigSetSomeRequest) GetValues 

func (x *AccountConfigSetSomeRequest) GetValues() []*AccountConfig

func (*AccountConfigSetSomeRequest) ProtoMessage 

func (*AccountConfigSetSomeRequest) ProtoMessage()

func (*AccountConfigSetSomeRequest) ProtoReflect 

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

func (*AccountConfigSetSomeRequest) Reset 

func (x *AccountConfigSetSomeRequest) Reset()

func (*AccountConfigSetSomeRequest) String 

func (x *AccountConfigSetSomeRequest) String() string

type AccountConfigSetSomeResponse 

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

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

Deprecated: Use AccountConfigSetSomeResponse.ProtoReflect.Descriptor instead.

func (*AccountConfigSetSomeResponse) GetError 

func (x *AccountConfigSetSomeResponse) GetError() string

func (*AccountConfigSetSomeResponse) GetKey 

func (x *AccountConfigSetSomeResponse) GetKey() *AccountKey

func (*AccountConfigSetSomeResponse) ProtoMessage 

func (*AccountConfigSetSomeResponse) ProtoMessage()

func (*AccountConfigSetSomeResponse) ProtoReflect 

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

func (*AccountConfigSetSomeResponse) Reset 

func (x *AccountConfigSetSomeResponse) Reset()

func (*AccountConfigSetSomeResponse) String 

func (x *AccountConfigSetSomeResponse) String() string

type AccountConfigSomeRequest 

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

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

Deprecated: Use AccountConfigSomeRequest.ProtoReflect.Descriptor instead.

func (*AccountConfigSomeRequest) GetKeys 

func (x *AccountConfigSomeRequest) GetKeys() []*AccountKey

func (*AccountConfigSomeRequest) GetTime 

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

func (*AccountConfigSomeRequest) ProtoMessage 

func (*AccountConfigSomeRequest) ProtoMessage()

func (*AccountConfigSomeRequest) ProtoReflect 

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

func (*AccountConfigSomeRequest) Reset 

func (x *AccountConfigSomeRequest) Reset()

func (*AccountConfigSomeRequest) String 

func (x *AccountConfigSomeRequest) String() string

type AccountConfigSomeResponse 

type AccountConfigSomeResponse 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 *AccountConfig `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 (*AccountConfigSomeResponse) Descriptor deprecated 

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

Deprecated: Use AccountConfigSomeResponse.ProtoReflect.Descriptor instead.

func (*AccountConfigSomeResponse) GetError 

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

func (*AccountConfigSomeResponse) GetTime 

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

func (*AccountConfigSomeResponse) GetValue 

func (x *AccountConfigSomeResponse) GetValue() *AccountConfig

func (*AccountConfigSomeResponse) ProtoMessage 

func (*AccountConfigSomeResponse) ProtoMessage()

func (*AccountConfigSomeResponse) ProtoReflect 

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

func (*AccountConfigSomeResponse) Reset 

func (x *AccountConfigSomeResponse) Reset()

func (*AccountConfigSomeResponse) String 

func (x *AccountConfigSomeResponse) String() string

type AccountConfigStreamRequest 

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

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

Deprecated: Use AccountConfigStreamRequest.ProtoReflect.Descriptor instead.

func (*AccountConfigStreamRequest) GetPartialEqFilter 

func (x *AccountConfigStreamRequest) GetPartialEqFilter() []*AccountConfig

func (*AccountConfigStreamRequest) GetTime 

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

func (*AccountConfigStreamRequest) ProtoMessage 

func (*AccountConfigStreamRequest) ProtoMessage()

func (*AccountConfigStreamRequest) ProtoReflect 

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

func (*AccountConfigStreamRequest) Reset 

func (x *AccountConfigStreamRequest) Reset()

func (*AccountConfigStreamRequest) String 

func (x *AccountConfigStreamRequest) String() string

type AccountConfigStreamResponse 

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

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

Deprecated: Use AccountConfigStreamResponse.ProtoReflect.Descriptor instead.

func (*AccountConfigStreamResponse) GetTime 

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

func (*AccountConfigStreamResponse) GetType 

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

func (*AccountConfigStreamResponse) GetValue 

func (x *AccountConfigStreamResponse) GetValue() *AccountConfig

func (*AccountConfigStreamResponse) ProtoMessage 

func (*AccountConfigStreamResponse) ProtoMessage()

func (*AccountConfigStreamResponse) ProtoReflect 

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

func (*AccountConfigStreamResponse) Reset 

func (x *AccountConfigStreamResponse) Reset()

func (*AccountConfigStreamResponse) String 

func (x *AccountConfigStreamResponse) String() string

type AccountKey 

type AccountKey struct {

	// name is the unique identifier of the service account.
	Name *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

AccountKey contains the name of the service account.

func (*AccountKey) Descriptor deprecated 

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

Deprecated: Use AccountKey.ProtoReflect.Descriptor instead.

func (*AccountKey) GetName 

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

func (*AccountKey) ProtoMessage 

func (*AccountKey) ProtoMessage()

func (*AccountKey) ProtoReflect 

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

func (*AccountKey) Reset 

func (x *AccountKey) Reset()

func (*AccountKey) String 

func (x *AccountKey) String() string

type AccountRequest 

type AccountRequest struct {

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

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

Deprecated: Use AccountRequest.ProtoReflect.Descriptor instead.

func (*AccountRequest) GetKey 

func (x *AccountRequest) GetKey() *AccountKey

func (*AccountRequest) GetTime 

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

func (*AccountRequest) ProtoMessage 

func (*AccountRequest) ProtoMessage()

func (*AccountRequest) ProtoReflect 

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

func (*AccountRequest) Reset 

func (x *AccountRequest) Reset()

func (*AccountRequest) String 

func (x *AccountRequest) String() string

type AccountResponse 

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

func (*AccountResponse) Descriptor deprecated 

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

Deprecated: Use AccountResponse.ProtoReflect.Descriptor instead.

func (*AccountResponse) GetTime 

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

func (*AccountResponse) GetValue 

func (x *AccountResponse) GetValue() *Account

func (*AccountResponse) ProtoMessage 

func (*AccountResponse) ProtoMessage()

func (*AccountResponse) ProtoReflect 

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

func (*AccountResponse) Reset 

func (x *AccountResponse) Reset()

func (*AccountResponse) String 

func (x *AccountResponse) String() string

type AccountServiceClient 

type AccountServiceClient interface {
	GetOne(ctx context.Context, in *AccountRequest, opts ...grpc.CallOption) (*AccountResponse, error)
	GetSome(ctx context.Context, in *AccountSomeRequest, opts ...grpc.CallOption) (AccountService_GetSomeClient, error)
	GetAll(ctx context.Context, in *AccountStreamRequest, opts ...grpc.CallOption) (AccountService_GetAllClient, error)
	Subscribe(ctx context.Context, in *AccountStreamRequest, opts ...grpc.CallOption) (AccountService_SubscribeClient, error)
	GetMeta(ctx context.Context, in *AccountStreamRequest, opts ...grpc.CallOption) (*MetaResponse, error)
	SubscribeMeta(ctx context.Context, in *AccountStreamRequest, opts ...grpc.CallOption) (AccountService_SubscribeMetaClient, error)
}

AccountServiceClient is the client API for AccountService 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 NewAccountServiceClient 

func NewAccountServiceClient(cc grpc.ClientConnInterface) AccountServiceClient

type AccountServiceServer 

type AccountServiceServer interface {
	GetOne(context.Context, *AccountRequest) (*AccountResponse, error)
	GetSome(*AccountSomeRequest, AccountService_GetSomeServer) error
	GetAll(*AccountStreamRequest, AccountService_GetAllServer) error
	Subscribe(*AccountStreamRequest, AccountService_SubscribeServer) error
	GetMeta(context.Context, *AccountStreamRequest) (*MetaResponse, error)
	SubscribeMeta(*AccountStreamRequest, AccountService_SubscribeMetaServer) error
	// contains filtered or unexported methods
}

AccountServiceServer is the server API for AccountService service. All implementations must embed UnimplementedAccountServiceServer for forward compatibility

type AccountService_GetAllClient 

type AccountService_GetAllClient interface {
	Recv() (*AccountStreamResponse, error)
	grpc.ClientStream
}

type AccountService_GetAllServer 

type AccountService_GetAllServer interface {
	Send(*AccountStreamResponse) error
	grpc.ServerStream
}

type AccountService_GetSomeClient 

type AccountService_GetSomeClient interface {
	Recv() (*AccountSomeResponse, error)
	grpc.ClientStream
}

type AccountService_GetSomeServer 

type AccountService_GetSomeServer interface {
	Send(*AccountSomeResponse) error
	grpc.ServerStream
}

type AccountService_SubscribeClient 

type AccountService_SubscribeClient interface {
	Recv() (*AccountStreamResponse, error)
	grpc.ClientStream
}

type AccountService_SubscribeMetaClient 

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

type AccountService_SubscribeMetaServer 

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

type AccountService_SubscribeServer 

type AccountService_SubscribeServer interface {
	Send(*AccountStreamResponse) error
	grpc.ServerStream
}

type AccountSomeRequest 

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

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

Deprecated: Use AccountSomeRequest.ProtoReflect.Descriptor instead.

func (*AccountSomeRequest) GetKeys 

func (x *AccountSomeRequest) GetKeys() []*AccountKey

func (*AccountSomeRequest) GetTime 

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

func (*AccountSomeRequest) ProtoMessage 

func (*AccountSomeRequest) ProtoMessage()

func (*AccountSomeRequest) ProtoReflect 

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

func (*AccountSomeRequest) Reset 

func (x *AccountSomeRequest) Reset()

func (*AccountSomeRequest) String 

func (x *AccountSomeRequest) String() string

type AccountSomeResponse 

type AccountSomeResponse 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 *Account `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 (*AccountSomeResponse) Descriptor deprecated 

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

Deprecated: Use AccountSomeResponse.ProtoReflect.Descriptor instead.

func (*AccountSomeResponse) GetError 

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

func (*AccountSomeResponse) GetTime 

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

func (*AccountSomeResponse) GetValue 

func (x *AccountSomeResponse) GetValue() *Account

func (*AccountSomeResponse) ProtoMessage 

func (*AccountSomeResponse) ProtoMessage()

func (*AccountSomeResponse) ProtoReflect 

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

func (*AccountSomeResponse) Reset 

func (x *AccountSomeResponse) Reset()

func (*AccountSomeResponse) String 

func (x *AccountSomeResponse) String() string

type AccountStatus 

type AccountStatus int32

AccountStatus determines whether an service account is enabled or disabled. 

const (
	// ACCOUNT_STATUS_UNSPECIFIED indicates the service account status is unspecified.
	AccountStatus_ACCOUNT_STATUS_UNSPECIFIED AccountStatus = 0
	// ACCOUNT_STATUS_ENABLED indicates the service account is enabled.
	AccountStatus_ACCOUNT_STATUS_ENABLED AccountStatus = 1
	// ACCOUNT_STATUS_DISABLED indicates the service account is disabled.
	AccountStatus_ACCOUNT_STATUS_DISABLED AccountStatus = 2
)

func (AccountStatus) Descriptor 

func (AccountStatus) Descriptor() protoreflect.EnumDescriptor

func (AccountStatus) Enum 

func (x AccountStatus) Enum() *AccountStatus

func (AccountStatus) EnumDescriptor deprecated 

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

Deprecated: Use AccountStatus.Descriptor instead.

func (AccountStatus) Number 

func (x AccountStatus) Number() protoreflect.EnumNumber

func (AccountStatus) String 

func (x AccountStatus) String() string

func (AccountStatus) Type 

func (AccountStatus) Type() protoreflect.EnumType

type AccountStreamRequest 

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

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

Deprecated: Use AccountStreamRequest.ProtoReflect.Descriptor instead.

func (*AccountStreamRequest) GetPartialEqFilter 

func (x *AccountStreamRequest) GetPartialEqFilter() []*Account

func (*AccountStreamRequest) GetTime 

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

func (*AccountStreamRequest) ProtoMessage 

func (*AccountStreamRequest) ProtoMessage()

func (*AccountStreamRequest) ProtoReflect 

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

func (*AccountStreamRequest) Reset 

func (x *AccountStreamRequest) Reset()

func (*AccountStreamRequest) String 

func (x *AccountStreamRequest) String() string

type AccountStreamResponse 

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

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

Deprecated: Use AccountStreamResponse.ProtoReflect.Descriptor instead.

func (*AccountStreamResponse) GetTime 

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

func (*AccountStreamResponse) GetType 

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

func (*AccountStreamResponse) GetValue 

func (x *AccountStreamResponse) GetValue() *Account

func (*AccountStreamResponse) ProtoMessage 

func (*AccountStreamResponse) ProtoMessage()

func (*AccountStreamResponse) ProtoReflect 

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

func (*AccountStreamResponse) Reset 

func (x *AccountStreamResponse) Reset()

func (*AccountStreamResponse) String 

func (x *AccountStreamResponse) String() string

type MetaResponse 

type MetaResponse struct {

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

func (*MetaResponse) Descriptor deprecated 

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

Deprecated: Use MetaResponse.ProtoReflect.Descriptor instead.

func (*MetaResponse) GetCount 

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

func (*MetaResponse) GetTime 

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

func (*MetaResponse) GetType 

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

func (*MetaResponse) ProtoMessage 

func (*MetaResponse) ProtoMessage()

func (*MetaResponse) ProtoReflect 

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

func (*MetaResponse) Reset 

func (x *MetaResponse) Reset()

func (*MetaResponse) String 

func (x *MetaResponse) String() string

type Token 

type Token struct {

	// key uniquely identifies the service account token.
	Key *TokenKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// user is the name of the service account that the token is generated for.
	User *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	// description is a short name or comment used to identify the service account token.
	Description *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// valid_until is the time that the service account token will be valid until.
	ValidUntil *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=valid_until,json=validUntil,proto3" json:"valid_until,omitempty"`
	// created_by is the name of the entity that created the service account token.
	CreatedBy *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=created_by,json=createdBy,proto3" json:"created_by,omitempty"`
	// last_used is the time when the service account token was last used to authenticate.
	LastUsed *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=last_used,json=lastUsed,proto3" json:"last_used,omitempty"`
	// contains filtered or unexported fields
}

Token describes a service account token.

func (*Token) Descriptor deprecated 

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

Deprecated: Use Token.ProtoReflect.Descriptor instead.

func (*Token) GetCreatedBy 

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

func (*Token) GetDescription 

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

func (*Token) GetKey 

func (x *Token) GetKey() *TokenKey

func (*Token) GetLastUsed 

func (x *Token) GetLastUsed() *timestamppb.Timestamp

func (*Token) GetUser 

func (x *Token) GetUser() *wrapperspb.StringValue

func (*Token) GetValidUntil 

func (x *Token) GetValidUntil() *timestamppb.Timestamp

func (*Token) ProtoMessage 

func (*Token) ProtoMessage()

func (*Token) ProtoReflect 

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

func (*Token) Reset 

func (x *Token) Reset()

func (*Token) String 

func (x *Token) String() string

type TokenConfig 

type TokenConfig struct {

	// key uniquely identifies the service account token.
	Key *TokenKey `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// user is the name of the service account that the token is generated for.
	User *wrapperspb.StringValue `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	// description is a short name or comment used to identify the service account token.
	Description *wrapperspb.StringValue `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	// valid_for determines the duration that the service account token will be valid for.
	ValidFor *durationpb.Duration `protobuf:"bytes,4,opt,name=valid_for,json=validFor,proto3" json:"valid_for,omitempty"`
	// token is the JWT token generated for a service account token.
	// It is only populated in Set response.
	Token *wrapperspb.StringValue `protobuf:"bytes,5,opt,name=token,proto3" json:"token,omitempty"`
	// contains filtered or unexported fields
}

TokenConfig holds the configuration for a service account token. The token is a signed JWT which can be used as a credential for REST and WRPC endpoints.

func (*TokenConfig) Descriptor deprecated 

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

Deprecated: Use TokenConfig.ProtoReflect.Descriptor instead.

func (*TokenConfig) GetDescription 

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

func (*TokenConfig) GetKey 

func (x *TokenConfig) GetKey() *TokenKey

func (*TokenConfig) GetToken 

func (x *TokenConfig) GetToken() *wrapperspb.StringValue

func (*TokenConfig) GetUser 

func (x *TokenConfig) GetUser() *wrapperspb.StringValue

func (*TokenConfig) GetValidFor 

func (x *TokenConfig) GetValidFor() *durationpb.Duration

func (*TokenConfig) ProtoMessage 

func (*TokenConfig) ProtoMessage()

func (*TokenConfig) ProtoReflect 

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

func (*TokenConfig) Reset 

func (x *TokenConfig) Reset()

func (*TokenConfig) String 

func (x *TokenConfig) String() string

type TokenConfigDeleteAllRequest 

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

func (*TokenConfigDeleteAllRequest) Descriptor deprecated 

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

Deprecated: Use TokenConfigDeleteAllRequest.ProtoReflect.Descriptor instead.

func (*TokenConfigDeleteAllRequest) ProtoMessage 

func (*TokenConfigDeleteAllRequest) ProtoMessage()

func (*TokenConfigDeleteAllRequest) ProtoReflect 

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

func (*TokenConfigDeleteAllRequest) Reset 

func (x *TokenConfigDeleteAllRequest) Reset()

func (*TokenConfigDeleteAllRequest) String 

func (x *TokenConfigDeleteAllRequest) String() string

type TokenConfigDeleteAllResponse 

type TokenConfigDeleteAllResponse struct {

	// This describes the class of delete 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 TokenConfig instance that failed to be deleted.
	Key *TokenKey `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 (*TokenConfigDeleteAllResponse) Descriptor deprecated 

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

Deprecated: Use TokenConfigDeleteAllResponse.ProtoReflect.Descriptor instead.

func (*TokenConfigDeleteAllResponse) GetError 

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

func (*TokenConfigDeleteAllResponse) GetKey 

func (x *TokenConfigDeleteAllResponse) GetKey() *TokenKey

func (*TokenConfigDeleteAllResponse) GetTime 

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

func (*TokenConfigDeleteAllResponse) GetType 

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

func (*TokenConfigDeleteAllResponse) ProtoMessage 

func (*TokenConfigDeleteAllResponse) ProtoMessage()

func (*TokenConfigDeleteAllResponse) ProtoReflect 

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

func (*TokenConfigDeleteAllResponse) Reset 

func (x *TokenConfigDeleteAllResponse) Reset()

func (*TokenConfigDeleteAllResponse) String 

func (x *TokenConfigDeleteAllResponse) String() string

type TokenConfigDeleteRequest 

type TokenConfigDeleteRequest struct {

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

func (*TokenConfigDeleteRequest) Descriptor deprecated 

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

Deprecated: Use TokenConfigDeleteRequest.ProtoReflect.Descriptor instead.

func (*TokenConfigDeleteRequest) GetKey 

func (x *TokenConfigDeleteRequest) GetKey() *TokenKey

func (*TokenConfigDeleteRequest) ProtoMessage 

func (*TokenConfigDeleteRequest) ProtoMessage()

func (*TokenConfigDeleteRequest) ProtoReflect 

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

func (*TokenConfigDeleteRequest) Reset 

func (x *TokenConfigDeleteRequest) Reset()

func (*TokenConfigDeleteRequest) String 

func (x *TokenConfigDeleteRequest) String() string

type TokenConfigDeleteResponse 

type TokenConfigDeleteResponse struct {

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

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

Deprecated: Use TokenConfigDeleteResponse.ProtoReflect.Descriptor instead.

func (*TokenConfigDeleteResponse) GetKey 

func (x *TokenConfigDeleteResponse) GetKey() *TokenKey

func (*TokenConfigDeleteResponse) GetTime 

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

func (*TokenConfigDeleteResponse) ProtoMessage 

func (*TokenConfigDeleteResponse) ProtoMessage()

func (*TokenConfigDeleteResponse) ProtoReflect 

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

func (*TokenConfigDeleteResponse) Reset 

func (x *TokenConfigDeleteResponse) Reset()

func (*TokenConfigDeleteResponse) String 

func (x *TokenConfigDeleteResponse) String() string

type TokenConfigDeleteSomeRequest 

type TokenConfigDeleteSomeRequest struct {

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

func (*TokenConfigDeleteSomeRequest) Descriptor deprecated 

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

Deprecated: Use TokenConfigDeleteSomeRequest.ProtoReflect.Descriptor instead.

func (*TokenConfigDeleteSomeRequest) GetKeys 

func (x *TokenConfigDeleteSomeRequest) GetKeys() []*TokenKey

func (*TokenConfigDeleteSomeRequest) ProtoMessage 

func (*TokenConfigDeleteSomeRequest) ProtoMessage()

func (*TokenConfigDeleteSomeRequest) ProtoReflect 

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

func (*TokenConfigDeleteSomeRequest) Reset 

func (x *TokenConfigDeleteSomeRequest) Reset()

func (*TokenConfigDeleteSomeRequest) String 

func (x *TokenConfigDeleteSomeRequest) String() string

type TokenConfigDeleteSomeResponse 

type TokenConfigDeleteSomeResponse struct {
	Key   *TokenKey `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
}

TokenConfigDeleteSomeResponse is only sent when there is an error.

func (*TokenConfigDeleteSomeResponse) Descriptor deprecated 

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

Deprecated: Use TokenConfigDeleteSomeResponse.ProtoReflect.Descriptor instead.

func (*TokenConfigDeleteSomeResponse) GetError 

func (x *TokenConfigDeleteSomeResponse) GetError() string

func (*TokenConfigDeleteSomeResponse) GetKey 

func (x *TokenConfigDeleteSomeResponse) GetKey() *TokenKey

func (*TokenConfigDeleteSomeResponse) ProtoMessage 

func (*TokenConfigDeleteSomeResponse) ProtoMessage()

func (*TokenConfigDeleteSomeResponse) ProtoReflect 

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

func (*TokenConfigDeleteSomeResponse) Reset 

func (x *TokenConfigDeleteSomeResponse) Reset()

func (*TokenConfigDeleteSomeResponse) String 

func (x *TokenConfigDeleteSomeResponse) String() string

type TokenConfigRequest 

type TokenConfigRequest struct {

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

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

Deprecated: Use TokenConfigRequest.ProtoReflect.Descriptor instead.

func (*TokenConfigRequest) GetKey 

func (x *TokenConfigRequest) GetKey() *TokenKey

func (*TokenConfigRequest) GetTime 

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

func (*TokenConfigRequest) ProtoMessage 

func (*TokenConfigRequest) ProtoMessage()

func (*TokenConfigRequest) ProtoReflect 

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

func (*TokenConfigRequest) Reset 

func (x *TokenConfigRequest) Reset()

func (*TokenConfigRequest) String 

func (x *TokenConfigRequest) String() string

type TokenConfigResponse 

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

func (*TokenConfigResponse) Descriptor deprecated 

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

Deprecated: Use TokenConfigResponse.ProtoReflect.Descriptor instead.

func (*TokenConfigResponse) GetTime 

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

func (*TokenConfigResponse) GetValue 

func (x *TokenConfigResponse) GetValue() *TokenConfig

func (*TokenConfigResponse) ProtoMessage 

func (*TokenConfigResponse) ProtoMessage()

func (*TokenConfigResponse) ProtoReflect 

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

func (*TokenConfigResponse) Reset 

func (x *TokenConfigResponse) Reset()

func (*TokenConfigResponse) String 

func (x *TokenConfigResponse) String() string

type TokenConfigServiceClient 

type TokenConfigServiceClient interface {
	GetOne(ctx context.Context, in *TokenConfigRequest, opts ...grpc.CallOption) (*TokenConfigResponse, error)
	GetSome(ctx context.Context, in *TokenConfigSomeRequest, opts ...grpc.CallOption) (TokenConfigService_GetSomeClient, error)
	GetAll(ctx context.Context, in *TokenConfigStreamRequest, opts ...grpc.CallOption) (TokenConfigService_GetAllClient, error)
	Subscribe(ctx context.Context, in *TokenConfigStreamRequest, opts ...grpc.CallOption) (TokenConfigService_SubscribeClient, error)
	GetMeta(ctx context.Context, in *TokenConfigStreamRequest, opts ...grpc.CallOption) (*MetaResponse, error)
	SubscribeMeta(ctx context.Context, in *TokenConfigStreamRequest, opts ...grpc.CallOption) (TokenConfigService_SubscribeMetaClient, error)
	Set(ctx context.Context, in *TokenConfigSetRequest, opts ...grpc.CallOption) (*TokenConfigSetResponse, error)
	SetSome(ctx context.Context, in *TokenConfigSetSomeRequest, opts ...grpc.CallOption) (TokenConfigService_SetSomeClient, error)
	Delete(ctx context.Context, in *TokenConfigDeleteRequest, opts ...grpc.CallOption) (*TokenConfigDeleteResponse, error)
	DeleteSome(ctx context.Context, in *TokenConfigDeleteSomeRequest, opts ...grpc.CallOption) (TokenConfigService_DeleteSomeClient, error)
	DeleteAll(ctx context.Context, in *TokenConfigDeleteAllRequest, opts ...grpc.CallOption) (TokenConfigService_DeleteAllClient, error)
}

TokenConfigServiceClient is the client API for TokenConfigService 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 NewTokenConfigServiceClient 

func NewTokenConfigServiceClient(cc grpc.ClientConnInterface) TokenConfigServiceClient

type TokenConfigServiceServer 

type TokenConfigServiceServer interface {
	GetOne(context.Context, *TokenConfigRequest) (*TokenConfigResponse, error)
	GetSome(*TokenConfigSomeRequest, TokenConfigService_GetSomeServer) error
	GetAll(*TokenConfigStreamRequest, TokenConfigService_GetAllServer) error
	Subscribe(*TokenConfigStreamRequest, TokenConfigService_SubscribeServer) error
	GetMeta(context.Context, *TokenConfigStreamRequest) (*MetaResponse, error)
	SubscribeMeta(*TokenConfigStreamRequest, TokenConfigService_SubscribeMetaServer) error
	Set(context.Context, *TokenConfigSetRequest) (*TokenConfigSetResponse, error)
	SetSome(*TokenConfigSetSomeRequest, TokenConfigService_SetSomeServer) error
	Delete(context.Context, *TokenConfigDeleteRequest) (*TokenConfigDeleteResponse, error)
	DeleteSome(*TokenConfigDeleteSomeRequest, TokenConfigService_DeleteSomeServer) error
	DeleteAll(*TokenConfigDeleteAllRequest, TokenConfigService_DeleteAllServer) error
	// contains filtered or unexported methods
}

TokenConfigServiceServer is the server API for TokenConfigService service. All implementations must embed UnimplementedTokenConfigServiceServer for forward compatibility

type TokenConfigService_DeleteAllClient 

type TokenConfigService_DeleteAllClient interface {
	Recv() (*TokenConfigDeleteAllResponse, error)
	grpc.ClientStream
}

type TokenConfigService_DeleteAllServer 

type TokenConfigService_DeleteAllServer interface {
	Send(*TokenConfigDeleteAllResponse) error
	grpc.ServerStream
}

type TokenConfigService_DeleteSomeClient 

type TokenConfigService_DeleteSomeClient interface {
	Recv() (*TokenConfigDeleteSomeResponse, error)
	grpc.ClientStream
}

type TokenConfigService_DeleteSomeServer 

type TokenConfigService_DeleteSomeServer interface {
	Send(*TokenConfigDeleteSomeResponse) error
	grpc.ServerStream
}

type TokenConfigService_GetAllClient 

type TokenConfigService_GetAllClient interface {
	Recv() (*TokenConfigStreamResponse, error)
	grpc.ClientStream
}

type TokenConfigService_GetAllServer 

type TokenConfigService_GetAllServer interface {
	Send(*TokenConfigStreamResponse) error
	grpc.ServerStream
}

type TokenConfigService_GetSomeClient 

type TokenConfigService_GetSomeClient interface {
	Recv() (*TokenConfigSomeResponse, error)
	grpc.ClientStream
}

type TokenConfigService_GetSomeServer 

type TokenConfigService_GetSomeServer interface {
	Send(*TokenConfigSomeResponse) error
	grpc.ServerStream
}

type TokenConfigService_SetSomeClient 

type TokenConfigService_SetSomeClient interface {
	Recv() (*TokenConfigSetSomeResponse, error)
	grpc.ClientStream
}

type TokenConfigService_SetSomeServer 

type TokenConfigService_SetSomeServer interface {
	Send(*TokenConfigSetSomeResponse) error
	grpc.ServerStream
}

type TokenConfigService_SubscribeClient 

type TokenConfigService_SubscribeClient interface {
	Recv() (*TokenConfigStreamResponse, error)
	grpc.ClientStream
}

type TokenConfigService_SubscribeMetaClient 

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

type TokenConfigService_SubscribeMetaServer 

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

type TokenConfigService_SubscribeServer 

type TokenConfigService_SubscribeServer interface {
	Send(*TokenConfigStreamResponse) error
	grpc.ServerStream
}

type TokenConfigSetRequest 

type TokenConfigSetRequest struct {

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

func (*TokenConfigSetRequest) Descriptor deprecated 

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

Deprecated: Use TokenConfigSetRequest.ProtoReflect.Descriptor instead.

func (*TokenConfigSetRequest) GetValue 

func (x *TokenConfigSetRequest) GetValue() *TokenConfig

func (*TokenConfigSetRequest) ProtoMessage 

func (*TokenConfigSetRequest) ProtoMessage()

func (*TokenConfigSetRequest) ProtoReflect 

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

func (*TokenConfigSetRequest) Reset 

func (x *TokenConfigSetRequest) Reset()

func (*TokenConfigSetRequest) String 

func (x *TokenConfigSetRequest) String() string

type TokenConfigSetResponse 

type TokenConfigSetResponse struct {

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

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

Deprecated: Use TokenConfigSetResponse.ProtoReflect.Descriptor instead.

func (*TokenConfigSetResponse) GetTime 

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

func (*TokenConfigSetResponse) GetValue 

func (x *TokenConfigSetResponse) GetValue() *TokenConfig

func (*TokenConfigSetResponse) ProtoMessage 

func (*TokenConfigSetResponse) ProtoMessage()

func (*TokenConfigSetResponse) ProtoReflect 

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

func (*TokenConfigSetResponse) Reset 

func (x *TokenConfigSetResponse) Reset()

func (*TokenConfigSetResponse) String 

func (x *TokenConfigSetResponse) String() string

type TokenConfigSetSomeRequest 

type TokenConfigSetSomeRequest struct {

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

func (*TokenConfigSetSomeRequest) Descriptor deprecated 

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

Deprecated: Use TokenConfigSetSomeRequest.ProtoReflect.Descriptor instead.

func (*TokenConfigSetSomeRequest) GetValues 

func (x *TokenConfigSetSomeRequest) GetValues() []*TokenConfig

func (*TokenConfigSetSomeRequest) ProtoMessage 

func (*TokenConfigSetSomeRequest) ProtoMessage()

func (*TokenConfigSetSomeRequest) ProtoReflect 

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

func (*TokenConfigSetSomeRequest) Reset 

func (x *TokenConfigSetSomeRequest) Reset()

func (*TokenConfigSetSomeRequest) String 

func (x *TokenConfigSetSomeRequest) String() string

type TokenConfigSetSomeResponse 

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

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

Deprecated: Use TokenConfigSetSomeResponse.ProtoReflect.Descriptor instead.

func (*TokenConfigSetSomeResponse) GetError 

func (x *TokenConfigSetSomeResponse) GetError() string

func (*TokenConfigSetSomeResponse) GetKey 

func (x *TokenConfigSetSomeResponse) GetKey() *TokenKey

func (*TokenConfigSetSomeResponse) ProtoMessage 

func (*TokenConfigSetSomeResponse) ProtoMessage()

func (*TokenConfigSetSomeResponse) ProtoReflect 

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

func (*TokenConfigSetSomeResponse) Reset 

func (x *TokenConfigSetSomeResponse) Reset()

func (*TokenConfigSetSomeResponse) String 

func (x *TokenConfigSetSomeResponse) String() string

type TokenConfigSomeRequest 

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

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

Deprecated: Use TokenConfigSomeRequest.ProtoReflect.Descriptor instead.

func (*TokenConfigSomeRequest) GetKeys 

func (x *TokenConfigSomeRequest) GetKeys() []*TokenKey

func (*TokenConfigSomeRequest) GetTime 

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

func (*TokenConfigSomeRequest) ProtoMessage 

func (*TokenConfigSomeRequest) ProtoMessage()

func (*TokenConfigSomeRequest) ProtoReflect 

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

func (*TokenConfigSomeRequest) Reset 

func (x *TokenConfigSomeRequest) Reset()

func (*TokenConfigSomeRequest) String 

func (x *TokenConfigSomeRequest) String() string

type TokenConfigSomeResponse 

type TokenConfigSomeResponse 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 *TokenConfig `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 (*TokenConfigSomeResponse) Descriptor deprecated 

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

Deprecated: Use TokenConfigSomeResponse.ProtoReflect.Descriptor instead.

func (*TokenConfigSomeResponse) GetError 

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

func (*TokenConfigSomeResponse) GetTime 

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

func (*TokenConfigSomeResponse) GetValue 

func (x *TokenConfigSomeResponse) GetValue() *TokenConfig

func (*TokenConfigSomeResponse) ProtoMessage 

func (*TokenConfigSomeResponse) ProtoMessage()

func (*TokenConfigSomeResponse) ProtoReflect 

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

func (*TokenConfigSomeResponse) Reset 

func (x *TokenConfigSomeResponse) Reset()

func (*TokenConfigSomeResponse) String 

func (x *TokenConfigSomeResponse) String() string

type TokenConfigStreamRequest 

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

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

Deprecated: Use TokenConfigStreamRequest.ProtoReflect.Descriptor instead.

func (*TokenConfigStreamRequest) GetPartialEqFilter 

func (x *TokenConfigStreamRequest) GetPartialEqFilter() []*TokenConfig

func (*TokenConfigStreamRequest) GetTime 

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

func (*TokenConfigStreamRequest) ProtoMessage 

func (*TokenConfigStreamRequest) ProtoMessage()

func (*TokenConfigStreamRequest) ProtoReflect 

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

func (*TokenConfigStreamRequest) Reset 

func (x *TokenConfigStreamRequest) Reset()

func (*TokenConfigStreamRequest) String 

func (x *TokenConfigStreamRequest) String() string

type TokenConfigStreamResponse 

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

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

Deprecated: Use TokenConfigStreamResponse.ProtoReflect.Descriptor instead.

func (*TokenConfigStreamResponse) GetTime 

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

func (*TokenConfigStreamResponse) GetType 

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

func (*TokenConfigStreamResponse) GetValue 

func (x *TokenConfigStreamResponse) GetValue() *TokenConfig

func (*TokenConfigStreamResponse) ProtoMessage 

func (*TokenConfigStreamResponse) ProtoMessage()

func (*TokenConfigStreamResponse) ProtoReflect 

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

func (*TokenConfigStreamResponse) Reset 

func (x *TokenConfigStreamResponse) Reset()

func (*TokenConfigStreamResponse) String 

func (x *TokenConfigStreamResponse) String() string

type TokenKey 

type TokenKey struct {

	// id is the unique identifier of the service account token.
	Id *wrapperspb.StringValue `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

TokenKey contains service account token ID.

func (*TokenKey) Descriptor deprecated 

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

Deprecated: Use TokenKey.ProtoReflect.Descriptor instead.

func (*TokenKey) GetId 

func (x *TokenKey) GetId() *wrapperspb.StringValue

func (*TokenKey) ProtoMessage 

func (*TokenKey) ProtoMessage()

func (*TokenKey) ProtoReflect 

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

func (*TokenKey) Reset 

func (x *TokenKey) Reset()

func (*TokenKey) String 

func (x *TokenKey) String() string

type TokenRequest 

type TokenRequest struct {

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

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

Deprecated: Use TokenRequest.ProtoReflect.Descriptor instead.

func (*TokenRequest) GetKey 

func (x *TokenRequest) GetKey() *TokenKey

func (*TokenRequest) GetTime 

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

func (*TokenRequest) ProtoMessage 

func (*TokenRequest) ProtoMessage()

func (*TokenRequest) ProtoReflect 

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

func (*TokenRequest) Reset 

func (x *TokenRequest) Reset()

func (*TokenRequest) String 

func (x *TokenRequest) String() string

type TokenResponse 

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

func (*TokenResponse) Descriptor deprecated 

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

Deprecated: Use TokenResponse.ProtoReflect.Descriptor instead.

func (*TokenResponse) GetTime 

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

func (*TokenResponse) GetValue 

func (x *TokenResponse) GetValue() *Token

func (*TokenResponse) ProtoMessage 

func (*TokenResponse) ProtoMessage()

func (*TokenResponse) ProtoReflect 

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

func (*TokenResponse) Reset 

func (x *TokenResponse) Reset()

func (*TokenResponse) String 

func (x *TokenResponse) String() string

type TokenServiceClient 

type TokenServiceClient interface {
	GetOne(ctx context.Context, in *TokenRequest, opts ...grpc.CallOption) (*TokenResponse, error)
	GetSome(ctx context.Context, in *TokenSomeRequest, opts ...grpc.CallOption) (TokenService_GetSomeClient, error)
	GetAll(ctx context.Context, in *TokenStreamRequest, opts ...grpc.CallOption) (TokenService_GetAllClient, error)
	Subscribe(ctx context.Context, in *TokenStreamRequest, opts ...grpc.CallOption) (TokenService_SubscribeClient, error)
	GetMeta(ctx context.Context, in *TokenStreamRequest, opts ...grpc.CallOption) (*MetaResponse, error)
	SubscribeMeta(ctx context.Context, in *TokenStreamRequest, opts ...grpc.CallOption) (TokenService_SubscribeMetaClient, error)
}

TokenServiceClient is the client API for TokenService 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 NewTokenServiceClient 

func NewTokenServiceClient(cc grpc.ClientConnInterface) TokenServiceClient

type TokenServiceServer 

type TokenServiceServer interface {
	GetOne(context.Context, *TokenRequest) (*TokenResponse, error)
	GetSome(*TokenSomeRequest, TokenService_GetSomeServer) error
	GetAll(*TokenStreamRequest, TokenService_GetAllServer) error
	Subscribe(*TokenStreamRequest, TokenService_SubscribeServer) error
	GetMeta(context.Context, *TokenStreamRequest) (*MetaResponse, error)
	SubscribeMeta(*TokenStreamRequest, TokenService_SubscribeMetaServer) error
	// contains filtered or unexported methods
}

TokenServiceServer is the server API for TokenService service. All implementations must embed UnimplementedTokenServiceServer for forward compatibility

type TokenService_GetAllClient 

type TokenService_GetAllClient interface {
	Recv() (*TokenStreamResponse, error)
	grpc.ClientStream
}

type TokenService_GetAllServer 

type TokenService_GetAllServer interface {
	Send(*TokenStreamResponse) error
	grpc.ServerStream
}

type TokenService_GetSomeClient 

type TokenService_GetSomeClient interface {
	Recv() (*TokenSomeResponse, error)
	grpc.ClientStream
}

type TokenService_GetSomeServer 

type TokenService_GetSomeServer interface {
	Send(*TokenSomeResponse) error
	grpc.ServerStream
}

type TokenService_SubscribeClient 

type TokenService_SubscribeClient interface {
	Recv() (*TokenStreamResponse, error)
	grpc.ClientStream
}

type TokenService_SubscribeMetaClient 

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

type TokenService_SubscribeMetaServer 

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

type TokenService_SubscribeServer 

type TokenService_SubscribeServer interface {
	Send(*TokenStreamResponse) error
	grpc.ServerStream
}

type TokenSomeRequest 

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

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

Deprecated: Use TokenSomeRequest.ProtoReflect.Descriptor instead.

func (*TokenSomeRequest) GetKeys 

func (x *TokenSomeRequest) GetKeys() []*TokenKey

func (*TokenSomeRequest) GetTime 

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

func (*TokenSomeRequest) ProtoMessage 

func (*TokenSomeRequest) ProtoMessage()

func (*TokenSomeRequest) ProtoReflect 

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

func (*TokenSomeRequest) Reset 

func (x *TokenSomeRequest) Reset()

func (*TokenSomeRequest) String 

func (x *TokenSomeRequest) String() string

type TokenSomeResponse 

type TokenSomeResponse 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 *Token `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 (*TokenSomeResponse) Descriptor deprecated 

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

Deprecated: Use TokenSomeResponse.ProtoReflect.Descriptor instead.

func (*TokenSomeResponse) GetError 

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

func (*TokenSomeResponse) GetTime 

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

func (*TokenSomeResponse) GetValue 

func (x *TokenSomeResponse) GetValue() *Token

func (*TokenSomeResponse) ProtoMessage 

func (*TokenSomeResponse) ProtoMessage()

func (*TokenSomeResponse) ProtoReflect 

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

func (*TokenSomeResponse) Reset 

func (x *TokenSomeResponse) Reset()

func (*TokenSomeResponse) String 

func (x *TokenSomeResponse) String() string

type TokenStreamRequest 

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

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

Deprecated: Use TokenStreamRequest.ProtoReflect.Descriptor instead.

func (*TokenStreamRequest) GetPartialEqFilter 

func (x *TokenStreamRequest) GetPartialEqFilter() []*Token

func (*TokenStreamRequest) GetTime 

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

func (*TokenStreamRequest) ProtoMessage 

func (*TokenStreamRequest) ProtoMessage()

func (*TokenStreamRequest) ProtoReflect 

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

func (*TokenStreamRequest) Reset 

func (x *TokenStreamRequest) Reset()

func (*TokenStreamRequest) String 

func (x *TokenStreamRequest) String() string

type TokenStreamResponse 

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

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

Deprecated: Use TokenStreamResponse.ProtoReflect.Descriptor instead.

func (*TokenStreamResponse) GetTime 

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

func (*TokenStreamResponse) GetType 

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

func (*TokenStreamResponse) GetValue 

func (x *TokenStreamResponse) GetValue() *Token

func (*TokenStreamResponse) ProtoMessage 

func (*TokenStreamResponse) ProtoMessage()

func (*TokenStreamResponse) ProtoReflect 

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

func (*TokenStreamResponse) Reset 

func (x *TokenStreamResponse) Reset()

func (*TokenStreamResponse) String 

func (x *TokenStreamResponse) String() string

type UnimplementedAccountConfigServiceServer 

type UnimplementedAccountConfigServiceServer struct {
}

UnimplementedAccountConfigServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAccountConfigServiceServer) Delete 

func (UnimplementedAccountConfigServiceServer) Delete(context.Context, *AccountConfigDeleteRequest) (*AccountConfigDeleteResponse, error)

func (UnimplementedAccountConfigServiceServer) DeleteAll 

func (UnimplementedAccountConfigServiceServer) DeleteAll(*AccountConfigDeleteAllRequest, AccountConfigService_DeleteAllServer) error

func (UnimplementedAccountConfigServiceServer) DeleteSome 

func (UnimplementedAccountConfigServiceServer) DeleteSome(*AccountConfigDeleteSomeRequest, AccountConfigService_DeleteSomeServer) error

func (UnimplementedAccountConfigServiceServer) GetAll 

func (UnimplementedAccountConfigServiceServer) GetAll(*AccountConfigStreamRequest, AccountConfigService_GetAllServer) error

func (UnimplementedAccountConfigServiceServer) GetMeta 

func (UnimplementedAccountConfigServiceServer) GetMeta(context.Context, *AccountConfigStreamRequest) (*MetaResponse, error)

func (UnimplementedAccountConfigServiceServer) GetOne 

func (UnimplementedAccountConfigServiceServer) GetOne(context.Context, *AccountConfigRequest) (*AccountConfigResponse, error)

func (UnimplementedAccountConfigServiceServer) GetSome 

func (UnimplementedAccountConfigServiceServer) GetSome(*AccountConfigSomeRequest, AccountConfigService_GetSomeServer) error

func (UnimplementedAccountConfigServiceServer) Set 

func (UnimplementedAccountConfigServiceServer) Set(context.Context, *AccountConfigSetRequest) (*AccountConfigSetResponse, error)

func (UnimplementedAccountConfigServiceServer) SetSome 

func (UnimplementedAccountConfigServiceServer) SetSome(*AccountConfigSetSomeRequest, AccountConfigService_SetSomeServer) error

func (UnimplementedAccountConfigServiceServer) Subscribe 

func (UnimplementedAccountConfigServiceServer) Subscribe(*AccountConfigStreamRequest, AccountConfigService_SubscribeServer) error

func (UnimplementedAccountConfigServiceServer) SubscribeMeta 

func (UnimplementedAccountConfigServiceServer) SubscribeMeta(*AccountConfigStreamRequest, AccountConfigService_SubscribeMetaServer) error

type UnimplementedAccountServiceServer 

type UnimplementedAccountServiceServer struct {
}

UnimplementedAccountServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedAccountServiceServer) GetAll 

func (UnimplementedAccountServiceServer) GetAll(*AccountStreamRequest, AccountService_GetAllServer) error

func (UnimplementedAccountServiceServer) GetMeta 

func (UnimplementedAccountServiceServer) GetMeta(context.Context, *AccountStreamRequest) (*MetaResponse, error)

func (UnimplementedAccountServiceServer) GetOne 

func (UnimplementedAccountServiceServer) GetOne(context.Context, *AccountRequest) (*AccountResponse, error)

func (UnimplementedAccountServiceServer) GetSome 

func (UnimplementedAccountServiceServer) GetSome(*AccountSomeRequest, AccountService_GetSomeServer) error

func (UnimplementedAccountServiceServer) Subscribe 

func (UnimplementedAccountServiceServer) Subscribe(*AccountStreamRequest, AccountService_SubscribeServer) error

func (UnimplementedAccountServiceServer) SubscribeMeta 

func (UnimplementedAccountServiceServer) SubscribeMeta(*AccountStreamRequest, AccountService_SubscribeMetaServer) error

type UnimplementedTokenConfigServiceServer 

type UnimplementedTokenConfigServiceServer struct {
}

UnimplementedTokenConfigServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTokenConfigServiceServer) Delete 

func (UnimplementedTokenConfigServiceServer) Delete(context.Context, *TokenConfigDeleteRequest) (*TokenConfigDeleteResponse, error)

func (UnimplementedTokenConfigServiceServer) DeleteAll 

func (UnimplementedTokenConfigServiceServer) DeleteAll(*TokenConfigDeleteAllRequest, TokenConfigService_DeleteAllServer) error

func (UnimplementedTokenConfigServiceServer) DeleteSome 

func (UnimplementedTokenConfigServiceServer) DeleteSome(*TokenConfigDeleteSomeRequest, TokenConfigService_DeleteSomeServer) error

func (UnimplementedTokenConfigServiceServer) GetAll 

func (UnimplementedTokenConfigServiceServer) GetAll(*TokenConfigStreamRequest, TokenConfigService_GetAllServer) error

func (UnimplementedTokenConfigServiceServer) GetMeta 

func (UnimplementedTokenConfigServiceServer) GetMeta(context.Context, *TokenConfigStreamRequest) (*MetaResponse, error)

func (UnimplementedTokenConfigServiceServer) GetOne 

func (UnimplementedTokenConfigServiceServer) GetOne(context.Context, *TokenConfigRequest) (*TokenConfigResponse, error)

func (UnimplementedTokenConfigServiceServer) GetSome 

func (UnimplementedTokenConfigServiceServer) GetSome(*TokenConfigSomeRequest, TokenConfigService_GetSomeServer) error

func (UnimplementedTokenConfigServiceServer) Set 

func (UnimplementedTokenConfigServiceServer) Set(context.Context, *TokenConfigSetRequest) (*TokenConfigSetResponse, error)

func (UnimplementedTokenConfigServiceServer) SetSome 

func (UnimplementedTokenConfigServiceServer) SetSome(*TokenConfigSetSomeRequest, TokenConfigService_SetSomeServer) error

func (UnimplementedTokenConfigServiceServer) Subscribe 

func (UnimplementedTokenConfigServiceServer) Subscribe(*TokenConfigStreamRequest, TokenConfigService_SubscribeServer) error

func (UnimplementedTokenConfigServiceServer) SubscribeMeta 

func (UnimplementedTokenConfigServiceServer) SubscribeMeta(*TokenConfigStreamRequest, TokenConfigService_SubscribeMetaServer) error

type UnimplementedTokenServiceServer 

type UnimplementedTokenServiceServer struct {
}

UnimplementedTokenServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedTokenServiceServer) GetAll 

func (UnimplementedTokenServiceServer) GetAll(*TokenStreamRequest, TokenService_GetAllServer) error

func (UnimplementedTokenServiceServer) GetMeta 

func (UnimplementedTokenServiceServer) GetMeta(context.Context, *TokenStreamRequest) (*MetaResponse, error)

func (UnimplementedTokenServiceServer) GetOne 

func (UnimplementedTokenServiceServer) GetOne(context.Context, *TokenRequest) (*TokenResponse, error)

func (UnimplementedTokenServiceServer) GetSome 

func (UnimplementedTokenServiceServer) GetSome(*TokenSomeRequest, TokenService_GetSomeServer) error

func (UnimplementedTokenServiceServer) Subscribe 

func (UnimplementedTokenServiceServer) Subscribe(*TokenStreamRequest, TokenService_SubscribeServer) error

func (UnimplementedTokenServiceServer) SubscribeMeta 

func (UnimplementedTokenServiceServer) SubscribeMeta(*TokenStreamRequest, TokenService_SubscribeMetaServer) error

type UnsafeAccountConfigServiceServer 

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

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

type UnsafeAccountServiceServer 

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

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

type UnsafeTokenConfigServiceServer 

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

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

type UnsafeTokenServiceServer 

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

UnsafeTokenServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TokenServiceServer 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.