Documentation ¶
Index ¶
- Constants
- Variables
- func RegisterSystemACRUDServer(s grpc.ServiceRegistrar, srv SystemACRUDServer)
- func RegisterSystemACliServer(s grpc.ServiceRegistrar, srv SystemACliServer)
- func RegisterSystemAProxyServer(s grpc.ServiceRegistrar, srv SystemAProxyServer)
- type Chunk
- type CommandMessageResponse
- func (*CommandMessageResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CommandMessageResponse) GetIntercept() string
- func (*CommandMessageResponse) ProtoMessage()
- func (x *CommandMessageResponse) ProtoReflect() protoreflect.Message
- func (x *CommandMessageResponse) Reset()
- func (x *CommandMessageResponse) String() string
- type CreateDomainRequest
- func (*CreateDomainRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateDomainRequest) GetAddRequestHeaders() map[string]string
- func (x *CreateDomainRequest) GetDisplayBanner() bool
- func (x *CreateDomainRequest) GetHost() string
- func (x *CreateDomainRequest) GetInterceptId() string
- func (x *CreateDomainRequest) GetInterceptSpec() *manager.InterceptSpec
- func (x *CreateDomainRequest) GetPullRequestUrl() string
- func (*CreateDomainRequest) ProtoMessage()
- func (x *CreateDomainRequest) ProtoReflect() protoreflect.Message
- func (x *CreateDomainRequest) Reset()
- func (x *CreateDomainRequest) String() string
- type CreateDomainResponse
- func (*CreateDomainResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CreateDomainResponse) GetDomain() string
- func (*CreateDomainResponse) ProtoMessage()
- func (x *CreateDomainResponse) ProtoReflect() protoreflect.Message
- func (x *CreateDomainResponse) Reset()
- func (x *CreateDomainResponse) String() string
- type InterceptRemoval
- type PreferredAgentResponse
- func (*PreferredAgentResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PreferredAgentResponse) GetImageName() string
- func (*PreferredAgentResponse) ProtoMessage()
- func (x *PreferredAgentResponse) ProtoReflect() protoreflect.Message
- func (x *PreferredAgentResponse) Reset()
- func (x *PreferredAgentResponse) String() string
- type RemoveDomainRequest
- func (*RemoveDomainRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RemoveDomainRequest) GetDomain() string
- func (*RemoveDomainRequest) ProtoMessage()
- func (x *RemoveDomainRequest) ProtoReflect() protoreflect.Message
- func (x *RemoveDomainRequest) Reset()
- func (x *RemoveDomainRequest) String() string
- type SystemACRUDClient
- type SystemACRUDServer
- type SystemACliClient
- type SystemACliServer
- type SystemAProxyClient
- type SystemAProxyServer
- type SystemAProxy_ReverseConnectionClient
- type SystemAProxy_ReverseConnectionServer
- type UnimplementedSystemACRUDServer
- func (UnimplementedSystemACRUDServer) CreateDomain(context.Context, *CreateDomainRequest) (*CreateDomainResponse, error)
- func (UnimplementedSystemACRUDServer) PreferredAgent(context.Context, *common.VersionInfo) (*PreferredAgentResponse, error)
- func (UnimplementedSystemACRUDServer) RemoveDomain(context.Context, *RemoveDomainRequest) (*emptypb.Empty, error)
- func (UnimplementedSystemACRUDServer) RemoveIntercept(context.Context, *InterceptRemoval) (*emptypb.Empty, error)
- type UnimplementedSystemACliServer
- type UnimplementedSystemAProxyServer
- type UnsafeSystemACRUDServer
- type UnsafeSystemACliServer
- type UnsafeSystemAProxyServer
Constants ¶
const ( SystemACRUD_CreateDomain_FullMethodName = "/telepresence.systema.SystemACRUD/CreateDomain" SystemACRUD_RemoveDomain_FullMethodName = "/telepresence.systema.SystemACRUD/RemoveDomain" SystemACRUD_RemoveIntercept_FullMethodName = "/telepresence.systema.SystemACRUD/RemoveIntercept" SystemACRUD_PreferredAgent_FullMethodName = "/telepresence.systema.SystemACRUD/PreferredAgent" )
const (
SystemACli_GetUnauthenticatedCommandMessages_FullMethodName = "/telepresence.systema.SystemACli/GetUnauthenticatedCommandMessages"
)
const (
SystemAProxy_ReverseConnection_FullMethodName = "/telepresence.systema.SystemAProxy/ReverseConnection"
)
Variables ¶
var File_systema_cli2systema_proto protoreflect.FileDescriptor
var File_systema_manager2systema_proto protoreflect.FileDescriptor
var SystemACRUD_ServiceDesc = grpc.ServiceDesc{ ServiceName: "telepresence.systema.SystemACRUD", HandlerType: (*SystemACRUDServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "CreateDomain", Handler: _SystemACRUD_CreateDomain_Handler, }, { MethodName: "RemoveDomain", Handler: _SystemACRUD_RemoveDomain_Handler, }, { MethodName: "RemoveIntercept", Handler: _SystemACRUD_RemoveIntercept_Handler, }, { MethodName: "PreferredAgent", Handler: _SystemACRUD_PreferredAgent_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "systema/manager2systema.proto", }
SystemACRUD_ServiceDesc is the grpc.ServiceDesc for SystemACRUD service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var SystemACli_ServiceDesc = grpc.ServiceDesc{ ServiceName: "telepresence.systema.SystemACli", HandlerType: (*SystemACliServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetUnauthenticatedCommandMessages", Handler: _SystemACli_GetUnauthenticatedCommandMessages_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "systema/cli2systema.proto", }
SystemACli_ServiceDesc is the grpc.ServiceDesc for SystemACli service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var SystemAProxy_ServiceDesc = grpc.ServiceDesc{ ServiceName: "telepresence.systema.SystemAProxy", HandlerType: (*SystemAProxyServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "ReverseConnection", Handler: _SystemAProxy_ReverseConnection_Handler, ServerStreams: true, ClientStreams: true, }, }, Metadata: "systema/manager2systema.proto", }
SystemAProxy_ServiceDesc is the grpc.ServiceDesc for SystemAProxy service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterSystemACRUDServer ¶
func RegisterSystemACRUDServer(s grpc.ServiceRegistrar, srv SystemACRUDServer)
func RegisterSystemACliServer ¶ added in v2.3.7
func RegisterSystemACliServer(s grpc.ServiceRegistrar, srv SystemACliServer)
func RegisterSystemAProxyServer ¶
func RegisterSystemAProxyServer(s grpc.ServiceRegistrar, srv SystemAProxyServer)
Types ¶
type Chunk ¶
type Chunk struct { Content []byte `protobuf:"bytes,1,opt,name=content,proto3" json:"content,omitempty"` // contains filtered or unexported fields }
func (*Chunk) Descriptor
deprecated
func (*Chunk) GetContent ¶
func (*Chunk) ProtoMessage ¶
func (*Chunk) ProtoMessage()
func (*Chunk) ProtoReflect ¶
func (x *Chunk) ProtoReflect() protoreflect.Message
type CommandMessageResponse ¶ added in v2.3.7
type CommandMessageResponse struct { // intercept is the message to give when a user performs an intercept command. Intercept string `protobuf:"bytes,1,opt,name=intercept,proto3" json:"intercept,omitempty"` // contains filtered or unexported fields }
func (*CommandMessageResponse) Descriptor
deprecated
added in
v2.3.7
func (*CommandMessageResponse) Descriptor() ([]byte, []int)
Deprecated: Use CommandMessageResponse.ProtoReflect.Descriptor instead.
func (*CommandMessageResponse) GetIntercept ¶ added in v2.3.7
func (x *CommandMessageResponse) GetIntercept() string
func (*CommandMessageResponse) ProtoMessage ¶ added in v2.3.7
func (*CommandMessageResponse) ProtoMessage()
func (*CommandMessageResponse) ProtoReflect ¶ added in v2.3.7
func (x *CommandMessageResponse) ProtoReflect() protoreflect.Message
func (*CommandMessageResponse) Reset ¶ added in v2.3.7
func (x *CommandMessageResponse) Reset()
func (*CommandMessageResponse) String ¶ added in v2.3.7
func (x *CommandMessageResponse) String() string
type CreateDomainRequest ¶
type CreateDomainRequest struct { InterceptId string `protobuf:"bytes,1,opt,name=intercept_id,json=interceptId,proto3" json:"intercept_id,omitempty"` DisplayBanner bool `protobuf:"varint,2,opt,name=display_banner,json=displayBanner,proto3" json:"display_banner,omitempty"` InterceptSpec *manager.InterceptSpec `protobuf:"bytes,3,opt,name=intercept_spec,json=interceptSpec,proto3" json:"intercept_spec,omitempty"` Host string `protobuf:"bytes,4,opt,name=host,proto3" json:"host,omitempty"` PullRequestUrl string `protobuf:"bytes,5,opt,name=pull_request_url,json=pullRequestUrl,proto3" json:"pull_request_url,omitempty"` AddRequestHeaders map[string]string `` /* 202-byte string literal not displayed */ // contains filtered or unexported fields }
func (*CreateDomainRequest) Descriptor
deprecated
func (*CreateDomainRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateDomainRequest.ProtoReflect.Descriptor instead.
func (*CreateDomainRequest) GetAddRequestHeaders ¶ added in v2.7.0
func (x *CreateDomainRequest) GetAddRequestHeaders() map[string]string
func (*CreateDomainRequest) GetDisplayBanner ¶
func (x *CreateDomainRequest) GetDisplayBanner() bool
func (*CreateDomainRequest) GetHost ¶
func (x *CreateDomainRequest) GetHost() string
func (*CreateDomainRequest) GetInterceptId ¶
func (x *CreateDomainRequest) GetInterceptId() string
func (*CreateDomainRequest) GetInterceptSpec ¶
func (x *CreateDomainRequest) GetInterceptSpec() *manager.InterceptSpec
func (*CreateDomainRequest) GetPullRequestUrl ¶ added in v2.7.0
func (x *CreateDomainRequest) GetPullRequestUrl() string
func (*CreateDomainRequest) ProtoMessage ¶
func (*CreateDomainRequest) ProtoMessage()
func (*CreateDomainRequest) ProtoReflect ¶
func (x *CreateDomainRequest) ProtoReflect() protoreflect.Message
func (*CreateDomainRequest) Reset ¶
func (x *CreateDomainRequest) Reset()
func (*CreateDomainRequest) String ¶
func (x *CreateDomainRequest) String() string
type CreateDomainResponse ¶
type CreateDomainResponse struct { Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"` // contains filtered or unexported fields }
func (*CreateDomainResponse) Descriptor
deprecated
func (*CreateDomainResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateDomainResponse.ProtoReflect.Descriptor instead.
func (*CreateDomainResponse) GetDomain ¶
func (x *CreateDomainResponse) GetDomain() string
func (*CreateDomainResponse) ProtoMessage ¶
func (*CreateDomainResponse) ProtoMessage()
func (*CreateDomainResponse) ProtoReflect ¶
func (x *CreateDomainResponse) ProtoReflect() protoreflect.Message
func (*CreateDomainResponse) Reset ¶
func (x *CreateDomainResponse) Reset()
func (*CreateDomainResponse) String ¶
func (x *CreateDomainResponse) String() string
type InterceptRemoval ¶ added in v2.3.1
type InterceptRemoval struct { InterceptId string `protobuf:"bytes,1,opt,name=intercept_id,json=interceptId,proto3" json:"intercept_id,omitempty"` // contains filtered or unexported fields }
func (*InterceptRemoval) Descriptor
deprecated
added in
v2.3.1
func (*InterceptRemoval) Descriptor() ([]byte, []int)
Deprecated: Use InterceptRemoval.ProtoReflect.Descriptor instead.
func (*InterceptRemoval) GetInterceptId ¶ added in v2.3.1
func (x *InterceptRemoval) GetInterceptId() string
func (*InterceptRemoval) ProtoMessage ¶ added in v2.3.1
func (*InterceptRemoval) ProtoMessage()
func (*InterceptRemoval) ProtoReflect ¶ added in v2.3.1
func (x *InterceptRemoval) ProtoReflect() protoreflect.Message
func (*InterceptRemoval) Reset ¶ added in v2.3.1
func (x *InterceptRemoval) Reset()
func (*InterceptRemoval) String ¶ added in v2.3.1
func (x *InterceptRemoval) String() string
type PreferredAgentResponse ¶
type PreferredAgentResponse struct { ImageName string `protobuf:"bytes,1,opt,name=image_name,json=imageName,proto3" json:"image_name,omitempty"` // contains filtered or unexported fields }
func (*PreferredAgentResponse) Descriptor
deprecated
func (*PreferredAgentResponse) Descriptor() ([]byte, []int)
Deprecated: Use PreferredAgentResponse.ProtoReflect.Descriptor instead.
func (*PreferredAgentResponse) GetImageName ¶
func (x *PreferredAgentResponse) GetImageName() string
func (*PreferredAgentResponse) ProtoMessage ¶
func (*PreferredAgentResponse) ProtoMessage()
func (*PreferredAgentResponse) ProtoReflect ¶
func (x *PreferredAgentResponse) ProtoReflect() protoreflect.Message
func (*PreferredAgentResponse) Reset ¶
func (x *PreferredAgentResponse) Reset()
func (*PreferredAgentResponse) String ¶
func (x *PreferredAgentResponse) String() string
type RemoveDomainRequest ¶
type RemoveDomainRequest struct { Domain string `protobuf:"bytes,1,opt,name=domain,proto3" json:"domain,omitempty"` // contains filtered or unexported fields }
func (*RemoveDomainRequest) Descriptor
deprecated
func (*RemoveDomainRequest) Descriptor() ([]byte, []int)
Deprecated: Use RemoveDomainRequest.ProtoReflect.Descriptor instead.
func (*RemoveDomainRequest) GetDomain ¶
func (x *RemoveDomainRequest) GetDomain() string
func (*RemoveDomainRequest) ProtoMessage ¶
func (*RemoveDomainRequest) ProtoMessage()
func (*RemoveDomainRequest) ProtoReflect ¶
func (x *RemoveDomainRequest) ProtoReflect() protoreflect.Message
func (*RemoveDomainRequest) Reset ¶
func (x *RemoveDomainRequest) Reset()
func (*RemoveDomainRequest) String ¶
func (x *RemoveDomainRequest) String() string
type SystemACRUDClient ¶
type SystemACRUDClient interface { // CreateDomain requires that the manager authenticate using an // end-user's API key, to perform the action on behalf of that // user. CreateDomain(ctx context.Context, in *CreateDomainRequest, opts ...grpc.CallOption) (*CreateDomainResponse, error) // RemoveDomain removes a domain that was previously created by the // same manager using CreateDomain. The manager can take this // action itself, not on behalf of the user that created the domain, // so this requires that the manager authenticate itself, but does // not require an end-user's API key. RemoveDomain(ctx context.Context, in *RemoveDomainRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) // RemoveIntercept is used to inform AmbassadorCloud (SystemA) that an // intercept has been removed. RemoveIntercept(ctx context.Context, in *InterceptRemoval, opts ...grpc.CallOption) (*emptypb.Empty, error) // PreferredAgent returns the active account's perferred agent // sidecar, for the given Telepresence version. PreferredAgent(ctx context.Context, in *common.VersionInfo, opts ...grpc.CallOption) (*PreferredAgentResponse, error) }
SystemACRUDClient is the client API for SystemACRUD 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 NewSystemACRUDClient ¶
func NewSystemACRUDClient(cc grpc.ClientConnInterface) SystemACRUDClient
type SystemACRUDServer ¶
type SystemACRUDServer interface { // CreateDomain requires that the manager authenticate using an // end-user's API key, to perform the action on behalf of that // user. CreateDomain(context.Context, *CreateDomainRequest) (*CreateDomainResponse, error) // RemoveDomain removes a domain that was previously created by the // same manager using CreateDomain. The manager can take this // action itself, not on behalf of the user that created the domain, // so this requires that the manager authenticate itself, but does // not require an end-user's API key. RemoveDomain(context.Context, *RemoveDomainRequest) (*emptypb.Empty, error) // RemoveIntercept is used to inform AmbassadorCloud (SystemA) that an // intercept has been removed. RemoveIntercept(context.Context, *InterceptRemoval) (*emptypb.Empty, error) // PreferredAgent returns the active account's perferred agent // sidecar, for the given Telepresence version. PreferredAgent(context.Context, *common.VersionInfo) (*PreferredAgentResponse, error) // contains filtered or unexported methods }
SystemACRUDServer is the server API for SystemACRUD service. All implementations must embed UnimplementedSystemACRUDServer for forward compatibility
type SystemACliClient ¶ added in v2.3.7
type SystemACliClient interface { // GetUnauthenticatedCommandMessages is used by the cli to get messages from // Ambassador Cloud that should be raised when specified commands are ran if // a user is not authenticated with Ambassador Cloud. These are messages // that we want to get to users who aren't currently logged into Ambassador // Cloud. Telepresence should cache these messages, since they won't change // frequently. GetUnauthenticatedCommandMessages(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*CommandMessageResponse, error) }
SystemACliClient is the client API for SystemACli 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 NewSystemACliClient ¶ added in v2.3.7
func NewSystemACliClient(cc grpc.ClientConnInterface) SystemACliClient
type SystemACliServer ¶ added in v2.3.7
type SystemACliServer interface { // GetUnauthenticatedCommandMessages is used by the cli to get messages from // Ambassador Cloud that should be raised when specified commands are ran if // a user is not authenticated with Ambassador Cloud. These are messages // that we want to get to users who aren't currently logged into Ambassador // Cloud. Telepresence should cache these messages, since they won't change // frequently. GetUnauthenticatedCommandMessages(context.Context, *emptypb.Empty) (*CommandMessageResponse, error) // contains filtered or unexported methods }
SystemACliServer is the server API for SystemACli service. All implementations must embed UnimplementedSystemACliServer for forward compatibility
type SystemAProxyClient ¶
type SystemAProxyClient interface { // ReverseConnection establishes a stream that is used for System A // to send gRPC requests back to the manager. This requires that // the manager authenticate itself, but does not require an // end-user's token. ReverseConnection(ctx context.Context, opts ...grpc.CallOption) (SystemAProxy_ReverseConnectionClient, error) }
SystemAProxyClient is the client API for SystemAProxy 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 NewSystemAProxyClient ¶
func NewSystemAProxyClient(cc grpc.ClientConnInterface) SystemAProxyClient
type SystemAProxyServer ¶
type SystemAProxyServer interface { // ReverseConnection establishes a stream that is used for System A // to send gRPC requests back to the manager. This requires that // the manager authenticate itself, but does not require an // end-user's token. ReverseConnection(SystemAProxy_ReverseConnectionServer) error // contains filtered or unexported methods }
SystemAProxyServer is the server API for SystemAProxy service. All implementations must embed UnimplementedSystemAProxyServer for forward compatibility
type UnimplementedSystemACRUDServer ¶
type UnimplementedSystemACRUDServer struct { }
UnimplementedSystemACRUDServer must be embedded to have forward compatible implementations.
func (UnimplementedSystemACRUDServer) CreateDomain ¶
func (UnimplementedSystemACRUDServer) CreateDomain(context.Context, *CreateDomainRequest) (*CreateDomainResponse, error)
func (UnimplementedSystemACRUDServer) PreferredAgent ¶
func (UnimplementedSystemACRUDServer) PreferredAgent(context.Context, *common.VersionInfo) (*PreferredAgentResponse, error)
func (UnimplementedSystemACRUDServer) RemoveDomain ¶
func (UnimplementedSystemACRUDServer) RemoveDomain(context.Context, *RemoveDomainRequest) (*emptypb.Empty, error)
func (UnimplementedSystemACRUDServer) RemoveIntercept ¶ added in v2.3.1
func (UnimplementedSystemACRUDServer) RemoveIntercept(context.Context, *InterceptRemoval) (*emptypb.Empty, error)
type UnimplementedSystemACliServer ¶ added in v2.3.7
type UnimplementedSystemACliServer struct { }
UnimplementedSystemACliServer must be embedded to have forward compatible implementations.
func (UnimplementedSystemACliServer) GetUnauthenticatedCommandMessages ¶ added in v2.3.7
func (UnimplementedSystemACliServer) GetUnauthenticatedCommandMessages(context.Context, *emptypb.Empty) (*CommandMessageResponse, error)
type UnimplementedSystemAProxyServer ¶
type UnimplementedSystemAProxyServer struct { }
UnimplementedSystemAProxyServer must be embedded to have forward compatible implementations.
func (UnimplementedSystemAProxyServer) ReverseConnection ¶
func (UnimplementedSystemAProxyServer) ReverseConnection(SystemAProxy_ReverseConnectionServer) error
type UnsafeSystemACRUDServer ¶
type UnsafeSystemACRUDServer interface {
// contains filtered or unexported methods
}
UnsafeSystemACRUDServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SystemACRUDServer will result in compilation errors.
type UnsafeSystemACliServer ¶ added in v2.3.7
type UnsafeSystemACliServer interface {
// contains filtered or unexported methods
}
UnsafeSystemACliServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SystemACliServer will result in compilation errors.
type UnsafeSystemAProxyServer ¶
type UnsafeSystemAProxyServer interface {
// contains filtered or unexported methods
}
UnsafeSystemAProxyServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SystemAProxyServer will result in compilation errors.