cli

package
v0.26.1 Latest Latest
Warning

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

 Go to latest Published: Jun 27, 2024 License: Apache-2.0 Imports: 8 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 (
	ConnectionStatusUpdates_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",
	}
	ConnectionStatusUpdates_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,
	}
)

Enum value maps for ConnectionStatusUpdates_ConnectionStatus.

View Source 
var File_api_proto protoreflect.FileDescriptor

Functions

func RegisterConfigServer 

func RegisterConfigServer(s *grpc.Server, srv ConfigServer)

func RegisterListenerServer 

func RegisterListenerServer(s *grpc.Server, srv ListenerServer)

Types

type ConfigClient 

type ConfigClient interface {
	List(ctx context.Context, in *Selector, opts ...grpc.CallOption) (*ListRecordsResponse, error)
	Delete(ctx context.Context, in *Selector, opts ...grpc.CallOption) (*DeleteRecordsResponse, error)
	Upsert(ctx context.Context, in *Record, opts ...grpc.CallOption) (*Record, error)
	Export(ctx context.Context, in *ExportRequest, opts ...grpc.CallOption) (*ConfigData, error)
	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://godoc.org/google.golang.org/grpc#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(context.Context, *Selector) (*ListRecordsResponse, error)
	Delete(context.Context, *Selector) (*DeleteRecordsResponse, error)
	Upsert(context.Context, *Record) (*Record, error)
	Export(context.Context, *ExportRequest) (*ConfigData, error)
	Import(context.Context, *ImportRequest) (*ImportResponse, error)
}

ConfigServer is the server API for Config service.

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"`
	// 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) 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 ConnectionStatusUpdates 

type ConnectionStatusUpdates 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" json:"peer_addr,omitempty"`
	Status   ConnectionStatusUpdates_ConnectionStatus `protobuf:"varint,3,opt,name=status,proto3,enum=pomerium.cli.ConnectionStatusUpdates_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"`
	// contains filtered or unexported fields
}

ConnectionStatusUpdates represent connection state changes

func (*ConnectionStatusUpdates) Descriptor deprecated 

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

Deprecated: Use ConnectionStatusUpdates.ProtoReflect.Descriptor instead.

func (*ConnectionStatusUpdates) GetId 

func (x *ConnectionStatusUpdates) GetId() string

func (*ConnectionStatusUpdates) GetLastError 

func (x *ConnectionStatusUpdates) GetLastError() string

func (*ConnectionStatusUpdates) GetPeerAddr 

func (x *ConnectionStatusUpdates) GetPeerAddr() string

func (*ConnectionStatusUpdates) GetStatus 

func (x *ConnectionStatusUpdates) GetStatus() ConnectionStatusUpdates_ConnectionStatus

func (*ConnectionStatusUpdates) ProtoMessage 

func (*ConnectionStatusUpdates) ProtoMessage()

func (*ConnectionStatusUpdates) ProtoReflect 

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

func (*ConnectionStatusUpdates) Reset 

func (x *ConnectionStatusUpdates) Reset()

func (*ConnectionStatusUpdates) String 

func (x *ConnectionStatusUpdates) String() string

type ConnectionStatusUpdates_ConnectionStatus 

type ConnectionStatusUpdates_ConnectionStatus int32
const (
	ConnectionStatusUpdates_CONNECTION_STATUS_UNDEFINED     ConnectionStatusUpdates_ConnectionStatus = 0
	ConnectionStatusUpdates_CONNECTION_STATUS_CONNECTING    ConnectionStatusUpdates_ConnectionStatus = 1
	ConnectionStatusUpdates_CONNECTION_STATUS_AUTH_REQUIRED ConnectionStatusUpdates_ConnectionStatus = 2
	ConnectionStatusUpdates_CONNECTION_STATUS_CONNECTED     ConnectionStatusUpdates_ConnectionStatus = 3
	ConnectionStatusUpdates_CONNECTION_STATUS_DISCONNECTED  ConnectionStatusUpdates_ConnectionStatus = 4
)

func (ConnectionStatusUpdates_ConnectionStatus) Descriptor 

func (ConnectionStatusUpdates_ConnectionStatus) Descriptor() protoreflect.EnumDescriptor

func (ConnectionStatusUpdates_ConnectionStatus) Enum 

func (x ConnectionStatusUpdates_ConnectionStatus) Enum() *ConnectionStatusUpdates_ConnectionStatus

func (ConnectionStatusUpdates_ConnectionStatus) EnumDescriptor deprecated 

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

Deprecated: Use ConnectionStatusUpdates_ConnectionStatus.Descriptor instead.

func (ConnectionStatusUpdates_ConnectionStatus) Number 

func (x ConnectionStatusUpdates_ConnectionStatus) Number() protoreflect.EnumNumber

func (ConnectionStatusUpdates_ConnectionStatus) String 

func (x ConnectionStatusUpdates_ConnectionStatus) String() string

func (ConnectionStatusUpdates_ConnectionStatus) Type 

func (ConnectionStatusUpdates_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 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 ListRecordsResponse 

type ListRecordsResponse struct {
	Records []*Record `protobuf:"bytes,1,rep,name=records,proto3" json:"records,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRecordsResponse) Descriptor deprecated 

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

Deprecated: Use ListRecordsResponse.ProtoReflect.Descriptor instead.

func (*ListRecordsResponse) GetRecords 

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

func (*ListRecordsResponse) ProtoMessage 

func (*ListRecordsResponse) ProtoMessage()

func (*ListRecordsResponse) ProtoReflect 

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

func (*ListRecordsResponse) Reset 

func (x *ListRecordsResponse) Reset()

func (*ListRecordsResponse) String 

func (x *ListRecordsResponse) String() string

type ListenerClient 

type ListenerClient interface {
	// Listen starts connection listener
	Update(ctx context.Context, in *ListenerUpdateRequest, opts ...grpc.CallOption) (*ListenerStatus, 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 *Selector, 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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewListenerClient 

func NewListenerClient(cc grpc.ClientConnInterface) ListenerClient

type ListenerServer 

type ListenerServer interface {
	// Listen starts connection listener
	Update(context.Context, *ListenerUpdateRequest) (*ListenerStatus, error)
	// StatusUpdates opens a stream to listen to connection status updates
	// a client has to subscribe and continuously
	// listen to the broadcasted updates
	StatusUpdates(*Selector, Listener_StatusUpdatesServer) error
}

ListenerServer is the server API for Listener service.

type ListenerStatus 

type ListenerStatus struct {

	// active listeners with their current ports
	Active map[string]uint32 `` /* 154-byte string literal not displayed */
	// if some listeners were unable to start up
	Errors map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ListenerStatus) Descriptor deprecated 

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

Deprecated: Use ListenerStatus.ProtoReflect.Descriptor instead.

func (*ListenerStatus) GetActive 

func (x *ListenerStatus) GetActive() map[string]uint32

func (*ListenerStatus) GetErrors 

func (x *ListenerStatus) GetErrors() map[string]string

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 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() (*ConnectionStatusUpdates, error)
	grpc.ClientStream
}

type Listener_StatusUpdatesServer 

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

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
}

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 Selector 

type Selector struct {

	// Types that are assignable to Filter:
	//
	//	*Selector_All
	//	*Selector_Tag
	//	*Selector_IdFilter_
	Filter isSelector_Filter `protobuf_oneof:"filter"`
	// contains filtered or unexported fields
}

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

func (m *Selector) GetFilter() isSelector_Filter

func (*Selector) GetIdFilter 

func (x *Selector) GetIdFilter() *Selector_IdFilter

func (*Selector) GetTag 

func (x *Selector) GetTag() *Selector_TagFilter

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 Selector_All 

type Selector_All struct {
	// all records
	All bool `protobuf:"varint,1,opt,name=all,proto3,oneof"`
}

type Selector_IdFilter 

type Selector_IdFilter struct {
	Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*Selector_IdFilter) Descriptor deprecated 

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

Deprecated: Use Selector_IdFilter.ProtoReflect.Descriptor instead.

func (*Selector_IdFilter) GetIds 

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

func (*Selector_IdFilter) ProtoMessage 

func (*Selector_IdFilter) ProtoMessage()

func (*Selector_IdFilter) ProtoReflect 

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

func (*Selector_IdFilter) Reset 

func (x *Selector_IdFilter) Reset()

func (*Selector_IdFilter) String 

func (x *Selector_IdFilter) String() string

type Selector_IdFilter_ 

type Selector_IdFilter_ struct {
	// only return specific connection(s)
	IdFilter *Selector_IdFilter `protobuf:"bytes,3,opt,name=id_filter,json=idFilter,proto3,oneof"`
}

type Selector_Tag 

type Selector_Tag struct {
	// only return connections matching tag(s)
	Tag *Selector_TagFilter `protobuf:"bytes,2,opt,name=tag,proto3,oneof"`
}

type Selector_TagFilter 

type Selector_TagFilter struct {
	Tags []string `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

func (*Selector_TagFilter) Descriptor deprecated 

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

Deprecated: Use Selector_TagFilter.ProtoReflect.Descriptor instead.

func (*Selector_TagFilter) GetTags 

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

func (*Selector_TagFilter) ProtoMessage 

func (*Selector_TagFilter) ProtoMessage()

func (*Selector_TagFilter) ProtoReflect 

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

func (*Selector_TagFilter) Reset 

func (x *Selector_TagFilter) Reset()

func (*Selector_TagFilter) String 

func (x *Selector_TagFilter) String() string

type StatusUpdatesRequest 

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

func (*StatusUpdatesRequest) Descriptor deprecated 

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

Deprecated: Use StatusUpdatesRequest.ProtoReflect.Descriptor instead.

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 can be embedded to have forward compatible implementations.

func (*UnimplementedConfigServer) Delete 

func (*UnimplementedConfigServer) Delete(context.Context, *Selector) (*DeleteRecordsResponse, error)

func (*UnimplementedConfigServer) Export 

func (*UnimplementedConfigServer) Export(context.Context, *ExportRequest) (*ConfigData, error)

func (*UnimplementedConfigServer) Import 

func (*UnimplementedConfigServer) Import(context.Context, *ImportRequest) (*ImportResponse, error)

func (*UnimplementedConfigServer) List 

func (*UnimplementedConfigServer) List(context.Context, *Selector) (*ListRecordsResponse, error)

func (*UnimplementedConfigServer) Upsert 

func (*UnimplementedConfigServer) Upsert(context.Context, *Record) (*Record, error)

type UnimplementedListenerServer 

type UnimplementedListenerServer struct {
}

UnimplementedListenerServer can be embedded to have forward compatible implementations.

func (*UnimplementedListenerServer) StatusUpdates 

func (*UnimplementedListenerServer) StatusUpdates(*Selector, Listener_StatusUpdatesServer) error

func (*UnimplementedListenerServer) Update 

func (*UnimplementedListenerServer) Update(context.Context, *ListenerUpdateRequest) (*ListenerStatus, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.