Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterFilterServiceServer(s grpc.ServiceRegistrar, srv FilterServiceServer)
- func RegisterHealthServiceServer(s grpc.ServiceRegistrar, srv HealthServiceServer)
- func RegisterManagementServiceServer(s grpc.ServiceRegistrar, srv ManagementServiceServer)
- type AllowRequest
- func (*AllowRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AllowRequest) GetIp() string
- func (x *AllowRequest) GetPort() uint32
- func (*AllowRequest) ProtoMessage()
- func (x *AllowRequest) ProtoReflect() protoreflect.Message
- func (x *AllowRequest) Reset()
- func (x *AllowRequest) String() string
- type AllowResponse
- func (*AllowResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AllowResponse) GetExpiresAt() *timestamppb.Timestamp
- func (x *AllowResponse) GetIp() string
- func (x *AllowResponse) GetMessage() string
- func (x *AllowResponse) GetPort() uint32
- func (*AllowResponse) ProtoMessage()
- func (x *AllowResponse) ProtoReflect() protoreflect.Message
- func (x *AllowResponse) Reset()
- func (x *AllowResponse) String() string
- type BlockManagementResponse
- func (*BlockManagementResponse) Descriptor() ([]byte, []int)deprecated
- func (x *BlockManagementResponse) GetActiveFlowsRemoved() uint64
- func (x *BlockManagementResponse) GetMessage() string
- func (x *BlockManagementResponse) GetPendingEntriesRemoved() uint64
- func (x *BlockManagementResponse) GetRuntimeAttached() bool
- func (x *BlockManagementResponse) GetRuntimeIface() string
- func (*BlockManagementResponse) ProtoMessage()
- func (x *BlockManagementResponse) ProtoReflect() protoreflect.Message
- func (x *BlockManagementResponse) Reset()
- func (x *BlockManagementResponse) String() string
- type FilterServiceClient
- type FilterServiceServer
- type GetManagementSettingsResponse
- func (*GetManagementSettingsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetManagementSettingsResponse) GetAudience() string
- func (x *GetManagementSettingsResponse) GetAuthConfigured() bool
- func (x *GetManagementSettingsResponse) GetGuardedPortsRange() string
- func (x *GetManagementSettingsResponse) GetHandshakeWindowSec() int32
- func (x *GetManagementSettingsResponse) GetIface() string
- func (x *GetManagementSettingsResponse) GetInactiveTimerSec() int32
- func (x *GetManagementSettingsResponse) GetIssuer() string
- func (x *GetManagementSettingsResponse) GetJwksUrl() string
- func (x *GetManagementSettingsResponse) GetRequiredScope() string
- func (x *GetManagementSettingsResponse) GetRuntimeAttached() bool
- func (x *GetManagementSettingsResponse) GetRuntimeIface() string
- func (x *GetManagementSettingsResponse) GetUpdatedAt() *timestamppb.Timestamp
- func (*GetManagementSettingsResponse) ProtoMessage()
- func (x *GetManagementSettingsResponse) ProtoReflect() protoreflect.Message
- func (x *GetManagementSettingsResponse) Reset()
- func (x *GetManagementSettingsResponse) String() string
- type HealthResponse
- func (*HealthResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HealthResponse) GetRuntimeAttached() bool
- func (x *HealthResponse) GetStatus() string
- func (*HealthResponse) ProtoMessage()
- func (x *HealthResponse) ProtoReflect() protoreflect.Message
- func (x *HealthResponse) Reset()
- func (x *HealthResponse) String() string
- type HealthServiceClient
- type HealthServiceServer
- type ManagementServiceClient
- type ManagementServiceServer
- type StatsResponse
- func (*StatsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StatsResponse) GetActiveFlowHits() uint64
- func (x *StatsResponse) GetAllowRatePercent() float64
- func (x *StatsResponse) GetAllowed() uint64
- func (x *StatsResponse) GetDropRatePercent() float64
- func (x *StatsResponse) GetDropped() uint64
- func (x *StatsResponse) GetGuardedPortDropped() uint64
- func (x *StatsResponse) GetIpPortAuthHits() uint64
- func (x *StatsResponse) GetNonGuardedPortAllowed() uint64
- func (x *StatsResponse) GetPendingExpiredCleanups() uint64
- func (x *StatsResponse) GetPendingPromotions() uint64
- func (x *StatsResponse) GetSynAllowed() uint64
- func (x *StatsResponse) GetSynDropped() uint64
- func (*StatsResponse) ProtoMessage()
- func (x *StatsResponse) ProtoReflect() protoreflect.Message
- func (x *StatsResponse) Reset()
- func (x *StatsResponse) String() string
- type UnimplementedFilterServiceServer
- type UnimplementedHealthServiceServer
- type UnimplementedManagementServiceServer
- func (UnimplementedManagementServiceServer) Block(context.Context, *emptypb.Empty) (*BlockManagementResponse, error)
- func (UnimplementedManagementServiceServer) CreateSettings(context.Context, *UpsertManagementSettingsRequest) (*UpsertManagementSettingsResponse, error)
- func (UnimplementedManagementServiceServer) GetSettings(context.Context, *emptypb.Empty) (*GetManagementSettingsResponse, error)
- func (UnimplementedManagementServiceServer) UpdateSettings(context.Context, *UpsertManagementSettingsRequest) (*UpsertManagementSettingsResponse, error)
- type UnsafeFilterServiceServer
- type UnsafeHealthServiceServer
- type UnsafeManagementServiceServer
- type UpsertManagementSettingsRequest
- func (*UpsertManagementSettingsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpsertManagementSettingsRequest) GetAudience() string
- func (x *UpsertManagementSettingsRequest) GetGuardedPortsRange() string
- func (x *UpsertManagementSettingsRequest) GetHandshakeWindowSec() int32
- func (x *UpsertManagementSettingsRequest) GetIface() string
- func (x *UpsertManagementSettingsRequest) GetInactiveTimerSec() int32
- func (x *UpsertManagementSettingsRequest) GetIssuer() string
- func (x *UpsertManagementSettingsRequest) GetJwksUrl() string
- func (x *UpsertManagementSettingsRequest) GetRequiredScope() string
- func (*UpsertManagementSettingsRequest) ProtoMessage()
- func (x *UpsertManagementSettingsRequest) ProtoReflect() protoreflect.Message
- func (x *UpsertManagementSettingsRequest) Reset()
- func (x *UpsertManagementSettingsRequest) String() string
- type UpsertManagementSettingsResponse
- func (*UpsertManagementSettingsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpsertManagementSettingsResponse) GetAudience() string
- func (x *UpsertManagementSettingsResponse) GetAuthConfigured() bool
- func (x *UpsertManagementSettingsResponse) GetGuardedPortsRange() string
- func (x *UpsertManagementSettingsResponse) GetHandshakeWindowSec() int32
- func (x *UpsertManagementSettingsResponse) GetIface() string
- func (x *UpsertManagementSettingsResponse) GetInactiveTimerSec() int32
- func (x *UpsertManagementSettingsResponse) GetIssuer() string
- func (x *UpsertManagementSettingsResponse) GetJwksUrl() string
- func (x *UpsertManagementSettingsResponse) GetMessage() string
- func (x *UpsertManagementSettingsResponse) GetRequiredScope() string
- func (x *UpsertManagementSettingsResponse) GetRuntimeAttached() bool
- func (x *UpsertManagementSettingsResponse) GetRuntimeIface() string
- func (x *UpsertManagementSettingsResponse) GetUpdatedAt() *timestamppb.Timestamp
- func (*UpsertManagementSettingsResponse) ProtoMessage()
- func (x *UpsertManagementSettingsResponse) ProtoReflect() protoreflect.Message
- func (x *UpsertManagementSettingsResponse) Reset()
- func (x *UpsertManagementSettingsResponse) String() string
Constants ¶
const ( FilterService_Allow_FullMethodName = "/leshy.controller.v1.FilterService/Allow" FilterService_Stats_FullMethodName = "/leshy.controller.v1.FilterService/Stats" )
const ( ManagementService_CreateSettings_FullMethodName = "/leshy.controller.v1.ManagementService/CreateSettings" ManagementService_UpdateSettings_FullMethodName = "/leshy.controller.v1.ManagementService/UpdateSettings" ManagementService_GetSettings_FullMethodName = "/leshy.controller.v1.ManagementService/GetSettings" ManagementService_Block_FullMethodName = "/leshy.controller.v1.ManagementService/Block" )
const (
HealthService_Health_FullMethodName = "/leshy.controller.v1.HealthService/Health"
)
Variables ¶
var File_docs_api_grpc_leshy_controller_v1_proto protoreflect.FileDescriptor
var FilterService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "leshy.controller.v1.FilterService", HandlerType: (*FilterServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Allow", Handler: _FilterService_Allow_Handler, }, { MethodName: "Stats", Handler: _FilterService_Stats_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "docs/api/grpc/leshy_controller_v1.proto", }
FilterService_ServiceDesc is the grpc.ServiceDesc for FilterService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var HealthService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "leshy.controller.v1.HealthService", HandlerType: (*HealthServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Health", Handler: _HealthService_Health_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "docs/api/grpc/leshy_controller_v1.proto", }
HealthService_ServiceDesc is the grpc.ServiceDesc for HealthService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var ManagementService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "leshy.controller.v1.ManagementService", HandlerType: (*ManagementServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateSettings", Handler: _ManagementService_CreateSettings_Handler, }, { MethodName: "UpdateSettings", Handler: _ManagementService_UpdateSettings_Handler, }, { MethodName: "GetSettings", Handler: _ManagementService_GetSettings_Handler, }, { MethodName: "Block", Handler: _ManagementService_Block_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "docs/api/grpc/leshy_controller_v1.proto", }
ManagementService_ServiceDesc is the grpc.ServiceDesc for ManagementService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterFilterServiceServer ¶
func RegisterFilterServiceServer(s grpc.ServiceRegistrar, srv FilterServiceServer)
func RegisterHealthServiceServer ¶
func RegisterHealthServiceServer(s grpc.ServiceRegistrar, srv HealthServiceServer)
func RegisterManagementServiceServer ¶
func RegisterManagementServiceServer(s grpc.ServiceRegistrar, srv ManagementServiceServer)
Types ¶
type AllowRequest ¶
type AllowRequest struct {
Ip string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
Port uint32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
// contains filtered or unexported fields
}
func (*AllowRequest) Descriptor
deprecated
func (*AllowRequest) Descriptor() ([]byte, []int)
Deprecated: Use AllowRequest.ProtoReflect.Descriptor instead.
func (*AllowRequest) GetIp ¶
func (x *AllowRequest) GetIp() string
func (*AllowRequest) GetPort ¶
func (x *AllowRequest) GetPort() uint32
func (*AllowRequest) ProtoMessage ¶
func (*AllowRequest) ProtoMessage()
func (*AllowRequest) ProtoReflect ¶
func (x *AllowRequest) ProtoReflect() protoreflect.Message
func (*AllowRequest) Reset ¶
func (x *AllowRequest) Reset()
func (*AllowRequest) String ¶
func (x *AllowRequest) String() string
type AllowResponse ¶
type AllowResponse struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
ExpiresAt *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=expires_at,json=expiresAt,proto3" json:"expires_at,omitempty"`
Ip string `protobuf:"bytes,3,opt,name=ip,proto3" json:"ip,omitempty"`
Port uint32 `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
// contains filtered or unexported fields
}
func (*AllowResponse) Descriptor
deprecated
func (*AllowResponse) Descriptor() ([]byte, []int)
Deprecated: Use AllowResponse.ProtoReflect.Descriptor instead.
func (*AllowResponse) GetExpiresAt ¶
func (x *AllowResponse) GetExpiresAt() *timestamppb.Timestamp
func (*AllowResponse) GetIp ¶
func (x *AllowResponse) GetIp() string
func (*AllowResponse) GetMessage ¶
func (x *AllowResponse) GetMessage() string
func (*AllowResponse) GetPort ¶
func (x *AllowResponse) GetPort() uint32
func (*AllowResponse) ProtoMessage ¶
func (*AllowResponse) ProtoMessage()
func (*AllowResponse) ProtoReflect ¶
func (x *AllowResponse) ProtoReflect() protoreflect.Message
func (*AllowResponse) Reset ¶
func (x *AllowResponse) Reset()
func (*AllowResponse) String ¶
func (x *AllowResponse) String() string
type BlockManagementResponse ¶
type BlockManagementResponse struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
PendingEntriesRemoved uint64 `` /* 127-byte string literal not displayed */
ActiveFlowsRemoved uint64 `protobuf:"varint,3,opt,name=active_flows_removed,json=activeFlowsRemoved,proto3" json:"active_flows_removed,omitempty"`
RuntimeAttached bool `protobuf:"varint,4,opt,name=runtime_attached,json=runtimeAttached,proto3" json:"runtime_attached,omitempty"`
RuntimeIface string `protobuf:"bytes,5,opt,name=runtime_iface,json=runtimeIface,proto3" json:"runtime_iface,omitempty"`
// contains filtered or unexported fields
}
func (*BlockManagementResponse) Descriptor
deprecated
func (*BlockManagementResponse) Descriptor() ([]byte, []int)
Deprecated: Use BlockManagementResponse.ProtoReflect.Descriptor instead.
func (*BlockManagementResponse) GetActiveFlowsRemoved ¶
func (x *BlockManagementResponse) GetActiveFlowsRemoved() uint64
func (*BlockManagementResponse) GetMessage ¶
func (x *BlockManagementResponse) GetMessage() string
func (*BlockManagementResponse) GetPendingEntriesRemoved ¶
func (x *BlockManagementResponse) GetPendingEntriesRemoved() uint64
func (*BlockManagementResponse) GetRuntimeAttached ¶
func (x *BlockManagementResponse) GetRuntimeAttached() bool
func (*BlockManagementResponse) GetRuntimeIface ¶
func (x *BlockManagementResponse) GetRuntimeIface() string
func (*BlockManagementResponse) ProtoMessage ¶
func (*BlockManagementResponse) ProtoMessage()
func (*BlockManagementResponse) ProtoReflect ¶
func (x *BlockManagementResponse) ProtoReflect() protoreflect.Message
func (*BlockManagementResponse) Reset ¶
func (x *BlockManagementResponse) Reset()
func (*BlockManagementResponse) String ¶
func (x *BlockManagementResponse) String() string
type FilterServiceClient ¶
type FilterServiceClient interface {
// Mirrors POST /api/v1/allow.
// Auth metadata: "authorization: Bearer <access_token>".
Allow(ctx context.Context, in *AllowRequest, opts ...grpc.CallOption) (*AllowResponse, error)
// Mirrors GET /api/v1/stats.
// Auth metadata: "authorization: Bearer <access_token>".
Stats(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*StatsResponse, error)
}
FilterServiceClient is the client API for FilterService 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.
FilterService mirrors /api/v1/filter endpoints.
func NewFilterServiceClient ¶
func NewFilterServiceClient(cc grpc.ClientConnInterface) FilterServiceClient
type FilterServiceServer ¶
type FilterServiceServer interface {
// Mirrors POST /api/v1/allow.
// Auth metadata: "authorization: Bearer <access_token>".
Allow(context.Context, *AllowRequest) (*AllowResponse, error)
// Mirrors GET /api/v1/stats.
// Auth metadata: "authorization: Bearer <access_token>".
Stats(context.Context, *emptypb.Empty) (*StatsResponse, error)
// contains filtered or unexported methods
}
FilterServiceServer is the server API for FilterService service. All implementations must embed UnimplementedFilterServiceServer for forward compatibility.
FilterService mirrors /api/v1/filter endpoints.
type GetManagementSettingsResponse ¶
type GetManagementSettingsResponse struct {
AuthConfigured bool `protobuf:"varint,1,opt,name=auth_configured,json=authConfigured,proto3" json:"auth_configured,omitempty"`
RuntimeAttached bool `protobuf:"varint,2,opt,name=runtime_attached,json=runtimeAttached,proto3" json:"runtime_attached,omitempty"`
RuntimeIface string `protobuf:"bytes,3,opt,name=runtime_iface,json=runtimeIface,proto3" json:"runtime_iface,omitempty"`
Issuer string `protobuf:"bytes,4,opt,name=issuer,proto3" json:"issuer,omitempty"`
Audience string `protobuf:"bytes,5,opt,name=audience,proto3" json:"audience,omitempty"`
JwksUrl string `protobuf:"bytes,6,opt,name=jwks_url,json=jwksUrl,proto3" json:"jwks_url,omitempty"`
RequiredScope string `protobuf:"bytes,7,opt,name=required_scope,json=requiredScope,proto3" json:"required_scope,omitempty"`
GuardedPortsRange string `protobuf:"bytes,8,opt,name=guarded_ports_range,json=guardedPortsRange,proto3" json:"guarded_ports_range,omitempty"`
Iface string `protobuf:"bytes,9,opt,name=iface,proto3" json:"iface,omitempty"`
HandshakeWindowSec int32 `protobuf:"varint,10,opt,name=handshake_window_sec,json=handshakeWindowSec,proto3" json:"handshake_window_sec,omitempty"`
InactiveTimerSec int32 `protobuf:"varint,11,opt,name=inactive_timer_sec,json=inactiveTimerSec,proto3" json:"inactive_timer_sec,omitempty"`
UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,12,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
// contains filtered or unexported fields
}
func (*GetManagementSettingsResponse) Descriptor
deprecated
func (*GetManagementSettingsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetManagementSettingsResponse.ProtoReflect.Descriptor instead.
func (*GetManagementSettingsResponse) GetAudience ¶
func (x *GetManagementSettingsResponse) GetAudience() string
func (*GetManagementSettingsResponse) GetAuthConfigured ¶
func (x *GetManagementSettingsResponse) GetAuthConfigured() bool
func (*GetManagementSettingsResponse) GetGuardedPortsRange ¶
func (x *GetManagementSettingsResponse) GetGuardedPortsRange() string
func (*GetManagementSettingsResponse) GetHandshakeWindowSec ¶
func (x *GetManagementSettingsResponse) GetHandshakeWindowSec() int32
func (*GetManagementSettingsResponse) GetIface ¶
func (x *GetManagementSettingsResponse) GetIface() string
func (*GetManagementSettingsResponse) GetInactiveTimerSec ¶
func (x *GetManagementSettingsResponse) GetInactiveTimerSec() int32
func (*GetManagementSettingsResponse) GetIssuer ¶
func (x *GetManagementSettingsResponse) GetIssuer() string
func (*GetManagementSettingsResponse) GetJwksUrl ¶
func (x *GetManagementSettingsResponse) GetJwksUrl() string
func (*GetManagementSettingsResponse) GetRequiredScope ¶
func (x *GetManagementSettingsResponse) GetRequiredScope() string
func (*GetManagementSettingsResponse) GetRuntimeAttached ¶
func (x *GetManagementSettingsResponse) GetRuntimeAttached() bool
func (*GetManagementSettingsResponse) GetRuntimeIface ¶
func (x *GetManagementSettingsResponse) GetRuntimeIface() string
func (*GetManagementSettingsResponse) GetUpdatedAt ¶
func (x *GetManagementSettingsResponse) GetUpdatedAt() *timestamppb.Timestamp
func (*GetManagementSettingsResponse) ProtoMessage ¶
func (*GetManagementSettingsResponse) ProtoMessage()
func (*GetManagementSettingsResponse) ProtoReflect ¶
func (x *GetManagementSettingsResponse) ProtoReflect() protoreflect.Message
func (*GetManagementSettingsResponse) Reset ¶
func (x *GetManagementSettingsResponse) Reset()
func (*GetManagementSettingsResponse) String ¶
func (x *GetManagementSettingsResponse) String() string
type HealthResponse ¶
type HealthResponse struct {
Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
RuntimeAttached bool `protobuf:"varint,2,opt,name=runtime_attached,json=runtimeAttached,proto3" json:"runtime_attached,omitempty"`
// contains filtered or unexported fields
}
func (*HealthResponse) Descriptor
deprecated
func (*HealthResponse) Descriptor() ([]byte, []int)
Deprecated: Use HealthResponse.ProtoReflect.Descriptor instead.
func (*HealthResponse) GetRuntimeAttached ¶
func (x *HealthResponse) GetRuntimeAttached() bool
func (*HealthResponse) GetStatus ¶
func (x *HealthResponse) GetStatus() string
func (*HealthResponse) ProtoMessage ¶
func (*HealthResponse) ProtoMessage()
func (*HealthResponse) ProtoReflect ¶
func (x *HealthResponse) ProtoReflect() protoreflect.Message
func (*HealthResponse) Reset ¶
func (x *HealthResponse) Reset()
func (*HealthResponse) String ¶
func (x *HealthResponse) String() string
type HealthServiceClient ¶
type HealthServiceClient interface {
Health(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*HealthResponse, error)
}
HealthServiceClient is the client API for HealthService 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.
HealthService mirrors GET /api/healthz.
func NewHealthServiceClient ¶
func NewHealthServiceClient(cc grpc.ClientConnInterface) HealthServiceClient
type HealthServiceServer ¶
type HealthServiceServer interface {
Health(context.Context, *emptypb.Empty) (*HealthResponse, error)
// contains filtered or unexported methods
}
HealthServiceServer is the server API for HealthService service. All implementations must embed UnimplementedHealthServiceServer for forward compatibility.
HealthService mirrors GET /api/healthz.
type ManagementServiceClient ¶
type ManagementServiceClient interface {
// Mirrors POST /api/v1/management/settings.
// Bootstrap metadata: "x-bootstrap-token: <bootstrap_token>".
CreateSettings(ctx context.Context, in *UpsertManagementSettingsRequest, opts ...grpc.CallOption) (*UpsertManagementSettingsResponse, error)
// Mirrors PATCH /api/v1/management/settings.
// Auth metadata: "authorization: Bearer <access_token>".
UpdateSettings(ctx context.Context, in *UpsertManagementSettingsRequest, opts ...grpc.CallOption) (*UpsertManagementSettingsResponse, error)
// Mirrors GET /api/v1/management/settings.
// Auth metadata: "authorization: Bearer <access_token>".
GetSettings(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetManagementSettingsResponse, error)
// Mirrors POST /api/v1/management/block.
// Auth metadata: "authorization: Bearer <access_token>".
Block(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*BlockManagementResponse, error)
}
ManagementServiceClient is the client API for ManagementService 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.
ManagementService mirrors /api/v1/management endpoints.
func NewManagementServiceClient ¶
func NewManagementServiceClient(cc grpc.ClientConnInterface) ManagementServiceClient
type ManagementServiceServer ¶
type ManagementServiceServer interface {
// Mirrors POST /api/v1/management/settings.
// Bootstrap metadata: "x-bootstrap-token: <bootstrap_token>".
CreateSettings(context.Context, *UpsertManagementSettingsRequest) (*UpsertManagementSettingsResponse, error)
// Mirrors PATCH /api/v1/management/settings.
// Auth metadata: "authorization: Bearer <access_token>".
UpdateSettings(context.Context, *UpsertManagementSettingsRequest) (*UpsertManagementSettingsResponse, error)
// Mirrors GET /api/v1/management/settings.
// Auth metadata: "authorization: Bearer <access_token>".
GetSettings(context.Context, *emptypb.Empty) (*GetManagementSettingsResponse, error)
// Mirrors POST /api/v1/management/block.
// Auth metadata: "authorization: Bearer <access_token>".
Block(context.Context, *emptypb.Empty) (*BlockManagementResponse, error)
// contains filtered or unexported methods
}
ManagementServiceServer is the server API for ManagementService service. All implementations must embed UnimplementedManagementServiceServer for forward compatibility.
ManagementService mirrors /api/v1/management endpoints.
type StatsResponse ¶
type StatsResponse struct {
Allowed uint64 `protobuf:"varint,1,opt,name=allowed,proto3" json:"allowed,omitempty"`
Dropped uint64 `protobuf:"varint,2,opt,name=dropped,proto3" json:"dropped,omitempty"`
SynAllowed uint64 `protobuf:"varint,3,opt,name=syn_allowed,json=synAllowed,proto3" json:"syn_allowed,omitempty"`
SynDropped uint64 `protobuf:"varint,4,opt,name=syn_dropped,json=synDropped,proto3" json:"syn_dropped,omitempty"`
ActiveFlowHits uint64 `protobuf:"varint,5,opt,name=active_flow_hits,json=activeFlowHits,proto3" json:"active_flow_hits,omitempty"`
PendingPromotions uint64 `protobuf:"varint,6,opt,name=pending_promotions,json=pendingPromotions,proto3" json:"pending_promotions,omitempty"`
PendingExpiredCleanups uint64 `` /* 130-byte string literal not displayed */
IpPortAuthHits uint64 `protobuf:"varint,8,opt,name=ip_port_auth_hits,json=ipPortAuthHits,proto3" json:"ip_port_auth_hits,omitempty"`
NonGuardedPortAllowed uint64 `` /* 129-byte string literal not displayed */
GuardedPortDropped uint64 `protobuf:"varint,10,opt,name=guarded_port_dropped,json=guardedPortDropped,proto3" json:"guarded_port_dropped,omitempty"`
AllowRatePercent float64 `protobuf:"fixed64,11,opt,name=allow_rate_percent,json=allowRatePercent,proto3" json:"allow_rate_percent,omitempty"`
DropRatePercent float64 `protobuf:"fixed64,12,opt,name=drop_rate_percent,json=dropRatePercent,proto3" json:"drop_rate_percent,omitempty"`
// contains filtered or unexported fields
}
func (*StatsResponse) Descriptor
deprecated
func (*StatsResponse) Descriptor() ([]byte, []int)
Deprecated: Use StatsResponse.ProtoReflect.Descriptor instead.
func (*StatsResponse) GetActiveFlowHits ¶
func (x *StatsResponse) GetActiveFlowHits() uint64
func (*StatsResponse) GetAllowRatePercent ¶
func (x *StatsResponse) GetAllowRatePercent() float64
func (*StatsResponse) GetAllowed ¶
func (x *StatsResponse) GetAllowed() uint64
func (*StatsResponse) GetDropRatePercent ¶
func (x *StatsResponse) GetDropRatePercent() float64
func (*StatsResponse) GetDropped ¶
func (x *StatsResponse) GetDropped() uint64
func (*StatsResponse) GetGuardedPortDropped ¶
func (x *StatsResponse) GetGuardedPortDropped() uint64
func (*StatsResponse) GetIpPortAuthHits ¶
func (x *StatsResponse) GetIpPortAuthHits() uint64
func (*StatsResponse) GetNonGuardedPortAllowed ¶
func (x *StatsResponse) GetNonGuardedPortAllowed() uint64
func (*StatsResponse) GetPendingExpiredCleanups ¶
func (x *StatsResponse) GetPendingExpiredCleanups() uint64
func (*StatsResponse) GetPendingPromotions ¶
func (x *StatsResponse) GetPendingPromotions() uint64
func (*StatsResponse) GetSynAllowed ¶
func (x *StatsResponse) GetSynAllowed() uint64
func (*StatsResponse) GetSynDropped ¶
func (x *StatsResponse) GetSynDropped() uint64
func (*StatsResponse) ProtoMessage ¶
func (*StatsResponse) ProtoMessage()
func (*StatsResponse) ProtoReflect ¶
func (x *StatsResponse) ProtoReflect() protoreflect.Message
func (*StatsResponse) Reset ¶
func (x *StatsResponse) Reset()
func (*StatsResponse) String ¶
func (x *StatsResponse) String() string
type UnimplementedFilterServiceServer ¶
type UnimplementedFilterServiceServer struct{}
UnimplementedFilterServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedFilterServiceServer) Allow ¶
func (UnimplementedFilterServiceServer) Allow(context.Context, *AllowRequest) (*AllowResponse, error)
func (UnimplementedFilterServiceServer) Stats ¶
func (UnimplementedFilterServiceServer) Stats(context.Context, *emptypb.Empty) (*StatsResponse, error)
type UnimplementedHealthServiceServer ¶
type UnimplementedHealthServiceServer struct{}
UnimplementedHealthServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedHealthServiceServer) Health ¶
func (UnimplementedHealthServiceServer) Health(context.Context, *emptypb.Empty) (*HealthResponse, error)
type UnimplementedManagementServiceServer ¶
type UnimplementedManagementServiceServer struct{}
UnimplementedManagementServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedManagementServiceServer) Block ¶
func (UnimplementedManagementServiceServer) Block(context.Context, *emptypb.Empty) (*BlockManagementResponse, error)
func (UnimplementedManagementServiceServer) CreateSettings ¶
func (UnimplementedManagementServiceServer) CreateSettings(context.Context, *UpsertManagementSettingsRequest) (*UpsertManagementSettingsResponse, error)
func (UnimplementedManagementServiceServer) GetSettings ¶
func (UnimplementedManagementServiceServer) GetSettings(context.Context, *emptypb.Empty) (*GetManagementSettingsResponse, error)
func (UnimplementedManagementServiceServer) UpdateSettings ¶
func (UnimplementedManagementServiceServer) UpdateSettings(context.Context, *UpsertManagementSettingsRequest) (*UpsertManagementSettingsResponse, error)
type UnsafeFilterServiceServer ¶
type UnsafeFilterServiceServer interface {
// contains filtered or unexported methods
}
UnsafeFilterServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FilterServiceServer will result in compilation errors.
type UnsafeHealthServiceServer ¶
type UnsafeHealthServiceServer interface {
// contains filtered or unexported methods
}
UnsafeHealthServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HealthServiceServer will result in compilation errors.
type UnsafeManagementServiceServer ¶
type UnsafeManagementServiceServer interface {
// contains filtered or unexported methods
}
UnsafeManagementServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ManagementServiceServer will result in compilation errors.
type UpsertManagementSettingsRequest ¶
type UpsertManagementSettingsRequest struct {
Issuer string `protobuf:"bytes,1,opt,name=issuer,proto3" json:"issuer,omitempty"`
Audience string `protobuf:"bytes,2,opt,name=audience,proto3" json:"audience,omitempty"`
JwksUrl string `protobuf:"bytes,3,opt,name=jwks_url,json=jwksUrl,proto3" json:"jwks_url,omitempty"`
RequiredScope string `protobuf:"bytes,4,opt,name=required_scope,json=requiredScope,proto3" json:"required_scope,omitempty"`
GuardedPortsRange string `protobuf:"bytes,5,opt,name=guarded_ports_range,json=guardedPortsRange,proto3" json:"guarded_ports_range,omitempty"`
Iface string `protobuf:"bytes,6,opt,name=iface,proto3" json:"iface,omitempty"`
HandshakeWindowSec int32 `protobuf:"varint,7,opt,name=handshake_window_sec,json=handshakeWindowSec,proto3" json:"handshake_window_sec,omitempty"`
InactiveTimerSec int32 `protobuf:"varint,8,opt,name=inactive_timer_sec,json=inactiveTimerSec,proto3" json:"inactive_timer_sec,omitempty"`
// contains filtered or unexported fields
}
func (*UpsertManagementSettingsRequest) Descriptor
deprecated
func (*UpsertManagementSettingsRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpsertManagementSettingsRequest.ProtoReflect.Descriptor instead.
func (*UpsertManagementSettingsRequest) GetAudience ¶
func (x *UpsertManagementSettingsRequest) GetAudience() string
func (*UpsertManagementSettingsRequest) GetGuardedPortsRange ¶
func (x *UpsertManagementSettingsRequest) GetGuardedPortsRange() string
func (*UpsertManagementSettingsRequest) GetHandshakeWindowSec ¶
func (x *UpsertManagementSettingsRequest) GetHandshakeWindowSec() int32
func (*UpsertManagementSettingsRequest) GetIface ¶
func (x *UpsertManagementSettingsRequest) GetIface() string
func (*UpsertManagementSettingsRequest) GetInactiveTimerSec ¶
func (x *UpsertManagementSettingsRequest) GetInactiveTimerSec() int32
func (*UpsertManagementSettingsRequest) GetIssuer ¶
func (x *UpsertManagementSettingsRequest) GetIssuer() string
func (*UpsertManagementSettingsRequest) GetJwksUrl ¶
func (x *UpsertManagementSettingsRequest) GetJwksUrl() string
func (*UpsertManagementSettingsRequest) GetRequiredScope ¶
func (x *UpsertManagementSettingsRequest) GetRequiredScope() string
func (*UpsertManagementSettingsRequest) ProtoMessage ¶
func (*UpsertManagementSettingsRequest) ProtoMessage()
func (*UpsertManagementSettingsRequest) ProtoReflect ¶
func (x *UpsertManagementSettingsRequest) ProtoReflect() protoreflect.Message
func (*UpsertManagementSettingsRequest) Reset ¶
func (x *UpsertManagementSettingsRequest) Reset()
func (*UpsertManagementSettingsRequest) String ¶
func (x *UpsertManagementSettingsRequest) String() string
type UpsertManagementSettingsResponse ¶
type UpsertManagementSettingsResponse struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
AuthConfigured bool `protobuf:"varint,2,opt,name=auth_configured,json=authConfigured,proto3" json:"auth_configured,omitempty"`
RuntimeAttached bool `protobuf:"varint,3,opt,name=runtime_attached,json=runtimeAttached,proto3" json:"runtime_attached,omitempty"`
RuntimeIface string `protobuf:"bytes,4,opt,name=runtime_iface,json=runtimeIface,proto3" json:"runtime_iface,omitempty"`
Issuer string `protobuf:"bytes,5,opt,name=issuer,proto3" json:"issuer,omitempty"`
Audience string `protobuf:"bytes,6,opt,name=audience,proto3" json:"audience,omitempty"`
JwksUrl string `protobuf:"bytes,7,opt,name=jwks_url,json=jwksUrl,proto3" json:"jwks_url,omitempty"`
RequiredScope string `protobuf:"bytes,8,opt,name=required_scope,json=requiredScope,proto3" json:"required_scope,omitempty"`
GuardedPortsRange string `protobuf:"bytes,9,opt,name=guarded_ports_range,json=guardedPortsRange,proto3" json:"guarded_ports_range,omitempty"`
Iface string `protobuf:"bytes,10,opt,name=iface,proto3" json:"iface,omitempty"`
HandshakeWindowSec int32 `protobuf:"varint,11,opt,name=handshake_window_sec,json=handshakeWindowSec,proto3" json:"handshake_window_sec,omitempty"`
InactiveTimerSec int32 `protobuf:"varint,12,opt,name=inactive_timer_sec,json=inactiveTimerSec,proto3" json:"inactive_timer_sec,omitempty"`
UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,13,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
// contains filtered or unexported fields
}
func (*UpsertManagementSettingsResponse) Descriptor
deprecated
func (*UpsertManagementSettingsResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpsertManagementSettingsResponse.ProtoReflect.Descriptor instead.
func (*UpsertManagementSettingsResponse) GetAudience ¶
func (x *UpsertManagementSettingsResponse) GetAudience() string
func (*UpsertManagementSettingsResponse) GetAuthConfigured ¶
func (x *UpsertManagementSettingsResponse) GetAuthConfigured() bool
func (*UpsertManagementSettingsResponse) GetGuardedPortsRange ¶
func (x *UpsertManagementSettingsResponse) GetGuardedPortsRange() string
func (*UpsertManagementSettingsResponse) GetHandshakeWindowSec ¶
func (x *UpsertManagementSettingsResponse) GetHandshakeWindowSec() int32
func (*UpsertManagementSettingsResponse) GetIface ¶
func (x *UpsertManagementSettingsResponse) GetIface() string
func (*UpsertManagementSettingsResponse) GetInactiveTimerSec ¶
func (x *UpsertManagementSettingsResponse) GetInactiveTimerSec() int32
func (*UpsertManagementSettingsResponse) GetIssuer ¶
func (x *UpsertManagementSettingsResponse) GetIssuer() string
func (*UpsertManagementSettingsResponse) GetJwksUrl ¶
func (x *UpsertManagementSettingsResponse) GetJwksUrl() string
func (*UpsertManagementSettingsResponse) GetMessage ¶
func (x *UpsertManagementSettingsResponse) GetMessage() string
func (*UpsertManagementSettingsResponse) GetRequiredScope ¶
func (x *UpsertManagementSettingsResponse) GetRequiredScope() string
func (*UpsertManagementSettingsResponse) GetRuntimeAttached ¶
func (x *UpsertManagementSettingsResponse) GetRuntimeAttached() bool
func (*UpsertManagementSettingsResponse) GetRuntimeIface ¶
func (x *UpsertManagementSettingsResponse) GetRuntimeIface() string
func (*UpsertManagementSettingsResponse) GetUpdatedAt ¶
func (x *UpsertManagementSettingsResponse) GetUpdatedAt() *timestamppb.Timestamp
func (*UpsertManagementSettingsResponse) ProtoMessage ¶
func (*UpsertManagementSettingsResponse) ProtoMessage()
func (*UpsertManagementSettingsResponse) ProtoReflect ¶
func (x *UpsertManagementSettingsResponse) ProtoReflect() protoreflect.Message
func (*UpsertManagementSettingsResponse) Reset ¶
func (x *UpsertManagementSettingsResponse) Reset()
func (*UpsertManagementSettingsResponse) String ¶
func (x *UpsertManagementSettingsResponse) String() string