pluginv2

package
v0.259.4 Latest Latest
Warning

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

 Go to latest Published: Nov 22, 2024 License: Apache-2.0 Imports: 8 Imported by: 9

Documentation

Overview

Package pluginv2 includes code generated by protoc-gen-go. DO NOT EDIT.

Index

Constants

View Source 
const (
	Diagnostics_CheckHealth_FullMethodName    = "/pluginv2.Diagnostics/CheckHealth"
	Diagnostics_CollectMetrics_FullMethodName = "/pluginv2.Diagnostics/CollectMetrics"
)
View Source 
const (
	Stream_SubscribeStream_FullMethodName = "/pluginv2.Stream/SubscribeStream"
	Stream_RunStream_FullMethodName       = "/pluginv2.Stream/RunStream"
	Stream_PublishStream_FullMethodName   = "/pluginv2.Stream/PublishStream"
)
View Source 
const (
	AdmissionControl_ValidateAdmission_FullMethodName = "/pluginv2.AdmissionControl/ValidateAdmission"
	AdmissionControl_MutateAdmission_FullMethodName   = "/pluginv2.AdmissionControl/MutateAdmission"
)
View Source 
const (
	Data_QueryData_FullMethodName = "/pluginv2.Data/QueryData"
)
View Source 
const (
	ResourceConversion_ConvertObjects_FullMethodName = "/pluginv2.ResourceConversion/ConvertObjects"
)
View Source 
const (
	Resource_CallResource_FullMethodName = "/pluginv2.Resource/CallResource"
)

Variables

View Source 
var (
	CheckHealthResponse_HealthStatus_name = map[int32]string{
		0: "UNKNOWN",
		1: "OK",
		2: "ERROR",
	}
	CheckHealthResponse_HealthStatus_value = map[string]int32{
		"UNKNOWN": 0,
		"OK":      1,
		"ERROR":   2,
	}
)

Enum value maps for CheckHealthResponse_HealthStatus.

View Source 
var (
	SubscribeStreamResponse_Status_name = map[int32]string{
		0: "OK",
		1: "NOT_FOUND",
		2: "PERMISSION_DENIED",
	}
	SubscribeStreamResponse_Status_value = map[string]int32{
		"OK":                0,
		"NOT_FOUND":         1,
		"PERMISSION_DENIED": 2,
	}
)

Enum value maps for SubscribeStreamResponse_Status.

View Source 
var (
	PublishStreamResponse_Status_name = map[int32]string{
		0: "OK",
		1: "NOT_FOUND",
		2: "PERMISSION_DENIED",
	}
	PublishStreamResponse_Status_value = map[string]int32{
		"OK":                0,
		"NOT_FOUND":         1,
		"PERMISSION_DENIED": 2,
	}
)

Enum value maps for PublishStreamResponse_Status.

View Source 
var (
	AdmissionRequest_Operation_name = map[int32]string{
		0: "CREATE",
		1: "UPDATE",
		2: "DELETE",
	}
	AdmissionRequest_Operation_value = map[string]int32{
		"CREATE": 0,
		"UPDATE": 1,
		"DELETE": 2,
	}
)

Enum value maps for AdmissionRequest_Operation.

View Source 
var AdmissionControl_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pluginv2.AdmissionControl",
	HandlerType: (*AdmissionControlServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ValidateAdmission",
			Handler:    _AdmissionControl_ValidateAdmission_Handler,
		},
		{
			MethodName: "MutateAdmission",
			Handler:    _AdmissionControl_MutateAdmission_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "backend.proto",
}

AdmissionControl_ServiceDesc is the grpc.ServiceDesc for AdmissionControl 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 Data_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pluginv2.Data",
	HandlerType: (*DataServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "QueryData",
			Handler:    _Data_QueryData_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "backend.proto",
}

Data_ServiceDesc is the grpc.ServiceDesc for Data 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 Diagnostics_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pluginv2.Diagnostics",
	HandlerType: (*DiagnosticsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CheckHealth",
			Handler:    _Diagnostics_CheckHealth_Handler,
		},
		{
			MethodName: "CollectMetrics",
			Handler:    _Diagnostics_CollectMetrics_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "backend.proto",
}

Diagnostics_ServiceDesc is the grpc.ServiceDesc for Diagnostics 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 File_backend_proto protoreflect.FileDescriptor
View Source 
var ResourceConversion_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pluginv2.ResourceConversion",
	HandlerType: (*ResourceConversionServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ConvertObjects",
			Handler:    _ResourceConversion_ConvertObjects_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "backend.proto",
}

ResourceConversion_ServiceDesc is the grpc.ServiceDesc for ResourceConversion 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 Resource_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pluginv2.Resource",
	HandlerType: (*ResourceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "CallResource",
			Handler:       _Resource_CallResource_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "backend.proto",
}

Resource_ServiceDesc is the grpc.ServiceDesc for Resource 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 Stream_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "pluginv2.Stream",
	HandlerType: (*StreamServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "SubscribeStream",
			Handler:    _Stream_SubscribeStream_Handler,
		},
		{
			MethodName: "PublishStream",
			Handler:    _Stream_PublishStream_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "RunStream",
			Handler:       _Stream_RunStream_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "backend.proto",
}

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

Functions

func RegisterAdmissionControlServer added in v0.232.0 

func RegisterAdmissionControlServer(s grpc.ServiceRegistrar, srv AdmissionControlServer)

func RegisterDataServer 

func RegisterDataServer(s grpc.ServiceRegistrar, srv DataServer)

func RegisterDiagnosticsServer 

func RegisterDiagnosticsServer(s grpc.ServiceRegistrar, srv DiagnosticsServer)

func RegisterResourceConversionServer added in v0.243.0 

func RegisterResourceConversionServer(s grpc.ServiceRegistrar, srv ResourceConversionServer)

func RegisterResourceServer 

func RegisterResourceServer(s grpc.ServiceRegistrar, srv ResourceServer)

func RegisterStreamServer added in v0.89.0 

func RegisterStreamServer(s grpc.ServiceRegistrar, srv StreamServer)

Types

type AdmissionControlClient added in v0.232.0 

type AdmissionControlClient interface {
	// Validate a resource -- the response is a simple yes/no
	ValidateAdmission(ctx context.Context, in *AdmissionRequest, opts ...grpc.CallOption) (*ValidationResponse, error)
	// Return a modified copy of the request that can be saved or a descriptive error
	MutateAdmission(ctx context.Context, in *AdmissionRequest, opts ...grpc.CallOption) (*MutationResponse, error)
}

AdmissionControlClient is the client API for AdmissionControl 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.

Admission control is a service based on the kubernetes admission webhook patterns. This service can be used to verify if objects are valid and convert between versions See: https://github.com/kubernetes/kubernetes/blob/v1.30.0/pkg/apis/admission/types.go#L41 And: https://github.com/grafana/grafana-app-sdk/blob/main/resource/admission.go#L14

func NewAdmissionControlClient added in v0.232.0 

func NewAdmissionControlClient(cc grpc.ClientConnInterface) AdmissionControlClient

type AdmissionControlServer added in v0.232.0 

type AdmissionControlServer interface {
	// Validate a resource -- the response is a simple yes/no
	ValidateAdmission(context.Context, *AdmissionRequest) (*ValidationResponse, error)
	// Return a modified copy of the request that can be saved or a descriptive error
	MutateAdmission(context.Context, *AdmissionRequest) (*MutationResponse, error)
}

AdmissionControlServer is the server API for AdmissionControl service. All implementations should embed UnimplementedAdmissionControlServer for forward compatibility.

Admission control is a service based on the kubernetes admission webhook patterns. This service can be used to verify if objects are valid and convert between versions See: https://github.com/kubernetes/kubernetes/blob/v1.30.0/pkg/apis/admission/types.go#L41 And: https://github.com/grafana/grafana-app-sdk/blob/main/resource/admission.go#L14

type AdmissionRequest added in v0.232.0 

type AdmissionRequest struct {

	// NOTE: this may not include app or datasource instance settings depending on the request
	PluginContext *PluginContext `protobuf:"bytes,1,opt,name=pluginContext,proto3" json:"pluginContext,omitempty"`
	// The requested operation
	Operation AdmissionRequest_Operation `protobuf:"varint,2,opt,name=operation,proto3,enum=pluginv2.AdmissionRequest_Operation" json:"operation,omitempty"`
	// The object kind
	Kind *GroupVersionKind `protobuf:"bytes,3,opt,name=kind,proto3" json:"kind,omitempty"`
	// Object is the object in the request.  This includes the full metadata envelope.
	ObjectBytes []byte `protobuf:"bytes,4,opt,name=object_bytes,json=objectBytes,proto3" json:"object_bytes,omitempty"`
	// OldObject is the object as it currently exists in storage. This includes the full metadata envelope.
	OldObjectBytes []byte `protobuf:"bytes,5,opt,name=old_object_bytes,json=oldObjectBytes,proto3" json:"old_object_bytes,omitempty"`
	// contains filtered or unexported fields
}

AdmissionRequest contains information from a kubernetes Admission request and decoded object(s).

func (*AdmissionRequest) Descriptor deprecated added in v0.232.0 

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

Deprecated: Use AdmissionRequest.ProtoReflect.Descriptor instead.

func (*AdmissionRequest) GetKind added in v0.232.0 

func (x *AdmissionRequest) GetKind() *GroupVersionKind

func (*AdmissionRequest) GetObjectBytes added in v0.232.0 

func (x *AdmissionRequest) GetObjectBytes() []byte

func (*AdmissionRequest) GetOldObjectBytes added in v0.232.0 

func (x *AdmissionRequest) GetOldObjectBytes() []byte

func (*AdmissionRequest) GetOperation added in v0.232.0 

func (x *AdmissionRequest) GetOperation() AdmissionRequest_Operation

func (*AdmissionRequest) GetPluginContext added in v0.232.0 

func (x *AdmissionRequest) GetPluginContext() *PluginContext

func (*AdmissionRequest) ProtoMessage added in v0.232.0 

func (*AdmissionRequest) ProtoMessage()

func (*AdmissionRequest) ProtoReflect added in v0.232.0 

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

func (*AdmissionRequest) Reset added in v0.232.0 

func (x *AdmissionRequest) Reset()

func (*AdmissionRequest) String added in v0.232.0 

func (x *AdmissionRequest) String() string

type AdmissionRequest_Operation added in v0.232.0 

type AdmissionRequest_Operation int32

Operation is the type of resource operation being checked for admission control https://github.com/kubernetes/kubernetes/blob/v1.30.0/pkg/apis/admission/types.go#L158 

const (
	AdmissionRequest_CREATE AdmissionRequest_Operation = 0
	AdmissionRequest_UPDATE AdmissionRequest_Operation = 1
	AdmissionRequest_DELETE AdmissionRequest_Operation = 2
)

func (AdmissionRequest_Operation) Descriptor added in v0.232.0 

func (AdmissionRequest_Operation) Descriptor() protoreflect.EnumDescriptor

func (AdmissionRequest_Operation) Enum added in v0.232.0 

func (x AdmissionRequest_Operation) Enum() *AdmissionRequest_Operation

func (AdmissionRequest_Operation) EnumDescriptor deprecated added in v0.232.0 

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

Deprecated: Use AdmissionRequest_Operation.Descriptor instead.

func (AdmissionRequest_Operation) Number added in v0.232.0 

func (x AdmissionRequest_Operation) Number() protoreflect.EnumNumber

func (AdmissionRequest_Operation) String added in v0.232.0 

func (x AdmissionRequest_Operation) String() string

func (AdmissionRequest_Operation) Type added in v0.232.0 

func (AdmissionRequest_Operation) Type() protoreflect.EnumType

type AppInstanceSettings added in v0.54.0 

type AppInstanceSettings struct {
	JsonData                []byte            `protobuf:"bytes,3,opt,name=jsonData,proto3" json:"jsonData,omitempty"`
	DecryptedSecureJsonData map[string]string `` /* 187-byte string literal not displayed */
	LastUpdatedMS           int64             `protobuf:"varint,5,opt,name=lastUpdatedMS,proto3" json:"lastUpdatedMS,omitempty"`
	// The API version when the settings were saved
	// NOTE: this may be an older version than the current apiVersion
	ApiVersion string `protobuf:"bytes,6,opt,name=apiVersion,proto3" json:"apiVersion,omitempty"`
	// contains filtered or unexported fields
}

func (*AppInstanceSettings) Descriptor deprecated added in v0.54.0 

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

Deprecated: Use AppInstanceSettings.ProtoReflect.Descriptor instead.

func (*AppInstanceSettings) GetApiVersion added in v0.230.0 

func (x *AppInstanceSettings) GetApiVersion() string

func (*AppInstanceSettings) GetDecryptedSecureJsonData added in v0.54.0 

func (x *AppInstanceSettings) GetDecryptedSecureJsonData() map[string]string

func (*AppInstanceSettings) GetJsonData added in v0.54.0 

func (x *AppInstanceSettings) GetJsonData() []byte

func (*AppInstanceSettings) GetLastUpdatedMS added in v0.54.0 

func (x *AppInstanceSettings) GetLastUpdatedMS() int64

func (*AppInstanceSettings) ProtoMessage added in v0.54.0 

func (*AppInstanceSettings) ProtoMessage()

func (*AppInstanceSettings) ProtoReflect added in v0.87.0 

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

func (*AppInstanceSettings) Reset added in v0.54.0 

func (x *AppInstanceSettings) Reset()

func (*AppInstanceSettings) String added in v0.54.0 

func (x *AppInstanceSettings) String() string

type CallResourceRequest 

type CallResourceRequest struct {
	PluginContext *PluginContext         `protobuf:"bytes,1,opt,name=pluginContext,proto3" json:"pluginContext,omitempty"`
	Path          string                 `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Method        string                 `protobuf:"bytes,3,opt,name=method,proto3" json:"method,omitempty"`
	Url           string                 `protobuf:"bytes,4,opt,name=url,proto3" json:"url,omitempty"`
	Headers       map[string]*StringList `` /* 155-byte string literal not displayed */
	Body          []byte                 `protobuf:"bytes,6,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*CallResourceRequest) Descriptor deprecated 

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

Deprecated: Use CallResourceRequest.ProtoReflect.Descriptor instead.

func (*CallResourceRequest) GetBody 

func (x *CallResourceRequest) GetBody() []byte

func (*CallResourceRequest) GetHeaders 

func (x *CallResourceRequest) GetHeaders() map[string]*StringList

func (*CallResourceRequest) GetMethod 

func (x *CallResourceRequest) GetMethod() string

func (*CallResourceRequest) GetPath 

func (x *CallResourceRequest) GetPath() string

func (*CallResourceRequest) GetPluginContext added in v0.54.0 

func (x *CallResourceRequest) GetPluginContext() *PluginContext

func (*CallResourceRequest) GetUrl 

func (x *CallResourceRequest) GetUrl() string

func (*CallResourceRequest) ProtoMessage 

func (*CallResourceRequest) ProtoMessage()

func (*CallResourceRequest) ProtoReflect added in v0.87.0 

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

func (*CallResourceRequest) Reset 

func (x *CallResourceRequest) Reset()

func (*CallResourceRequest) String 

func (x *CallResourceRequest) String() string

type CallResourceResponse 

type CallResourceResponse struct {

	// Maps to raw HTTP status codes when passed over HTTP
	Code int32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	// Raw HTTP headers sent to the client
	Headers map[string]*StringList `` /* 155-byte string literal not displayed */
	// Raw HTTP body bytes sent to the client
	Body []byte `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	// contains filtered or unexported fields
}

func (*CallResourceResponse) Descriptor deprecated 

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

Deprecated: Use CallResourceResponse.ProtoReflect.Descriptor instead.

func (*CallResourceResponse) GetBody 

func (x *CallResourceResponse) GetBody() []byte

func (*CallResourceResponse) GetCode 

func (x *CallResourceResponse) GetCode() int32

func (*CallResourceResponse) GetHeaders 

func (x *CallResourceResponse) GetHeaders() map[string]*StringList

func (*CallResourceResponse) ProtoMessage 

func (*CallResourceResponse) ProtoMessage()

func (*CallResourceResponse) ProtoReflect added in v0.87.0 

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

func (*CallResourceResponse) Reset 

func (x *CallResourceResponse) Reset()

func (*CallResourceResponse) String 

func (x *CallResourceResponse) String() string

type CheckHealthRequest 

type CheckHealthRequest struct {
	PluginContext *PluginContext `protobuf:"bytes,1,opt,name=pluginContext,proto3" json:"pluginContext,omitempty"`
	// Environment info
	Headers map[string]string `` /* 155-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CheckHealthRequest) Descriptor deprecated 

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

Deprecated: Use CheckHealthRequest.ProtoReflect.Descriptor instead.

func (*CheckHealthRequest) GetHeaders added in v0.135.0 

func (x *CheckHealthRequest) GetHeaders() map[string]string

func (*CheckHealthRequest) GetPluginContext added in v0.54.0 

func (x *CheckHealthRequest) GetPluginContext() *PluginContext

func (*CheckHealthRequest) ProtoMessage 

func (*CheckHealthRequest) ProtoMessage()

func (*CheckHealthRequest) ProtoReflect added in v0.87.0 

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

func (*CheckHealthRequest) Reset 

func (x *CheckHealthRequest) Reset()

func (*CheckHealthRequest) String 

func (x *CheckHealthRequest) String() string

type CheckHealthResponse 

type CheckHealthResponse struct {
	Status      CheckHealthResponse_HealthStatus `protobuf:"varint,1,opt,name=status,proto3,enum=pluginv2.CheckHealthResponse_HealthStatus" json:"status,omitempty"`
	Message     string                           `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	JsonDetails []byte                           `protobuf:"bytes,3,opt,name=jsonDetails,proto3" json:"jsonDetails,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckHealthResponse) Descriptor deprecated 

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

Deprecated: Use CheckHealthResponse.ProtoReflect.Descriptor instead.

func (*CheckHealthResponse) GetJsonDetails 

func (x *CheckHealthResponse) GetJsonDetails() []byte

func (*CheckHealthResponse) GetMessage 

func (x *CheckHealthResponse) GetMessage() string

func (*CheckHealthResponse) GetStatus 

func (x *CheckHealthResponse) GetStatus() CheckHealthResponse_HealthStatus

func (*CheckHealthResponse) ProtoMessage 

func (*CheckHealthResponse) ProtoMessage()

func (*CheckHealthResponse) ProtoReflect added in v0.87.0 

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

func (*CheckHealthResponse) Reset 

func (x *CheckHealthResponse) Reset()

func (*CheckHealthResponse) String 

func (x *CheckHealthResponse) String() string

type CheckHealthResponse_HealthStatus 

type CheckHealthResponse_HealthStatus int32
const (
	CheckHealthResponse_UNKNOWN CheckHealthResponse_HealthStatus = 0
	CheckHealthResponse_OK      CheckHealthResponse_HealthStatus = 1
	CheckHealthResponse_ERROR   CheckHealthResponse_HealthStatus = 2
)

func (CheckHealthResponse_HealthStatus) Descriptor added in v0.87.0 

func (CheckHealthResponse_HealthStatus) Descriptor() protoreflect.EnumDescriptor

func (CheckHealthResponse_HealthStatus) Enum added in v0.87.0 

func (x CheckHealthResponse_HealthStatus) Enum() *CheckHealthResponse_HealthStatus

func (CheckHealthResponse_HealthStatus) EnumDescriptor deprecated 

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

Deprecated: Use CheckHealthResponse_HealthStatus.Descriptor instead.

func (CheckHealthResponse_HealthStatus) Number added in v0.87.0 

func (x CheckHealthResponse_HealthStatus) Number() protoreflect.EnumNumber

func (CheckHealthResponse_HealthStatus) String 

func (x CheckHealthResponse_HealthStatus) String() string

func (CheckHealthResponse_HealthStatus) Type added in v0.87.0 

func (CheckHealthResponse_HealthStatus) Type() protoreflect.EnumType

type CollectMetricsRequest 

type CollectMetricsRequest struct {
	PluginContext *PluginContext `protobuf:"bytes,1,opt,name=pluginContext,proto3" json:"pluginContext,omitempty"`
	// contains filtered or unexported fields
}

func (*CollectMetricsRequest) Descriptor deprecated 

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

Deprecated: Use CollectMetricsRequest.ProtoReflect.Descriptor instead.

func (*CollectMetricsRequest) GetPluginContext added in v0.54.0 

func (x *CollectMetricsRequest) GetPluginContext() *PluginContext

func (*CollectMetricsRequest) ProtoMessage 

func (*CollectMetricsRequest) ProtoMessage()

func (*CollectMetricsRequest) ProtoReflect added in v0.87.0 

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

func (*CollectMetricsRequest) Reset 

func (x *CollectMetricsRequest) Reset()

func (*CollectMetricsRequest) String 

func (x *CollectMetricsRequest) String() string

type CollectMetricsResponse 

type CollectMetricsResponse struct {
	Metrics *CollectMetricsResponse_Payload `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"`
	// contains filtered or unexported fields
}

func (*CollectMetricsResponse) Descriptor deprecated 

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

Deprecated: Use CollectMetricsResponse.ProtoReflect.Descriptor instead.

func (*CollectMetricsResponse) GetMetrics 

func (x *CollectMetricsResponse) GetMetrics() *CollectMetricsResponse_Payload

func (*CollectMetricsResponse) ProtoMessage 

func (*CollectMetricsResponse) ProtoMessage()

func (*CollectMetricsResponse) ProtoReflect added in v0.87.0 

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

func (*CollectMetricsResponse) Reset 

func (x *CollectMetricsResponse) Reset()

func (*CollectMetricsResponse) String 

func (x *CollectMetricsResponse) String() string

type CollectMetricsResponse_Payload 

type CollectMetricsResponse_Payload struct {
	Prometheus []byte `protobuf:"bytes,1,opt,name=prometheus,proto3" json:"prometheus,omitempty"`
	// contains filtered or unexported fields
}

func (*CollectMetricsResponse_Payload) Descriptor deprecated 

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

Deprecated: Use CollectMetricsResponse_Payload.ProtoReflect.Descriptor instead.

func (*CollectMetricsResponse_Payload) GetPrometheus 

func (x *CollectMetricsResponse_Payload) GetPrometheus() []byte

func (*CollectMetricsResponse_Payload) ProtoMessage 

func (*CollectMetricsResponse_Payload) ProtoMessage()

func (*CollectMetricsResponse_Payload) ProtoReflect added in v0.87.0 

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

func (*CollectMetricsResponse_Payload) Reset 

func (x *CollectMetricsResponse_Payload) Reset()

func (*CollectMetricsResponse_Payload) String 

func (x *CollectMetricsResponse_Payload) String() string

type ConversionRequest added in v0.232.0 

type ConversionRequest struct {

	// NOTE: this may not include app or datasource instance settings depending on the request
	PluginContext *PluginContext `protobuf:"bytes,1,opt,name=pluginContext,proto3" json:"pluginContext,omitempty"`
	// uid is an identifier for the individual request/response. It allows distinguishing instances of requests which are
	// otherwise identical (parallel requests, etc).
	// The UID is meant to track the round trip (request/response) between the Kubernetes API server and the webhook, not the user request.
	// It is suitable for correlating log entries between the webhook and apiserver, for either auditing or debugging.
	Uid string `protobuf:"bytes,2,opt,name=uid,proto3" json:"uid,omitempty"`
	// Objects to convert
	// +listType=atomic
	Objects []*RawObject `protobuf:"bytes,3,rep,name=objects,proto3" json:"objects,omitempty"`
	// Target converted version
	TargetVersion *GroupVersion `protobuf:"bytes,4,opt,name=target_version,json=targetVersion,proto3" json:"target_version,omitempty"`
	// contains filtered or unexported fields
}

ConversionRequest supports converting objects from one version to another

func (*ConversionRequest) Descriptor deprecated added in v0.232.0 

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

Deprecated: Use ConversionRequest.ProtoReflect.Descriptor instead.

func (*ConversionRequest) GetObjects added in v0.243.0 

func (x *ConversionRequest) GetObjects() []*RawObject

func (*ConversionRequest) GetPluginContext added in v0.232.0 

func (x *ConversionRequest) GetPluginContext() *PluginContext

func (*ConversionRequest) GetTargetVersion added in v0.232.0 

func (x *ConversionRequest) GetTargetVersion() *GroupVersion

func (*ConversionRequest) GetUid added in v0.243.0 

func (x *ConversionRequest) GetUid() string

func (*ConversionRequest) ProtoMessage added in v0.232.0 

func (*ConversionRequest) ProtoMessage()

func (*ConversionRequest) ProtoReflect added in v0.232.0 

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

func (*ConversionRequest) Reset added in v0.232.0 

func (x *ConversionRequest) Reset()

func (*ConversionRequest) String added in v0.232.0 

func (x *ConversionRequest) String() string

type ConversionResponse added in v0.232.0 

type ConversionResponse struct {

	// uid is an identifier for the individual request/response.
	// This should be copied over from the corresponding `request.uid`.
	Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	// result contains extra details into why an admission request was denied.
	Result *StatusResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// objects is the list of converted version of `request.objects` if the `result` is successful, otherwise empty.
	// +listType=atomic
	Objects []*RawObject `protobuf:"bytes,3,rep,name=objects,proto3" json:"objects,omitempty"`
	// contains filtered or unexported fields
}

ConversionResponse contains the converted objects

func (*ConversionResponse) Descriptor deprecated added in v0.232.0 

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

Deprecated: Use ConversionResponse.ProtoReflect.Descriptor instead.

func (*ConversionResponse) GetObjects added in v0.243.0 

func (x *ConversionResponse) GetObjects() []*RawObject

func (*ConversionResponse) GetResult added in v0.232.0 

func (x *ConversionResponse) GetResult() *StatusResult

func (*ConversionResponse) GetUid added in v0.243.0 

func (x *ConversionResponse) GetUid() string

func (*ConversionResponse) ProtoMessage added in v0.232.0 

func (*ConversionResponse) ProtoMessage()

func (*ConversionResponse) ProtoReflect added in v0.232.0 

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

func (*ConversionResponse) Reset added in v0.232.0 

func (x *ConversionResponse) Reset()

func (*ConversionResponse) String added in v0.232.0 

func (x *ConversionResponse) String() string

type DataClient 

type DataClient interface {
	QueryData(ctx context.Context, in *QueryDataRequest, opts ...grpc.CallOption) (*QueryDataResponse, error)
}

DataClient is the client API for Data 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 NewDataClient 

func NewDataClient(cc grpc.ClientConnInterface) DataClient

type DataQuery 

type DataQuery struct {
	RefId         string     `protobuf:"bytes,1,opt,name=refId,proto3" json:"refId,omitempty"`
	MaxDataPoints int64      `protobuf:"varint,2,opt,name=maxDataPoints,proto3" json:"maxDataPoints,omitempty"`
	IntervalMS    int64      `protobuf:"varint,3,opt,name=intervalMS,proto3" json:"intervalMS,omitempty"`
	TimeRange     *TimeRange `protobuf:"bytes,4,opt,name=timeRange,proto3" json:"timeRange,omitempty"`
	Json          []byte     `protobuf:"bytes,5,opt,name=json,proto3" json:"json,omitempty"`
	QueryType     string     `protobuf:"bytes,6,opt,name=queryType,proto3" json:"queryType,omitempty"`
	// contains filtered or unexported fields
}

func (*DataQuery) Descriptor deprecated 

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

Deprecated: Use DataQuery.ProtoReflect.Descriptor instead.

func (*DataQuery) GetIntervalMS 

func (x *DataQuery) GetIntervalMS() int64

func (*DataQuery) GetJson 

func (x *DataQuery) GetJson() []byte

func (*DataQuery) GetMaxDataPoints 

func (x *DataQuery) GetMaxDataPoints() int64

func (*DataQuery) GetQueryType added in v0.60.0 

func (x *DataQuery) GetQueryType() string

func (*DataQuery) GetRefId 

func (x *DataQuery) GetRefId() string

func (*DataQuery) GetTimeRange 

func (x *DataQuery) GetTimeRange() *TimeRange

func (*DataQuery) ProtoMessage 

func (*DataQuery) ProtoMessage()

func (*DataQuery) ProtoReflect added in v0.87.0 

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

func (*DataQuery) Reset 

func (x *DataQuery) Reset()

func (*DataQuery) String 

func (x *DataQuery) String() string

type DataResponse added in v0.35.0 

type DataResponse struct {

	// Arrow encoded DataFrames
	// Frame has its own meta, warnings, and repeats refId
	Frames [][]byte `protobuf:"bytes,1,rep,name=frames,proto3" json:"frames,omitempty"`
	// Error message
	Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// Currently not used and not exposed in the frontend
	JsonMeta []byte `protobuf:"bytes,3,opt,name=jsonMeta,proto3" json:"jsonMeta,omitempty"`
	// When errors exist or a non 2XX status, clients will be passed a 207 HTTP error code in /ds/query
	// The status codes should match values from standard HTTP status codes
	// If not set explicitly, it will be marshaled to 200 if no error exists, or 500 if one does
	Status int32 `protobuf:"varint,4,opt,name=status,proto3" json:"status,omitempty"`
	// Error source
	ErrorSource string `protobuf:"bytes,5,opt,name=errorSource,proto3" json:"errorSource,omitempty"`
	// contains filtered or unexported fields
}

func (*DataResponse) Descriptor deprecated added in v0.35.0 

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

Deprecated: Use DataResponse.ProtoReflect.Descriptor instead.

func (*DataResponse) GetError added in v0.35.0 

func (x *DataResponse) GetError() string

func (*DataResponse) GetErrorSource added in v0.179.0 

func (x *DataResponse) GetErrorSource() string

func (*DataResponse) GetFrames added in v0.35.0 

func (x *DataResponse) GetFrames() [][]byte

func (*DataResponse) GetJsonMeta added in v0.35.0 

func (x *DataResponse) GetJsonMeta() []byte

func (*DataResponse) GetStatus added in v0.142.0 

func (x *DataResponse) GetStatus() int32

func (*DataResponse) ProtoMessage added in v0.35.0 

func (*DataResponse) ProtoMessage()

func (*DataResponse) ProtoReflect added in v0.87.0 

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

func (*DataResponse) Reset added in v0.35.0 

func (x *DataResponse) Reset()

func (*DataResponse) String added in v0.35.0 

func (x *DataResponse) String() string

type DataServer 

type DataServer interface {
	QueryData(context.Context, *QueryDataRequest) (*QueryDataResponse, error)
}

DataServer is the server API for Data service. All implementations should embed UnimplementedDataServer for forward compatibility.

type DataSourceInstanceSettings added in v0.54.0 

type DataSourceInstanceSettings struct {

	// Deprecatd: Internal ID, do not use this for anythign important
	Id                      int64             `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Name                    string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Url                     string            `protobuf:"bytes,3,opt,name=url,proto3" json:"url,omitempty"`
	User                    string            `protobuf:"bytes,4,opt,name=user,proto3" json:"user,omitempty"`
	Database                string            `protobuf:"bytes,5,opt,name=database,proto3" json:"database,omitempty"`
	BasicAuthEnabled        bool              `protobuf:"varint,6,opt,name=basicAuthEnabled,proto3" json:"basicAuthEnabled,omitempty"`
	BasicAuthUser           string            `protobuf:"bytes,7,opt,name=basicAuthUser,proto3" json:"basicAuthUser,omitempty"`
	JsonData                []byte            `protobuf:"bytes,8,opt,name=jsonData,proto3" json:"jsonData,omitempty"`
	DecryptedSecureJsonData map[string]string `` /* 187-byte string literal not displayed */
	// timestamp when the settings where last changed
	LastUpdatedMS int64 `protobuf:"varint,10,opt,name=lastUpdatedMS,proto3" json:"lastUpdatedMS,omitempty"`
	// Datasoruce unique ID (within an org/stack namespace)
	Uid string `protobuf:"bytes,11,opt,name=uid,proto3" json:"uid,omitempty"`
	// The API version when the settings were saved.
	// NOTE: this may be an older version than the current apiVersion
	ApiVersion string `protobuf:"bytes,12,opt,name=apiVersion,proto3" json:"apiVersion,omitempty"`
	// contains filtered or unexported fields
}

func (*DataSourceInstanceSettings) Descriptor deprecated added in v0.54.0 

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

Deprecated: Use DataSourceInstanceSettings.ProtoReflect.Descriptor instead.

func (*DataSourceInstanceSettings) GetApiVersion added in v0.230.0 

func (x *DataSourceInstanceSettings) GetApiVersion() string

func (*DataSourceInstanceSettings) GetBasicAuthEnabled added in v0.54.0 

func (x *DataSourceInstanceSettings) GetBasicAuthEnabled() bool

func (*DataSourceInstanceSettings) GetBasicAuthUser added in v0.54.0 

func (x *DataSourceInstanceSettings) GetBasicAuthUser() string

func (*DataSourceInstanceSettings) GetDatabase added in v0.54.0 

func (x *DataSourceInstanceSettings) GetDatabase() string

func (*DataSourceInstanceSettings) GetDecryptedSecureJsonData added in v0.54.0 

func (x *DataSourceInstanceSettings) GetDecryptedSecureJsonData() map[string]string

func (*DataSourceInstanceSettings) GetId added in v0.54.0 

func (x *DataSourceInstanceSettings) GetId() int64

func (*DataSourceInstanceSettings) GetJsonData added in v0.54.0 

func (x *DataSourceInstanceSettings) GetJsonData() []byte

func (*DataSourceInstanceSettings) GetLastUpdatedMS added in v0.54.0 

func (x *DataSourceInstanceSettings) GetLastUpdatedMS() int64

func (*DataSourceInstanceSettings) GetName added in v0.54.0 

func (x *DataSourceInstanceSettings) GetName() string

func (*DataSourceInstanceSettings) GetUid added in v0.82.0 

func (x *DataSourceInstanceSettings) GetUid() string

func (*DataSourceInstanceSettings) GetUrl added in v0.54.0 

func (x *DataSourceInstanceSettings) GetUrl() string

func (*DataSourceInstanceSettings) GetUser added in v0.54.0 

func (x *DataSourceInstanceSettings) GetUser() string

func (*DataSourceInstanceSettings) ProtoMessage added in v0.54.0 

func (*DataSourceInstanceSettings) ProtoMessage()

func (*DataSourceInstanceSettings) ProtoReflect added in v0.87.0 

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

func (*DataSourceInstanceSettings) Reset added in v0.54.0 

func (x *DataSourceInstanceSettings) Reset()

func (*DataSourceInstanceSettings) String added in v0.54.0 

func (x *DataSourceInstanceSettings) String() string

type DiagnosticsClient 

type DiagnosticsClient interface {
	CheckHealth(ctx context.Context, in *CheckHealthRequest, opts ...grpc.CallOption) (*CheckHealthResponse, error)
	CollectMetrics(ctx context.Context, in *CollectMetricsRequest, opts ...grpc.CallOption) (*CollectMetricsResponse, error)
}

DiagnosticsClient is the client API for Diagnostics 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 NewDiagnosticsClient 

func NewDiagnosticsClient(cc grpc.ClientConnInterface) DiagnosticsClient

type DiagnosticsServer 

type DiagnosticsServer interface {
	CheckHealth(context.Context, *CheckHealthRequest) (*CheckHealthResponse, error)
	CollectMetrics(context.Context, *CollectMetricsRequest) (*CollectMetricsResponse, error)
}

DiagnosticsServer is the server API for Diagnostics service. All implementations should embed UnimplementedDiagnosticsServer for forward compatibility.

type GroupVersion added in v0.243.0 

type GroupVersion struct {
	Group   string `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

GroupVersion represents the API group and version of a resource.

func (*GroupVersion) Descriptor deprecated added in v0.243.0 

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

Deprecated: Use GroupVersion.ProtoReflect.Descriptor instead.

func (*GroupVersion) GetGroup added in v0.243.0 

func (x *GroupVersion) GetGroup() string

func (*GroupVersion) GetVersion added in v0.243.0 

func (x *GroupVersion) GetVersion() string

func (*GroupVersion) ProtoMessage added in v0.243.0 

func (*GroupVersion) ProtoMessage()

func (*GroupVersion) ProtoReflect added in v0.243.0 

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

func (*GroupVersion) Reset added in v0.243.0 

func (x *GroupVersion) Reset()

func (*GroupVersion) String added in v0.243.0 

func (x *GroupVersion) String() string

type GroupVersionKind added in v0.232.0 

type GroupVersionKind struct {
	Group   string `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Kind    string `protobuf:"bytes,3,opt,name=kind,proto3" json:"kind,omitempty"`
	// contains filtered or unexported fields
}

Identify the Object properties

func (*GroupVersionKind) Descriptor deprecated added in v0.232.0 

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

Deprecated: Use GroupVersionKind.ProtoReflect.Descriptor instead.

func (*GroupVersionKind) GetGroup added in v0.232.0 

func (x *GroupVersionKind) GetGroup() string

func (*GroupVersionKind) GetKind added in v0.232.0 

func (x *GroupVersionKind) GetKind() string

func (*GroupVersionKind) GetVersion added in v0.232.0 

func (x *GroupVersionKind) GetVersion() string

func (*GroupVersionKind) ProtoMessage added in v0.232.0 

func (*GroupVersionKind) ProtoMessage()

func (*GroupVersionKind) ProtoReflect added in v0.232.0 

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

func (*GroupVersionKind) Reset added in v0.232.0 

func (x *GroupVersionKind) Reset()

func (*GroupVersionKind) String added in v0.232.0 

func (x *GroupVersionKind) String() string

type MutationResponse added in v0.232.0 

type MutationResponse struct {

	// Allowed indicates whether or not the admission request was permitted.
	Allowed bool `protobuf:"varint,1,opt,name=allowed,proto3" json:"allowed,omitempty"`
	// Result contains extra details into why an admission request was denied.
	// This field IS NOT consulted in any way if "Allowed" is "true".
	// +optional
	Result *StatusResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// warnings is a list of warning messages to return to the requesting API client.
	// Warning messages describe a problem the client making the API request should correct or be aware of.
	// Limit warnings to 120 characters if possible.
	// Warnings over 256 characters and large numbers of warnings may be truncated.
	// +optional
	Warnings []string `protobuf:"bytes,3,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// Mutated object bytes
	ObjectBytes []byte `protobuf:"bytes,4,opt,name=object_bytes,json=objectBytes,proto3" json:"object_bytes,omitempty"`
	// contains filtered or unexported fields
}

Return a mutated copy of the object in a form that can be admitted

func (*MutationResponse) Descriptor deprecated added in v0.232.0 

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

Deprecated: Use MutationResponse.ProtoReflect.Descriptor instead.

func (*MutationResponse) GetAllowed added in v0.232.0 

func (x *MutationResponse) GetAllowed() bool

func (*MutationResponse) GetObjectBytes added in v0.232.0 

func (x *MutationResponse) GetObjectBytes() []byte

func (*MutationResponse) GetResult added in v0.232.0 

func (x *MutationResponse) GetResult() *StatusResult

func (*MutationResponse) GetWarnings added in v0.232.0 

func (x *MutationResponse) GetWarnings() []string

func (*MutationResponse) ProtoMessage added in v0.232.0 

func (*MutationResponse) ProtoMessage()

func (*MutationResponse) ProtoReflect added in v0.232.0 

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

func (*MutationResponse) Reset added in v0.232.0 

func (x *MutationResponse) Reset()

func (*MutationResponse) String added in v0.232.0 

func (x *MutationResponse) String() string

type PluginContext added in v0.54.0 

type PluginContext struct {

	// The Grafana organization id the request originates from.
	OrgId int64 `protobuf:"varint,1,opt,name=orgId,proto3" json:"orgId,omitempty"`
	// The unique identifier of the plugin the request is targeted for.
	PluginId string `protobuf:"bytes,2,opt,name=pluginId,proto3" json:"pluginId,omitempty"`
	// The Grafana user the request originates from.
	//
	// Will not be provided if Grafana backend initiated the request.
	User *User `protobuf:"bytes,3,opt,name=user,proto3" json:"user,omitempty"`
	// App plugin instance settings is the configured app instance settings.
	// In Grafana an app instance is an enabled app plugin in a
	// Grafana organization.
	//
	// Will only be set if request targeting an app instance.
	AppInstanceSettings *AppInstanceSettings `protobuf:"bytes,4,opt,name=appInstanceSettings,proto3" json:"appInstanceSettings,omitempty"`
	// Data source instance settings is the configured data source instance
	// settings. In Grafana a data source instance is a created data source
	// in a Grafana organization.
	//
	// Will only be set if request targeting a data source instance.
	DataSourceInstanceSettings *DataSourceInstanceSettings `protobuf:"bytes,5,opt,name=dataSourceInstanceSettings,proto3" json:"dataSourceInstanceSettings,omitempty"`
	// The grafana configuration as a map of key/value pairs.
	GrafanaConfig map[string]string `` /* 167-byte string literal not displayed */
	// The version of the plugin the request is targeted for.
	PluginVersion string `protobuf:"bytes,7,opt,name=pluginVersion,proto3" json:"pluginVersion,omitempty"`
	// The user agent of the Grafana server that initiated the gRPC request.
	UserAgent string `protobuf:"bytes,8,opt,name=userAgent,proto3" json:"userAgent,omitempty"`
	// The API version that initiated a request
	ApiVersion string `protobuf:"bytes,9,opt,name=apiVersion,proto3" json:"apiVersion,omitempty"`
	// contains filtered or unexported fields
}

func (*PluginContext) Descriptor deprecated added in v0.54.0 

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

Deprecated: Use PluginContext.ProtoReflect.Descriptor instead.

func (*PluginContext) GetApiVersion added in v0.230.0 

func (x *PluginContext) GetApiVersion() string

func (*PluginContext) GetAppInstanceSettings added in v0.54.0 

func (x *PluginContext) GetAppInstanceSettings() *AppInstanceSettings

func (*PluginContext) GetDataSourceInstanceSettings added in v0.54.0 

func (x *PluginContext) GetDataSourceInstanceSettings() *DataSourceInstanceSettings

func (*PluginContext) GetGrafanaConfig added in v0.177.0 

func (x *PluginContext) GetGrafanaConfig() map[string]string

func (*PluginContext) GetOrgId added in v0.54.0 

func (x *PluginContext) GetOrgId() int64

func (*PluginContext) GetPluginId added in v0.54.0 

func (x *PluginContext) GetPluginId() string

func (*PluginContext) GetPluginVersion added in v0.177.0 

func (x *PluginContext) GetPluginVersion() string

func (*PluginContext) GetUser added in v0.54.0 

func (x *PluginContext) GetUser() *User

func (*PluginContext) GetUserAgent added in v0.177.0 

func (x *PluginContext) GetUserAgent() string

func (*PluginContext) ProtoMessage added in v0.54.0 

func (*PluginContext) ProtoMessage()

func (*PluginContext) ProtoReflect added in v0.87.0 

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

func (*PluginContext) Reset added in v0.54.0 

func (x *PluginContext) Reset()

func (*PluginContext) String added in v0.54.0 

func (x *PluginContext) String() string

type PublishStreamRequest added in v0.91.0 

type PublishStreamRequest struct {
	PluginContext *PluginContext `protobuf:"bytes,1,opt,name=pluginContext,proto3" json:"pluginContext,omitempty"`
	// path part of a channel.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// data that user wants to publish into a stream
	// (only JSON-encoded at the moment).
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishStreamRequest) Descriptor deprecated added in v0.91.0 

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

Deprecated: Use PublishStreamRequest.ProtoReflect.Descriptor instead.

func (*PublishStreamRequest) GetData added in v0.91.0 

func (x *PublishStreamRequest) GetData() []byte

func (*PublishStreamRequest) GetPath added in v0.91.0 

func (x *PublishStreamRequest) GetPath() string

func (*PublishStreamRequest) GetPluginContext added in v0.91.0 

func (x *PublishStreamRequest) GetPluginContext() *PluginContext

func (*PublishStreamRequest) ProtoMessage added in v0.91.0 

func (*PublishStreamRequest) ProtoMessage()

func (*PublishStreamRequest) ProtoReflect added in v0.91.0 

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

func (*PublishStreamRequest) Reset added in v0.91.0 

func (x *PublishStreamRequest) Reset()

func (*PublishStreamRequest) String added in v0.91.0 

func (x *PublishStreamRequest) String() string

type PublishStreamResponse added in v0.91.0 

type PublishStreamResponse struct {

	// status of publish response.
	Status PublishStreamResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=pluginv2.PublishStreamResponse_Status" json:"status,omitempty"`
	// JSON-encoded data to publish into a channel. This can be
	// unmodified data from a PublishRequest or any modified data.
	// If empty data returned here then Grafana won't publish data
	// to a channel itself but will return a successful result to a
	// client (supposing plugin published data to a channel itself).
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishStreamResponse) Descriptor deprecated added in v0.91.0 

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

Deprecated: Use PublishStreamResponse.ProtoReflect.Descriptor instead.

func (*PublishStreamResponse) GetData added in v0.91.0 

func (x *PublishStreamResponse) GetData() []byte

func (*PublishStreamResponse) GetStatus added in v0.91.0 

func (x *PublishStreamResponse) GetStatus() PublishStreamResponse_Status

func (*PublishStreamResponse) ProtoMessage added in v0.91.0 

func (*PublishStreamResponse) ProtoMessage()

func (*PublishStreamResponse) ProtoReflect added in v0.91.0 

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

func (*PublishStreamResponse) Reset added in v0.91.0 

func (x *PublishStreamResponse) Reset()

func (*PublishStreamResponse) String added in v0.91.0 

func (x *PublishStreamResponse) String() string

type PublishStreamResponse_Status added in v0.91.0 

type PublishStreamResponse_Status int32
const (
	PublishStreamResponse_OK                PublishStreamResponse_Status = 0
	PublishStreamResponse_NOT_FOUND         PublishStreamResponse_Status = 1
	PublishStreamResponse_PERMISSION_DENIED PublishStreamResponse_Status = 2
)

func (PublishStreamResponse_Status) Descriptor added in v0.91.0 

func (PublishStreamResponse_Status) Descriptor() protoreflect.EnumDescriptor

func (PublishStreamResponse_Status) Enum added in v0.91.0 

func (x PublishStreamResponse_Status) Enum() *PublishStreamResponse_Status

func (PublishStreamResponse_Status) EnumDescriptor deprecated added in v0.91.0 

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

Deprecated: Use PublishStreamResponse_Status.Descriptor instead.

func (PublishStreamResponse_Status) Number added in v0.91.0 

func (x PublishStreamResponse_Status) Number() protoreflect.EnumNumber

func (PublishStreamResponse_Status) String added in v0.91.0 

func (x PublishStreamResponse_Status) String() string

func (PublishStreamResponse_Status) Type added in v0.91.0 

func (PublishStreamResponse_Status) Type() protoreflect.EnumType

type QueryDataRequest 

type QueryDataRequest struct {
	PluginContext *PluginContext `protobuf:"bytes,1,opt,name=pluginContext,proto3" json:"pluginContext,omitempty"`
	// Environment info
	Headers map[string]string `` /* 155-byte string literal not displayed */
	// List of data queries
	Queries []*DataQuery `protobuf:"bytes,3,rep,name=queries,proto3" json:"queries,omitempty"`
	// contains filtered or unexported fields
}

QueryDataRequest

func (*QueryDataRequest) Descriptor deprecated 

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

Deprecated: Use QueryDataRequest.ProtoReflect.Descriptor instead.

func (*QueryDataRequest) GetHeaders 

func (x *QueryDataRequest) GetHeaders() map[string]string

func (*QueryDataRequest) GetPluginContext added in v0.54.0 

func (x *QueryDataRequest) GetPluginContext() *PluginContext

func (*QueryDataRequest) GetQueries 

func (x *QueryDataRequest) GetQueries() []*DataQuery

func (*QueryDataRequest) ProtoMessage 

func (*QueryDataRequest) ProtoMessage()

func (*QueryDataRequest) ProtoReflect added in v0.87.0 

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

func (*QueryDataRequest) Reset 

func (x *QueryDataRequest) Reset()

func (*QueryDataRequest) String 

func (x *QueryDataRequest) String() string

type QueryDataResponse 

type QueryDataResponse struct {

	// Map of refId to response
	Responses map[string]*DataResponse `` /* 159-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*QueryDataResponse) Descriptor deprecated 

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

Deprecated: Use QueryDataResponse.ProtoReflect.Descriptor instead.

func (*QueryDataResponse) GetResponses added in v0.35.0 

func (x *QueryDataResponse) GetResponses() map[string]*DataResponse

func (*QueryDataResponse) ProtoMessage 

func (*QueryDataResponse) ProtoMessage()

func (*QueryDataResponse) ProtoReflect added in v0.87.0 

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

func (*QueryDataResponse) Reset 

func (x *QueryDataResponse) Reset()

func (*QueryDataResponse) String 

func (x *QueryDataResponse) String() string

type RawObject added in v0.243.0 

type RawObject struct {

	// Raw is the serialized object
	Raw []byte `protobuf:"bytes,1,opt,name=raw,proto3" json:"raw,omitempty"`
	// ContentType is the media type of the raw object
	ContentType string `protobuf:"bytes,2,opt,name=content_type,json=contentType,proto3" json:"content_type,omitempty"`
	// contains filtered or unexported fields
}

RawObject contains a resource serialized into a byte array with a content type

func (*RawObject) Descriptor deprecated added in v0.243.0 

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

Deprecated: Use RawObject.ProtoReflect.Descriptor instead.

func (*RawObject) GetContentType added in v0.243.0 

func (x *RawObject) GetContentType() string

func (*RawObject) GetRaw added in v0.243.0 

func (x *RawObject) GetRaw() []byte

func (*RawObject) ProtoMessage added in v0.243.0 

func (*RawObject) ProtoMessage()

func (*RawObject) ProtoReflect added in v0.243.0 

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

func (*RawObject) Reset added in v0.243.0 

func (x *RawObject) Reset()

func (*RawObject) String added in v0.243.0 

func (x *RawObject) String() string

type ResourceClient 

type ResourceClient interface {
	CallResource(ctx context.Context, in *CallResourceRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[CallResourceResponse], error)
}

ResourceClient is the client API for Resource 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 NewResourceClient 

func NewResourceClient(cc grpc.ClientConnInterface) ResourceClient

type ResourceConversionClient added in v0.243.0 

type ResourceConversionClient interface {
	// Convert objects to a target version
	ConvertObjects(ctx context.Context, in *ConversionRequest, opts ...grpc.CallOption) (*ConversionResponse, error)
}

ResourceConversionClient is the client API for ResourceConversion 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.

ResourceConversion is a service that can be used to convert resources between versions See: https://kubernetes.io/docs/tasks/extend-kubernetes/custom-resources/custom-resource-definition-versioning/#webhook-request-and-response

func NewResourceConversionClient added in v0.243.0 

func NewResourceConversionClient(cc grpc.ClientConnInterface) ResourceConversionClient

type ResourceConversionServer added in v0.243.0 

type ResourceConversionServer interface {
	// Convert objects to a target version
	ConvertObjects(context.Context, *ConversionRequest) (*ConversionResponse, error)
}

ResourceConversionServer is the server API for ResourceConversion service. All implementations should embed UnimplementedResourceConversionServer for forward compatibility.

ResourceConversion is a service that can be used to convert resources between versions See: https://kubernetes.io/docs/tasks/extend-kubernetes/custom-resources/custom-resource-definition-versioning/#webhook-request-and-response

type ResourceServer 

type ResourceServer interface {
	CallResource(*CallResourceRequest, grpc.ServerStreamingServer[CallResourceResponse]) error
}

ResourceServer is the server API for Resource service. All implementations should embed UnimplementedResourceServer for forward compatibility.

type Resource_CallResourceClient 

type Resource_CallResourceClient = grpc.ServerStreamingClient[CallResourceResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Resource_CallResourceServer 

type Resource_CallResourceServer = grpc.ServerStreamingServer[CallResourceResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type RunStreamRequest added in v0.89.0 

type RunStreamRequest struct {
	PluginContext *PluginContext `protobuf:"bytes,1,opt,name=pluginContext,proto3" json:"pluginContext,omitempty"`
	// path part of a channel.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// optional raw data. May be used as an extra payload supplied upon subscription.
	// For example, can contain JSON query object.
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*RunStreamRequest) Descriptor deprecated added in v0.89.0 

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

Deprecated: Use RunStreamRequest.ProtoReflect.Descriptor instead.

func (*RunStreamRequest) GetData added in v0.121.0 

func (x *RunStreamRequest) GetData() []byte

func (*RunStreamRequest) GetPath added in v0.89.0 

func (x *RunStreamRequest) GetPath() string

func (*RunStreamRequest) GetPluginContext added in v0.89.0 

func (x *RunStreamRequest) GetPluginContext() *PluginContext

func (*RunStreamRequest) ProtoMessage added in v0.89.0 

func (*RunStreamRequest) ProtoMessage()

func (*RunStreamRequest) ProtoReflect added in v0.89.0 

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

func (*RunStreamRequest) Reset added in v0.89.0 

func (x *RunStreamRequest) Reset()

func (*RunStreamRequest) String added in v0.89.0 

func (x *RunStreamRequest) String() string

type StatusResult added in v0.232.0 

type StatusResult struct {

	// Status of the operation.
	// One of: "Success" or "Failure".
	// More info: https://git.k8s.io/community/contributors/devel/sig-architecture/api-conventions.md#spec-and-status
	// +optional
	Status string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// A human-readable description of the status of this operation.
	// +optional
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	// A machine-readable description of why this operation is in the
	// "Failure" status. If this value is empty there
	// is no information available. A Reason clarifies an HTTP status
	// code but does not override it.
	// +optional
	Reason string `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	// Suggested HTTP return code for this status, 0 if not set.
	// +optional
	Code int32 `protobuf:"varint,4,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

Status structure is copied from: https://github.com/kubernetes/apimachinery/blob/v0.30.1/pkg/apis/meta/v1/generated.proto#L979

func (*StatusResult) Descriptor deprecated added in v0.232.0 

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

Deprecated: Use StatusResult.ProtoReflect.Descriptor instead.

func (*StatusResult) GetCode added in v0.232.0 

func (x *StatusResult) GetCode() int32

func (*StatusResult) GetMessage added in v0.232.0 

func (x *StatusResult) GetMessage() string

func (*StatusResult) GetReason added in v0.232.0 

func (x *StatusResult) GetReason() string

func (*StatusResult) GetStatus added in v0.232.0 

func (x *StatusResult) GetStatus() string

func (*StatusResult) ProtoMessage added in v0.232.0 

func (*StatusResult) ProtoMessage()

func (*StatusResult) ProtoReflect added in v0.232.0 

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

func (*StatusResult) Reset added in v0.232.0 

func (x *StatusResult) Reset()

func (*StatusResult) String added in v0.232.0 

func (x *StatusResult) String() string

type StreamClient added in v0.89.0 

type StreamClient interface {
	// SubscribeStream called when a user tries to subscribe to a plugin/datasource
	// managed channel path – thus plugin can check subscribe permissions and communicate
	// options with Grafana Core. When the first subscriber joins a channel, RunStream
	// will be called.
	SubscribeStream(ctx context.Context, in *SubscribeStreamRequest, opts ...grpc.CallOption) (*SubscribeStreamResponse, error)
	// RunStream will be initiated by Grafana to consume a stream. RunStream will be
	// called once for the first client successfully subscribed to a channel path.
	// When Grafana detects that there are no longer any subscribers inside a channel,
	// the call will be terminated until next active subscriber appears. Call termination
	// can happen with a delay.
	RunStream(ctx context.Context, in *RunStreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[StreamPacket], error)
	// PublishStream called when a user tries to publish to a plugin/datasource
	// managed channel path. Here plugin can check publish permissions and
	// modify publication data if required.
	PublishStream(ctx context.Context, in *PublishStreamRequest, opts ...grpc.CallOption) (*PublishStreamResponse, error)
}

StreamClient is the client API for Stream 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 NewStreamClient added in v0.89.0 

func NewStreamClient(cc grpc.ClientConnInterface) StreamClient

type StreamPacket added in v0.89.0 

type StreamPacket struct {

	// JSON-encoded data to publish into a channel.
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*StreamPacket) Descriptor deprecated added in v0.89.0 

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

Deprecated: Use StreamPacket.ProtoReflect.Descriptor instead.

func (*StreamPacket) GetData added in v0.91.0 

func (x *StreamPacket) GetData() []byte

func (*StreamPacket) ProtoMessage added in v0.89.0 

func (*StreamPacket) ProtoMessage()

func (*StreamPacket) ProtoReflect added in v0.89.0 

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

func (*StreamPacket) Reset added in v0.89.0 

func (x *StreamPacket) Reset()

func (*StreamPacket) String added in v0.89.0 

func (x *StreamPacket) String() string

type StreamServer added in v0.89.0 

type StreamServer interface {
	// SubscribeStream called when a user tries to subscribe to a plugin/datasource
	// managed channel path – thus plugin can check subscribe permissions and communicate
	// options with Grafana Core. When the first subscriber joins a channel, RunStream
	// will be called.
	SubscribeStream(context.Context, *SubscribeStreamRequest) (*SubscribeStreamResponse, error)
	// RunStream will be initiated by Grafana to consume a stream. RunStream will be
	// called once for the first client successfully subscribed to a channel path.
	// When Grafana detects that there are no longer any subscribers inside a channel,
	// the call will be terminated until next active subscriber appears. Call termination
	// can happen with a delay.
	RunStream(*RunStreamRequest, grpc.ServerStreamingServer[StreamPacket]) error
	// PublishStream called when a user tries to publish to a plugin/datasource
	// managed channel path. Here plugin can check publish permissions and
	// modify publication data if required.
	PublishStream(context.Context, *PublishStreamRequest) (*PublishStreamResponse, error)
}

StreamServer is the server API for Stream service. All implementations should embed UnimplementedStreamServer for forward compatibility.

type Stream_RunStreamClient added in v0.89.0 

type Stream_RunStreamClient = grpc.ServerStreamingClient[StreamPacket]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Stream_RunStreamServer added in v0.89.0 

type Stream_RunStreamServer = grpc.ServerStreamingServer[StreamPacket]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type StringList 

type StringList struct {
	Values []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

func (*StringList) Descriptor deprecated 

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

Deprecated: Use StringList.ProtoReflect.Descriptor instead.

func (*StringList) GetValues 

func (x *StringList) GetValues() []string

func (*StringList) ProtoMessage 

func (*StringList) ProtoMessage()

func (*StringList) ProtoReflect added in v0.87.0 

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

func (*StringList) Reset 

func (x *StringList) Reset()

func (*StringList) String 

func (x *StringList) String() string

type SubscribeStreamRequest added in v0.91.0 

type SubscribeStreamRequest struct {
	PluginContext *PluginContext `protobuf:"bytes,1,opt,name=pluginContext,proto3" json:"pluginContext,omitempty"`
	// path part of channel.
	Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	// optional raw data. May be used as an extra payload supplied upon subscription.
	// For example, can contain JSON query object.
	Data []byte `protobuf:"bytes,3,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeStreamRequest) Descriptor deprecated added in v0.91.0 

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

Deprecated: Use SubscribeStreamRequest.ProtoReflect.Descriptor instead.

func (*SubscribeStreamRequest) GetData added in v0.121.0 

func (x *SubscribeStreamRequest) GetData() []byte

func (*SubscribeStreamRequest) GetPath added in v0.91.0 

func (x *SubscribeStreamRequest) GetPath() string

func (*SubscribeStreamRequest) GetPluginContext added in v0.91.0 

func (x *SubscribeStreamRequest) GetPluginContext() *PluginContext

func (*SubscribeStreamRequest) ProtoMessage added in v0.91.0 

func (*SubscribeStreamRequest) ProtoMessage()

func (*SubscribeStreamRequest) ProtoReflect added in v0.91.0 

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

func (*SubscribeStreamRequest) Reset added in v0.91.0 

func (x *SubscribeStreamRequest) Reset()

func (*SubscribeStreamRequest) String added in v0.91.0 

func (x *SubscribeStreamRequest) String() string

type SubscribeStreamResponse added in v0.91.0 

type SubscribeStreamResponse struct {

	// status of subscribe response.
	Status SubscribeStreamResponse_Status `protobuf:"varint,1,opt,name=status,proto3,enum=pluginv2.SubscribeStreamResponse_Status" json:"status,omitempty"`
	// JSON-encoded data to return to a client in a successful
	// subscription result.
	// For data frame streams this can be a JSON-encoded frame schema.
	Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*SubscribeStreamResponse) Descriptor deprecated added in v0.91.0 

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

Deprecated: Use SubscribeStreamResponse.ProtoReflect.Descriptor instead.

func (*SubscribeStreamResponse) GetData added in v0.91.0 

func (x *SubscribeStreamResponse) GetData() []byte

func (*SubscribeStreamResponse) GetStatus added in v0.91.0 

func (x *SubscribeStreamResponse) GetStatus() SubscribeStreamResponse_Status

func (*SubscribeStreamResponse) ProtoMessage added in v0.91.0 

func (*SubscribeStreamResponse) ProtoMessage()

func (*SubscribeStreamResponse) ProtoReflect added in v0.91.0 

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

func (*SubscribeStreamResponse) Reset added in v0.91.0 

func (x *SubscribeStreamResponse) Reset()

func (*SubscribeStreamResponse) String added in v0.91.0 

func (x *SubscribeStreamResponse) String() string

type SubscribeStreamResponse_Status added in v0.91.0 

type SubscribeStreamResponse_Status int32
const (
	SubscribeStreamResponse_OK                SubscribeStreamResponse_Status = 0
	SubscribeStreamResponse_NOT_FOUND         SubscribeStreamResponse_Status = 1
	SubscribeStreamResponse_PERMISSION_DENIED SubscribeStreamResponse_Status = 2
)

func (SubscribeStreamResponse_Status) Descriptor added in v0.91.0 

func (SubscribeStreamResponse_Status) Descriptor() protoreflect.EnumDescriptor

func (SubscribeStreamResponse_Status) Enum added in v0.91.0 

func (x SubscribeStreamResponse_Status) Enum() *SubscribeStreamResponse_Status

func (SubscribeStreamResponse_Status) EnumDescriptor deprecated added in v0.91.0 

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

Deprecated: Use SubscribeStreamResponse_Status.Descriptor instead.

func (SubscribeStreamResponse_Status) Number added in v0.91.0 

func (x SubscribeStreamResponse_Status) Number() protoreflect.EnumNumber

func (SubscribeStreamResponse_Status) String added in v0.91.0 

func (x SubscribeStreamResponse_Status) String() string

func (SubscribeStreamResponse_Status) Type added in v0.91.0 

func (SubscribeStreamResponse_Status) Type() protoreflect.EnumType

type TimeRange 

type TimeRange struct {
	FromEpochMS int64 `protobuf:"varint,1,opt,name=fromEpochMS,proto3" json:"fromEpochMS,omitempty"`
	ToEpochMS   int64 `protobuf:"varint,2,opt,name=toEpochMS,proto3" json:"toEpochMS,omitempty"`
	// contains filtered or unexported fields
}

func (*TimeRange) Descriptor deprecated 

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

Deprecated: Use TimeRange.ProtoReflect.Descriptor instead.

func (*TimeRange) GetFromEpochMS 

func (x *TimeRange) GetFromEpochMS() int64

func (*TimeRange) GetToEpochMS 

func (x *TimeRange) GetToEpochMS() int64

func (*TimeRange) ProtoMessage 

func (*TimeRange) ProtoMessage()

func (*TimeRange) ProtoReflect added in v0.87.0 

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

func (*TimeRange) Reset 

func (x *TimeRange) Reset()

func (*TimeRange) String 

func (x *TimeRange) String() string

type UnimplementedAdmissionControlServer added in v0.232.0 

type UnimplementedAdmissionControlServer struct{}

UnimplementedAdmissionControlServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedAdmissionControlServer) MutateAdmission added in v0.232.0 

func (UnimplementedAdmissionControlServer) MutateAdmission(context.Context, *AdmissionRequest) (*MutationResponse, error)

func (UnimplementedAdmissionControlServer) ValidateAdmission added in v0.232.0 

func (UnimplementedAdmissionControlServer) ValidateAdmission(context.Context, *AdmissionRequest) (*ValidationResponse, error)

type UnimplementedDataServer 

type UnimplementedDataServer struct{}

UnimplementedDataServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedDataServer) QueryData 

func (UnimplementedDataServer) QueryData(context.Context, *QueryDataRequest) (*QueryDataResponse, error)

type UnimplementedDiagnosticsServer 

type UnimplementedDiagnosticsServer struct{}

UnimplementedDiagnosticsServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedDiagnosticsServer) CheckHealth 

func (UnimplementedDiagnosticsServer) CheckHealth(context.Context, *CheckHealthRequest) (*CheckHealthResponse, error)

func (UnimplementedDiagnosticsServer) CollectMetrics 

func (UnimplementedDiagnosticsServer) CollectMetrics(context.Context, *CollectMetricsRequest) (*CollectMetricsResponse, error)

type UnimplementedResourceConversionServer added in v0.243.0 

type UnimplementedResourceConversionServer struct{}

UnimplementedResourceConversionServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedResourceConversionServer) ConvertObjects added in v0.243.0 

func (UnimplementedResourceConversionServer) ConvertObjects(context.Context, *ConversionRequest) (*ConversionResponse, error)

type UnimplementedResourceServer 

type UnimplementedResourceServer struct{}

UnimplementedResourceServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedResourceServer) CallResource 

func (UnimplementedResourceServer) CallResource(*CallResourceRequest, grpc.ServerStreamingServer[CallResourceResponse]) error

type UnimplementedStreamServer added in v0.89.0 

type UnimplementedStreamServer struct{}

UnimplementedStreamServer should be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedStreamServer) PublishStream added in v0.91.0 

func (UnimplementedStreamServer) PublishStream(context.Context, *PublishStreamRequest) (*PublishStreamResponse, error)

func (UnimplementedStreamServer) RunStream added in v0.89.0 

func (UnimplementedStreamServer) RunStream(*RunStreamRequest, grpc.ServerStreamingServer[StreamPacket]) error

func (UnimplementedStreamServer) SubscribeStream added in v0.91.0 

func (UnimplementedStreamServer) SubscribeStream(context.Context, *SubscribeStreamRequest) (*SubscribeStreamResponse, error)

type UnsafeAdmissionControlServer added in v0.232.0 

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

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

type UnsafeDataServer added in v0.87.0 

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

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

type UnsafeDiagnosticsServer added in v0.87.0 

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

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

type UnsafeResourceConversionServer added in v0.243.0 

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

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

type UnsafeResourceServer added in v0.87.0 

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

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

type UnsafeStreamServer added in v0.89.0 

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

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

type User 

type User struct {
	Login string `protobuf:"bytes,1,opt,name=login,proto3" json:"login,omitempty"`
	Name  string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Email string `protobuf:"bytes,3,opt,name=email,proto3" json:"email,omitempty"`
	Role  string `protobuf:"bytes,4,opt,name=role,proto3" json:"role,omitempty"`
	// contains filtered or unexported fields
}

func (*User) Descriptor deprecated 

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

Deprecated: Use User.ProtoReflect.Descriptor instead.

func (*User) GetEmail 

func (x *User) GetEmail() string

func (*User) GetLogin 

func (x *User) GetLogin() string

func (*User) GetName 

func (x *User) GetName() string

func (*User) GetRole 

func (x *User) GetRole() string

func (*User) ProtoMessage 

func (*User) ProtoMessage()

func (*User) ProtoReflect added in v0.87.0 

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

func (*User) Reset 

func (x *User) Reset()

func (*User) String 

func (x *User) String() string

type ValidationResponse added in v0.232.0 

type ValidationResponse struct {

	// Allowed indicates whether or not the admission request was permitted.
	Allowed bool `protobuf:"varint,1,opt,name=allowed,proto3" json:"allowed,omitempty"`
	// Result contains extra details into why an admission request was denied.
	// This field IS NOT consulted in any way if "Allowed" is "true".
	// +optional
	Result *StatusResult `protobuf:"bytes,2,opt,name=result,proto3" json:"result,omitempty"`
	// warnings is a list of warning messages to return to the requesting API client.
	// Warning messages describe a problem the client making the API request should correct or be aware of.
	// Limit warnings to 120 characters if possible.
	// Warnings over 256 characters and large numbers of warnings may be truncated.
	// +optional
	Warnings []string `protobuf:"bytes,3,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// contains filtered or unexported fields
}

Check if an object can be admitted

func (*ValidationResponse) Descriptor deprecated added in v0.232.0 

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

Deprecated: Use ValidationResponse.ProtoReflect.Descriptor instead.

func (*ValidationResponse) GetAllowed added in v0.232.0 

func (x *ValidationResponse) GetAllowed() bool

func (*ValidationResponse) GetResult added in v0.232.0 

func (x *ValidationResponse) GetResult() *StatusResult

func (*ValidationResponse) GetWarnings added in v0.232.0 

func (x *ValidationResponse) GetWarnings() []string

func (*ValidationResponse) ProtoMessage added in v0.232.0 

func (*ValidationResponse) ProtoMessage()

func (*ValidationResponse) ProtoReflect added in v0.232.0 

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

func (*ValidationResponse) Reset added in v0.232.0 

func (x *ValidationResponse) Reset()

func (*ValidationResponse) String added in v0.232.0 

func (x *ValidationResponse) String() string

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.