backend

package

Go to main page

Versions in this module

v0

v0.0.10

Mar 10, 2025

v0.0.9

Feb 19, 2025

Changes in this version

type ConvertFromProtobuf

+ func (f ConvertFromProtobuf) Pub2ChannelRequest(protoReq *pluginv2.Pub2ChannelRequest) *Pub2ChannelRequest

+ func (f ConvertFromProtobuf) Pub2ChannelResponse(protoResp *pluginv2.Pub2ChannelResponse) *Pub2ChannelResponse

type ConvertToProtobuf

+ func (t ConvertToProtobuf) Pub2ChannelResponse(res *Pub2ChannelResponse) *pluginv2.Pub2ChannelResponse

+ func (t ConvertToProtobuf) PubStatus(status PubStatus) pluginv2.Pub2ChannelResponse_PubStatus

+ type LiveHandler interface

+ Pub2Channel func(ctx context.Context, req *Pub2ChannelRequest) (*Pub2ChannelResponse, error)

+ type LiveHandlerFunc func(ctx context.Context, req *Pub2ChannelRequest) (*Pub2ChannelResponse, error)

+ func (fn LiveHandlerFunc) Pub2Channel(ctx context.Context, req *Pub2ChannelRequest) (*Pub2ChannelResponse, error)

+ type Pub2ChannelRequest struct

+ Channel string

+ Data []byte

+ PluginContext PluginContext

+ type Pub2ChannelResponse struct

+ JsonDetails []byte

+ Message string

+ Status PubStatus

+ type PubStatus int

+ const PubStatusError

+ const PubStatusOk

+ const PubStatusUnknown

+ func (hs PubStatus) String() string

type ServeOpts

+ LiveHandler LiveHandler

v0.0.8

Dec 31, 2024

v0.0.7

Dec 26, 2024

v0.0.6

Nov 1, 2024

v0.0.5

Oct 31, 2024

v0.0.4

Oct 31, 2024

Changes in this version

+ const CookiesHeaderName

+ const OAuthIdentityIDTokenHeaderName

+ const OAuthIdentityTokenHeaderName

+ func Serve(opts ServeOpts)

+ func StandaloneServe(dsopts ServeOpts, address string) error

+ type AppInstanceSettings struct

+ DecryptedSecureJSONData map[string]string

+ JSONData json.RawMessage

+ Updated time.Time

+ type CallResourceHandler interface

+ CallResource func(ctx context.Context, req *CallResourceRequest, ...) error

+ type CallResourceHandlerFunc func(ctx context.Context, req *CallResourceRequest, ...) error

+ func (fn CallResourceHandlerFunc) CallResource(ctx context.Context, req *CallResourceRequest, ...) error

+ type CallResourceRequest struct

+ Body []byte

+ Headers map[string][]string

+ Method string

+ Path string

+ PluginContext PluginContext

+ URL string

+ type CallResourceResponse struct

+ Body []byte

+ Headers map[string][]string

+ Status int

+ type CallResourceResponseSender interface

+ Send func(*CallResourceResponse) error

+ type CheckHealthHandler interface

+ CheckHealth func(ctx context.Context, req *CheckHealthRequest) (*CheckHealthResult, error)

+ type CheckHealthHandlerFunc func(ctx context.Context, req *CheckHealthRequest) (*CheckHealthResult, error)

+ func (fn CheckHealthHandlerFunc) CheckHealth(ctx context.Context, req *CheckHealthRequest) (*CheckHealthResult, error)

+ type CheckHealthRequest struct

+ Headers map[string]string

+ PluginContext PluginContext

+ func (req *CheckHealthRequest) DeleteHTTPHeader(key string)

+ func (req *CheckHealthRequest) GetHTTPHeader(key string) string

+ func (req *CheckHealthRequest) GetHTTPHeaders() http.Header

+ func (req *CheckHealthRequest) SetHTTPHeader(key, value string)

+ type CheckHealthResult struct

+ JSONDetails []byte

+ Message string

+ Status HealthStatus

+ type ConvertFromProtobuf struct

+ func FromProto() ConvertFromProtobuf

+ func (f ConvertFromProtobuf) AppInstanceSettings(proto *pluginv2.AppInstanceSettings) *AppInstanceSettings

+ func (f ConvertFromProtobuf) CallResourceRequest(protoReq *pluginv2.CallResourceRequest) *CallResourceRequest

+ func (f ConvertFromProtobuf) CallResourceResponse(protoResp *pluginv2.CallResourceResponse) *CallResourceResponse

+ func (f ConvertFromProtobuf) CheckHealthRequest(protoReq *pluginv2.CheckHealthRequest) *CheckHealthRequest

+ func (f ConvertFromProtobuf) CheckHealthResponse(protoResp *pluginv2.CheckHealthResponse) *CheckHealthResult

+ func (f ConvertFromProtobuf) DataSourceInstanceSettings(proto *pluginv2.DataSourceInstanceSettings, pluginID string) *DataSourceInstanceSettings

+ func (f ConvertFromProtobuf) PluginContext(proto *pluginv2.PluginContext) PluginContext

+ func (f ConvertFromProtobuf) PluginInfoGetReq(protoReq *pluginv2.PluginInfoGetReq) *PluginInfoGetReq

+ func (f ConvertFromProtobuf) PluginInfoGetRes(protoResp *pluginv2.PluginInfoGetRes) *PluginInfoGetRes

+ func (f ConvertFromProtobuf) User(user *pluginv2.User) *User

+ type ConvertToProtobuf struct

+ func ToProto() ConvertToProtobuf

+ func (f ConvertToProtobuf) PluginInfoGetRes(protoResp *PluginInfoGetRes) *pluginv2.PluginInfoGetRes

+ func (t ConvertToProtobuf) AppInstanceSettings(s *AppInstanceSettings) *pluginv2.AppInstanceSettings

+ func (t ConvertToProtobuf) CallResourceRequest(req *CallResourceRequest) *pluginv2.CallResourceRequest

+ func (t ConvertToProtobuf) CallResourceResponse(resp *CallResourceResponse) *pluginv2.CallResourceResponse

+ func (t ConvertToProtobuf) CheckHealthResponse(res *CheckHealthResult) *pluginv2.CheckHealthResponse

+ func (t ConvertToProtobuf) DataSourceInstanceSettings(s *DataSourceInstanceSettings) *pluginv2.DataSourceInstanceSettings

+ func (t ConvertToProtobuf) HealthStatus(status HealthStatus) pluginv2.CheckHealthResponse_HealthStatus

+ func (t ConvertToProtobuf) PluginContext(pluginCtx PluginContext) *pluginv2.PluginContext

+ func (t ConvertToProtobuf) User(user *User) *pluginv2.User

+ type DataSourceInstanceSettings struct

+ BasicAuthEnabled bool

+ BasicAuthUser string

+ Database string

+ DecryptedSecureJSONData map[string]string

+ ID int64

+ JSONData json.RawMessage

+ Name string

+ Type string

+ UID string

+ URL string

+ Updated time.Time

+ User string

+ type DefaultPluginInfoHandler struct

+ PluginID string

+ PluginVersion string

+ func NewDefaultPluginInfoHandler(pluginID string, pluginVersion string) *DefaultPluginInfoHandler

+ func (d DefaultPluginInfoHandler) PluginInfo(ctx context.Context, req *PluginInfoGetReq) (*PluginInfoGetRes, error)

+ type ForwardHTTPHeaders interface

+ DeleteHTTPHeader func(key string)

+ GetHTTPHeader func(key string) string

+ GetHTTPHeaders func() http.Header

+ SetHTTPHeader func(key, value string)

+ type GRPCSettings struct

+ MaxReceiveMsgSize int

+ MaxSendMsgSize int

+ type HealthStatus int

+ const HealthStatusError

+ const HealthStatusOk

+ const HealthStatusUnknown

+ func (hs HealthStatus) String() string

+ type PluginContext struct

+ AppInstanceSettings *AppInstanceSettings

+ DataSourceInstanceSettings *DataSourceInstanceSettings

+ OrgID int64

+ PluginID string

+ User *User

+ type PluginInfoGetReq struct

+ PluginContext PluginContext

+ type PluginInfoGetRes struct

+ PluginID string

+ PluginVersion string

+ type PluginInfoHandler interface

+ PluginInfo func(ctx context.Context, req *PluginInfoGetReq) (*PluginInfoGetRes, error)

+ type PluginInfoHandlerFunc func(ctx context.Context, req *PluginInfoGetReq) (*PluginInfoGetRes, error)

+ func (fn PluginInfoHandlerFunc) PluginInfo(ctx context.Context, req *PluginInfoGetReq) (*PluginInfoGetRes, error)

+ type ServeOpts struct

+ CallResourceHandler CallResourceHandler

+ CheckHealthHandler CheckHealthHandler

+ EvRpcKey string

+ EvRpcPort string

+ ExitCallback func()

+ GRPCSettings GRPCSettings

+ PluginInfoHandler PluginInfoHandler

+ PluginJson *build.PluginJsonData

+ type User struct

+ Email string

+ Login string

+ Name string

+ Role string

v0.0.3

Oct 24, 2024

v0.0.2

Sep 28, 2024

v0.0.1

Aug 27, 2024

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL