Documentation ¶
Overview ¶
Package entitycachev1 is a reverse proxy.
It translates gRPC into RESTful JSON APIs.
Code generated by protoc-gen-deepcopy. DO NOT EDIT.
Index ¶
- Variables
- func RegisterEntityCacheServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
- func RegisterEntityCacheServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EntityCacheServiceClient) error
- func RegisterEntityCacheServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)
- func RegisterEntityCacheServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server EntityCacheServiceServer) error
- func RegisterEntityCacheServiceServer(s grpc.ServiceRegistrar, srv EntityCacheServiceServer)
- type Entity
- func (in *Entity) DeepCopy() *Entity
- func (in *Entity) DeepCopyInterface() interface{}
- func (in *Entity) DeepCopyInto(out *Entity)
- func (*Entity) Descriptor() ([]byte, []int)deprecated
- func (x *Entity) GetIpAddress() string
- func (x *Entity) GetName() string
- func (x *Entity) GetPrefix() string
- func (x *Entity) GetServices() []string
- func (x *Entity) GetUid() string
- func (msg *Entity) MarshalJSON() ([]byte, error)
- func (*Entity) ProtoMessage()
- func (x *Entity) ProtoReflect() protoreflect.Message
- func (x *Entity) Reset()
- func (x *Entity) String() string
- func (msg *Entity) UnmarshalJSON(b []byte) error
- type EntityCache
- func (in *EntityCache) DeepCopy() *EntityCache
- func (in *EntityCache) DeepCopyInterface() interface{}
- func (in *EntityCache) DeepCopyInto(out *EntityCache)
- func (*EntityCache) Descriptor() ([]byte, []int)deprecated
- func (x *EntityCache) GetEntitiesByIpAddress() *EntityCache_Entities
- func (x *EntityCache) GetEntitiesByName() *EntityCache_Entities
- func (msg *EntityCache) MarshalJSON() ([]byte, error)
- func (*EntityCache) ProtoMessage()
- func (x *EntityCache) ProtoReflect() protoreflect.Message
- func (x *EntityCache) Reset()
- func (x *EntityCache) String() string
- func (msg *EntityCache) UnmarshalJSON(b []byte) error
- type EntityCacheServiceClient
- type EntityCacheServiceServer
- type EntityCache_Entities
- func (in *EntityCache_Entities) DeepCopy() *EntityCache_Entities
- func (in *EntityCache_Entities) DeepCopyInterface() interface{}
- func (in *EntityCache_Entities) DeepCopyInto(out *EntityCache_Entities)
- func (*EntityCache_Entities) Descriptor() ([]byte, []int)deprecated
- func (x *EntityCache_Entities) GetEntities() map[string]*Entity
- func (msg *EntityCache_Entities) MarshalJSON() ([]byte, error)
- func (*EntityCache_Entities) ProtoMessage()
- func (x *EntityCache_Entities) ProtoReflect() protoreflect.Message
- func (x *EntityCache_Entities) Reset()
- func (x *EntityCache_Entities) String() string
- func (msg *EntityCache_Entities) UnmarshalJSON(b []byte) error
- type GetEntityByIPAddressRequest
- func (in *GetEntityByIPAddressRequest) DeepCopy() *GetEntityByIPAddressRequest
- func (in *GetEntityByIPAddressRequest) DeepCopyInterface() interface{}
- func (in *GetEntityByIPAddressRequest) DeepCopyInto(out *GetEntityByIPAddressRequest)
- func (*GetEntityByIPAddressRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetEntityByIPAddressRequest) GetIpAddress() string
- func (msg *GetEntityByIPAddressRequest) MarshalJSON() ([]byte, error)
- func (*GetEntityByIPAddressRequest) ProtoMessage()
- func (x *GetEntityByIPAddressRequest) ProtoReflect() protoreflect.Message
- func (x *GetEntityByIPAddressRequest) Reset()
- func (x *GetEntityByIPAddressRequest) String() string
- func (msg *GetEntityByIPAddressRequest) UnmarshalJSON(b []byte) error
- type GetEntityByNameRequest
- func (in *GetEntityByNameRequest) DeepCopy() *GetEntityByNameRequest
- func (in *GetEntityByNameRequest) DeepCopyInterface() interface{}
- func (in *GetEntityByNameRequest) DeepCopyInto(out *GetEntityByNameRequest)
- func (*GetEntityByNameRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetEntityByNameRequest) GetName() string
- func (msg *GetEntityByNameRequest) MarshalJSON() ([]byte, error)
- func (*GetEntityByNameRequest) ProtoMessage()
- func (x *GetEntityByNameRequest) ProtoReflect() protoreflect.Message
- func (x *GetEntityByNameRequest) Reset()
- func (x *GetEntityByNameRequest) String() string
- func (msg *GetEntityByNameRequest) UnmarshalJSON(b []byte) error
- type UnimplementedEntityCacheServiceServer
- func (UnimplementedEntityCacheServiceServer) GetEntityByIPAddress(context.Context, *GetEntityByIPAddressRequest) (*Entity, error)
- func (UnimplementedEntityCacheServiceServer) GetEntityByName(context.Context, *GetEntityByNameRequest) (*Entity, error)
- func (UnimplementedEntityCacheServiceServer) GetEntityCache(context.Context, *emptypb.Empty) (*EntityCache, error)
- type UnsafeEntityCacheServiceServer
Constants ¶
This section is empty.
Variables ¶
var EntityCacheService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "aperture.flowcontrol.entitycache.v1.EntityCacheService", HandlerType: (*EntityCacheServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetEntityCache", Handler: _EntityCacheService_GetEntityCache_Handler, }, { MethodName: "GetEntityByIPAddress", Handler: _EntityCacheService_GetEntityByIPAddress_Handler, }, { MethodName: "GetEntityByName", Handler: _EntityCacheService_GetEntityByName_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "aperture/flowcontrol/entitycache/v1/entitycache.proto", }
EntityCacheService_ServiceDesc is the grpc.ServiceDesc for EntityCacheService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_aperture_flowcontrol_entitycache_v1_entitycache_proto protoreflect.FileDescriptor
Functions ¶
func RegisterEntityCacheServiceHandler ¶
func RegisterEntityCacheServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error
RegisterEntityCacheServiceHandler registers the http handlers for service EntityCacheService to "mux". The handlers forward requests to the grpc endpoint over "conn".
func RegisterEntityCacheServiceHandlerClient ¶
func RegisterEntityCacheServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client EntityCacheServiceClient) error
RegisterEntityCacheServiceHandlerClient registers the http handlers for service EntityCacheService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "EntityCacheServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "EntityCacheServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "EntityCacheServiceClient" to call the correct interceptors.
func RegisterEntityCacheServiceHandlerFromEndpoint ¶
func RegisterEntityCacheServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)
RegisterEntityCacheServiceHandlerFromEndpoint is same as RegisterEntityCacheServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.
func RegisterEntityCacheServiceHandlerServer ¶
func RegisterEntityCacheServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server EntityCacheServiceServer) error
RegisterEntityCacheServiceHandlerServer registers the http handlers for service EntityCacheService to "mux". UnaryRPC :call EntityCacheServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterEntityCacheServiceHandlerFromEndpoint instead.
func RegisterEntityCacheServiceServer ¶
func RegisterEntityCacheServiceServer(s grpc.ServiceRegistrar, srv EntityCacheServiceServer)
Types ¶
type Entity ¶
type Entity struct { Prefix string `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"` Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"` IpAddress string `protobuf:"bytes,3,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"` Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"` Services []string `protobuf:"bytes,5,rep,name=services,proto3" json:"services,omitempty"` // contains filtered or unexported fields }
Entity represents a pod, vm, etc.
func (*Entity) DeepCopy ¶
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new Entity. Required by controller-gen.
func (*Entity) DeepCopyInterface ¶
func (in *Entity) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new Entity. Required by controller-gen.
func (*Entity) DeepCopyInto ¶
DeepCopyInto supports using Entity within kubernetes types, where deepcopy-gen is used.
func (*Entity) Descriptor
deprecated
func (*Entity) GetIpAddress ¶
func (*Entity) GetServices ¶
func (*Entity) MarshalJSON ¶
MarshalJSON implements json.Marshaler
func (*Entity) ProtoMessage ¶
func (*Entity) ProtoMessage()
func (*Entity) ProtoReflect ¶
func (x *Entity) ProtoReflect() protoreflect.Message
func (*Entity) UnmarshalJSON ¶
UnmarshalJSON implements json.Unmarshaler
type EntityCache ¶
type EntityCache struct { EntitiesByIpAddress *EntityCache_Entities `protobuf:"bytes,1,opt,name=entities_by_ip_address,json=entitiesByIpAddress,proto3" json:"entities_by_ip_address,omitempty"` EntitiesByName *EntityCache_Entities `protobuf:"bytes,2,opt,name=entities_by_name,json=entitiesByName,proto3" json:"entities_by_name,omitempty"` // contains filtered or unexported fields }
EntityCache contains both mappings of ip address to entity and entity name to entity.
func (*EntityCache) DeepCopy ¶
func (in *EntityCache) DeepCopy() *EntityCache
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EntityCache. Required by controller-gen.
func (*EntityCache) DeepCopyInterface ¶
func (in *EntityCache) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new EntityCache. Required by controller-gen.
func (*EntityCache) DeepCopyInto ¶
func (in *EntityCache) DeepCopyInto(out *EntityCache)
DeepCopyInto supports using EntityCache within kubernetes types, where deepcopy-gen is used.
func (*EntityCache) Descriptor
deprecated
func (*EntityCache) Descriptor() ([]byte, []int)
Deprecated: Use EntityCache.ProtoReflect.Descriptor instead.
func (*EntityCache) GetEntitiesByIpAddress ¶
func (x *EntityCache) GetEntitiesByIpAddress() *EntityCache_Entities
func (*EntityCache) GetEntitiesByName ¶
func (x *EntityCache) GetEntitiesByName() *EntityCache_Entities
func (*EntityCache) MarshalJSON ¶
func (msg *EntityCache) MarshalJSON() ([]byte, error)
MarshalJSON implements json.Marshaler
func (*EntityCache) ProtoMessage ¶
func (*EntityCache) ProtoMessage()
func (*EntityCache) ProtoReflect ¶
func (x *EntityCache) ProtoReflect() protoreflect.Message
func (*EntityCache) Reset ¶
func (x *EntityCache) Reset()
func (*EntityCache) String ¶
func (x *EntityCache) String() string
func (*EntityCache) UnmarshalJSON ¶
func (msg *EntityCache) UnmarshalJSON(b []byte) error
UnmarshalJSON implements json.Unmarshaler
type EntityCacheServiceClient ¶
type EntityCacheServiceClient interface { GetEntityCache(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*EntityCache, error) GetEntityByIPAddress(ctx context.Context, in *GetEntityByIPAddressRequest, opts ...grpc.CallOption) (*Entity, error) GetEntityByName(ctx context.Context, in *GetEntityByNameRequest, opts ...grpc.CallOption) (*Entity, error) }
EntityCacheServiceClient is the client API for EntityCacheService 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 NewEntityCacheServiceClient ¶
func NewEntityCacheServiceClient(cc grpc.ClientConnInterface) EntityCacheServiceClient
type EntityCacheServiceServer ¶
type EntityCacheServiceServer interface { GetEntityCache(context.Context, *emptypb.Empty) (*EntityCache, error) GetEntityByIPAddress(context.Context, *GetEntityByIPAddressRequest) (*Entity, error) GetEntityByName(context.Context, *GetEntityByNameRequest) (*Entity, error) }
EntityCacheServiceServer is the server API for EntityCacheService service. All implementations should embed UnimplementedEntityCacheServiceServer for forward compatibility
type EntityCache_Entities ¶
type EntityCache_Entities struct { Entities map[string]*Entity `` /* 157-byte string literal not displayed */ // contains filtered or unexported fields }
Entities defines mapping of entities.
func (*EntityCache_Entities) DeepCopy ¶
func (in *EntityCache_Entities) DeepCopy() *EntityCache_Entities
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new EntityCache_Entities. Required by controller-gen.
func (*EntityCache_Entities) DeepCopyInterface ¶
func (in *EntityCache_Entities) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new EntityCache_Entities. Required by controller-gen.
func (*EntityCache_Entities) DeepCopyInto ¶
func (in *EntityCache_Entities) DeepCopyInto(out *EntityCache_Entities)
DeepCopyInto supports using EntityCache_Entities within kubernetes types, where deepcopy-gen is used.
func (*EntityCache_Entities) Descriptor
deprecated
func (*EntityCache_Entities) Descriptor() ([]byte, []int)
Deprecated: Use EntityCache_Entities.ProtoReflect.Descriptor instead.
func (*EntityCache_Entities) GetEntities ¶
func (x *EntityCache_Entities) GetEntities() map[string]*Entity
func (*EntityCache_Entities) MarshalJSON ¶
func (msg *EntityCache_Entities) MarshalJSON() ([]byte, error)
MarshalJSON implements json.Marshaler
func (*EntityCache_Entities) ProtoMessage ¶
func (*EntityCache_Entities) ProtoMessage()
func (*EntityCache_Entities) ProtoReflect ¶
func (x *EntityCache_Entities) ProtoReflect() protoreflect.Message
func (*EntityCache_Entities) Reset ¶
func (x *EntityCache_Entities) Reset()
func (*EntityCache_Entities) String ¶
func (x *EntityCache_Entities) String() string
func (*EntityCache_Entities) UnmarshalJSON ¶
func (msg *EntityCache_Entities) UnmarshalJSON(b []byte) error
UnmarshalJSON implements json.Unmarshaler
type GetEntityByIPAddressRequest ¶
type GetEntityByIPAddressRequest struct { IpAddress string `protobuf:"bytes,1,opt,name=ip_address,json=ipAddress,proto3" json:"ip_address,omitempty"` // contains filtered or unexported fields }
func (*GetEntityByIPAddressRequest) DeepCopy ¶
func (in *GetEntityByIPAddressRequest) DeepCopy() *GetEntityByIPAddressRequest
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GetEntityByIPAddressRequest. Required by controller-gen.
func (*GetEntityByIPAddressRequest) DeepCopyInterface ¶
func (in *GetEntityByIPAddressRequest) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new GetEntityByIPAddressRequest. Required by controller-gen.
func (*GetEntityByIPAddressRequest) DeepCopyInto ¶
func (in *GetEntityByIPAddressRequest) DeepCopyInto(out *GetEntityByIPAddressRequest)
DeepCopyInto supports using GetEntityByIPAddressRequest within kubernetes types, where deepcopy-gen is used.
func (*GetEntityByIPAddressRequest) Descriptor
deprecated
func (*GetEntityByIPAddressRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetEntityByIPAddressRequest.ProtoReflect.Descriptor instead.
func (*GetEntityByIPAddressRequest) GetIpAddress ¶
func (x *GetEntityByIPAddressRequest) GetIpAddress() string
func (*GetEntityByIPAddressRequest) MarshalJSON ¶
func (msg *GetEntityByIPAddressRequest) MarshalJSON() ([]byte, error)
MarshalJSON implements json.Marshaler
func (*GetEntityByIPAddressRequest) ProtoMessage ¶
func (*GetEntityByIPAddressRequest) ProtoMessage()
func (*GetEntityByIPAddressRequest) ProtoReflect ¶
func (x *GetEntityByIPAddressRequest) ProtoReflect() protoreflect.Message
func (*GetEntityByIPAddressRequest) Reset ¶
func (x *GetEntityByIPAddressRequest) Reset()
func (*GetEntityByIPAddressRequest) String ¶
func (x *GetEntityByIPAddressRequest) String() string
func (*GetEntityByIPAddressRequest) UnmarshalJSON ¶
func (msg *GetEntityByIPAddressRequest) UnmarshalJSON(b []byte) error
UnmarshalJSON implements json.Unmarshaler
type GetEntityByNameRequest ¶
type GetEntityByNameRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*GetEntityByNameRequest) DeepCopy ¶
func (in *GetEntityByNameRequest) DeepCopy() *GetEntityByNameRequest
DeepCopy is an autogenerated deepcopy function, copying the receiver, creating a new GetEntityByNameRequest. Required by controller-gen.
func (*GetEntityByNameRequest) DeepCopyInterface ¶
func (in *GetEntityByNameRequest) DeepCopyInterface() interface{}
DeepCopyInterface is an autogenerated deepcopy function, copying the receiver, creating a new GetEntityByNameRequest. Required by controller-gen.
func (*GetEntityByNameRequest) DeepCopyInto ¶
func (in *GetEntityByNameRequest) DeepCopyInto(out *GetEntityByNameRequest)
DeepCopyInto supports using GetEntityByNameRequest within kubernetes types, where deepcopy-gen is used.
func (*GetEntityByNameRequest) Descriptor
deprecated
func (*GetEntityByNameRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetEntityByNameRequest.ProtoReflect.Descriptor instead.
func (*GetEntityByNameRequest) GetName ¶
func (x *GetEntityByNameRequest) GetName() string
func (*GetEntityByNameRequest) MarshalJSON ¶
func (msg *GetEntityByNameRequest) MarshalJSON() ([]byte, error)
MarshalJSON implements json.Marshaler
func (*GetEntityByNameRequest) ProtoMessage ¶
func (*GetEntityByNameRequest) ProtoMessage()
func (*GetEntityByNameRequest) ProtoReflect ¶
func (x *GetEntityByNameRequest) ProtoReflect() protoreflect.Message
func (*GetEntityByNameRequest) Reset ¶
func (x *GetEntityByNameRequest) Reset()
func (*GetEntityByNameRequest) String ¶
func (x *GetEntityByNameRequest) String() string
func (*GetEntityByNameRequest) UnmarshalJSON ¶
func (msg *GetEntityByNameRequest) UnmarshalJSON(b []byte) error
UnmarshalJSON implements json.Unmarshaler
type UnimplementedEntityCacheServiceServer ¶
type UnimplementedEntityCacheServiceServer struct { }
UnimplementedEntityCacheServiceServer should be embedded to have forward compatible implementations.
func (UnimplementedEntityCacheServiceServer) GetEntityByIPAddress ¶
func (UnimplementedEntityCacheServiceServer) GetEntityByIPAddress(context.Context, *GetEntityByIPAddressRequest) (*Entity, error)
func (UnimplementedEntityCacheServiceServer) GetEntityByName ¶
func (UnimplementedEntityCacheServiceServer) GetEntityByName(context.Context, *GetEntityByNameRequest) (*Entity, error)
func (UnimplementedEntityCacheServiceServer) GetEntityCache ¶
func (UnimplementedEntityCacheServiceServer) GetEntityCache(context.Context, *emptypb.Empty) (*EntityCache, error)
type UnsafeEntityCacheServiceServer ¶
type UnsafeEntityCacheServiceServer interface {
// contains filtered or unexported methods
}
UnsafeEntityCacheServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EntityCacheServiceServer will result in compilation errors.