pluginv2

package
v0.77.1 Latest Latest
Warning

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

 Go to latest Published: Oct 5, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

Functions

func RegisterDataServer 

func RegisterDataServer(s *grpc.Server, srv DataServer)

func RegisterDiagnosticsServer 

func RegisterDiagnosticsServer(s *grpc.Server, srv DiagnosticsServer)

func RegisterResourceServer 

func RegisterResourceServer(s *grpc.Server, srv ResourceServer)

func RegisterTransformDataCallBackServer 

func RegisterTransformDataCallBackServer(s *grpc.Server, srv TransformDataCallBackServer)

func RegisterTransformServer 

func RegisterTransformServer(s *grpc.Server, srv TransformServer)

Types

type AppInstanceSettings 

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"`
	XXX_NoUnkeyedLiteral    struct{}          `json:"-"`
	XXX_unrecognized        []byte            `json:"-"`
	XXX_sizecache           int32             `json:"-"`
}

func (*AppInstanceSettings) Descriptor 

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

func (*AppInstanceSettings) GetDecryptedSecureJsonData 

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

func (*AppInstanceSettings) GetJsonData 

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

func (*AppInstanceSettings) GetLastUpdatedMS 

func (m *AppInstanceSettings) GetLastUpdatedMS() int64

func (*AppInstanceSettings) ProtoMessage 

func (*AppInstanceSettings) ProtoMessage()

func (*AppInstanceSettings) Reset 

func (m *AppInstanceSettings) Reset()

func (*AppInstanceSettings) String 

func (m *AppInstanceSettings) String() string

func (*AppInstanceSettings) XXX_DiscardUnknown 

func (m *AppInstanceSettings) XXX_DiscardUnknown()

func (*AppInstanceSettings) XXX_Marshal 

func (m *AppInstanceSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AppInstanceSettings) XXX_Merge 

func (m *AppInstanceSettings) XXX_Merge(src proto.Message)

func (*AppInstanceSettings) XXX_Size 

func (m *AppInstanceSettings) XXX_Size() int

func (*AppInstanceSettings) XXX_Unmarshal 

func (m *AppInstanceSettings) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*CallResourceRequest) Descriptor 

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

func (*CallResourceRequest) GetBody 

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

func (*CallResourceRequest) GetHeaders 

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

func (*CallResourceRequest) GetMethod 

func (m *CallResourceRequest) GetMethod() string

func (*CallResourceRequest) GetPath 

func (m *CallResourceRequest) GetPath() string

func (*CallResourceRequest) GetPluginContext 

func (m *CallResourceRequest) GetPluginContext() *PluginContext

func (*CallResourceRequest) GetUrl 

func (m *CallResourceRequest) GetUrl() string

func (*CallResourceRequest) ProtoMessage 

func (*CallResourceRequest) ProtoMessage()

func (*CallResourceRequest) Reset 

func (m *CallResourceRequest) Reset()

func (*CallResourceRequest) String 

func (m *CallResourceRequest) String() string

func (*CallResourceRequest) XXX_DiscardUnknown 

func (m *CallResourceRequest) XXX_DiscardUnknown()

func (*CallResourceRequest) XXX_Marshal 

func (m *CallResourceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CallResourceRequest) XXX_Merge 

func (m *CallResourceRequest) XXX_Merge(src proto.Message)

func (*CallResourceRequest) XXX_Size 

func (m *CallResourceRequest) XXX_Size() int

func (*CallResourceRequest) XXX_Unmarshal 

func (m *CallResourceRequest) XXX_Unmarshal(b []byte) error

type CallResourceResponse 

type CallResourceResponse struct {
	Code                 int32                  `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Headers              map[string]*StringList `` /* 155-byte string literal not displayed */
	Body                 []byte                 `protobuf:"bytes,3,opt,name=body,proto3" json:"body,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func (*CallResourceResponse) Descriptor 

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

func (*CallResourceResponse) GetBody 

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

func (*CallResourceResponse) GetCode 

func (m *CallResourceResponse) GetCode() int32

func (*CallResourceResponse) GetHeaders 

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

func (*CallResourceResponse) ProtoMessage 

func (*CallResourceResponse) ProtoMessage()

func (*CallResourceResponse) Reset 

func (m *CallResourceResponse) Reset()

func (*CallResourceResponse) String 

func (m *CallResourceResponse) String() string

func (*CallResourceResponse) XXX_DiscardUnknown 

func (m *CallResourceResponse) XXX_DiscardUnknown()

func (*CallResourceResponse) XXX_Marshal 

func (m *CallResourceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CallResourceResponse) XXX_Merge 

func (m *CallResourceResponse) XXX_Merge(src proto.Message)

func (*CallResourceResponse) XXX_Size 

func (m *CallResourceResponse) XXX_Size() int

func (*CallResourceResponse) XXX_Unmarshal 

func (m *CallResourceResponse) XXX_Unmarshal(b []byte) error

type CheckHealthRequest 

type CheckHealthRequest struct {
	PluginContext        *PluginContext `protobuf:"bytes,1,opt,name=pluginContext,proto3" json:"pluginContext,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*CheckHealthRequest) Descriptor 

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

func (*CheckHealthRequest) GetPluginContext 

func (m *CheckHealthRequest) GetPluginContext() *PluginContext

func (*CheckHealthRequest) ProtoMessage 

func (*CheckHealthRequest) ProtoMessage()

func (*CheckHealthRequest) Reset 

func (m *CheckHealthRequest) Reset()

func (*CheckHealthRequest) String 

func (m *CheckHealthRequest) String() string

func (*CheckHealthRequest) XXX_DiscardUnknown 

func (m *CheckHealthRequest) XXX_DiscardUnknown()

func (*CheckHealthRequest) XXX_Marshal 

func (m *CheckHealthRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckHealthRequest) XXX_Merge 

func (m *CheckHealthRequest) XXX_Merge(src proto.Message)

func (*CheckHealthRequest) XXX_Size 

func (m *CheckHealthRequest) XXX_Size() int

func (*CheckHealthRequest) XXX_Unmarshal 

func (m *CheckHealthRequest) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}                         `json:"-"`
	XXX_unrecognized     []byte                           `json:"-"`
	XXX_sizecache        int32                            `json:"-"`
}

func (*CheckHealthResponse) Descriptor 

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

func (*CheckHealthResponse) GetJsonDetails 

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

func (*CheckHealthResponse) GetMessage 

func (m *CheckHealthResponse) GetMessage() string

func (*CheckHealthResponse) GetStatus 

func (m *CheckHealthResponse) GetStatus() CheckHealthResponse_HealthStatus

func (*CheckHealthResponse) ProtoMessage 

func (*CheckHealthResponse) ProtoMessage()

func (*CheckHealthResponse) Reset 

func (m *CheckHealthResponse) Reset()

func (*CheckHealthResponse) String 

func (m *CheckHealthResponse) String() string

func (*CheckHealthResponse) XXX_DiscardUnknown 

func (m *CheckHealthResponse) XXX_DiscardUnknown()

func (*CheckHealthResponse) XXX_Marshal 

func (m *CheckHealthResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckHealthResponse) XXX_Merge 

func (m *CheckHealthResponse) XXX_Merge(src proto.Message)

func (*CheckHealthResponse) XXX_Size 

func (m *CheckHealthResponse) XXX_Size() int

func (*CheckHealthResponse) XXX_Unmarshal 

func (m *CheckHealthResponse) XXX_Unmarshal(b []byte) error

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

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

func (CheckHealthResponse_HealthStatus) String 

func (x CheckHealthResponse_HealthStatus) String() string

type CollectMetricsRequest 

type CollectMetricsRequest struct {
	PluginContext        *PluginContext `protobuf:"bytes,1,opt,name=pluginContext,proto3" json:"pluginContext,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*CollectMetricsRequest) Descriptor 

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

func (*CollectMetricsRequest) GetPluginContext 

func (m *CollectMetricsRequest) GetPluginContext() *PluginContext

func (*CollectMetricsRequest) ProtoMessage 

func (*CollectMetricsRequest) ProtoMessage()

func (*CollectMetricsRequest) Reset 

func (m *CollectMetricsRequest) Reset()

func (*CollectMetricsRequest) String 

func (m *CollectMetricsRequest) String() string

func (*CollectMetricsRequest) XXX_DiscardUnknown 

func (m *CollectMetricsRequest) XXX_DiscardUnknown()

func (*CollectMetricsRequest) XXX_Marshal 

func (m *CollectMetricsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CollectMetricsRequest) XXX_Merge 

func (m *CollectMetricsRequest) XXX_Merge(src proto.Message)

func (*CollectMetricsRequest) XXX_Size 

func (m *CollectMetricsRequest) XXX_Size() int

func (*CollectMetricsRequest) XXX_Unmarshal 

func (m *CollectMetricsRequest) XXX_Unmarshal(b []byte) error

type CollectMetricsResponse 

type CollectMetricsResponse struct {
	Metrics              *CollectMetricsResponse_Payload `protobuf:"bytes,1,opt,name=metrics,proto3" json:"metrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                        `json:"-"`
	XXX_unrecognized     []byte                          `json:"-"`
	XXX_sizecache        int32                           `json:"-"`
}

func (*CollectMetricsResponse) Descriptor 

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

func (*CollectMetricsResponse) GetMetrics 

func (m *CollectMetricsResponse) GetMetrics() *CollectMetricsResponse_Payload

func (*CollectMetricsResponse) ProtoMessage 

func (*CollectMetricsResponse) ProtoMessage()

func (*CollectMetricsResponse) Reset 

func (m *CollectMetricsResponse) Reset()

func (*CollectMetricsResponse) String 

func (m *CollectMetricsResponse) String() string

func (*CollectMetricsResponse) XXX_DiscardUnknown 

func (m *CollectMetricsResponse) XXX_DiscardUnknown()

func (*CollectMetricsResponse) XXX_Marshal 

func (m *CollectMetricsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CollectMetricsResponse) XXX_Merge 

func (m *CollectMetricsResponse) XXX_Merge(src proto.Message)

func (*CollectMetricsResponse) XXX_Size 

func (m *CollectMetricsResponse) XXX_Size() int

func (*CollectMetricsResponse) XXX_Unmarshal 

func (m *CollectMetricsResponse) XXX_Unmarshal(b []byte) error

type CollectMetricsResponse_Payload 

type CollectMetricsResponse_Payload struct {
	Prometheus           []byte   `protobuf:"bytes,1,opt,name=prometheus,proto3" json:"prometheus,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CollectMetricsResponse_Payload) Descriptor 

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

func (*CollectMetricsResponse_Payload) GetPrometheus 

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

func (*CollectMetricsResponse_Payload) ProtoMessage 

func (*CollectMetricsResponse_Payload) ProtoMessage()

func (*CollectMetricsResponse_Payload) Reset 

func (m *CollectMetricsResponse_Payload) Reset()

func (*CollectMetricsResponse_Payload) String 

func (m *CollectMetricsResponse_Payload) String() string

func (*CollectMetricsResponse_Payload) XXX_DiscardUnknown 

func (m *CollectMetricsResponse_Payload) XXX_DiscardUnknown()

func (*CollectMetricsResponse_Payload) XXX_Marshal 

func (m *CollectMetricsResponse_Payload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CollectMetricsResponse_Payload) XXX_Merge 

func (m *CollectMetricsResponse_Payload) XXX_Merge(src proto.Message)

func (*CollectMetricsResponse_Payload) XXX_Size 

func (m *CollectMetricsResponse_Payload) XXX_Size() int

func (*CollectMetricsResponse_Payload) XXX_Unmarshal 

func (m *CollectMetricsResponse_Payload) XXX_Unmarshal(b []byte) error

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://godoc.org/google.golang.org/grpc#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"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*DataQuery) Descriptor 

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

func (*DataQuery) GetIntervalMS 

func (m *DataQuery) GetIntervalMS() int64

func (*DataQuery) GetJson 

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

func (*DataQuery) GetMaxDataPoints 

func (m *DataQuery) GetMaxDataPoints() int64

func (*DataQuery) GetQueryType 

func (m *DataQuery) GetQueryType() string

func (*DataQuery) GetRefId 

func (m *DataQuery) GetRefId() string

func (*DataQuery) GetTimeRange 

func (m *DataQuery) GetTimeRange() *TimeRange

func (*DataQuery) ProtoMessage 

func (*DataQuery) ProtoMessage()

func (*DataQuery) Reset 

func (m *DataQuery) Reset()

func (*DataQuery) String 

func (m *DataQuery) String() string

func (*DataQuery) XXX_DiscardUnknown 

func (m *DataQuery) XXX_DiscardUnknown()

func (*DataQuery) XXX_Marshal 

func (m *DataQuery) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataQuery) XXX_Merge 

func (m *DataQuery) XXX_Merge(src proto.Message)

func (*DataQuery) XXX_Size 

func (m *DataQuery) XXX_Size() int

func (*DataQuery) XXX_Unmarshal 

func (m *DataQuery) XXX_Unmarshal(b []byte) error

type DataResponse 

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                string   `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	JsonMeta             []byte   `protobuf:"bytes,3,opt,name=jsonMeta,proto3" json:"jsonMeta,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DataResponse) Descriptor 

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

func (*DataResponse) GetError 

func (m *DataResponse) GetError() string

func (*DataResponse) GetFrames 

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

func (*DataResponse) GetJsonMeta 

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

func (*DataResponse) ProtoMessage 

func (*DataResponse) ProtoMessage()

func (*DataResponse) Reset 

func (m *DataResponse) Reset()

func (*DataResponse) String 

func (m *DataResponse) String() string

func (*DataResponse) XXX_DiscardUnknown 

func (m *DataResponse) XXX_DiscardUnknown()

func (*DataResponse) XXX_Marshal 

func (m *DataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataResponse) XXX_Merge 

func (m *DataResponse) XXX_Merge(src proto.Message)

func (*DataResponse) XXX_Size 

func (m *DataResponse) XXX_Size() int

func (*DataResponse) XXX_Unmarshal 

func (m *DataResponse) XXX_Unmarshal(b []byte) error

type DataServer 

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

DataServer is the server API for Data service.

type DataSourceInstanceSettings 

type DataSourceInstanceSettings struct {
	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 */
	LastUpdatedMS           int64             `protobuf:"varint,10,opt,name=lastUpdatedMS,proto3" json:"lastUpdatedMS,omitempty"`
	XXX_NoUnkeyedLiteral    struct{}          `json:"-"`
	XXX_unrecognized        []byte            `json:"-"`
	XXX_sizecache           int32             `json:"-"`
}

func (*DataSourceInstanceSettings) Descriptor 

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

func (*DataSourceInstanceSettings) GetBasicAuthEnabled 

func (m *DataSourceInstanceSettings) GetBasicAuthEnabled() bool

func (*DataSourceInstanceSettings) GetBasicAuthUser 

func (m *DataSourceInstanceSettings) GetBasicAuthUser() string

func (*DataSourceInstanceSettings) GetDatabase 

func (m *DataSourceInstanceSettings) GetDatabase() string

func (*DataSourceInstanceSettings) GetDecryptedSecureJsonData 

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

func (*DataSourceInstanceSettings) GetId 

func (m *DataSourceInstanceSettings) GetId() int64

func (*DataSourceInstanceSettings) GetJsonData 

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

func (*DataSourceInstanceSettings) GetLastUpdatedMS 

func (m *DataSourceInstanceSettings) GetLastUpdatedMS() int64

func (*DataSourceInstanceSettings) GetName 

func (m *DataSourceInstanceSettings) GetName() string

func (*DataSourceInstanceSettings) GetUrl 

func (m *DataSourceInstanceSettings) GetUrl() string

func (*DataSourceInstanceSettings) GetUser 

func (m *DataSourceInstanceSettings) GetUser() string

func (*DataSourceInstanceSettings) ProtoMessage 

func (*DataSourceInstanceSettings) ProtoMessage()

func (*DataSourceInstanceSettings) Reset 

func (m *DataSourceInstanceSettings) Reset()

func (*DataSourceInstanceSettings) String 

func (m *DataSourceInstanceSettings) String() string

func (*DataSourceInstanceSettings) XXX_DiscardUnknown 

func (m *DataSourceInstanceSettings) XXX_DiscardUnknown()

func (*DataSourceInstanceSettings) XXX_Marshal 

func (m *DataSourceInstanceSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DataSourceInstanceSettings) XXX_Merge 

func (m *DataSourceInstanceSettings) XXX_Merge(src proto.Message)

func (*DataSourceInstanceSettings) XXX_Size 

func (m *DataSourceInstanceSettings) XXX_Size() int

func (*DataSourceInstanceSettings) XXX_Unmarshal 

func (m *DataSourceInstanceSettings) XXX_Unmarshal(b []byte) error

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://godoc.org/google.golang.org/grpc#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.

type PluginContext 

type PluginContext struct {
	// The Grafana organization id the request originating from.
	OrgId int64 `protobuf:"varint,1,opt,name=orgId,proto3" json:"orgId,omitempty"`
	// The unique identifier of the plugin the request  originating from.
	PluginId string `protobuf:"bytes,2,opt,name=pluginId,proto3" json:"pluginId,omitempty"`
	// The Grafana user the request originating 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"`
	XXX_NoUnkeyedLiteral       struct{}                    `json:"-"`
	XXX_unrecognized           []byte                      `json:"-"`
	XXX_sizecache              int32                       `json:"-"`
}

func (*PluginContext) Descriptor 

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

func (*PluginContext) GetAppInstanceSettings 

func (m *PluginContext) GetAppInstanceSettings() *AppInstanceSettings

func (*PluginContext) GetDataSourceInstanceSettings 

func (m *PluginContext) GetDataSourceInstanceSettings() *DataSourceInstanceSettings

func (*PluginContext) GetOrgId 

func (m *PluginContext) GetOrgId() int64

func (*PluginContext) GetPluginId 

func (m *PluginContext) GetPluginId() string

func (*PluginContext) GetUser 

func (m *PluginContext) GetUser() *User

func (*PluginContext) ProtoMessage 

func (*PluginContext) ProtoMessage()

func (*PluginContext) Reset 

func (m *PluginContext) Reset()

func (*PluginContext) String 

func (m *PluginContext) String() string

func (*PluginContext) XXX_DiscardUnknown 

func (m *PluginContext) XXX_DiscardUnknown()

func (*PluginContext) XXX_Marshal 

func (m *PluginContext) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PluginContext) XXX_Merge 

func (m *PluginContext) XXX_Merge(src proto.Message)

func (*PluginContext) XXX_Size 

func (m *PluginContext) XXX_Size() int

func (*PluginContext) XXX_Unmarshal 

func (m *PluginContext) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

QueryDataRequest

func (*QueryDataRequest) Descriptor 

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

func (*QueryDataRequest) GetHeaders 

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

func (*QueryDataRequest) GetPluginContext 

func (m *QueryDataRequest) GetPluginContext() *PluginContext

func (*QueryDataRequest) GetQueries 

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

func (*QueryDataRequest) ProtoMessage 

func (*QueryDataRequest) ProtoMessage()

func (*QueryDataRequest) Reset 

func (m *QueryDataRequest) Reset()

func (*QueryDataRequest) String 

func (m *QueryDataRequest) String() string

func (*QueryDataRequest) XXX_DiscardUnknown 

func (m *QueryDataRequest) XXX_DiscardUnknown()

func (*QueryDataRequest) XXX_Marshal 

func (m *QueryDataRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryDataRequest) XXX_Merge 

func (m *QueryDataRequest) XXX_Merge(src proto.Message)

func (*QueryDataRequest) XXX_Size 

func (m *QueryDataRequest) XXX_Size() int

func (*QueryDataRequest) XXX_Unmarshal 

func (m *QueryDataRequest) XXX_Unmarshal(b []byte) error

type QueryDataResponse 

type QueryDataResponse struct {
	// Map of refId to response
	Responses            map[string]*DataResponse `` /* 159-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*QueryDataResponse) Descriptor 

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

func (*QueryDataResponse) GetResponses 

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

func (*QueryDataResponse) ProtoMessage 

func (*QueryDataResponse) ProtoMessage()

func (*QueryDataResponse) Reset 

func (m *QueryDataResponse) Reset()

func (*QueryDataResponse) String 

func (m *QueryDataResponse) String() string

func (*QueryDataResponse) XXX_DiscardUnknown 

func (m *QueryDataResponse) XXX_DiscardUnknown()

func (*QueryDataResponse) XXX_Marshal 

func (m *QueryDataResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*QueryDataResponse) XXX_Merge 

func (m *QueryDataResponse) XXX_Merge(src proto.Message)

func (*QueryDataResponse) XXX_Size 

func (m *QueryDataResponse) XXX_Size() int

func (*QueryDataResponse) XXX_Unmarshal 

func (m *QueryDataResponse) XXX_Unmarshal(b []byte) error

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://godoc.org/google.golang.org/grpc#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.

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 StringList 

type StringList struct {
	Values               []string `protobuf:"bytes,1,rep,name=values,proto3" json:"values,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StringList) Descriptor 

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

func (*StringList) GetValues 

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

func (*StringList) ProtoMessage 

func (*StringList) ProtoMessage()

func (*StringList) Reset 

func (m *StringList) Reset()

func (*StringList) String 

func (m *StringList) String() string

func (*StringList) XXX_DiscardUnknown 

func (m *StringList) XXX_DiscardUnknown()

func (*StringList) XXX_Marshal 

func (m *StringList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StringList) XXX_Merge 

func (m *StringList) XXX_Merge(src proto.Message)

func (*StringList) XXX_Size 

func (m *StringList) XXX_Size() int

func (*StringList) XXX_Unmarshal 

func (m *StringList) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*TimeRange) Descriptor 

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

func (*TimeRange) GetFromEpochMS 

func (m *TimeRange) GetFromEpochMS() int64

func (*TimeRange) GetToEpochMS 

func (m *TimeRange) GetToEpochMS() int64

func (*TimeRange) ProtoMessage 

func (*TimeRange) ProtoMessage()

func (*TimeRange) Reset 

func (m *TimeRange) Reset()

func (*TimeRange) String 

func (m *TimeRange) String() string

func (*TimeRange) XXX_DiscardUnknown 

func (m *TimeRange) XXX_DiscardUnknown()

func (*TimeRange) XXX_Marshal 

func (m *TimeRange) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TimeRange) XXX_Merge 

func (m *TimeRange) XXX_Merge(src proto.Message)

func (*TimeRange) XXX_Size 

func (m *TimeRange) XXX_Size() int

func (*TimeRange) XXX_Unmarshal 

func (m *TimeRange) XXX_Unmarshal(b []byte) error

type TransformClient 

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

TransformClient is the client API for Transform service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTransformClient 

func NewTransformClient(cc grpc.ClientConnInterface) TransformClient

type TransformDataCallBackClient 

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

TransformDataCallBackClient is the client API for TransformDataCallBack service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewTransformDataCallBackClient 

func NewTransformDataCallBackClient(cc grpc.ClientConnInterface) TransformDataCallBackClient

type TransformDataCallBackServer 

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

TransformDataCallBackServer is the server API for TransformDataCallBack service.

type TransformServer 

type TransformServer interface {
	TransformData(context.Context, *QueryDataRequest) (*QueryDataResponse, error)
}

TransformServer is the server API for Transform service.

type UnimplementedDataServer 

type UnimplementedDataServer struct {
}

UnimplementedDataServer can be embedded to have forward compatible implementations.

func (*UnimplementedDataServer) QueryData 

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

type UnimplementedDiagnosticsServer 

type UnimplementedDiagnosticsServer struct {
}

UnimplementedDiagnosticsServer can be embedded to have forward compatible implementations.

func (*UnimplementedDiagnosticsServer) CheckHealth 

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

func (*UnimplementedDiagnosticsServer) CollectMetrics 

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

type UnimplementedResourceServer 

type UnimplementedResourceServer struct {
}

UnimplementedResourceServer can be embedded to have forward compatible implementations.

func (*UnimplementedResourceServer) CallResource 

func (*UnimplementedResourceServer) CallResource(req *CallResourceRequest, srv Resource_CallResourceServer) error

type UnimplementedTransformDataCallBackServer 

type UnimplementedTransformDataCallBackServer struct {
}

UnimplementedTransformDataCallBackServer can be embedded to have forward compatible implementations.

func (*UnimplementedTransformDataCallBackServer) QueryData 

func (*UnimplementedTransformDataCallBackServer) QueryData(ctx context.Context, req *QueryDataRequest) (*QueryDataResponse, error)

type UnimplementedTransformServer 

type UnimplementedTransformServer struct {
}

UnimplementedTransformServer can be embedded to have forward compatible implementations.

func (*UnimplementedTransformServer) TransformData 

func (*UnimplementedTransformServer) TransformData(ctx context.Context, req *QueryDataRequest) (*QueryDataResponse, error)

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*User) Descriptor 

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

func (*User) GetEmail 

func (m *User) GetEmail() string

func (*User) GetLogin 

func (m *User) GetLogin() string

func (*User) GetName 

func (m *User) GetName() string

func (*User) GetRole 

func (m *User) GetRole() string

func (*User) ProtoMessage 

func (*User) ProtoMessage()

func (*User) Reset 

func (m *User) Reset()

func (*User) String 

func (m *User) String() string

func (*User) XXX_DiscardUnknown 

func (m *User) XXX_DiscardUnknown()

func (*User) XXX_Marshal 

func (m *User) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*User) XXX_Merge 

func (m *User) XXX_Merge(src proto.Message)

func (*User) XXX_Size 

func (m *User) XXX_Size() int

func (*User) XXX_Unmarshal 

func (m *User) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.