Documentation
¶
Overview ¶
Package proto contains code related to protobuf.
Index ¶
- Constants
- Variables
- func RegisterConfigServer(s grpc.ServiceRegistrar, srv ConfigServer)
- func RegisterListenerServer(s grpc.ServiceRegistrar, srv ListenerServer)
- func SentryErrorLog(client *sentry.Client) grpc.UnaryServerInterceptor
- func UnaryLog(ctx context.Context, req any, info *grpc.UnaryServerInfo, ...) (resp any, err error)
- type Certificate
- func (*Certificate) Descriptor() ([]byte, []int)deprecated
- func (x *Certificate) GetCert() []byte
- func (x *Certificate) GetInfo() *CertificateInfo
- func (x *Certificate) GetKey() []byte
- func (*Certificate) ProtoMessage()
- func (x *Certificate) ProtoReflect() protoreflect.Message
- func (x *Certificate) Reset()
- func (x *Certificate) String() string
- type CertificateInfo
- func (*CertificateInfo) Descriptor() ([]byte, []int)deprecated
- func (x *CertificateInfo) GetDnsNames() []string
- func (x *CertificateInfo) GetEmailAddresses() []string
- func (x *CertificateInfo) GetError() string
- func (x *CertificateInfo) GetExcludedDnsDomains() []string
- func (x *CertificateInfo) GetExcludedEmailAddresses() []string
- func (x *CertificateInfo) GetExcludedIpRanges() []string
- func (x *CertificateInfo) GetExcludedUriDomains() []string
- func (x *CertificateInfo) GetIpAddresses() []string
- func (x *CertificateInfo) GetIssuer() *Name
- func (x *CertificateInfo) GetKeyUsage() *KeyUsage
- func (x *CertificateInfo) GetNotAfter() *timestamppb.Timestamp
- func (x *CertificateInfo) GetNotBefore() *timestamppb.Timestamp
- func (x *CertificateInfo) GetPermittedDnsDomains() []string
- func (x *CertificateInfo) GetPermittedDnsDomainsCritical() bool
- func (x *CertificateInfo) GetPermittedEmailAddresses() []string
- func (x *CertificateInfo) GetPermittedIpRanges() []string
- func (x *CertificateInfo) GetPermittedUriDomains() []string
- func (x *CertificateInfo) GetSerial() string
- func (x *CertificateInfo) GetSubject() *Name
- func (x *CertificateInfo) GetUris() []string
- func (x *CertificateInfo) GetVersion() int64
- func (*CertificateInfo) ProtoMessage()
- func (x *CertificateInfo) ProtoReflect() protoreflect.Message
- func (x *CertificateInfo) Reset()
- func (x *CertificateInfo) String() string
- type ClientCertFromStore
- func (*ClientCertFromStore) Descriptor() ([]byte, []int)deprecated
- func (x *ClientCertFromStore) GetIssuerFilter() string
- func (x *ClientCertFromStore) GetSubjectFilter() string
- func (*ClientCertFromStore) ProtoMessage()
- func (x *ClientCertFromStore) ProtoReflect() protoreflect.Message
- func (x *ClientCertFromStore) Reset()
- func (x *ClientCertFromStore) String() string
- type ConfigClient
- type ConfigData
- type ConfigServer
- type Connection
- func (*Connection) Descriptor() ([]byte, []int)deprecated
- func (x *Connection) GetAutostart() bool
- func (x *Connection) GetCaCert() []byte
- func (x *Connection) GetClientCert() *Certificate
- func (x *Connection) GetClientCertFromStore() *ClientCertFromStore
- func (x *Connection) GetDisableTlsVerification() bool
- func (x *Connection) GetListenAddr() string
- func (x *Connection) GetName() string
- func (x *Connection) GetPomeriumUrl() string
- func (x *Connection) GetProtocol() Protocol
- func (x *Connection) GetRemoteAddr() string
- func (x *Connection) GetTlsOptions() isConnection_TlsOptions
- func (*Connection) ProtoMessage()
- func (x *Connection) ProtoReflect() protoreflect.Message
- func (x *Connection) Reset()
- func (x *Connection) String() string
- type ConnectionStatusUpdate
- func (*ConnectionStatusUpdate) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectionStatusUpdate) GetAuthUrl() string
- func (x *ConnectionStatusUpdate) GetId() string
- func (x *ConnectionStatusUpdate) GetLastError() string
- func (x *ConnectionStatusUpdate) GetPeerAddr() string
- func (x *ConnectionStatusUpdate) GetStatus() ConnectionStatusUpdate_ConnectionStatus
- func (x *ConnectionStatusUpdate) GetTs() *timestamppb.Timestamp
- func (*ConnectionStatusUpdate) ProtoMessage()
- func (x *ConnectionStatusUpdate) ProtoReflect() protoreflect.Message
- func (x *ConnectionStatusUpdate) Reset()
- func (x *ConnectionStatusUpdate) String() string
- type ConnectionStatusUpdate_ConnectionStatus
- func (ConnectionStatusUpdate_ConnectionStatus) Descriptor() protoreflect.EnumDescriptor
- func (x ConnectionStatusUpdate_ConnectionStatus) Enum() *ConnectionStatusUpdate_ConnectionStatus
- func (ConnectionStatusUpdate_ConnectionStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x ConnectionStatusUpdate_ConnectionStatus) Number() protoreflect.EnumNumber
- func (x ConnectionStatusUpdate_ConnectionStatus) String() string
- func (ConnectionStatusUpdate_ConnectionStatus) Type() protoreflect.EnumType
- type Connection_CaCert
- type Connection_DisableTlsVerification
- type DeleteRecordsResponse
- type ExportRequest
- func (*ExportRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ExportRequest) GetFormat() ExportRequest_Format
- func (x *ExportRequest) GetRemoveTags() bool
- func (x *ExportRequest) GetSelector() *Selector
- func (*ExportRequest) ProtoMessage()
- func (x *ExportRequest) ProtoReflect() protoreflect.Message
- func (x *ExportRequest) Reset()
- func (x *ExportRequest) String() string
- type ExportRequest_Format
- func (ExportRequest_Format) Descriptor() protoreflect.EnumDescriptor
- func (x ExportRequest_Format) Enum() *ExportRequest_Format
- func (ExportRequest_Format) EnumDescriptor() ([]byte, []int)deprecated
- func (x ExportRequest_Format) Number() protoreflect.EnumNumber
- func (x ExportRequest_Format) String() string
- func (ExportRequest_Format) Type() protoreflect.EnumType
- type FetchRoutesRequest
- func (*FetchRoutesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *FetchRoutesRequest) GetCaCert() []byte
- func (x *FetchRoutesRequest) GetClientCert() *Certificate
- func (x *FetchRoutesRequest) GetClientCertFromStore() *ClientCertFromStore
- func (x *FetchRoutesRequest) GetDisableTlsVerification() bool
- func (x *FetchRoutesRequest) GetServerUrl() string
- func (x *FetchRoutesRequest) GetTlsOptions() isFetchRoutesRequest_TlsOptions
- func (*FetchRoutesRequest) ProtoMessage()
- func (x *FetchRoutesRequest) ProtoReflect() protoreflect.Message
- func (x *FetchRoutesRequest) Reset()
- func (x *FetchRoutesRequest) String() string
- type FetchRoutesRequest_CaCert
- type FetchRoutesRequest_DisableTlsVerification
- type FetchRoutesResponse
- func (*FetchRoutesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *FetchRoutesResponse) GetRoutes() []*PortalRoute
- func (*FetchRoutesResponse) ProtoMessage()
- func (x *FetchRoutesResponse) ProtoReflect() protoreflect.Message
- func (x *FetchRoutesResponse) Reset()
- func (x *FetchRoutesResponse) String() string
- type GetTagsRequest
- type GetTagsResponse
- type ImportRequest
- func (*ImportRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ImportRequest) GetData() []byte
- func (x *ImportRequest) GetOverrideTag() string
- func (*ImportRequest) ProtoMessage()
- func (x *ImportRequest) ProtoReflect() protoreflect.Message
- func (x *ImportRequest) Reset()
- func (x *ImportRequest) String() string
- type ImportResponse
- type KeyUsage
- func (*KeyUsage) Descriptor() ([]byte, []int)deprecated
- func (x *KeyUsage) GetCertSign() bool
- func (x *KeyUsage) GetClientAuth() bool
- func (x *KeyUsage) GetContentCommitment() bool
- func (x *KeyUsage) GetCrlSign() bool
- func (x *KeyUsage) GetDataEncipherment() bool
- func (x *KeyUsage) GetDecipherOnly() bool
- func (x *KeyUsage) GetDigitalSignature() bool
- func (x *KeyUsage) GetEncipherOnly() bool
- func (x *KeyUsage) GetKeyAgreement() bool
- func (x *KeyUsage) GetKeyEncipherment() bool
- func (x *KeyUsage) GetServerAuth() bool
- func (*KeyUsage) ProtoMessage()
- func (x *KeyUsage) ProtoReflect() protoreflect.Message
- func (x *KeyUsage) Reset()
- func (x *KeyUsage) String() string
- type ListenerClient
- type ListenerServer
- type ListenerStatus
- func (*ListenerStatus) Descriptor() ([]byte, []int)deprecated
- func (x *ListenerStatus) GetLastError() string
- func (x *ListenerStatus) GetListenAddr() string
- func (x *ListenerStatus) GetListening() bool
- func (*ListenerStatus) ProtoMessage()
- func (x *ListenerStatus) ProtoReflect() protoreflect.Message
- func (x *ListenerStatus) Reset()
- func (x *ListenerStatus) String() string
- type ListenerStatusResponse
- func (*ListenerStatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListenerStatusResponse) GetListeners() map[string]*ListenerStatus
- func (*ListenerStatusResponse) ProtoMessage()
- func (x *ListenerStatusResponse) ProtoReflect() protoreflect.Message
- func (x *ListenerStatusResponse) Reset()
- func (x *ListenerStatusResponse) String() string
- type ListenerUpdateRequest
- func (*ListenerUpdateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListenerUpdateRequest) GetConnected() bool
- func (x *ListenerUpdateRequest) GetConnectionIds() []string
- func (*ListenerUpdateRequest) ProtoMessage()
- func (x *ListenerUpdateRequest) ProtoReflect() protoreflect.Message
- func (x *ListenerUpdateRequest) Reset()
- func (x *ListenerUpdateRequest) String() string
- type Listener_StatusUpdatesClient
- type Listener_StatusUpdatesServer
- type Name
- func (*Name) Descriptor() ([]byte, []int)deprecated
- func (x *Name) GetCommonName() string
- func (x *Name) GetCountry() []string
- func (x *Name) GetLocality() []string
- func (x *Name) GetOrganization() []string
- func (x *Name) GetOrganizationalUnit() []string
- func (x *Name) GetPostalCode() []string
- func (x *Name) GetProvince() []string
- func (x *Name) GetSerialNumber() string
- func (x *Name) GetStreetAddress() []string
- func (*Name) ProtoMessage()
- func (x *Name) ProtoReflect() protoreflect.Message
- func (x *Name) Reset()
- func (x *Name) String() string
- type PortalRoute
- func (*PortalRoute) Descriptor() ([]byte, []int)deprecated
- func (x *PortalRoute) GetConnectCommand() string
- func (x *PortalRoute) GetDescription() string
- func (x *PortalRoute) GetFrom() string
- func (x *PortalRoute) GetId() string
- func (x *PortalRoute) GetLogoUrl() string
- func (x *PortalRoute) GetName() string
- func (x *PortalRoute) GetType() string
- func (*PortalRoute) ProtoMessage()
- func (x *PortalRoute) ProtoReflect() protoreflect.Message
- func (x *PortalRoute) Reset()
- func (x *PortalRoute) String() string
- type Protocol
- type Record
- func (*Record) Descriptor() ([]byte, []int)deprecated
- func (x *Record) GetConn() *Connection
- func (x *Record) GetId() string
- func (x *Record) GetSource() string
- func (x *Record) GetTags() []string
- func (*Record) ProtoMessage()
- func (x *Record) ProtoReflect() protoreflect.Message
- func (x *Record) Reset()
- func (x *Record) String() string
- type Records
- type Selector
- func (*Selector) Descriptor() ([]byte, []int)deprecated
- func (x *Selector) GetAll() bool
- func (x *Selector) GetIds() []string
- func (x *Selector) GetTags() []string
- func (*Selector) ProtoMessage()
- func (x *Selector) ProtoReflect() protoreflect.Message
- func (x *Selector) Reset()
- func (x *Selector) String() string
- type StatusUpdatesRequest
- func (*StatusUpdatesRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StatusUpdatesRequest) GetConnectionId() string
- func (*StatusUpdatesRequest) ProtoMessage()
- func (x *StatusUpdatesRequest) ProtoReflect() protoreflect.Message
- func (x *StatusUpdatesRequest) Reset()
- func (x *StatusUpdatesRequest) String() string
- type UnimplementedConfigServer
- func (UnimplementedConfigServer) Delete(context.Context, *Selector) (*DeleteRecordsResponse, error)
- func (UnimplementedConfigServer) Export(context.Context, *ExportRequest) (*ConfigData, error)
- func (UnimplementedConfigServer) FetchRoutes(context.Context, *FetchRoutesRequest) (*FetchRoutesResponse, error)
- func (UnimplementedConfigServer) GetTags(context.Context, *GetTagsRequest) (*GetTagsResponse, error)
- func (UnimplementedConfigServer) Import(context.Context, *ImportRequest) (*ImportResponse, error)
- func (UnimplementedConfigServer) List(context.Context, *Selector) (*Records, error)
- func (UnimplementedConfigServer) Upsert(context.Context, *Record) (*Record, error)
- type UnimplementedListenerServer
- func (UnimplementedListenerServer) GetStatus(context.Context, *Selector) (*ListenerStatusResponse, error)
- func (UnimplementedListenerServer) StatusUpdates(*StatusUpdatesRequest, grpc.ServerStreamingServer[ConnectionStatusUpdate]) error
- func (UnimplementedListenerServer) Update(context.Context, *ListenerUpdateRequest) (*ListenerStatusResponse, error)
- type UnsafeConfigServer
- type UnsafeListenerServer
Constants ¶
const ( Config_List_FullMethodName = "/pomerium.cli.Config/List" Config_Delete_FullMethodName = "/pomerium.cli.Config/Delete" Config_Upsert_FullMethodName = "/pomerium.cli.Config/Upsert" Config_GetTags_FullMethodName = "/pomerium.cli.Config/GetTags" Config_Export_FullMethodName = "/pomerium.cli.Config/Export" Config_Import_FullMethodName = "/pomerium.cli.Config/Import" Config_FetchRoutes_FullMethodName = "/pomerium.cli.Config/FetchRoutes" )
const ( Listener_Update_FullMethodName = "/pomerium.cli.Listener/Update" Listener_GetStatus_FullMethodName = "/pomerium.cli.Listener/GetStatus" Listener_StatusUpdates_FullMethodName = "/pomerium.cli.Listener/StatusUpdates" )
Variables ¶
var ( Protocol_name = map[int32]string{ 0: "UNKNOWN", 1: "TCP", 2: "UDP", } Protocol_value = map[string]int32{ "UNKNOWN": 0, "TCP": 1, "UDP": 2, } )
Enum value maps for Protocol.
var ( ExportRequest_Format_name = map[int32]string{ 0: "EXPORT_FORMAT_UNDEFINED", 1: "EXPORT_FORMAT_JSON_COMPACT", 2: "EXPORT_FORMAT_JSON_PRETTY", } ExportRequest_Format_value = map[string]int32{ "EXPORT_FORMAT_UNDEFINED": 0, "EXPORT_FORMAT_JSON_COMPACT": 1, "EXPORT_FORMAT_JSON_PRETTY": 2, } )
Enum value maps for ExportRequest_Format.
var ( ConnectionStatusUpdate_ConnectionStatus_name = map[int32]string{ 0: "CONNECTION_STATUS_UNDEFINED", 1: "CONNECTION_STATUS_CONNECTING", 2: "CONNECTION_STATUS_AUTH_REQUIRED", 3: "CONNECTION_STATUS_CONNECTED", 4: "CONNECTION_STATUS_DISCONNECTED", 5: "CONNECTION_STATUS_LISTENING", 6: "CONNECTION_STATUS_CLOSED", } ConnectionStatusUpdate_ConnectionStatus_value = map[string]int32{ "CONNECTION_STATUS_UNDEFINED": 0, "CONNECTION_STATUS_CONNECTING": 1, "CONNECTION_STATUS_AUTH_REQUIRED": 2, "CONNECTION_STATUS_CONNECTED": 3, "CONNECTION_STATUS_DISCONNECTED": 4, "CONNECTION_STATUS_LISTENING": 5, "CONNECTION_STATUS_CLOSED": 6, } )
Enum value maps for ConnectionStatusUpdate_ConnectionStatus.
var Config_ServiceDesc = grpc.ServiceDesc{ ServiceName: "pomerium.cli.Config", HandlerType: (*ConfigServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "List", Handler: _Config_List_Handler, }, { MethodName: "Delete", Handler: _Config_Delete_Handler, }, { MethodName: "Upsert", Handler: _Config_Upsert_Handler, }, { MethodName: "GetTags", Handler: _Config_GetTags_Handler, }, { MethodName: "Export", Handler: _Config_Export_Handler, }, { MethodName: "Import", Handler: _Config_Import_Handler, }, { MethodName: "FetchRoutes", Handler: _Config_FetchRoutes_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/api.proto", }
Config_ServiceDesc is the grpc.ServiceDesc for Config service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_proto_api_proto protoreflect.FileDescriptor
var Listener_ServiceDesc = grpc.ServiceDesc{ ServiceName: "pomerium.cli.Listener", HandlerType: (*ListenerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Update", Handler: _Listener_Update_Handler, }, { MethodName: "GetStatus", Handler: _Listener_GetStatus_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StatusUpdates", Handler: _Listener_StatusUpdates_Handler, ServerStreams: true, }, }, Metadata: "proto/api.proto", }
Listener_ServiceDesc is the grpc.ServiceDesc for Listener service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterConfigServer ¶
func RegisterConfigServer(s grpc.ServiceRegistrar, srv ConfigServer)
func RegisterListenerServer ¶
func RegisterListenerServer(s grpc.ServiceRegistrar, srv ListenerServer)
func SentryErrorLog ¶
func SentryErrorLog(client *sentry.Client) grpc.UnaryServerInterceptor
SentryErrorLog spools gRPC errors to Sentry
Types ¶
type Certificate ¶
type Certificate struct {
Cert []byte `protobuf:"bytes,1,opt,name=cert,proto3" json:"cert,omitempty"`
Key []byte `protobuf:"bytes,2,opt,name=key,proto3,oneof" json:"key,omitempty"`
// info field is ignored during upsert requests
// and is set when returning certificate info
Info *CertificateInfo `protobuf:"bytes,3,opt,name=info,proto3,oneof" json:"info,omitempty"`
// contains filtered or unexported fields
}
func (*Certificate) Descriptor
deprecated
func (*Certificate) Descriptor() ([]byte, []int)
Deprecated: Use Certificate.ProtoReflect.Descriptor instead.
func (*Certificate) GetCert ¶
func (x *Certificate) GetCert() []byte
func (*Certificate) GetInfo ¶
func (x *Certificate) GetInfo() *CertificateInfo
func (*Certificate) GetKey ¶
func (x *Certificate) GetKey() []byte
func (*Certificate) ProtoMessage ¶
func (*Certificate) ProtoMessage()
func (*Certificate) ProtoReflect ¶
func (x *Certificate) ProtoReflect() protoreflect.Message
func (*Certificate) Reset ¶
func (x *Certificate) Reset()
func (*Certificate) String ¶
func (x *Certificate) String() string
type CertificateInfo ¶
type CertificateInfo struct {
Version int64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
Serial string `protobuf:"bytes,2,opt,name=serial,proto3" json:"serial,omitempty"`
Issuer *Name `protobuf:"bytes,3,opt,name=issuer,proto3" json:"issuer,omitempty"`
Subject *Name `protobuf:"bytes,4,opt,name=subject,proto3" json:"subject,omitempty"`
NotBefore *timestamppb.Timestamp `protobuf:"bytes,5,opt,name=not_before,json=notBefore,proto3" json:"not_before,omitempty"`
NotAfter *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=not_after,json=notAfter,proto3" json:"not_after,omitempty"`
KeyUsage *KeyUsage `protobuf:"bytes,7,opt,name=key_usage,json=keyUsage,proto3" json:"key_usage,omitempty"`
DnsNames []string `protobuf:"bytes,10,rep,name=dns_names,json=dnsNames,proto3" json:"dns_names,omitempty"`
EmailAddresses []string `protobuf:"bytes,11,rep,name=email_addresses,json=emailAddresses,proto3" json:"email_addresses,omitempty"`
IpAddresses []string `protobuf:"bytes,12,rep,name=ip_addresses,json=ipAddresses,proto3" json:"ip_addresses,omitempty"`
Uris []string `protobuf:"bytes,13,rep,name=uris,proto3" json:"uris,omitempty"`
PermittedDnsDomainsCritical bool `` /* 148-byte string literal not displayed */
PermittedDnsDomains []string `protobuf:"bytes,15,rep,name=permitted_dns_domains,json=permittedDnsDomains,proto3" json:"permitted_dns_domains,omitempty"`
ExcludedDnsDomains []string `protobuf:"bytes,16,rep,name=excluded_dns_domains,json=excludedDnsDomains,proto3" json:"excluded_dns_domains,omitempty"`
PermittedIpRanges []string `protobuf:"bytes,17,rep,name=permitted_ip_ranges,json=permittedIpRanges,proto3" json:"permitted_ip_ranges,omitempty"`
ExcludedIpRanges []string `protobuf:"bytes,18,rep,name=excluded_ip_ranges,json=excludedIpRanges,proto3" json:"excluded_ip_ranges,omitempty"`
PermittedEmailAddresses []string `` /* 133-byte string literal not displayed */
ExcludedEmailAddresses []string `` /* 130-byte string literal not displayed */
PermittedUriDomains []string `protobuf:"bytes,21,rep,name=permitted_uri_domains,json=permittedUriDomains,proto3" json:"permitted_uri_domains,omitempty"`
ExcludedUriDomains []string `protobuf:"bytes,22,rep,name=excluded_uri_domains,json=excludedUriDomains,proto3" json:"excluded_uri_domains,omitempty"`
// error is set if there was an error parsing provided certificate
Error *string `protobuf:"bytes,23,opt,name=error,proto3,oneof" json:"error,omitempty"`
// contains filtered or unexported fields
}
func NewCertInfo ¶
func NewCertInfo(cert *x509.Certificate) *CertificateInfo
NewCertInfo extracts certificate info to the protobuf format
func (*CertificateInfo) Descriptor
deprecated
func (*CertificateInfo) Descriptor() ([]byte, []int)
Deprecated: Use CertificateInfo.ProtoReflect.Descriptor instead.
func (*CertificateInfo) GetDnsNames ¶
func (x *CertificateInfo) GetDnsNames() []string
func (*CertificateInfo) GetEmailAddresses ¶
func (x *CertificateInfo) GetEmailAddresses() []string
func (*CertificateInfo) GetError ¶
func (x *CertificateInfo) GetError() string
func (*CertificateInfo) GetExcludedDnsDomains ¶
func (x *CertificateInfo) GetExcludedDnsDomains() []string
func (*CertificateInfo) GetExcludedEmailAddresses ¶
func (x *CertificateInfo) GetExcludedEmailAddresses() []string
func (*CertificateInfo) GetExcludedIpRanges ¶
func (x *CertificateInfo) GetExcludedIpRanges() []string
func (*CertificateInfo) GetExcludedUriDomains ¶
func (x *CertificateInfo) GetExcludedUriDomains() []string
func (*CertificateInfo) GetIpAddresses ¶
func (x *CertificateInfo) GetIpAddresses() []string
func (*CertificateInfo) GetIssuer ¶
func (x *CertificateInfo) GetIssuer() *Name
func (*CertificateInfo) GetKeyUsage ¶
func (x *CertificateInfo) GetKeyUsage() *KeyUsage
func (*CertificateInfo) GetNotAfter ¶
func (x *CertificateInfo) GetNotAfter() *timestamppb.Timestamp
func (*CertificateInfo) GetNotBefore ¶
func (x *CertificateInfo) GetNotBefore() *timestamppb.Timestamp
func (*CertificateInfo) GetPermittedDnsDomains ¶
func (x *CertificateInfo) GetPermittedDnsDomains() []string
func (*CertificateInfo) GetPermittedDnsDomainsCritical ¶
func (x *CertificateInfo) GetPermittedDnsDomainsCritical() bool
func (*CertificateInfo) GetPermittedEmailAddresses ¶
func (x *CertificateInfo) GetPermittedEmailAddresses() []string
func (*CertificateInfo) GetPermittedIpRanges ¶
func (x *CertificateInfo) GetPermittedIpRanges() []string
func (*CertificateInfo) GetPermittedUriDomains ¶
func (x *CertificateInfo) GetPermittedUriDomains() []string
func (*CertificateInfo) GetSerial ¶
func (x *CertificateInfo) GetSerial() string
func (*CertificateInfo) GetSubject ¶
func (x *CertificateInfo) GetSubject() *Name
func (*CertificateInfo) GetUris ¶
func (x *CertificateInfo) GetUris() []string
func (*CertificateInfo) GetVersion ¶
func (x *CertificateInfo) GetVersion() int64
func (*CertificateInfo) ProtoMessage ¶
func (*CertificateInfo) ProtoMessage()
func (*CertificateInfo) ProtoReflect ¶
func (x *CertificateInfo) ProtoReflect() protoreflect.Message
func (*CertificateInfo) Reset ¶
func (x *CertificateInfo) Reset()
func (*CertificateInfo) String ¶
func (x *CertificateInfo) String() string
type ClientCertFromStore ¶
type ClientCertFromStore struct {
// filters based on a single name attribute (e.g. "CN=my cert" or "O=my org")
IssuerFilter *string `protobuf:"bytes,1,opt,name=issuer_filter,json=issuerFilter,proto3,oneof" json:"issuer_filter,omitempty"`
SubjectFilter *string `protobuf:"bytes,2,opt,name=subject_filter,json=subjectFilter,proto3,oneof" json:"subject_filter,omitempty"`
// contains filtered or unexported fields
}
ClientCertFromStore contains additional filters to apply when searching for a client certificate in the system trust store. (This search will always take into account any CA names from the TLS CertificateRequest message.)
func (*ClientCertFromStore) Descriptor
deprecated
func (*ClientCertFromStore) Descriptor() ([]byte, []int)
Deprecated: Use ClientCertFromStore.ProtoReflect.Descriptor instead.
func (*ClientCertFromStore) GetIssuerFilter ¶
func (x *ClientCertFromStore) GetIssuerFilter() string
func (*ClientCertFromStore) GetSubjectFilter ¶
func (x *ClientCertFromStore) GetSubjectFilter() string
func (*ClientCertFromStore) ProtoMessage ¶
func (*ClientCertFromStore) ProtoMessage()
func (*ClientCertFromStore) ProtoReflect ¶
func (x *ClientCertFromStore) ProtoReflect() protoreflect.Message
func (*ClientCertFromStore) Reset ¶
func (x *ClientCertFromStore) Reset()
func (*ClientCertFromStore) String ¶
func (x *ClientCertFromStore) String() string
type ConfigClient ¶
type ConfigClient interface {
// List returns records that match Selector
List(ctx context.Context, in *Selector, opts ...grpc.CallOption) (*Records, error)
// Delete deletes records that match Selector
Delete(ctx context.Context, in *Selector, opts ...grpc.CallOption) (*DeleteRecordsResponse, error)
// Upsert inserts (if no ID is provided) or updates records
// you may omit the Connection data to just manipulate tags
Upsert(ctx context.Context, in *Record, opts ...grpc.CallOption) (*Record, error)
// GetTags returns all tags. Note that tags are case sensitive
GetTags(ctx context.Context, in *GetTagsRequest, opts ...grpc.CallOption) (*GetTagsResponse, error)
// Export dumps config into serialized format
Export(ctx context.Context, in *ExportRequest, opts ...grpc.CallOption) (*ConfigData, error)
// Import imports previously serialized records
Import(ctx context.Context, in *ImportRequest, opts ...grpc.CallOption) (*ImportResponse, error)
// FetchRoutes fetches all the routes from the routes portal.
FetchRoutes(ctx context.Context, in *FetchRoutesRequest, opts ...grpc.CallOption) (*FetchRoutesResponse, error)
}
ConfigClient is the client API for Config 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.
Config represents desktop client configuration
func NewConfigClient ¶
func NewConfigClient(cc grpc.ClientConnInterface) ConfigClient
type ConfigData ¶
type ConfigData struct {
Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
// contains filtered or unexported fields
}
func (*ConfigData) Descriptor
deprecated
func (*ConfigData) Descriptor() ([]byte, []int)
Deprecated: Use ConfigData.ProtoReflect.Descriptor instead.
func (*ConfigData) GetData ¶
func (x *ConfigData) GetData() []byte
func (*ConfigData) ProtoMessage ¶
func (*ConfigData) ProtoMessage()
func (*ConfigData) ProtoReflect ¶
func (x *ConfigData) ProtoReflect() protoreflect.Message
func (*ConfigData) Reset ¶
func (x *ConfigData) Reset()
func (*ConfigData) String ¶
func (x *ConfigData) String() string
type ConfigServer ¶
type ConfigServer interface {
// List returns records that match Selector
List(context.Context, *Selector) (*Records, error)
// Delete deletes records that match Selector
Delete(context.Context, *Selector) (*DeleteRecordsResponse, error)
// Upsert inserts (if no ID is provided) or updates records
// you may omit the Connection data to just manipulate tags
Upsert(context.Context, *Record) (*Record, error)
// GetTags returns all tags. Note that tags are case sensitive
GetTags(context.Context, *GetTagsRequest) (*GetTagsResponse, error)
// Export dumps config into serialized format
Export(context.Context, *ExportRequest) (*ConfigData, error)
// Import imports previously serialized records
Import(context.Context, *ImportRequest) (*ImportResponse, error)
// FetchRoutes fetches all the routes from the routes portal.
FetchRoutes(context.Context, *FetchRoutesRequest) (*FetchRoutesResponse, error)
}
ConfigServer is the server API for Config service. All implementations should embed UnimplementedConfigServer for forward compatibility.
Config represents desktop client configuration
type Connection ¶
type Connection struct {
// name is a user friendly connection name that a user may define
Name *string `protobuf:"bytes,1,opt,name=name,proto3,oneof" json:"name,omitempty"`
// the protocol to use for the connection
Protocol *Protocol `protobuf:"varint,10,opt,name=protocol,proto3,enum=pomerium.cli.Protocol,oneof" json:"protocol,omitempty"`
// remote_addr is a remote pomerium host:port
RemoteAddr string `protobuf:"bytes,2,opt,name=remote_addr,json=remoteAddr,proto3" json:"remote_addr,omitempty"`
// listen_address, if not provided, will assign a random port each time
ListenAddr *string `protobuf:"bytes,3,opt,name=listen_addr,json=listenAddr,proto3,oneof" json:"listen_addr,omitempty"`
// the URL of the pomerium server to connect to
PomeriumUrl *string `protobuf:"bytes,4,opt,name=pomerium_url,json=pomeriumUrl,proto3,oneof" json:"pomerium_url,omitempty"`
// Types that are valid to be assigned to TlsOptions:
//
// *Connection_DisableTlsVerification
// *Connection_CaCert
TlsOptions isConnection_TlsOptions `protobuf_oneof:"tls_options"`
ClientCert *Certificate `protobuf:"bytes,7,opt,name=client_cert,json=clientCert,proto3,oneof" json:"client_cert,omitempty"`
// indicates to search the system trust store for a client certificate
ClientCertFromStore *ClientCertFromStore `` /* 128-byte string literal not displayed */
Autostart *bool `protobuf:"varint,11,opt,name=autostart,proto3,oneof" json:"autostart,omitempty"`
// contains filtered or unexported fields
}
Connection
func (*Connection) Descriptor
deprecated
func (*Connection) Descriptor() ([]byte, []int)
Deprecated: Use Connection.ProtoReflect.Descriptor instead.
func (*Connection) GetAutostart ¶
func (x *Connection) GetAutostart() bool
func (*Connection) GetCaCert ¶
func (x *Connection) GetCaCert() []byte
func (*Connection) GetClientCert ¶
func (x *Connection) GetClientCert() *Certificate
func (*Connection) GetClientCertFromStore ¶
func (x *Connection) GetClientCertFromStore() *ClientCertFromStore
func (*Connection) GetDisableTlsVerification ¶
func (x *Connection) GetDisableTlsVerification() bool
func (*Connection) GetListenAddr ¶
func (x *Connection) GetListenAddr() string
func (*Connection) GetName ¶
func (x *Connection) GetName() string
func (*Connection) GetPomeriumUrl ¶
func (x *Connection) GetPomeriumUrl() string
func (*Connection) GetProtocol ¶
func (x *Connection) GetProtocol() Protocol
func (*Connection) GetRemoteAddr ¶
func (x *Connection) GetRemoteAddr() string
func (*Connection) GetTlsOptions ¶
func (x *Connection) GetTlsOptions() isConnection_TlsOptions
func (*Connection) ProtoMessage ¶
func (*Connection) ProtoMessage()
func (*Connection) ProtoReflect ¶
func (x *Connection) ProtoReflect() protoreflect.Message
func (*Connection) Reset ¶
func (x *Connection) Reset()
func (*Connection) String ¶
func (x *Connection) String() string
type ConnectionStatusUpdate ¶
type ConnectionStatusUpdate struct {
// record this event relates to
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
// peer_addr represents connecting party remote address and may be used to
// distinguish between individual TCP connections
PeerAddr *string `protobuf:"bytes,2,opt,name=peer_addr,json=peerAddr,proto3,oneof" json:"peer_addr,omitempty"`
Status ConnectionStatusUpdate_ConnectionStatus `protobuf:"varint,3,opt,name=status,proto3,enum=pomerium.cli.ConnectionStatusUpdate_ConnectionStatus" json:"status,omitempty"`
// in case the connection failed or terminated, last error may be available
LastError *string `protobuf:"bytes,4,opt,name=last_error,json=lastError,proto3,oneof" json:"last_error,omitempty"`
// provides an authentication URL when AUTH_REQUIRED status is set
AuthUrl *string `protobuf:"bytes,5,opt,name=auth_url,json=authUrl,proto3,oneof" json:"auth_url,omitempty"`
// event timestamp
Ts *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=ts,proto3" json:"ts,omitempty"`
// contains filtered or unexported fields
}
ConnectionStatusUpdates represent connection state changes
func (*ConnectionStatusUpdate) Descriptor
deprecated
func (*ConnectionStatusUpdate) Descriptor() ([]byte, []int)
Deprecated: Use ConnectionStatusUpdate.ProtoReflect.Descriptor instead.
func (*ConnectionStatusUpdate) GetAuthUrl ¶
func (x *ConnectionStatusUpdate) GetAuthUrl() string
func (*ConnectionStatusUpdate) GetId ¶
func (x *ConnectionStatusUpdate) GetId() string
func (*ConnectionStatusUpdate) GetLastError ¶
func (x *ConnectionStatusUpdate) GetLastError() string
func (*ConnectionStatusUpdate) GetPeerAddr ¶
func (x *ConnectionStatusUpdate) GetPeerAddr() string
func (*ConnectionStatusUpdate) GetStatus ¶
func (x *ConnectionStatusUpdate) GetStatus() ConnectionStatusUpdate_ConnectionStatus
func (*ConnectionStatusUpdate) GetTs ¶
func (x *ConnectionStatusUpdate) GetTs() *timestamppb.Timestamp
func (*ConnectionStatusUpdate) ProtoMessage ¶
func (*ConnectionStatusUpdate) ProtoMessage()
func (*ConnectionStatusUpdate) ProtoReflect ¶
func (x *ConnectionStatusUpdate) ProtoReflect() protoreflect.Message
func (*ConnectionStatusUpdate) Reset ¶
func (x *ConnectionStatusUpdate) Reset()
func (*ConnectionStatusUpdate) String ¶
func (x *ConnectionStatusUpdate) String() string
type ConnectionStatusUpdate_ConnectionStatus ¶
type ConnectionStatusUpdate_ConnectionStatus int32
const ( ConnectionStatusUpdate_CONNECTION_STATUS_UNDEFINED ConnectionStatusUpdate_ConnectionStatus = 0 ConnectionStatusUpdate_CONNECTION_STATUS_CONNECTING ConnectionStatusUpdate_ConnectionStatus = 1 ConnectionStatusUpdate_CONNECTION_STATUS_AUTH_REQUIRED ConnectionStatusUpdate_ConnectionStatus = 2 ConnectionStatusUpdate_CONNECTION_STATUS_CONNECTED ConnectionStatusUpdate_ConnectionStatus = 3 ConnectionStatusUpdate_CONNECTION_STATUS_DISCONNECTED ConnectionStatusUpdate_ConnectionStatus = 4 // listener is up; peer_addr would not be set ConnectionStatusUpdate_CONNECTION_STATUS_LISTENING ConnectionStatusUpdate_ConnectionStatus = 5 // listener is closed; peer_addr would not be set ConnectionStatusUpdate_CONNECTION_STATUS_CLOSED ConnectionStatusUpdate_ConnectionStatus = 6 )
func (ConnectionStatusUpdate_ConnectionStatus) Descriptor ¶
func (ConnectionStatusUpdate_ConnectionStatus) Descriptor() protoreflect.EnumDescriptor
func (ConnectionStatusUpdate_ConnectionStatus) EnumDescriptor
deprecated
func (ConnectionStatusUpdate_ConnectionStatus) EnumDescriptor() ([]byte, []int)
Deprecated: Use ConnectionStatusUpdate_ConnectionStatus.Descriptor instead.
func (ConnectionStatusUpdate_ConnectionStatus) Number ¶
func (x ConnectionStatusUpdate_ConnectionStatus) Number() protoreflect.EnumNumber
func (ConnectionStatusUpdate_ConnectionStatus) String ¶
func (x ConnectionStatusUpdate_ConnectionStatus) String() string
func (ConnectionStatusUpdate_ConnectionStatus) Type ¶
func (ConnectionStatusUpdate_ConnectionStatus) Type() protoreflect.EnumType
type Connection_CaCert ¶
type Connection_CaCert struct {
CaCert []byte `protobuf:"bytes,6,opt,name=ca_cert,json=caCert,proto3,oneof"`
}
type Connection_DisableTlsVerification ¶
type Connection_DisableTlsVerification struct {
DisableTlsVerification bool `protobuf:"varint,5,opt,name=disable_tls_verification,json=disableTlsVerification,proto3,oneof"`
}
type DeleteRecordsResponse ¶
type DeleteRecordsResponse struct {
// contains filtered or unexported fields
}
func (*DeleteRecordsResponse) Descriptor
deprecated
func (*DeleteRecordsResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteRecordsResponse.ProtoReflect.Descriptor instead.
func (*DeleteRecordsResponse) ProtoMessage ¶
func (*DeleteRecordsResponse) ProtoMessage()
func (*DeleteRecordsResponse) ProtoReflect ¶
func (x *DeleteRecordsResponse) ProtoReflect() protoreflect.Message
func (*DeleteRecordsResponse) Reset ¶
func (x *DeleteRecordsResponse) Reset()
func (*DeleteRecordsResponse) String ¶
func (x *DeleteRecordsResponse) String() string
type ExportRequest ¶
type ExportRequest struct {
Selector *Selector `protobuf:"bytes,1,opt,name=selector,proto3" json:"selector,omitempty"`
// remove_tags to strip tags from output
RemoveTags bool `protobuf:"varint,2,opt,name=remove_tags,json=removeTags,proto3" json:"remove_tags,omitempty"`
Format ExportRequest_Format `protobuf:"varint,3,opt,name=format,proto3,enum=pomerium.cli.ExportRequest_Format" json:"format,omitempty"`
// contains filtered or unexported fields
}
Export dumps configuration (or subset of, based on provided tag filter) in the JSON format
func (*ExportRequest) Descriptor
deprecated
func (*ExportRequest) Descriptor() ([]byte, []int)
Deprecated: Use ExportRequest.ProtoReflect.Descriptor instead.
func (*ExportRequest) GetFormat ¶
func (x *ExportRequest) GetFormat() ExportRequest_Format
func (*ExportRequest) GetRemoveTags ¶
func (x *ExportRequest) GetRemoveTags() bool
func (*ExportRequest) GetSelector ¶
func (x *ExportRequest) GetSelector() *Selector
func (*ExportRequest) ProtoMessage ¶
func (*ExportRequest) ProtoMessage()
func (*ExportRequest) ProtoReflect ¶
func (x *ExportRequest) ProtoReflect() protoreflect.Message
func (*ExportRequest) Reset ¶
func (x *ExportRequest) Reset()
func (*ExportRequest) String ¶
func (x *ExportRequest) String() string
type ExportRequest_Format ¶
type ExportRequest_Format int32
const ( ExportRequest_EXPORT_FORMAT_UNDEFINED ExportRequest_Format = 0 ExportRequest_EXPORT_FORMAT_JSON_COMPACT ExportRequest_Format = 1 ExportRequest_EXPORT_FORMAT_JSON_PRETTY ExportRequest_Format = 2 )
func (ExportRequest_Format) Descriptor ¶
func (ExportRequest_Format) Descriptor() protoreflect.EnumDescriptor
func (ExportRequest_Format) Enum ¶
func (x ExportRequest_Format) Enum() *ExportRequest_Format
func (ExportRequest_Format) EnumDescriptor
deprecated
func (ExportRequest_Format) EnumDescriptor() ([]byte, []int)
Deprecated: Use ExportRequest_Format.Descriptor instead.
func (ExportRequest_Format) Number ¶
func (x ExportRequest_Format) Number() protoreflect.EnumNumber
func (ExportRequest_Format) String ¶
func (x ExportRequest_Format) String() string
func (ExportRequest_Format) Type ¶
func (ExportRequest_Format) Type() protoreflect.EnumType
type FetchRoutesRequest ¶
type FetchRoutesRequest struct {
ServerUrl string `protobuf:"bytes,1,opt,name=server_url,json=serverUrl,proto3" json:"server_url,omitempty"`
// Types that are valid to be assigned to TlsOptions:
//
// *FetchRoutesRequest_DisableTlsVerification
// *FetchRoutesRequest_CaCert
TlsOptions isFetchRoutesRequest_TlsOptions `protobuf_oneof:"tls_options"`
ClientCert *Certificate `protobuf:"bytes,4,opt,name=client_cert,json=clientCert,proto3,oneof" json:"client_cert,omitempty"`
ClientCertFromStore *ClientCertFromStore `` /* 128-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*FetchRoutesRequest) Descriptor
deprecated
func (*FetchRoutesRequest) Descriptor() ([]byte, []int)
Deprecated: Use FetchRoutesRequest.ProtoReflect.Descriptor instead.
func (*FetchRoutesRequest) GetCaCert ¶
func (x *FetchRoutesRequest) GetCaCert() []byte
func (*FetchRoutesRequest) GetClientCert ¶
func (x *FetchRoutesRequest) GetClientCert() *Certificate
func (*FetchRoutesRequest) GetClientCertFromStore ¶
func (x *FetchRoutesRequest) GetClientCertFromStore() *ClientCertFromStore
func (*FetchRoutesRequest) GetDisableTlsVerification ¶
func (x *FetchRoutesRequest) GetDisableTlsVerification() bool
func (*FetchRoutesRequest) GetServerUrl ¶
func (x *FetchRoutesRequest) GetServerUrl() string
func (*FetchRoutesRequest) GetTlsOptions ¶
func (x *FetchRoutesRequest) GetTlsOptions() isFetchRoutesRequest_TlsOptions
func (*FetchRoutesRequest) ProtoMessage ¶
func (*FetchRoutesRequest) ProtoMessage()
func (*FetchRoutesRequest) ProtoReflect ¶
func (x *FetchRoutesRequest) ProtoReflect() protoreflect.Message
func (*FetchRoutesRequest) Reset ¶
func (x *FetchRoutesRequest) Reset()
func (*FetchRoutesRequest) String ¶
func (x *FetchRoutesRequest) String() string
type FetchRoutesRequest_CaCert ¶
type FetchRoutesRequest_CaCert struct {
CaCert []byte `protobuf:"bytes,3,opt,name=ca_cert,json=caCert,proto3,oneof"`
}
type FetchRoutesRequest_DisableTlsVerification ¶
type FetchRoutesRequest_DisableTlsVerification struct {
DisableTlsVerification bool `protobuf:"varint,2,opt,name=disable_tls_verification,json=disableTlsVerification,proto3,oneof"`
}
type FetchRoutesResponse ¶
type FetchRoutesResponse struct {
Routes []*PortalRoute `protobuf:"bytes,1,rep,name=routes,proto3" json:"routes,omitempty"`
// contains filtered or unexported fields
}
func (*FetchRoutesResponse) Descriptor
deprecated
func (*FetchRoutesResponse) Descriptor() ([]byte, []int)
Deprecated: Use FetchRoutesResponse.ProtoReflect.Descriptor instead.
func (*FetchRoutesResponse) GetRoutes ¶
func (x *FetchRoutesResponse) GetRoutes() []*PortalRoute
func (*FetchRoutesResponse) ProtoMessage ¶
func (*FetchRoutesResponse) ProtoMessage()
func (*FetchRoutesResponse) ProtoReflect ¶
func (x *FetchRoutesResponse) ProtoReflect() protoreflect.Message
func (*FetchRoutesResponse) Reset ¶
func (x *FetchRoutesResponse) Reset()
func (*FetchRoutesResponse) String ¶
func (x *FetchRoutesResponse) String() string
type GetTagsRequest ¶
type GetTagsRequest struct {
// contains filtered or unexported fields
}
func (*GetTagsRequest) Descriptor
deprecated
func (*GetTagsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetTagsRequest.ProtoReflect.Descriptor instead.
func (*GetTagsRequest) ProtoMessage ¶
func (*GetTagsRequest) ProtoMessage()
func (*GetTagsRequest) ProtoReflect ¶
func (x *GetTagsRequest) ProtoReflect() protoreflect.Message
func (*GetTagsRequest) Reset ¶
func (x *GetTagsRequest) Reset()
func (*GetTagsRequest) String ¶
func (x *GetTagsRequest) String() string
type GetTagsResponse ¶
type GetTagsResponse struct {
Tags []string `protobuf:"bytes,1,rep,name=tags,proto3" json:"tags,omitempty"`
// contains filtered or unexported fields
}
func (*GetTagsResponse) Descriptor
deprecated
func (*GetTagsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetTagsResponse.ProtoReflect.Descriptor instead.
func (*GetTagsResponse) GetTags ¶
func (x *GetTagsResponse) GetTags() []string
func (*GetTagsResponse) ProtoMessage ¶
func (*GetTagsResponse) ProtoMessage()
func (*GetTagsResponse) ProtoReflect ¶
func (x *GetTagsResponse) ProtoReflect() protoreflect.Message
func (*GetTagsResponse) Reset ¶
func (x *GetTagsResponse) Reset()
func (*GetTagsResponse) String ¶
func (x *GetTagsResponse) String() string
type ImportRequest ¶
type ImportRequest struct {
// if set, all connections would receive that tag instead
OverrideTag *string `protobuf:"bytes,1,opt,name=override_tag,json=overrideTag,proto3,oneof" json:"override_tag,omitempty"`
Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
// contains filtered or unexported fields
}
ImportRequest would consume the previously exported data back, merging it with existing configuration, and performing de-duplication of the records so that multiple imports would yield the same result
func (*ImportRequest) Descriptor
deprecated
func (*ImportRequest) Descriptor() ([]byte, []int)
Deprecated: Use ImportRequest.ProtoReflect.Descriptor instead.
func (*ImportRequest) GetData ¶
func (x *ImportRequest) GetData() []byte
func (*ImportRequest) GetOverrideTag ¶
func (x *ImportRequest) GetOverrideTag() string
func (*ImportRequest) ProtoMessage ¶
func (*ImportRequest) ProtoMessage()
func (*ImportRequest) ProtoReflect ¶
func (x *ImportRequest) ProtoReflect() protoreflect.Message
func (*ImportRequest) Reset ¶
func (x *ImportRequest) Reset()
func (*ImportRequest) String ¶
func (x *ImportRequest) String() string
type ImportResponse ¶
type ImportResponse struct {
// contains filtered or unexported fields
}
func (*ImportResponse) Descriptor
deprecated
func (*ImportResponse) Descriptor() ([]byte, []int)
Deprecated: Use ImportResponse.ProtoReflect.Descriptor instead.
func (*ImportResponse) ProtoMessage ¶
func (*ImportResponse) ProtoMessage()
func (*ImportResponse) ProtoReflect ¶
func (x *ImportResponse) ProtoReflect() protoreflect.Message
func (*ImportResponse) Reset ¶
func (x *ImportResponse) Reset()
func (*ImportResponse) String ¶
func (x *ImportResponse) String() string
type KeyUsage ¶
type KeyUsage struct {
// standard key usages
DigitalSignature bool `protobuf:"varint,1,opt,name=digital_signature,json=digitalSignature,proto3" json:"digital_signature,omitempty"`
ContentCommitment bool `protobuf:"varint,2,opt,name=content_commitment,json=contentCommitment,proto3" json:"content_commitment,omitempty"`
KeyEncipherment bool `protobuf:"varint,3,opt,name=key_encipherment,json=keyEncipherment,proto3" json:"key_encipherment,omitempty"`
DataEncipherment bool `protobuf:"varint,4,opt,name=data_encipherment,json=dataEncipherment,proto3" json:"data_encipherment,omitempty"`
KeyAgreement bool `protobuf:"varint,5,opt,name=key_agreement,json=keyAgreement,proto3" json:"key_agreement,omitempty"`
// certificate authority
CertSign bool `protobuf:"varint,6,opt,name=cert_sign,json=certSign,proto3" json:"cert_sign,omitempty"`
CrlSign bool `protobuf:"varint,7,opt,name=crl_sign,json=crlSign,proto3" json:"crl_sign,omitempty"`
EncipherOnly bool `protobuf:"varint,8,opt,name=encipher_only,json=encipherOnly,proto3" json:"encipher_only,omitempty"`
DecipherOnly bool `protobuf:"varint,9,opt,name=decipher_only,json=decipherOnly,proto3" json:"decipher_only,omitempty"`
// extensions derived from x509.ExtKeyUsage
// server certificate
ServerAuth bool `protobuf:"varint,10,opt,name=server_auth,json=serverAuth,proto3" json:"server_auth,omitempty"`
// client certificate
ClientAuth bool `protobuf:"varint,11,opt,name=client_auth,json=clientAuth,proto3" json:"client_auth,omitempty"`
// contains filtered or unexported fields
}
func (*KeyUsage) Descriptor
deprecated
func (*KeyUsage) GetCertSign ¶
func (*KeyUsage) GetClientAuth ¶
func (*KeyUsage) GetContentCommitment ¶
func (*KeyUsage) GetCrlSign ¶
func (*KeyUsage) GetDataEncipherment ¶
func (*KeyUsage) GetDecipherOnly ¶
func (*KeyUsage) GetDigitalSignature ¶
func (*KeyUsage) GetEncipherOnly ¶
func (*KeyUsage) GetKeyAgreement ¶
func (*KeyUsage) GetKeyEncipherment ¶
func (*KeyUsage) GetServerAuth ¶
func (*KeyUsage) ProtoMessage ¶
func (*KeyUsage) ProtoMessage()
func (*KeyUsage) ProtoReflect ¶
func (x *KeyUsage) ProtoReflect() protoreflect.Message
type ListenerClient ¶
type ListenerClient interface {
// Update alters connection status.
Update(ctx context.Context, in *ListenerUpdateRequest, opts ...grpc.CallOption) (*ListenerStatusResponse, error)
// GetStatus returns current listener status for active tunnels
GetStatus(ctx context.Context, in *Selector, opts ...grpc.CallOption) (*ListenerStatusResponse, error)
// StatusUpdates opens a stream to listen to connection status updates
// a client has to subscribe and continuously
// listen to the broadcasted updates
StatusUpdates(ctx context.Context, in *StatusUpdatesRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[ConnectionStatusUpdate], error)
}
ListenerClient is the client API for Listener 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.
Listener service controls listeners
func NewListenerClient ¶
func NewListenerClient(cc grpc.ClientConnInterface) ListenerClient
type ListenerServer ¶
type ListenerServer interface {
// Update alters connection status.
Update(context.Context, *ListenerUpdateRequest) (*ListenerStatusResponse, error)
// GetStatus returns current listener status for active tunnels
GetStatus(context.Context, *Selector) (*ListenerStatusResponse, error)
// StatusUpdates opens a stream to listen to connection status updates
// a client has to subscribe and continuously
// listen to the broadcasted updates
StatusUpdates(*StatusUpdatesRequest, grpc.ServerStreamingServer[ConnectionStatusUpdate]) error
}
ListenerServer is the server API for Listener service. All implementations should embed UnimplementedListenerServer for forward compatibility.
Listener service controls listeners
type ListenerStatus ¶
type ListenerStatus struct {
Listening bool `protobuf:"varint,1,opt,name=listening,proto3" json:"listening,omitempty"`
ListenAddr *string `protobuf:"bytes,2,opt,name=listen_addr,json=listenAddr,proto3,oneof" json:"listen_addr,omitempty"`
LastError *string `protobuf:"bytes,3,opt,name=last_error,json=lastError,proto3,oneof" json:"last_error,omitempty"`
// contains filtered or unexported fields
}
func (*ListenerStatus) Descriptor
deprecated
func (*ListenerStatus) Descriptor() ([]byte, []int)
Deprecated: Use ListenerStatus.ProtoReflect.Descriptor instead.
func (*ListenerStatus) GetLastError ¶
func (x *ListenerStatus) GetLastError() string
func (*ListenerStatus) GetListenAddr ¶
func (x *ListenerStatus) GetListenAddr() string
func (*ListenerStatus) GetListening ¶
func (x *ListenerStatus) GetListening() bool
func (*ListenerStatus) ProtoMessage ¶
func (*ListenerStatus) ProtoMessage()
func (*ListenerStatus) ProtoReflect ¶
func (x *ListenerStatus) ProtoReflect() protoreflect.Message
func (*ListenerStatus) Reset ¶
func (x *ListenerStatus) Reset()
func (*ListenerStatus) String ¶
func (x *ListenerStatus) String() string
type ListenerStatusResponse ¶
type ListenerStatusResponse struct {
Listeners map[string]*ListenerStatus `` /* 145-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*ListenerStatusResponse) Descriptor
deprecated
func (*ListenerStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListenerStatusResponse.ProtoReflect.Descriptor instead.
func (*ListenerStatusResponse) GetListeners ¶
func (x *ListenerStatusResponse) GetListeners() map[string]*ListenerStatus
func (*ListenerStatusResponse) ProtoMessage ¶
func (*ListenerStatusResponse) ProtoMessage()
func (*ListenerStatusResponse) ProtoReflect ¶
func (x *ListenerStatusResponse) ProtoReflect() protoreflect.Message
func (*ListenerStatusResponse) Reset ¶
func (x *ListenerStatusResponse) Reset()
func (*ListenerStatusResponse) String ¶
func (x *ListenerStatusResponse) String() string
type ListenerUpdateRequest ¶
type ListenerUpdateRequest struct {
// omit connection ids to connect all connections
ConnectionIds []string `protobuf:"bytes,1,rep,name=connection_ids,json=connectionIds,proto3" json:"connection_ids,omitempty"`
Connected bool `protobuf:"varint,2,opt,name=connected,proto3" json:"connected,omitempty"`
// contains filtered or unexported fields
}
func (*ListenerUpdateRequest) Descriptor
deprecated
func (*ListenerUpdateRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListenerUpdateRequest.ProtoReflect.Descriptor instead.
func (*ListenerUpdateRequest) GetConnected ¶
func (x *ListenerUpdateRequest) GetConnected() bool
func (*ListenerUpdateRequest) GetConnectionIds ¶
func (x *ListenerUpdateRequest) GetConnectionIds() []string
func (*ListenerUpdateRequest) ProtoMessage ¶
func (*ListenerUpdateRequest) ProtoMessage()
func (*ListenerUpdateRequest) ProtoReflect ¶
func (x *ListenerUpdateRequest) ProtoReflect() protoreflect.Message
func (*ListenerUpdateRequest) Reset ¶
func (x *ListenerUpdateRequest) Reset()
func (*ListenerUpdateRequest) String ¶
func (x *ListenerUpdateRequest) String() string
type Listener_StatusUpdatesClient ¶
type Listener_StatusUpdatesClient = grpc.ServerStreamingClient[ConnectionStatusUpdate]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Listener_StatusUpdatesServer ¶
type Listener_StatusUpdatesServer = grpc.ServerStreamingServer[ConnectionStatusUpdate]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type Name ¶
type Name struct {
Country []string `protobuf:"bytes,1,rep,name=country,proto3" json:"country,omitempty"`
Organization []string `protobuf:"bytes,2,rep,name=organization,proto3" json:"organization,omitempty"`
OrganizationalUnit []string `protobuf:"bytes,3,rep,name=organizational_unit,json=organizationalUnit,proto3" json:"organizational_unit,omitempty"`
Locality []string `protobuf:"bytes,4,rep,name=locality,proto3" json:"locality,omitempty"`
Province []string `protobuf:"bytes,5,rep,name=province,proto3" json:"province,omitempty"`
StreetAddress []string `protobuf:"bytes,6,rep,name=street_address,json=streetAddress,proto3" json:"street_address,omitempty"`
PostalCode []string `protobuf:"bytes,7,rep,name=postal_code,json=postalCode,proto3" json:"postal_code,omitempty"`
SerialNumber string `protobuf:"bytes,8,opt,name=serial_number,json=serialNumber,proto3" json:"serial_number,omitempty"`
CommonName string `protobuf:"bytes,9,opt,name=common_name,json=commonName,proto3" json:"common_name,omitempty"`
// contains filtered or unexported fields
}
Name defines the x509 identity
func (*Name) Descriptor
deprecated
func (*Name) GetCommonName ¶
func (*Name) GetCountry ¶
func (*Name) GetLocality ¶
func (*Name) GetOrganization ¶
func (*Name) GetOrganizationalUnit ¶
func (*Name) GetPostalCode ¶
func (*Name) GetProvince ¶
func (*Name) GetSerialNumber ¶
func (*Name) GetStreetAddress ¶
func (*Name) ProtoMessage ¶
func (*Name) ProtoMessage()
func (*Name) ProtoReflect ¶
func (x *Name) ProtoReflect() protoreflect.Message
type PortalRoute ¶
type PortalRoute struct {
Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
Type string `protobuf:"bytes,3,opt,name=type,proto3" json:"type,omitempty"`
From string `protobuf:"bytes,4,opt,name=from,proto3" json:"from,omitempty"`
Description string `protobuf:"bytes,5,opt,name=description,proto3" json:"description,omitempty"`
ConnectCommand *string `protobuf:"bytes,6,opt,name=connect_command,json=connectCommand,proto3,oneof" json:"connect_command,omitempty"`
LogoUrl string `protobuf:"bytes,7,opt,name=logo_url,json=logoUrl,proto3" json:"logo_url,omitempty"`
// contains filtered or unexported fields
}
func (*PortalRoute) Descriptor
deprecated
func (*PortalRoute) Descriptor() ([]byte, []int)
Deprecated: Use PortalRoute.ProtoReflect.Descriptor instead.
func (*PortalRoute) GetConnectCommand ¶
func (x *PortalRoute) GetConnectCommand() string
func (*PortalRoute) GetDescription ¶
func (x *PortalRoute) GetDescription() string
func (*PortalRoute) GetFrom ¶
func (x *PortalRoute) GetFrom() string
func (*PortalRoute) GetId ¶
func (x *PortalRoute) GetId() string
func (*PortalRoute) GetLogoUrl ¶
func (x *PortalRoute) GetLogoUrl() string
func (*PortalRoute) GetName ¶
func (x *PortalRoute) GetName() string
func (*PortalRoute) GetType ¶
func (x *PortalRoute) GetType() string
func (*PortalRoute) ProtoMessage ¶
func (*PortalRoute) ProtoMessage()
func (*PortalRoute) ProtoReflect ¶
func (x *PortalRoute) ProtoReflect() protoreflect.Message
func (*PortalRoute) Reset ¶
func (x *PortalRoute) Reset()
func (*PortalRoute) String ¶
func (x *PortalRoute) String() string
type Protocol ¶
type Protocol int32
func (Protocol) Descriptor ¶
func (Protocol) Descriptor() protoreflect.EnumDescriptor
func (Protocol) EnumDescriptor
deprecated
func (Protocol) Number ¶
func (x Protocol) Number() protoreflect.EnumNumber
func (Protocol) Type ¶
func (Protocol) Type() protoreflect.EnumType
type Record ¶
type Record struct {
// if omitted, a new record would be created
Id *string `protobuf:"bytes,1,opt,name=id,proto3,oneof" json:"id,omitempty"`
Tags []string `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
// connection data may be omitted if i.e. just manipulating the tags data
Conn *Connection `protobuf:"bytes,3,opt,name=conn,proto3,oneof" json:"conn,omitempty"`
Source *string `protobuf:"bytes,4,opt,name=source,proto3,oneof" json:"source,omitempty"`
// contains filtered or unexported fields
}
Record represents a single tunnel record in the configuration
func (*Record) Descriptor
deprecated
func (*Record) GetConn ¶
func (x *Record) GetConn() *Connection
func (*Record) ProtoMessage ¶
func (*Record) ProtoMessage()
func (*Record) ProtoReflect ¶
func (x *Record) ProtoReflect() protoreflect.Message
type Records ¶
type Records struct {
Records []*Record `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
// contains filtered or unexported fields
}
func (*Records) Descriptor
deprecated
func (*Records) GetRecords ¶
func (*Records) ProtoMessage ¶
func (*Records) ProtoMessage()
func (*Records) ProtoReflect ¶
func (x *Records) ProtoReflect() protoreflect.Message
type Selector ¶
type Selector struct {
// all records
All bool `protobuf:"varint,1,opt,name=all,proto3" json:"all,omitempty"`
// only return connections matching tag(s)
Ids []string `protobuf:"bytes,2,rep,name=ids,proto3" json:"ids,omitempty"`
// only return specific connection(s)
Tags []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
// contains filtered or unexported fields
}
Selector defines record filter one of the options must be set we do not use oneof as it results in inconveniences on the JS client side
func (*Selector) Descriptor
deprecated
func (*Selector) ProtoMessage ¶
func (*Selector) ProtoMessage()
func (*Selector) ProtoReflect ¶
func (x *Selector) ProtoReflect() protoreflect.Message
type StatusUpdatesRequest ¶
type StatusUpdatesRequest struct {
ConnectionId string `protobuf:"bytes,1,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
// contains filtered or unexported fields
}
func (*StatusUpdatesRequest) Descriptor
deprecated
func (*StatusUpdatesRequest) Descriptor() ([]byte, []int)
Deprecated: Use StatusUpdatesRequest.ProtoReflect.Descriptor instead.
func (*StatusUpdatesRequest) GetConnectionId ¶
func (x *StatusUpdatesRequest) GetConnectionId() string
func (*StatusUpdatesRequest) ProtoMessage ¶
func (*StatusUpdatesRequest) ProtoMessage()
func (*StatusUpdatesRequest) ProtoReflect ¶
func (x *StatusUpdatesRequest) ProtoReflect() protoreflect.Message
func (*StatusUpdatesRequest) Reset ¶
func (x *StatusUpdatesRequest) Reset()
func (*StatusUpdatesRequest) String ¶
func (x *StatusUpdatesRequest) String() string
type UnimplementedConfigServer ¶
type UnimplementedConfigServer struct{}
UnimplementedConfigServer should 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 (UnimplementedConfigServer) Delete ¶
func (UnimplementedConfigServer) Delete(context.Context, *Selector) (*DeleteRecordsResponse, error)
func (UnimplementedConfigServer) Export ¶
func (UnimplementedConfigServer) Export(context.Context, *ExportRequest) (*ConfigData, error)
func (UnimplementedConfigServer) FetchRoutes ¶
func (UnimplementedConfigServer) FetchRoutes(context.Context, *FetchRoutesRequest) (*FetchRoutesResponse, error)
func (UnimplementedConfigServer) GetTags ¶
func (UnimplementedConfigServer) GetTags(context.Context, *GetTagsRequest) (*GetTagsResponse, error)
func (UnimplementedConfigServer) Import ¶
func (UnimplementedConfigServer) Import(context.Context, *ImportRequest) (*ImportResponse, error)
type UnimplementedListenerServer ¶
type UnimplementedListenerServer struct{}
UnimplementedListenerServer should 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 (UnimplementedListenerServer) GetStatus ¶
func (UnimplementedListenerServer) GetStatus(context.Context, *Selector) (*ListenerStatusResponse, error)
func (UnimplementedListenerServer) StatusUpdates ¶
func (UnimplementedListenerServer) StatusUpdates(*StatusUpdatesRequest, grpc.ServerStreamingServer[ConnectionStatusUpdate]) error
func (UnimplementedListenerServer) Update ¶
func (UnimplementedListenerServer) Update(context.Context, *ListenerUpdateRequest) (*ListenerStatusResponse, error)
type UnsafeConfigServer ¶
type UnsafeConfigServer interface {
// contains filtered or unexported methods
}
UnsafeConfigServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ConfigServer will result in compilation errors.
type UnsafeListenerServer ¶
type UnsafeListenerServer interface {
// contains filtered or unexported methods
}
UnsafeListenerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ListenerServer will result in compilation errors.