| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/grafana-plugin-sdk-go/backend/ |
| H A D | convert_from_protobuf.go | 225 func (f ConvertFromProtobuf) PublishStreamRequest(protoReq *pluginv2.PublishStreamRequest) *Publish… func
226 return &PublishStreamRequest{
|
| H A D | stream_adapter.go | 34 …SDKAdapter) PublishStream(ctx context.Context, protoReq *pluginv2.PublishStreamRequest) (*pluginv2…
38 resp, err := a.streamHandler.PublishStream(ctx, FromProto().PublishStreamRequest(protoReq))
|
| H A D | convert_to_protobuf.go | 228 func (t ConvertToProtobuf) PublishStreamRequest(req *PublishStreamRequest) *pluginv2.PublishStreamR… func
229 return &pluginv2.PublishStreamRequest{
|
| H A D | stream.go | 24 PublishStream(context.Context, *PublishStreamRequest) (*PublishStreamResponse, error) argument
89 type PublishStreamRequest struct { struct
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/grafana-plugin-sdk-go/genproto/pluginv2/ |
| H A D | backend_grpc.pb.go | 350 …PublishStream(ctx context.Context, in *PublishStreamRequest, opts ...grpc.CallOption) (*PublishStr… argument
402 func (c *streamClient) PublishStream(ctx context.Context, in *PublishStreamRequest, opts ...grpc.Ca…
429 PublishStream(context.Context, *PublishStreamRequest) (*PublishStreamResponse, error) argument
442 func (UnimplementedStreamServer) PublishStream(context.Context, *PublishStreamRequest) (*PublishStr…
497 in := new(PublishStreamRequest)
509 return srv.(StreamServer).PublishStream(ctx, req.(*PublishStreamRequest))
|
| H A D | backend.pb.go | 1362 type PublishStreamRequest struct { struct
1375 func (x *PublishStreamRequest) Reset() { argument
1376 *x = PublishStreamRequest{}
1384 func (x *PublishStreamRequest) String() string { argument
1388 func (*PublishStreamRequest) ProtoMessage() {} argument
1390 func (x *PublishStreamRequest) ProtoReflect() protoreflect.Message { argument
1403 func (*PublishStreamRequest) Descriptor() ([]byte, []int) { argument
1407 func (x *PublishStreamRequest) GetPluginContext() *PluginContext { argument
1414 func (x *PublishStreamRequest) GetPath() string { argument
1421 func (x *PublishStreamRequest) GetData() []byte { argument
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/grafana-plugin-sdk-go/backend/grpcplugin/ |
| H A D | grpc_stream.go | 49 func (s streamGRPCServer) PublishStream(ctx context.Context, request *pluginv2.PublishStreamRequest…
65 func (s streamGRPCClient) PublishStream(ctx context.Context, in *pluginv2.PublishStreamRequest, opt…
|
| /dports/www/grafana8/grafana-8.3.6/pkg/plugins/backendplugin/grpcplugin/ |
| H A D | client_v2.go | 198 func (c *clientV2) PublishStream(ctx context.Context, req *backend.PublishStreamRequest) (*backend.…
202 protoResp, err := c.StreamClient.PublishStream(ctx, backend.ToProto().PublishStreamRequest(req))
|
| H A D | grpc_plugin.go | 175 func (p *grpcPlugin) PublishStream(ctx context.Context, request *backend.PublishStreamRequest) (*ba…
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/grafana-plugin-sdk-go/internal/automanagement/ |
| H A D | manager.go | 71 func (m *Manager) PublishStream(ctx context.Context, req *backend.PublishStreamRequest) (*backend.P…
|
| /dports/www/grafana8/grafana-8.3.6/pkg/plugins/backendplugin/coreplugin/ |
| H A D | core_plugin.go | 102 func (cp *corePlugin) PublishStream(ctx context.Context, req *backend.PublishStreamRequest) (*backe…
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/grafana-plugin-sdk-go/proto/ |
| H A D | backend.proto | 195 rpc PublishStream(PublishStreamRequest) returns (PublishStreamResponse);
220 message PublishStreamRequest { message
|
| /dports/www/grafana8/grafana-8.3.6/pkg/tsdb/testdatasource/ |
| H A D | stream_handler.go | 41 func (s *Service) PublishStream(_ context.Context, req *backend.PublishStreamRequest) (*backend.Pub… argument
|
| /dports/www/grafana8/grafana-8.3.6/pkg/services/live/features/ |
| H A D | plugin.go | 116 resp, err := r.handler.PublishStream(ctx, &backend.PublishStreamRequest{
|
| /dports/www/grafana8/grafana-8.3.6/pkg/plugins/ |
| H A D | plugins.go | 271 func (p *Plugin) PublishStream(ctx context.Context, req *backend.PublishStreamRequest) (*backend.Pu…
|
| /dports/www/grafana8/grafana-8.3.6/pkg/plugins/manager/ |
| H A D | manager.go | 460 func (m *PluginManager) PublishStream(ctx context.Context, req *backend.PublishStreamRequest) (*bac…
|
| H A D | manager_test.go | 757 …PluginClient) PublishStream(ctx context.Context, request *backend.PublishStreamRequest) (*backend.…
|