systema

package
v2.3.2 Latest Latest
Warning

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

Go to latest
Published: Jun 18, 2021 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ReviewInterceptResponse_Status_name = map[int32]string{
		0: "UNSPECIFIED",
		1: "ALLOW",
		2: "DENY",
	}
	ReviewInterceptResponse_Status_value = map[string]int32{
		"UNSPECIFIED": 0,
		"ALLOW":       1,
		"DENY":        2,
	}
)

Enum value maps for ReviewInterceptResponse_Status.

View Source
var File_rpc_systema_agent2systema_proto protoreflect.FileDescriptor
View Source
var File_rpc_systema_manager2systama_proto protoreflect.FileDescriptor

Functions

func RegisterSystemAAgentServer

func RegisterSystemAAgentServer(s grpc.ServiceRegistrar, srv SystemAAgentServer)

func RegisterSystemACRUDServer

func RegisterSystemACRUDServer(s grpc.ServiceRegistrar, srv SystemACRUDServer)

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

Deprecated: Use Chunk.ProtoReflect.Descriptor instead.

func (*Chunk) GetContent

func (x *Chunk) GetContent() []byte

func (*Chunk) ProtoMessage

func (*Chunk) ProtoMessage()

func (*Chunk) ProtoReflect

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

func (*Chunk) Reset

func (x *Chunk) Reset()

func (*Chunk) String

func (x *Chunk) 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"`
	// contains filtered or unexported fields
}

func (*CreateDomainRequest) Descriptor deprecated

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

Deprecated: Use CreateDomainRequest.ProtoReflect.Descriptor instead.

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

type ReviewInterceptResponse struct {

	// Status is whether or not to allow this intercept to become active.
	Status ReviewInterceptResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=telepresence.systema.ReviewInterceptResponse_Status" json:"status,omitempty"`
	// Msg is a user-facing explanation of why the intercept is not
	// allowed to become active.
	Msg string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

func (*ReviewInterceptResponse) Descriptor deprecated

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

Deprecated: Use ReviewInterceptResponse.ProtoReflect.Descriptor instead.

func (*ReviewInterceptResponse) GetMsg

func (x *ReviewInterceptResponse) GetMsg() string

func (*ReviewInterceptResponse) GetStatus

func (*ReviewInterceptResponse) ProtoMessage

func (*ReviewInterceptResponse) ProtoMessage()

func (*ReviewInterceptResponse) ProtoReflect

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

func (*ReviewInterceptResponse) Reset

func (x *ReviewInterceptResponse) Reset()

func (*ReviewInterceptResponse) String

func (x *ReviewInterceptResponse) String() string

type ReviewInterceptResponse_Status

type ReviewInterceptResponse_Status int32
const (
	ReviewInterceptResponse_UNSPECIFIED ReviewInterceptResponse_Status = 0
	ReviewInterceptResponse_ALLOW       ReviewInterceptResponse_Status = 1
	ReviewInterceptResponse_DENY        ReviewInterceptResponse_Status = 2
)

func (ReviewInterceptResponse_Status) Descriptor

func (ReviewInterceptResponse_Status) Enum

func (ReviewInterceptResponse_Status) EnumDescriptor deprecated

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

Deprecated: Use ReviewInterceptResponse_Status.Descriptor instead.

func (ReviewInterceptResponse_Status) Number

func (ReviewInterceptResponse_Status) String

func (ReviewInterceptResponse_Status) Type

type SystemAAgentClient

type SystemAAgentClient interface {
	// ReviewIntercept gives SystemA an opportunity to review an
	// intercept before the Ambassador Telepresence agent activates it.
	//
	// There is no "remove" call; SystemA should call
	// telepresence.manager.Manager/WatchIntercepts to be informed of
	// such things.
	ReviewIntercept(ctx context.Context, in *manager.InterceptInfo, opts ...grpc.CallOption) (*ReviewInterceptResponse, error)
}

SystemAAgentClient is the client API for SystemAAgent 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.

type SystemAAgentServer

type SystemAAgentServer interface {
	// ReviewIntercept gives SystemA an opportunity to review an
	// intercept before the Ambassador Telepresence agent activates it.
	//
	// There is no "remove" call; SystemA should call
	// telepresence.manager.Manager/WatchIntercepts to be informed of
	// such things.
	ReviewIntercept(context.Context, *manager.InterceptInfo) (*ReviewInterceptResponse, error)
	// contains filtered or unexported methods
}

SystemAAgentServer is the server API for SystemAAgent service. All implementations must embed UnimplementedSystemAAgentServer for forward compatibility

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) (*empty.Empty, error)
	// RemoveIntercept is used to inform AmbassadorCloud (SystemA) that an
	// intercept has been removed.
	RemoveIntercept(ctx context.Context, in *InterceptRemoval, opts ...grpc.CallOption) (*empty.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.

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) (*empty.Empty, error)
	// RemoveIntercept is used to inform AmbassadorCloud (SystemA) that an
	// intercept has been removed.
	RemoveIntercept(context.Context, *InterceptRemoval) (*empty.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 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.

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 SystemAProxy_ReverseConnectionClient

type SystemAProxy_ReverseConnectionClient interface {
	Send(*Chunk) error
	Recv() (*Chunk, error)
	grpc.ClientStream
}

type SystemAProxy_ReverseConnectionServer

type SystemAProxy_ReverseConnectionServer interface {
	Send(*Chunk) error
	Recv() (*Chunk, error)
	grpc.ServerStream
}

type UnimplementedSystemAAgentServer

type UnimplementedSystemAAgentServer struct {
}

UnimplementedSystemAAgentServer must be embedded to have forward compatible implementations.

func (UnimplementedSystemAAgentServer) ReviewIntercept

type UnimplementedSystemACRUDServer

type UnimplementedSystemACRUDServer struct {
}

UnimplementedSystemACRUDServer must be embedded to have forward compatible implementations.

func (UnimplementedSystemACRUDServer) CreateDomain

func (UnimplementedSystemACRUDServer) PreferredAgent

func (UnimplementedSystemACRUDServer) RemoveDomain

func (UnimplementedSystemACRUDServer) RemoveIntercept added in v2.3.1

type UnimplementedSystemAProxyServer

type UnimplementedSystemAProxyServer struct {
}

UnimplementedSystemAProxyServer must be embedded to have forward compatible implementations.

func (UnimplementedSystemAProxyServer) ReverseConnection

type UnsafeSystemAAgentServer

type UnsafeSystemAAgentServer interface {
	// contains filtered or unexported methods
}

UnsafeSystemAAgentServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SystemAAgentServer will result in compilation errors.

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

Jump to

Keyboard shortcuts

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