ptproxy

package

v0.0.0-...-0888c38 Latest Latest Go to latest Published: Apr 24, 2024 License: Apache-2.0 Imports: 21 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/pixie-io/pixie

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type ClusterIDer
type VizierPassThroughProxy
- func NewVizierPassThroughProxy(nc *nats.Conn, vc vzmgrClient) *VizierPassThroughProxy

Constants ¶

This section is empty.

Variables ¶

View Source

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

Functions ¶

This section is empty.

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.

Source Files ¶

View all Source files

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