systema

package
v2.5.4-test.0 Latest Latest
Warning

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

 Go to latest Published: Mar 7, 2022 License: Apache-2.0 Imports: 11 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_cli2systema_proto protoreflect.FileDescriptor
View Source 
var File_rpc_systema_manager2systama_proto protoreflect.FileDescriptor
View Source 
var SystemAAgent_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "telepresence.systema.SystemAAgent",
	HandlerType: (*SystemAAgentServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ReviewIntercept",
			Handler:    _SystemAAgent_ReviewIntercept_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "rpc/systema/agent2systema.proto",
}

SystemAAgent_ServiceDesc is the grpc.ServiceDesc for SystemAAgent 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 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: "rpc/systema/manager2systama.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)

View Source 
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: "rpc/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)

View Source 
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: "rpc/systema/manager2systama.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)

View Source 
var UserDaemonSystemAProxy_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "telepresence.systema.UserDaemonSystemAProxy",
	HandlerType: (*UserDaemonSystemAProxyServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ReverseConnection",
			Handler:       _UserDaemonSystemAProxy_ReverseConnection_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "rpc/systema/manager2systama.proto",
}

UserDaemonSystemAProxy_ServiceDesc is the grpc.ServiceDesc for UserDaemonSystemAProxy service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterSystemAAgentServer 

func RegisterSystemAAgentServer(s grpc.ServiceRegistrar, srv SystemAAgentServer)

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)

func RegisterUserDaemonSystemAProxyServer added in v2.5.0 

func RegisterUserDaemonSystemAProxyServer(s grpc.ServiceRegistrar, srv UserDaemonSystemAProxyServer)

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 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"`
	// 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 (x *ReviewInterceptResponse) GetStatus() ReviewInterceptResponse_Status

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) Descriptor() protoreflect.EnumDescriptor

func (ReviewInterceptResponse_Status) Enum 

func (x ReviewInterceptResponse_Status) Enum() *ReviewInterceptResponse_Status

func (ReviewInterceptResponse_Status) EnumDescriptor deprecated 

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

Deprecated: Use ReviewInterceptResponse_Status.Descriptor instead.

func (ReviewInterceptResponse_Status) Number 

func (x ReviewInterceptResponse_Status) Number() protoreflect.EnumNumber

func (ReviewInterceptResponse_Status) String 

func (x ReviewInterceptResponse_Status) String() string

func (ReviewInterceptResponse_Status) Type 

func (ReviewInterceptResponse_Status) Type() protoreflect.EnumType

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.

func NewSystemAAgentClient 

func NewSystemAAgentClient(cc grpc.ClientConnInterface) SystemAAgentClient

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) (*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 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 

func (UnimplementedSystemAAgentServer) ReviewIntercept(context.Context, *manager.InterceptInfo) (*ReviewInterceptResponse, error)

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 UnimplementedUserDaemonSystemAProxyServer added in v2.5.0 

type UnimplementedUserDaemonSystemAProxyServer struct {
}

UnimplementedUserDaemonSystemAProxyServer must be embedded to have forward compatible implementations.

func (UnimplementedUserDaemonSystemAProxyServer) ReverseConnection added in v2.5.0 

func (UnimplementedUserDaemonSystemAProxyServer) ReverseConnection(UserDaemonSystemAProxy_ReverseConnectionServer) error

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

type UnsafeUserDaemonSystemAProxyServer added in v2.5.0 

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

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

type UserDaemonSystemAProxyClient added in v2.5.0 

type UserDaemonSystemAProxyClient interface {
	ReverseConnection(ctx context.Context, opts ...grpc.CallOption) (UserDaemonSystemAProxy_ReverseConnectionClient, error)
}

UserDaemonSystemAProxyClient is the client API for UserDaemonSystemAProxy 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 NewUserDaemonSystemAProxyClient added in v2.5.0 

func NewUserDaemonSystemAProxyClient(cc grpc.ClientConnInterface) UserDaemonSystemAProxyClient

type UserDaemonSystemAProxyServer added in v2.5.0 

type UserDaemonSystemAProxyServer interface {
	ReverseConnection(UserDaemonSystemAProxy_ReverseConnectionServer) error
	// contains filtered or unexported methods
}

UserDaemonSystemAProxyServer is the server API for UserDaemonSystemAProxy service. All implementations must embed UnimplementedUserDaemonSystemAProxyServer for forward compatibility

type UserDaemonSystemAProxy_ReverseConnectionClient added in v2.5.0 

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

type UserDaemonSystemAProxy_ReverseConnectionServer added in v2.5.0 

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

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.