ptproxy

Documentation

Index

• Variables
• type ClusterIDer
• type VizierPassThroughProxy
  • func NewVizierPassThroughProxy(nc *nats.Conn, vc vzmgrClient) *VizierPassThroughProxy
  • func (v *VizierPassThroughProxy) DebugLog(req *vizierpb.DebugLogRequest, srv vizierpb.VizierDebugService_DebugLogServer) error
  • func (v *VizierPassThroughProxy) DebugPods(req *vizierpb.DebugPodsRequest, ...) error
  • func (v *VizierPassThroughProxy) ExecuteScript(req *vizierpb.ExecuteScriptRequest, ...) error
  • func (v *VizierPassThroughProxy) GenerateOTelScript(ctx context.Context, req *vizierpb.GenerateOTelScriptRequest) (*vizierpb.GenerateOTelScriptResponse, error)
  • func (v *VizierPassThroughProxy) HealthCheck(req *vizierpb.HealthCheckRequest, srv vizierpb.VizierService_HealthCheckServer) error

Variables

var (
	// ErrNotAvailable is he error produced when vizier is not yet available.
	ErrNotAvailable = status.Error(codes.Unavailable, "cluster is not in a healthy state")
	// ErrCredentialFetch occurs when we can't fetch credentials for a vizier.
	ErrCredentialFetch = status.Error(codes.Internal, "failed to fetch creds for cluster")
	// ErrCredentialGenerate occurs when we can't generate new credentials using the cluster key.
	ErrCredentialGenerate = status.Error(codes.Internal, "failed to generate creds for cluster")
	// ErrPermissionDenied occurs when permission is denied to the cluster.
	ErrPermissionDenied = status.Error(codes.PermissionDenied, "permission denied for access to cluster")
)

Types

type ClusterIDer

type ClusterIDer interface {
	GetClusterID() string
}

ClusterIDer is used to get cluster ID from request.

type VizierPassThroughProxy

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

VizierPassThroughProxy implements the VizierAPI and allows proxying the data to the actual vizier cluster.

func NewVizierPassThroughProxy

func NewVizierPassThroughProxy(nc *nats.Conn, vc vzmgrClient) *VizierPassThroughProxy

NewVizierPassThroughProxy creates a new passthrough proxy.

func (*VizierPassThroughProxy) DebugLog

func (v *VizierPassThroughProxy) DebugLog(req *vizierpb.DebugLogRequest, srv vizierpb.VizierDebugService_DebugLogServer) error

DebugLog is the GRPC stream method to fetch debug logs from vizier.

func (*VizierPassThroughProxy) DebugPods

func (v *VizierPassThroughProxy) DebugPods(req *vizierpb.DebugPodsRequest, srv vizierpb.VizierDebugService_DebugPodsServer) error

DebugPods is the GRPC method to fetch the list of Vizier pods (and statuses) from a cluster.

func (*VizierPassThroughProxy) ExecuteScript

func (v *VizierPassThroughProxy) ExecuteScript(req *vizierpb.ExecuteScriptRequest, srv vizierpb.VizierService_ExecuteScriptServer) error

ExecuteScript is the GRPC stream method.

func (*VizierPassThroughProxy) GenerateOTelScript

func (v *VizierPassThroughProxy) GenerateOTelScript(ctx context.Context, req *vizierpb.GenerateOTelScriptRequest) (*vizierpb.GenerateOTelScriptResponse, error)

GenerateOTelScript is the GRPC method to generate an OTel script from a DataFrame script.

func (*VizierPassThroughProxy) HealthCheck

func (v *VizierPassThroughProxy) HealthCheck(req *vizierpb.HealthCheckRequest, srv vizierpb.VizierService_HealthCheckServer) error

HealthCheck is the GRPC stream method.