Documentation ¶
Overview ¶
Package pluginv2 includes code generated by protoc-gen-go. DO NOT EDIT.
Index ¶
- Constants
- Variables
- func RegisterAdmissionControlServer(s grpc.ServiceRegistrar, srv AdmissionControlServer)
- func RegisterDataServer(s grpc.ServiceRegistrar, srv DataServer)
- func RegisterDiagnosticsServer(s grpc.ServiceRegistrar, srv DiagnosticsServer)
- func RegisterResourceServer(s grpc.ServiceRegistrar, srv ResourceServer)
- func RegisterStreamServer(s grpc.ServiceRegistrar, srv StreamServer)
- type AdmissionControlClient
- type AdmissionControlServer
- type AdmissionRequest
- func (*AdmissionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AdmissionRequest) GetKind() *GroupVersionKind
- func (x *AdmissionRequest) GetObjectBytes() []byte
- func (x *AdmissionRequest) GetOldObjectBytes() []byte
- func (x *AdmissionRequest) GetOperation() AdmissionRequest_Operation
- func (x *AdmissionRequest) GetPluginContext() *PluginContext
- func (*AdmissionRequest) ProtoMessage()
- func (x *AdmissionRequest) ProtoReflect() protoreflect.Message
- func (x *AdmissionRequest) Reset()
- func (x *AdmissionRequest) String() string
- type AdmissionRequest_Operation
- func (AdmissionRequest_Operation) Descriptor() protoreflect.EnumDescriptor
- func (x AdmissionRequest_Operation) Enum() *AdmissionRequest_Operation
- func (AdmissionRequest_Operation) EnumDescriptor() ([]byte, []int)deprecated
- func (x AdmissionRequest_Operation) Number() protoreflect.EnumNumber
- func (x AdmissionRequest_Operation) String() string
- func (AdmissionRequest_Operation) Type() protoreflect.EnumType
- type AppInstanceSettings
- func (*AppInstanceSettings) Descriptor() ([]byte, []int)deprecated
- func (x *AppInstanceSettings) GetApiVersion() string
- func (x *AppInstanceSettings) GetDecryptedSecureJsonData() map[string]string
- func (x *AppInstanceSettings) GetJsonData() []byte
- func (x *AppInstanceSettings) GetLastUpdatedMS() int64
- func (*AppInstanceSettings) ProtoMessage()
- func (x *AppInstanceSettings) ProtoReflect() protoreflect.Message
- func (x *AppInstanceSettings) Reset()
- func (x *AppInstanceSettings) String() string
- type CallResourceRequest
- func (*CallResourceRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CallResourceRequest) GetBody() []byte
- func (x *CallResourceRequest) GetHeaders() map[string]*StringList
- func (x *CallResourceRequest) GetMethod() string
- func (x *CallResourceRequest) GetPath() string
- func (x *CallResourceRequest) GetPluginContext() *PluginContext
- func (x *CallResourceRequest) GetUrl() string
- func (*CallResourceRequest) ProtoMessage()
- func (x *CallResourceRequest) ProtoReflect() protoreflect.Message
- func (x *CallResourceRequest) Reset()
- func (x *CallResourceRequest) String() string
- type CallResourceResponse
- func (*CallResourceResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CallResourceResponse) GetBody() []byte
- func (x *CallResourceResponse) GetCode() int32
- func (x *CallResourceResponse) GetHeaders() map[string]*StringList
- func (*CallResourceResponse) ProtoMessage()
- func (x *CallResourceResponse) ProtoReflect() protoreflect.Message
- func (x *CallResourceResponse) Reset()
- func (x *CallResourceResponse) String() string
- type CheckHealthRequest
- func (*CheckHealthRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CheckHealthRequest) GetHeaders() map[string]string
- func (x *CheckHealthRequest) GetPluginContext() *PluginContext
- func (*CheckHealthRequest) ProtoMessage()
- func (x *CheckHealthRequest) ProtoReflect() protoreflect.Message
- func (x *CheckHealthRequest) Reset()
- func (x *CheckHealthRequest) String() string
- type CheckHealthResponse
- func (*CheckHealthResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CheckHealthResponse) GetJsonDetails() []byte
- func (x *CheckHealthResponse) GetMessage() string
- func (x *CheckHealthResponse) GetStatus() CheckHealthResponse_HealthStatus
- func (*CheckHealthResponse) ProtoMessage()
- func (x *CheckHealthResponse) ProtoReflect() protoreflect.Message
- func (x *CheckHealthResponse) Reset()
- func (x *CheckHealthResponse) String() string
- type CheckHealthResponse_HealthStatus
- func (CheckHealthResponse_HealthStatus) Descriptor() protoreflect.EnumDescriptor
- func (x CheckHealthResponse_HealthStatus) Enum() *CheckHealthResponse_HealthStatus
- func (CheckHealthResponse_HealthStatus) EnumDescriptor() ([]byte, []int)deprecated
- func (x CheckHealthResponse_HealthStatus) Number() protoreflect.EnumNumber
- func (x CheckHealthResponse_HealthStatus) String() string
- func (CheckHealthResponse_HealthStatus) Type() protoreflect.EnumType
- type CollectMetricsRequest
- func (*CollectMetricsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CollectMetricsRequest) GetPluginContext() *PluginContext
- func (*CollectMetricsRequest) ProtoMessage()
- func (x *CollectMetricsRequest) ProtoReflect() protoreflect.Message
- func (x *CollectMetricsRequest) Reset()
- func (x *CollectMetricsRequest) String() string
- type CollectMetricsResponse
- func (*CollectMetricsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *CollectMetricsResponse) GetMetrics() *CollectMetricsResponse_Payload
- func (*CollectMetricsResponse) ProtoMessage()
- func (x *CollectMetricsResponse) ProtoReflect() protoreflect.Message
- func (x *CollectMetricsResponse) Reset()
- func (x *CollectMetricsResponse) String() string
- type CollectMetricsResponse_Payload
- func (*CollectMetricsResponse_Payload) Descriptor() ([]byte, []int)deprecated
- func (x *CollectMetricsResponse_Payload) GetPrometheus() []byte
- func (*CollectMetricsResponse_Payload) ProtoMessage()
- func (x *CollectMetricsResponse_Payload) ProtoReflect() protoreflect.Message
- func (x *CollectMetricsResponse_Payload) Reset()
- func (x *CollectMetricsResponse_Payload) String() string
- type ConversionRequest
- func (*ConversionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ConversionRequest) GetKind() *GroupVersionKind
- func (x *ConversionRequest) GetObjectBytes() []byte
- func (x *ConversionRequest) GetPluginContext() *PluginContext
- func (x *ConversionRequest) GetTargetVersion() string
- func (*ConversionRequest) ProtoMessage()
- func (x *ConversionRequest) ProtoReflect() protoreflect.Message
- func (x *ConversionRequest) Reset()
- func (x *ConversionRequest) String() string
- type ConversionResponse
- func (*ConversionResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ConversionResponse) GetAllowed() bool
- func (x *ConversionResponse) GetObjectBytes() []byte
- func (x *ConversionResponse) GetResult() *StatusResult
- func (*ConversionResponse) ProtoMessage()
- func (x *ConversionResponse) ProtoReflect() protoreflect.Message
- func (x *ConversionResponse) Reset()
- func (x *ConversionResponse) String() string
- type DataClient
- type DataQuery
- func (*DataQuery) Descriptor() ([]byte, []int)deprecated
- func (x *DataQuery) GetIntervalMS() int64
- func (x *DataQuery) GetJson() []byte
- func (x *DataQuery) GetMaxDataPoints() int64
- func (x *DataQuery) GetQueryType() string
- func (x *DataQuery) GetRefId() string
- func (x *DataQuery) GetTimeRange() *TimeRange
- func (*DataQuery) ProtoMessage()
- func (x *DataQuery) ProtoReflect() protoreflect.Message
- func (x *DataQuery) Reset()
- func (x *DataQuery) String() string
- type DataResponse
- func (*DataResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DataResponse) GetError() string
- func (x *DataResponse) GetErrorSource() string
- func (x *DataResponse) GetFrames() [][]byte
- func (x *DataResponse) GetJsonMeta() []byte
- func (x *DataResponse) GetStatus() int32
- func (*DataResponse) ProtoMessage()
- func (x *DataResponse) ProtoReflect() protoreflect.Message
- func (x *DataResponse) Reset()
- func (x *DataResponse) String() string
- type DataServer
- type DataSourceInstanceSettings
- func (*DataSourceInstanceSettings) Descriptor() ([]byte, []int)deprecated
- func (x *DataSourceInstanceSettings) GetApiVersion() string
- func (x *DataSourceInstanceSettings) GetBasicAuthEnabled() bool
- func (x *DataSourceInstanceSettings) GetBasicAuthUser() string
- func (x *DataSourceInstanceSettings) GetDatabase() string
- func (x *DataSourceInstanceSettings) GetDecryptedSecureJsonData() map[string]string
- func (x *DataSourceInstanceSettings) GetId() int64
- func (x *DataSourceInstanceSettings) GetJsonData() []byte
- func (x *DataSourceInstanceSettings) GetLastUpdatedMS() int64
- func (x *DataSourceInstanceSettings) GetName() string
- func (x *DataSourceInstanceSettings) GetUid() string
- func (x *DataSourceInstanceSettings) GetUrl() string
- func (x *DataSourceInstanceSettings) GetUser() string
- func (*DataSourceInstanceSettings) ProtoMessage()
- func (x *DataSourceInstanceSettings) ProtoReflect() protoreflect.Message
- func (x *DataSourceInstanceSettings) Reset()
- func (x *DataSourceInstanceSettings) String() string
- type DiagnosticsClient
- type DiagnosticsServer
- type GroupVersionKind
- func (*GroupVersionKind) Descriptor() ([]byte, []int)deprecated
- func (x *GroupVersionKind) GetGroup() string
- func (x *GroupVersionKind) GetKind() string
- func (x *GroupVersionKind) GetVersion() string
- func (*GroupVersionKind) ProtoMessage()
- func (x *GroupVersionKind) ProtoReflect() protoreflect.Message
- func (x *GroupVersionKind) Reset()
- func (x *GroupVersionKind) String() string
- type MutationResponse
- func (*MutationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *MutationResponse) GetAllowed() bool
- func (x *MutationResponse) GetObjectBytes() []byte
- func (x *MutationResponse) GetResult() *StatusResult
- func (x *MutationResponse) GetWarnings() []string
- func (*MutationResponse) ProtoMessage()
- func (x *MutationResponse) ProtoReflect() protoreflect.Message
- func (x *MutationResponse) Reset()
- func (x *MutationResponse) String() string
- type PluginContext
- func (*PluginContext) Descriptor() ([]byte, []int)deprecated
- func (x *PluginContext) GetApiVersion() string
- func (x *PluginContext) GetAppInstanceSettings() *AppInstanceSettings
- func (x *PluginContext) GetDataSourceInstanceSettings() *DataSourceInstanceSettings
- func (x *PluginContext) GetGrafanaConfig() map[string]string
- func (x *PluginContext) GetOrgId() int64
- func (x *PluginContext) GetPluginId() string
- func (x *PluginContext) GetPluginVersion() string
- func (x *PluginContext) GetUser() *User
- func (x *PluginContext) GetUserAgent() string
- func (*PluginContext) ProtoMessage()
- func (x *PluginContext) ProtoReflect() protoreflect.Message
- func (x *PluginContext) Reset()
- func (x *PluginContext) String() string
- type PublishStreamRequest
- func (*PublishStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PublishStreamRequest) GetData() []byte
- func (x *PublishStreamRequest) GetPath() string
- func (x *PublishStreamRequest) GetPluginContext() *PluginContext
- func (*PublishStreamRequest) ProtoMessage()
- func (x *PublishStreamRequest) ProtoReflect() protoreflect.Message
- func (x *PublishStreamRequest) Reset()
- func (x *PublishStreamRequest) String() string
- type PublishStreamResponse
- func (*PublishStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PublishStreamResponse) GetData() []byte
- func (x *PublishStreamResponse) GetStatus() PublishStreamResponse_Status
- func (*PublishStreamResponse) ProtoMessage()
- func (x *PublishStreamResponse) ProtoReflect() protoreflect.Message
- func (x *PublishStreamResponse) Reset()
- func (x *PublishStreamResponse) String() string
- type PublishStreamResponse_Status
- func (PublishStreamResponse_Status) Descriptor() protoreflect.EnumDescriptor
- func (x PublishStreamResponse_Status) Enum() *PublishStreamResponse_Status
- func (PublishStreamResponse_Status) EnumDescriptor() ([]byte, []int)deprecated
- func (x PublishStreamResponse_Status) Number() protoreflect.EnumNumber
- func (x PublishStreamResponse_Status) String() string
- func (PublishStreamResponse_Status) Type() protoreflect.EnumType
- type QueryDataRequest
- func (*QueryDataRequest) Descriptor() ([]byte, []int)deprecated
- func (x *QueryDataRequest) GetHeaders() map[string]string
- func (x *QueryDataRequest) GetPluginContext() *PluginContext
- func (x *QueryDataRequest) GetQueries() []*DataQuery
- func (*QueryDataRequest) ProtoMessage()
- func (x *QueryDataRequest) ProtoReflect() protoreflect.Message
- func (x *QueryDataRequest) Reset()
- func (x *QueryDataRequest) String() string
- type QueryDataResponse
- func (*QueryDataResponse) Descriptor() ([]byte, []int)deprecated
- func (x *QueryDataResponse) GetResponses() map[string]*DataResponse
- func (*QueryDataResponse) ProtoMessage()
- func (x *QueryDataResponse) ProtoReflect() protoreflect.Message
- func (x *QueryDataResponse) Reset()
- func (x *QueryDataResponse) String() string
- type ResourceClient
- type ResourceServer
- type Resource_CallResourceClient
- type Resource_CallResourceServer
- type RunStreamRequest
- func (*RunStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RunStreamRequest) GetData() []byte
- func (x *RunStreamRequest) GetPath() string
- func (x *RunStreamRequest) GetPluginContext() *PluginContext
- func (*RunStreamRequest) ProtoMessage()
- func (x *RunStreamRequest) ProtoReflect() protoreflect.Message
- func (x *RunStreamRequest) Reset()
- func (x *RunStreamRequest) String() string
- type StatusResult
- func (*StatusResult) Descriptor() ([]byte, []int)deprecated
- func (x *StatusResult) GetCode() int32
- func (x *StatusResult) GetMessage() string
- func (x *StatusResult) GetReason() string
- func (x *StatusResult) GetStatus() string
- func (*StatusResult) ProtoMessage()
- func (x *StatusResult) ProtoReflect() protoreflect.Message
- func (x *StatusResult) Reset()
- func (x *StatusResult) String() string
- type StreamClient
- type StreamPacket
- type StreamServer
- type Stream_RunStreamClient
- type Stream_RunStreamServer
- type StringList
- type SubscribeStreamRequest
- func (*SubscribeStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeStreamRequest) GetData() []byte
- func (x *SubscribeStreamRequest) GetPath() string
- func (x *SubscribeStreamRequest) GetPluginContext() *PluginContext
- func (*SubscribeStreamRequest) ProtoMessage()
- func (x *SubscribeStreamRequest) ProtoReflect() protoreflect.Message
- func (x *SubscribeStreamRequest) Reset()
- func (x *SubscribeStreamRequest) String() string
- type SubscribeStreamResponse
- func (*SubscribeStreamResponse) Descriptor() ([]byte, []int)deprecated
- func (x *SubscribeStreamResponse) GetData() []byte
- func (x *SubscribeStreamResponse) GetStatus() SubscribeStreamResponse_Status
- func (*SubscribeStreamResponse) ProtoMessage()
- func (x *SubscribeStreamResponse) ProtoReflect() protoreflect.Message
- func (x *SubscribeStreamResponse) Reset()
- func (x *SubscribeStreamResponse) String() string
- type SubscribeStreamResponse_Status
- func (SubscribeStreamResponse_Status) Descriptor() protoreflect.EnumDescriptor
- func (x SubscribeStreamResponse_Status) Enum() *SubscribeStreamResponse_Status
- func (SubscribeStreamResponse_Status) EnumDescriptor() ([]byte, []int)deprecated
- func (x SubscribeStreamResponse_Status) Number() protoreflect.EnumNumber
- func (x SubscribeStreamResponse_Status) String() string
- func (SubscribeStreamResponse_Status) Type() protoreflect.EnumType
- type TimeRange
- type UnimplementedAdmissionControlServer
- func (UnimplementedAdmissionControlServer) ConvertObject(context.Context, *ConversionRequest) (*ConversionResponse, error)
- func (UnimplementedAdmissionControlServer) MutateAdmission(context.Context, *AdmissionRequest) (*MutationResponse, error)
- func (UnimplementedAdmissionControlServer) ValidateAdmission(context.Context, *AdmissionRequest) (*ValidationResponse, error)
- type UnimplementedDataServer
- type UnimplementedDiagnosticsServer
- type UnimplementedResourceServer
- type UnimplementedStreamServer
- func (UnimplementedStreamServer) PublishStream(context.Context, *PublishStreamRequest) (*PublishStreamResponse, error)
- func (UnimplementedStreamServer) RunStream(*RunStreamRequest, Stream_RunStreamServer) error
- func (UnimplementedStreamServer) SubscribeStream(context.Context, *SubscribeStreamRequest) (*SubscribeStreamResponse, error)
- type UnsafeAdmissionControlServer
- type UnsafeDataServer
- type UnsafeDiagnosticsServer
- type UnsafeResourceServer
- type UnsafeStreamServer
- type User
- func (*User) Descriptor() ([]byte, []int)deprecated
- func (x *User) GetEmail() string
- func (x *User) GetLogin() string
- func (x *User) GetName() string
- func (x *User) GetRole() string
- func (*User) ProtoMessage()
- func (x *User) ProtoReflect() protoreflect.Message
- func (x *User) Reset()
- func (x *User) String() string
- type ValidationResponse
- func (*ValidationResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ValidationResponse) GetAllowed() bool
- func (x *ValidationResponse) GetResult() *StatusResult
- func (x *ValidationResponse) GetWarnings() []string
- func (*ValidationResponse) ProtoMessage()
- func (x *ValidationResponse) ProtoReflect() protoreflect.Message
- func (x *ValidationResponse) Reset()
- func (x *ValidationResponse) String() string
Constants ¶
const ( Diagnostics_CheckHealth_FullMethodName = "/pluginv2.Diagnostics/CheckHealth" Diagnostics_CollectMetrics_FullMethodName = "/pluginv2.Diagnostics/CollectMetrics" )
const ( Stream_SubscribeStream_FullMethodName = "/pluginv2.Stream/SubscribeStream" Stream_RunStream_FullMethodName = "/pluginv2.Stream/RunStream" Stream_PublishStream_FullMethodName = "/pluginv2.Stream/PublishStream" )
const ( AdmissionControl_ValidateAdmission_FullMethodName = "/pluginv2.AdmissionControl/ValidateAdmission" AdmissionControl_MutateAdmission_FullMethodName = "/pluginv2.AdmissionControl/MutateAdmission" AdmissionControl_ConvertObject_FullMethodName = "/pluginv2.AdmissionControl/ConvertObject" )
const (
Data_QueryData_FullMethodName = "/pluginv2.Data/QueryData"
)
const (
Resource_CallResource_FullMethodName = "/pluginv2.Resource/CallResource"
)
Variables ¶
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.
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.
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.
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.
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, }, { MethodName: "ConvertObject", Handler: _AdmissionControl_ConvertObject_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)
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)
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)
var File_backend_proto protoreflect.FileDescriptor
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)
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 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) // Convert a resource to a new version ConvertObject(ctx context.Context, in *ConversionRequest, opts ...grpc.CallOption) (*ConversionResponse, 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.
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) // Convert a resource to a new version ConvertObject(context.Context, *ConversionRequest) (*ConversionResponse, error) }
AdmissionControlServer is the server API for AdmissionControl service. All implementations should embed UnimplementedAdmissionControlServer for forward compatibility
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"` // The object kind Kind *GroupVersionKind `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"` // Object is the object in the request. This includes the full metadata envelope. ObjectBytes []byte `protobuf:"bytes,3,opt,name=object_bytes,json=objectBytes,proto3" json:"object_bytes,omitempty"` // Target converted version TargetVersion string `protobuf:"bytes,4,opt,name=target_version,json=targetVersion,proto3" json:"target_version,omitempty"` // contains filtered or unexported fields }
ConversionRequest supports converting an object 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) GetKind ¶ added in v0.232.0
func (x *ConversionRequest) GetKind() *GroupVersionKind
func (*ConversionRequest) GetObjectBytes ¶ added in v0.232.0
func (x *ConversionRequest) GetObjectBytes() []byte
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() 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 { // 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"` // Converted object bytes ObjectBytes []byte `protobuf:"bytes,3,opt,name=object_bytes,json=objectBytes,proto3" json:"object_bytes,omitempty"` // contains filtered or unexported fields }
func (*ConversionResponse) Descriptor
deprecated
added in
v0.232.0
func (*ConversionResponse) Descriptor() ([]byte, []int)
Deprecated: Use ConversionResponse.ProtoReflect.Descriptor instead.
func (*ConversionResponse) GetAllowed ¶ added in v0.232.0
func (x *ConversionResponse) GetAllowed() bool
func (*ConversionResponse) GetObjectBytes ¶ added in v0.232.0
func (x *ConversionResponse) GetObjectBytes() []byte
func (*ConversionResponse) GetResult ¶ added in v0.232.0
func (x *ConversionResponse) GetResult() *StatusResult
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) GetIntervalMS ¶
func (*DataQuery) GetMaxDataPoints ¶
func (*DataQuery) GetQueryType ¶ added in v0.60.0
func (*DataQuery) GetTimeRange ¶
func (*DataQuery) ProtoMessage ¶
func (*DataQuery) ProtoMessage()
func (*DataQuery) ProtoReflect ¶ added in v0.87.0
func (x *DataQuery) ProtoReflect() protoreflect.Message
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 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 ResourceClient ¶
type ResourceClient interface {
CallResource(ctx context.Context, in *CallResourceRequest, opts ...grpc.CallOption) (Resource_CallResourceClient, 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 ResourceServer ¶
type ResourceServer interface {
CallResource(*CallResourceRequest, Resource_CallResourceServer) error
}
ResourceServer is the server API for Resource service. All implementations should embed UnimplementedResourceServer for forward compatibility
type Resource_CallResourceClient ¶
type Resource_CallResourceClient interface { Recv() (*CallResourceResponse, error) grpc.ClientStream }
type Resource_CallResourceServer ¶
type Resource_CallResourceServer interface { Send(*CallResourceResponse) error grpc.ServerStream }
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) (Stream_RunStreamClient, 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, Stream_RunStreamServer) 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 interface { Recv() (*StreamPacket, error) grpc.ClientStream }
type Stream_RunStreamServer ¶ added in v0.89.0
type Stream_RunStreamServer interface { Send(*StreamPacket) error grpc.ServerStream }
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) GetFromEpochMS ¶
func (*TimeRange) GetToEpochMS ¶
func (*TimeRange) ProtoMessage ¶
func (*TimeRange) ProtoMessage()
func (*TimeRange) ProtoReflect ¶ added in v0.87.0
func (x *TimeRange) ProtoReflect() protoreflect.Message
type UnimplementedAdmissionControlServer ¶ added in v0.232.0
type UnimplementedAdmissionControlServer struct { }
UnimplementedAdmissionControlServer should be embedded to have forward compatible implementations.
func (UnimplementedAdmissionControlServer) ConvertObject ¶ added in v0.232.0
func (UnimplementedAdmissionControlServer) ConvertObject(context.Context, *ConversionRequest) (*ConversionResponse, error)
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.
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.
func (UnimplementedDiagnosticsServer) CheckHealth ¶
func (UnimplementedDiagnosticsServer) CheckHealth(context.Context, *CheckHealthRequest) (*CheckHealthResponse, error)
func (UnimplementedDiagnosticsServer) CollectMetrics ¶
func (UnimplementedDiagnosticsServer) CollectMetrics(context.Context, *CollectMetricsRequest) (*CollectMetricsResponse, error)
type UnimplementedResourceServer ¶
type UnimplementedResourceServer struct { }
UnimplementedResourceServer should be embedded to have forward compatible implementations.
func (UnimplementedResourceServer) CallResource ¶
func (UnimplementedResourceServer) CallResource(*CallResourceRequest, Resource_CallResourceServer) error
type UnimplementedStreamServer ¶ added in v0.89.0
type UnimplementedStreamServer struct { }
UnimplementedStreamServer should be embedded to have forward compatible implementations.
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, Stream_RunStreamServer) 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 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) ProtoMessage ¶
func (*User) ProtoMessage()
func (*User) ProtoReflect ¶ added in v0.87.0
func (x *User) ProtoReflect() protoreflect.Message
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