Versions in this module Expand all Collapse all v0 v0.179.0 Sep 14, 2023 Changes in this version + var CheckHealthResponse_HealthStatus_name = map[int32]string + var CheckHealthResponse_HealthStatus_value = map[string]int32 + var Data_ServiceDesc = grpc.ServiceDesc + var Diagnostics_ServiceDesc = grpc.ServiceDesc + var File_backend_proto protoreflect.FileDescriptor + var PublishStreamResponse_Status_name = map[int32]string + var PublishStreamResponse_Status_value = map[string]int32 + var Resource_ServiceDesc = grpc.ServiceDesc + var Stream_ServiceDesc = grpc.ServiceDesc + var SubscribeStreamResponse_Status_name = map[int32]string + var SubscribeStreamResponse_Status_value = map[string]int32 + 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 AppInstanceSettings struct + DecryptedSecureJsonData map[string]string + JsonData []byte + LastUpdatedMS int64 + func (*AppInstanceSettings) Descriptor() ([]byte, []int) + func (*AppInstanceSettings) ProtoMessage() + func (x *AppInstanceSettings) GetDecryptedSecureJsonData() map[string]string + func (x *AppInstanceSettings) GetJsonData() []byte + func (x *AppInstanceSettings) GetLastUpdatedMS() int64 + func (x *AppInstanceSettings) ProtoReflect() protoreflect.Message + func (x *AppInstanceSettings) Reset() + func (x *AppInstanceSettings) String() string + type CallResourceRequest struct + Body []byte + Headers map[string]*StringList + Method string + Path string + PluginContext *PluginContext + Url string + func (*CallResourceRequest) Descriptor() ([]byte, []int) + func (*CallResourceRequest) ProtoMessage() + 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 (x *CallResourceRequest) ProtoReflect() protoreflect.Message + func (x *CallResourceRequest) Reset() + func (x *CallResourceRequest) String() string + type CallResourceResponse struct + Body []byte + Code int32 + Headers map[string]*StringList + func (*CallResourceResponse) Descriptor() ([]byte, []int) + func (*CallResourceResponse) ProtoMessage() + func (x *CallResourceResponse) GetBody() []byte + func (x *CallResourceResponse) GetCode() int32 + func (x *CallResourceResponse) GetHeaders() map[string]*StringList + func (x *CallResourceResponse) ProtoReflect() protoreflect.Message + func (x *CallResourceResponse) Reset() + func (x *CallResourceResponse) String() string + type CheckHealthRequest struct + Headers map[string]string + PluginContext *PluginContext + func (*CheckHealthRequest) Descriptor() ([]byte, []int) + func (*CheckHealthRequest) ProtoMessage() + func (x *CheckHealthRequest) GetHeaders() map[string]string + func (x *CheckHealthRequest) GetPluginContext() *PluginContext + func (x *CheckHealthRequest) ProtoReflect() protoreflect.Message + func (x *CheckHealthRequest) Reset() + func (x *CheckHealthRequest) String() string + type CheckHealthResponse struct + JsonDetails []byte + Message string + Status CheckHealthResponse_HealthStatus + func (*CheckHealthResponse) Descriptor() ([]byte, []int) + func (*CheckHealthResponse) ProtoMessage() + func (x *CheckHealthResponse) GetJsonDetails() []byte + func (x *CheckHealthResponse) GetMessage() string + func (x *CheckHealthResponse) GetStatus() CheckHealthResponse_HealthStatus + func (x *CheckHealthResponse) ProtoReflect() protoreflect.Message + func (x *CheckHealthResponse) Reset() + func (x *CheckHealthResponse) String() string + type CheckHealthResponse_HealthStatus int32 + const CheckHealthResponse_ERROR + const CheckHealthResponse_OK + const CheckHealthResponse_UNKNOWN + func (CheckHealthResponse_HealthStatus) Descriptor() protoreflect.EnumDescriptor + func (CheckHealthResponse_HealthStatus) EnumDescriptor() ([]byte, []int) + func (CheckHealthResponse_HealthStatus) Type() protoreflect.EnumType + func (x CheckHealthResponse_HealthStatus) Enum() *CheckHealthResponse_HealthStatus + func (x CheckHealthResponse_HealthStatus) Number() protoreflect.EnumNumber + func (x CheckHealthResponse_HealthStatus) String() string + type CollectMetricsRequest struct + PluginContext *PluginContext + func (*CollectMetricsRequest) Descriptor() ([]byte, []int) + func (*CollectMetricsRequest) ProtoMessage() + func (x *CollectMetricsRequest) GetPluginContext() *PluginContext + func (x *CollectMetricsRequest) ProtoReflect() protoreflect.Message + func (x *CollectMetricsRequest) Reset() + func (x *CollectMetricsRequest) String() string + type CollectMetricsResponse struct + Metrics *CollectMetricsResponse_Payload + func (*CollectMetricsResponse) Descriptor() ([]byte, []int) + func (*CollectMetricsResponse) ProtoMessage() + func (x *CollectMetricsResponse) GetMetrics() *CollectMetricsResponse_Payload + func (x *CollectMetricsResponse) ProtoReflect() protoreflect.Message + func (x *CollectMetricsResponse) Reset() + func (x *CollectMetricsResponse) String() string + type CollectMetricsResponse_Payload struct + Prometheus []byte + func (*CollectMetricsResponse_Payload) Descriptor() ([]byte, []int) + func (*CollectMetricsResponse_Payload) ProtoMessage() + func (x *CollectMetricsResponse_Payload) GetPrometheus() []byte + func (x *CollectMetricsResponse_Payload) ProtoReflect() protoreflect.Message + func (x *CollectMetricsResponse_Payload) Reset() + func (x *CollectMetricsResponse_Payload) String() string + type DataClient interface + QueryData func(ctx context.Context, in *QueryDataRequest, opts ...grpc.CallOption) (*QueryDataResponse, error) + func NewDataClient(cc grpc.ClientConnInterface) DataClient + type DataQuery struct + IntervalMS int64 + Json []byte + MaxDataPoints int64 + QueryType string + RefId string + TimeRange *TimeRange + func (*DataQuery) Descriptor() ([]byte, []int) + func (*DataQuery) ProtoMessage() + 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 (x *DataQuery) ProtoReflect() protoreflect.Message + func (x *DataQuery) Reset() + func (x *DataQuery) String() string + type DataResponse struct + Error string + Frames [][]byte + JsonMeta []byte + Status int32 + func (*DataResponse) Descriptor() ([]byte, []int) + func (*DataResponse) ProtoMessage() + func (x *DataResponse) GetError() string + func (x *DataResponse) GetFrames() [][]byte + func (x *DataResponse) GetJsonMeta() []byte + func (x *DataResponse) GetStatus() int32 + func (x *DataResponse) ProtoReflect() protoreflect.Message + func (x *DataResponse) Reset() + func (x *DataResponse) String() string + type DataServer interface + QueryData func(context.Context, *QueryDataRequest) (*QueryDataResponse, error) + type DataSourceInstanceSettings struct + BasicAuthEnabled bool + BasicAuthUser string + Database string + DecryptedSecureJsonData map[string]string + Id int64 + JsonData []byte + LastUpdatedMS int64 + Name string + Uid string + Url string + User string + func (*DataSourceInstanceSettings) Descriptor() ([]byte, []int) + func (*DataSourceInstanceSettings) ProtoMessage() + 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 (x *DataSourceInstanceSettings) ProtoReflect() protoreflect.Message + func (x *DataSourceInstanceSettings) Reset() + func (x *DataSourceInstanceSettings) String() string + type DiagnosticsClient interface + CheckHealth func(ctx context.Context, in *CheckHealthRequest, opts ...grpc.CallOption) (*CheckHealthResponse, error) + CollectMetrics func(ctx context.Context, in *CollectMetricsRequest, opts ...grpc.CallOption) (*CollectMetricsResponse, error) + func NewDiagnosticsClient(cc grpc.ClientConnInterface) DiagnosticsClient + type DiagnosticsServer interface + CheckHealth func(context.Context, *CheckHealthRequest) (*CheckHealthResponse, error) + CollectMetrics func(context.Context, *CollectMetricsRequest) (*CollectMetricsResponse, error) + type PluginContext struct + AppInstanceSettings *AppInstanceSettings + DataSourceInstanceSettings *DataSourceInstanceSettings + OrgId int64 + PluginId string + User *User + func (*PluginContext) Descriptor() ([]byte, []int) + func (*PluginContext) ProtoMessage() + func (x *PluginContext) GetAppInstanceSettings() *AppInstanceSettings + func (x *PluginContext) GetDataSourceInstanceSettings() *DataSourceInstanceSettings + func (x *PluginContext) GetOrgId() int64 + func (x *PluginContext) GetPluginId() string + func (x *PluginContext) GetUser() *User + func (x *PluginContext) ProtoReflect() protoreflect.Message + func (x *PluginContext) Reset() + func (x *PluginContext) String() string + type PublishStreamRequest struct + Data []byte + Path string + PluginContext *PluginContext + func (*PublishStreamRequest) Descriptor() ([]byte, []int) + func (*PublishStreamRequest) ProtoMessage() + func (x *PublishStreamRequest) GetData() []byte + func (x *PublishStreamRequest) GetPath() string + func (x *PublishStreamRequest) GetPluginContext() *PluginContext + func (x *PublishStreamRequest) ProtoReflect() protoreflect.Message + func (x *PublishStreamRequest) Reset() + func (x *PublishStreamRequest) String() string + type PublishStreamResponse struct + Data []byte + Status PublishStreamResponse_Status + func (*PublishStreamResponse) Descriptor() ([]byte, []int) + func (*PublishStreamResponse) ProtoMessage() + func (x *PublishStreamResponse) GetData() []byte + func (x *PublishStreamResponse) GetStatus() PublishStreamResponse_Status + func (x *PublishStreamResponse) ProtoReflect() protoreflect.Message + func (x *PublishStreamResponse) Reset() + func (x *PublishStreamResponse) String() string + type PublishStreamResponse_Status int32 + const PublishStreamResponse_NOT_FOUND + const PublishStreamResponse_OK + const PublishStreamResponse_PERMISSION_DENIED + func (PublishStreamResponse_Status) Descriptor() protoreflect.EnumDescriptor + func (PublishStreamResponse_Status) EnumDescriptor() ([]byte, []int) + func (PublishStreamResponse_Status) Type() protoreflect.EnumType + func (x PublishStreamResponse_Status) Enum() *PublishStreamResponse_Status + func (x PublishStreamResponse_Status) Number() protoreflect.EnumNumber + func (x PublishStreamResponse_Status) String() string + type QueryDataRequest struct + Headers map[string]string + PluginContext *PluginContext + Queries []*DataQuery + func (*QueryDataRequest) Descriptor() ([]byte, []int) + func (*QueryDataRequest) ProtoMessage() + func (x *QueryDataRequest) GetHeaders() map[string]string + func (x *QueryDataRequest) GetPluginContext() *PluginContext + func (x *QueryDataRequest) GetQueries() []*DataQuery + func (x *QueryDataRequest) ProtoReflect() protoreflect.Message + func (x *QueryDataRequest) Reset() + func (x *QueryDataRequest) String() string + type QueryDataResponse struct + Responses map[string]*DataResponse + func (*QueryDataResponse) Descriptor() ([]byte, []int) + func (*QueryDataResponse) ProtoMessage() + func (x *QueryDataResponse) GetResponses() map[string]*DataResponse + func (x *QueryDataResponse) ProtoReflect() protoreflect.Message + func (x *QueryDataResponse) Reset() + func (x *QueryDataResponse) String() string + type ResourceClient interface + CallResource func(ctx context.Context, in *CallResourceRequest, opts ...grpc.CallOption) (Resource_CallResourceClient, error) + func NewResourceClient(cc grpc.ClientConnInterface) ResourceClient + type ResourceServer interface + CallResource func(*CallResourceRequest, Resource_CallResourceServer) error + type Resource_CallResourceClient interface + Recv func() (*CallResourceResponse, error) + type Resource_CallResourceServer interface + Send func(*CallResourceResponse) error + type RunStreamRequest struct + Data []byte + Path string + PluginContext *PluginContext + func (*RunStreamRequest) Descriptor() ([]byte, []int) + func (*RunStreamRequest) ProtoMessage() + func (x *RunStreamRequest) GetData() []byte + func (x *RunStreamRequest) GetPath() string + func (x *RunStreamRequest) GetPluginContext() *PluginContext + func (x *RunStreamRequest) ProtoReflect() protoreflect.Message + func (x *RunStreamRequest) Reset() + func (x *RunStreamRequest) String() string + type StreamClient interface + PublishStream func(ctx context.Context, in *PublishStreamRequest, opts ...grpc.CallOption) (*PublishStreamResponse, error) + RunStream func(ctx context.Context, in *RunStreamRequest, opts ...grpc.CallOption) (Stream_RunStreamClient, error) + SubscribeStream func(ctx context.Context, in *SubscribeStreamRequest, opts ...grpc.CallOption) (*SubscribeStreamResponse, error) + func NewStreamClient(cc grpc.ClientConnInterface) StreamClient + type StreamPacket struct + Data []byte + func (*StreamPacket) Descriptor() ([]byte, []int) + func (*StreamPacket) ProtoMessage() + func (x *StreamPacket) GetData() []byte + func (x *StreamPacket) ProtoReflect() protoreflect.Message + func (x *StreamPacket) Reset() + func (x *StreamPacket) String() string + type StreamServer interface + PublishStream func(context.Context, *PublishStreamRequest) (*PublishStreamResponse, error) + RunStream func(*RunStreamRequest, Stream_RunStreamServer) error + SubscribeStream func(context.Context, *SubscribeStreamRequest) (*SubscribeStreamResponse, error) + type Stream_RunStreamClient interface + Recv func() (*StreamPacket, error) + type Stream_RunStreamServer interface + Send func(*StreamPacket) error + type StringList struct + Values []string + func (*StringList) Descriptor() ([]byte, []int) + func (*StringList) ProtoMessage() + func (x *StringList) GetValues() []string + func (x *StringList) ProtoReflect() protoreflect.Message + func (x *StringList) Reset() + func (x *StringList) String() string + type SubscribeStreamRequest struct + Data []byte + Path string + PluginContext *PluginContext + func (*SubscribeStreamRequest) Descriptor() ([]byte, []int) + func (*SubscribeStreamRequest) ProtoMessage() + func (x *SubscribeStreamRequest) GetData() []byte + func (x *SubscribeStreamRequest) GetPath() string + func (x *SubscribeStreamRequest) GetPluginContext() *PluginContext + func (x *SubscribeStreamRequest) ProtoReflect() protoreflect.Message + func (x *SubscribeStreamRequest) Reset() + func (x *SubscribeStreamRequest) String() string + type SubscribeStreamResponse struct + Data []byte + Status SubscribeStreamResponse_Status + func (*SubscribeStreamResponse) Descriptor() ([]byte, []int) + func (*SubscribeStreamResponse) ProtoMessage() + func (x *SubscribeStreamResponse) GetData() []byte + func (x *SubscribeStreamResponse) GetStatus() SubscribeStreamResponse_Status + func (x *SubscribeStreamResponse) ProtoReflect() protoreflect.Message + func (x *SubscribeStreamResponse) Reset() + func (x *SubscribeStreamResponse) String() string + type SubscribeStreamResponse_Status int32 + const SubscribeStreamResponse_NOT_FOUND + const SubscribeStreamResponse_OK + const SubscribeStreamResponse_PERMISSION_DENIED + func (SubscribeStreamResponse_Status) Descriptor() protoreflect.EnumDescriptor + func (SubscribeStreamResponse_Status) EnumDescriptor() ([]byte, []int) + func (SubscribeStreamResponse_Status) Type() protoreflect.EnumType + func (x SubscribeStreamResponse_Status) Enum() *SubscribeStreamResponse_Status + func (x SubscribeStreamResponse_Status) Number() protoreflect.EnumNumber + func (x SubscribeStreamResponse_Status) String() string + type TimeRange struct + FromEpochMS int64 + ToEpochMS int64 + func (*TimeRange) Descriptor() ([]byte, []int) + func (*TimeRange) ProtoMessage() + func (x *TimeRange) GetFromEpochMS() int64 + func (x *TimeRange) GetToEpochMS() int64 + func (x *TimeRange) ProtoReflect() protoreflect.Message + func (x *TimeRange) Reset() + func (x *TimeRange) String() string + type UnimplementedDataServer struct + func (UnimplementedDataServer) QueryData(context.Context, *QueryDataRequest) (*QueryDataResponse, error) + type UnimplementedDiagnosticsServer struct + func (UnimplementedDiagnosticsServer) CheckHealth(context.Context, *CheckHealthRequest) (*CheckHealthResponse, error) + func (UnimplementedDiagnosticsServer) CollectMetrics(context.Context, *CollectMetricsRequest) (*CollectMetricsResponse, error) + type UnimplementedResourceServer struct + func (UnimplementedResourceServer) CallResource(*CallResourceRequest, Resource_CallResourceServer) error + type UnimplementedStreamServer struct + func (UnimplementedStreamServer) PublishStream(context.Context, *PublishStreamRequest) (*PublishStreamResponse, error) + func (UnimplementedStreamServer) RunStream(*RunStreamRequest, Stream_RunStreamServer) error + func (UnimplementedStreamServer) SubscribeStream(context.Context, *SubscribeStreamRequest) (*SubscribeStreamResponse, error) + type UnsafeDataServer interface + type UnsafeDiagnosticsServer interface + type UnsafeResourceServer interface + type UnsafeStreamServer interface + type User struct + Email string + Login string + Name string + Role string + func (*User) Descriptor() ([]byte, []int) + func (*User) ProtoMessage() + func (x *User) GetEmail() string + func (x *User) GetLogin() string + func (x *User) GetName() string + func (x *User) GetRole() string + func (x *User) ProtoReflect() protoreflect.Message + func (x *User) Reset() + func (x *User) String() string
Go to main page