proto

package
v0.22.0 Latest Latest
Warning

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

Go to latest
Published: May 1, 2023 License: Apache-2.0 Imports: 20 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.

View Source
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.

View Source
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,
		},
	},
	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)

View Source
var File_proto_api_proto protoreflect.FileDescriptor
View Source
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 added in v0.16.1

func SentryErrorLog(client *sentry.Client) grpc.UnaryServerInterceptor

SentryErrorLog spools gRPC errors to Sentry

func UnaryLog

func UnaryLog(ctx context.Context, req interface{}, info *grpc.UnaryServerInfo, handler grpc.UnaryHandler) (resp interface{}, err error)

Types

type Certificate added in v0.17.0

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 added in v0.17.0

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

Deprecated: Use Certificate.ProtoReflect.Descriptor instead.

func (*Certificate) GetCert added in v0.17.0

func (x *Certificate) GetCert() []byte

func (*Certificate) GetInfo added in v0.17.0

func (x *Certificate) GetInfo() *CertificateInfo

func (*Certificate) GetKey added in v0.17.0

func (x *Certificate) GetKey() []byte

func (*Certificate) ProtoMessage added in v0.17.0

func (*Certificate) ProtoMessage()

func (*Certificate) ProtoReflect added in v0.17.0

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

func (*Certificate) Reset added in v0.17.0

func (x *Certificate) Reset()

func (*Certificate) String added in v0.17.0

func (x *Certificate) String() string

type CertificateInfo added in v0.17.0

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 added in v0.17.0

func NewCertInfo(cert *x509.Certificate) *CertificateInfo

NewCertInfo extracts certificate info to the protobuf format

func (*CertificateInfo) Descriptor deprecated added in v0.17.0

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

Deprecated: Use CertificateInfo.ProtoReflect.Descriptor instead.

func (*CertificateInfo) GetDnsNames added in v0.17.0

func (x *CertificateInfo) GetDnsNames() []string

func (*CertificateInfo) GetEmailAddresses added in v0.17.0

func (x *CertificateInfo) GetEmailAddresses() []string

func (*CertificateInfo) GetError added in v0.17.0

func (x *CertificateInfo) GetError() string

func (*CertificateInfo) GetExcludedDnsDomains added in v0.17.0

func (x *CertificateInfo) GetExcludedDnsDomains() []string

func (*CertificateInfo) GetExcludedEmailAddresses added in v0.17.0

func (x *CertificateInfo) GetExcludedEmailAddresses() []string

func (*CertificateInfo) GetExcludedIpRanges added in v0.17.0

func (x *CertificateInfo) GetExcludedIpRanges() []string

func (*CertificateInfo) GetExcludedUriDomains added in v0.17.0

func (x *CertificateInfo) GetExcludedUriDomains() []string

func (*CertificateInfo) GetIpAddresses added in v0.17.0

func (x *CertificateInfo) GetIpAddresses() []string

func (*CertificateInfo) GetIssuer added in v0.17.0

func (x *CertificateInfo) GetIssuer() *Name

func (*CertificateInfo) GetKeyUsage added in v0.17.0

func (x *CertificateInfo) GetKeyUsage() *KeyUsage

func (*CertificateInfo) GetNotAfter added in v0.17.0

func (x *CertificateInfo) GetNotAfter() *timestamppb.Timestamp

func (*CertificateInfo) GetNotBefore added in v0.17.0

func (x *CertificateInfo) GetNotBefore() *timestamppb.Timestamp

func (*CertificateInfo) GetPermittedDnsDomains added in v0.17.0

func (x *CertificateInfo) GetPermittedDnsDomains() []string

func (*CertificateInfo) GetPermittedDnsDomainsCritical added in v0.17.0

func (x *CertificateInfo) GetPermittedDnsDomainsCritical() bool

func (*CertificateInfo) GetPermittedEmailAddresses added in v0.17.0

func (x *CertificateInfo) GetPermittedEmailAddresses() []string

func (*CertificateInfo) GetPermittedIpRanges added in v0.17.0

func (x *CertificateInfo) GetPermittedIpRanges() []string

func (*CertificateInfo) GetPermittedUriDomains added in v0.17.0

func (x *CertificateInfo) GetPermittedUriDomains() []string

func (*CertificateInfo) GetSerial added in v0.17.0

func (x *CertificateInfo) GetSerial() string

func (*CertificateInfo) GetSubject added in v0.17.0

func (x *CertificateInfo) GetSubject() *Name

func (*CertificateInfo) GetUris added in v0.17.0

func (x *CertificateInfo) GetUris() []string

func (*CertificateInfo) GetVersion added in v0.17.0

func (x *CertificateInfo) GetVersion() int64

func (*CertificateInfo) ProtoMessage added in v0.17.0

func (*CertificateInfo) ProtoMessage()

func (*CertificateInfo) ProtoReflect added in v0.17.0

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

func (*CertificateInfo) Reset added in v0.17.0

func (x *CertificateInfo) Reset()

func (*CertificateInfo) String added in v0.17.0

func (x *CertificateInfo) 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)
}

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.

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)
}

ConfigServer is the server API for Config service. All implementations should embed UnimplementedConfigServer for forward compatibility

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"`
	// 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 assignable 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"`
	// contains filtered or unexported fields
}

Connection

func (*Connection) Descriptor deprecated

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

Deprecated: Use Connection.ProtoReflect.Descriptor instead.

func (*Connection) GetCaCert

func (x *Connection) GetCaCert() []byte

func (*Connection) GetClientCert added in v0.17.0

func (x *Connection) GetClientCert() *Certificate

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) GetRemoteAddr

func (x *Connection) GetRemoteAddr() string

func (*Connection) GetTlsOptions

func (m *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 (*ConnectionStatusUpdate) GetTs

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) Enum

func (ConnectionStatusUpdate_ConnectionStatus) EnumDescriptor deprecated

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

Deprecated: Use ConnectionStatusUpdate_ConnectionStatus.Descriptor instead.

func (ConnectionStatusUpdate_ConnectionStatus) Number

func (ConnectionStatusUpdate_ConnectionStatus) String

func (ConnectionStatusUpdate_ConnectionStatus) Type

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) Enum

func (ExportRequest_Format) EnumDescriptor deprecated

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

Deprecated: Use ExportRequest_Format.Descriptor instead.

func (ExportRequest_Format) Number

func (ExportRequest_Format) String

func (x ExportRequest_Format) String() string

func (ExportRequest_Format) Type

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 added in v0.17.0

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 added in v0.17.0

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

Deprecated: Use KeyUsage.ProtoReflect.Descriptor instead.

func (*KeyUsage) GetCertSign added in v0.17.0

func (x *KeyUsage) GetCertSign() bool

func (*KeyUsage) GetClientAuth added in v0.17.0

func (x *KeyUsage) GetClientAuth() bool

func (*KeyUsage) GetContentCommitment added in v0.17.0

func (x *KeyUsage) GetContentCommitment() bool

func (*KeyUsage) GetCrlSign added in v0.17.0

func (x *KeyUsage) GetCrlSign() bool

func (*KeyUsage) GetDataEncipherment added in v0.17.0

func (x *KeyUsage) GetDataEncipherment() bool

func (*KeyUsage) GetDecipherOnly added in v0.17.0

func (x *KeyUsage) GetDecipherOnly() bool

func (*KeyUsage) GetDigitalSignature added in v0.17.0

func (x *KeyUsage) GetDigitalSignature() bool

func (*KeyUsage) GetEncipherOnly added in v0.17.0

func (x *KeyUsage) GetEncipherOnly() bool

func (*KeyUsage) GetKeyAgreement added in v0.17.0

func (x *KeyUsage) GetKeyAgreement() bool

func (*KeyUsage) GetKeyEncipherment added in v0.17.0

func (x *KeyUsage) GetKeyEncipherment() bool

func (*KeyUsage) GetServerAuth added in v0.17.0

func (x *KeyUsage) GetServerAuth() bool

func (*KeyUsage) ProtoMessage added in v0.17.0

func (*KeyUsage) ProtoMessage()

func (*KeyUsage) ProtoReflect added in v0.17.0

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

func (*KeyUsage) Reset added in v0.17.0

func (x *KeyUsage) Reset()

func (*KeyUsage) String added in v0.17.0

func (x *KeyUsage) String() string

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) (Listener_StatusUpdatesClient, 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.

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, Listener_StatusUpdatesServer) error
}

ListenerServer is the server API for Listener service. All implementations should embed UnimplementedListenerServer for forward compatibility

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 `` /* 159-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 interface {
	Recv() (*ConnectionStatusUpdate, error)
	grpc.ClientStream
}

type Listener_StatusUpdatesServer

type Listener_StatusUpdatesServer interface {
	Send(*ConnectionStatusUpdate) error
	grpc.ServerStream
}

type Name added in v0.17.0

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 added in v0.17.0

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

Deprecated: Use Name.ProtoReflect.Descriptor instead.

func (*Name) GetCommonName added in v0.17.0

func (x *Name) GetCommonName() string

func (*Name) GetCountry added in v0.17.0

func (x *Name) GetCountry() []string

func (*Name) GetLocality added in v0.17.0

func (x *Name) GetLocality() []string

func (*Name) GetOrganization added in v0.17.0

func (x *Name) GetOrganization() []string

func (*Name) GetOrganizationalUnit added in v0.17.0

func (x *Name) GetOrganizationalUnit() []string

func (*Name) GetPostalCode added in v0.17.0

func (x *Name) GetPostalCode() []string

func (*Name) GetProvince added in v0.17.0

func (x *Name) GetProvince() []string

func (*Name) GetSerialNumber added in v0.17.0

func (x *Name) GetSerialNumber() string

func (*Name) GetStreetAddress added in v0.17.0

func (x *Name) GetStreetAddress() []string

func (*Name) ProtoMessage added in v0.17.0

func (*Name) ProtoMessage()

func (*Name) ProtoReflect added in v0.17.0

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

func (*Name) Reset added in v0.17.0

func (x *Name) Reset()

func (*Name) String added in v0.17.0

func (x *Name) String() string

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"`
	// contains filtered or unexported fields
}

Record represents a single tunnel record in the configuration

func (*Record) Descriptor deprecated

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

Deprecated: Use Record.ProtoReflect.Descriptor instead.

func (*Record) GetConn

func (x *Record) GetConn() *Connection

func (*Record) GetId

func (x *Record) GetId() string

func (*Record) GetTags

func (x *Record) GetTags() []string

func (*Record) ProtoMessage

func (*Record) ProtoMessage()

func (*Record) ProtoReflect

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

func (*Record) Reset

func (x *Record) Reset()

func (*Record) String

func (x *Record) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Records.ProtoReflect.Descriptor instead.

func (*Records) GetRecords

func (x *Records) GetRecords() []*Record

func (*Records) ProtoMessage

func (*Records) ProtoMessage()

func (*Records) ProtoReflect

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

func (*Records) Reset

func (x *Records) Reset()

func (*Records) String

func (x *Records) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Selector.ProtoReflect.Descriptor instead.

func (*Selector) GetAll

func (x *Selector) GetAll() bool

func (*Selector) GetIds

func (x *Selector) GetIds() []string

func (*Selector) GetTags

func (x *Selector) GetTags() []string

func (*Selector) ProtoMessage

func (*Selector) ProtoMessage()

func (*Selector) ProtoReflect

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

func (*Selector) Reset

func (x *Selector) Reset()

func (*Selector) String

func (x *Selector) String() string

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.

func (UnimplementedConfigServer) Delete

func (UnimplementedConfigServer) Export

func (UnimplementedConfigServer) GetTags

func (UnimplementedConfigServer) Import

func (UnimplementedConfigServer) List

func (UnimplementedConfigServer) Upsert

type UnimplementedListenerServer

type UnimplementedListenerServer struct {
}

UnimplementedListenerServer should be embedded to have forward compatible implementations.

func (UnimplementedListenerServer) GetStatus

func (UnimplementedListenerServer) StatusUpdates

func (UnimplementedListenerServer) Update

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL