plugin

Documentation

Index

• func NewTwinMakerInstance(ctx context.Context, s backend.DataSourceInstanceSettings) (instancemgmt.Instance, error)
• type TwinMakerDatasource
  • func NewTwinMakerDatasource(settings models.TwinMakerDataSourceSetting) *TwinMakerDatasource
  • func (ds *TwinMakerDatasource) CallResource(ctx context.Context, req *backend.CallResourceRequest, ...) error
  • func (ds *TwinMakerDatasource) CheckHealth(ctx context.Context, _ *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)
  • func (ds *TwinMakerDatasource) Dispose()
  • func (ds *TwinMakerDatasource) DoQuery(ctx context.Context, query models.TwinMakerQuery) backend.DataResponse
  • func (ds *TwinMakerDatasource) HandleBatchPutPropertyValues(w http.ResponseWriter, r *http.Request)
  • func (ds *TwinMakerDatasource) HandleGetEntity(w http.ResponseWriter, r *http.Request)
  • func (ds *TwinMakerDatasource) HandleGetToken(w http.ResponseWriter, r *http.Request)
  • func (ds *TwinMakerDatasource) HandleListEntityOptions(w http.ResponseWriter, r *http.Request)
  • func (ds *TwinMakerDatasource) HandleListOptions(w http.ResponseWriter, r *http.Request)
  • func (ds *TwinMakerDatasource) HandleListScenes(w http.ResponseWriter, r *http.Request)
  • func (ds *TwinMakerDatasource) HandleListWorkspaces(w http.ResponseWriter, r *http.Request)
  • func (ds *TwinMakerDatasource) PublishStream(_ context.Context, _ *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)
  • func (ds *TwinMakerDatasource) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)
  • func (ds *TwinMakerDatasource) RequestLoop(ctx context.Context, query models.TwinMakerQuery, ...)
  • func (ds *TwinMakerDatasource) RunStream(ctx context.Context, req *backend.RunStreamRequest, ...) error
  • func (d *TwinMakerDatasource) ServeHTTP(w http.ResponseWriter, r *http.Request)
  • func (ds *TwinMakerDatasource) SubscribeStream(_ context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)

Functions

func NewTwinMakerInstance

func NewTwinMakerInstance(ctx context.Context, s backend.DataSourceInstanceSettings) (instancemgmt.Instance, error)

NewTwinMakerInstance creates a new datasource instance.

Types

type TwinMakerDatasource

type TwinMakerDatasource struct {
	// contains filtered or unexported fields
}

func NewTwinMakerDatasource

func NewTwinMakerDatasource(settings models.TwinMakerDataSourceSetting) *TwinMakerDatasource

NewTwinMakerDatasource creates a new datasource instance.

func (*TwinMakerDatasource) CallResource

func (ds *TwinMakerDatasource) CallResource(ctx context.Context, req *backend.CallResourceRequest, sender backend.CallResourceResponseSender) error

CallResource HTTP style resource

func (*TwinMakerDatasource) CheckHealth

func (ds *TwinMakerDatasource) CheckHealth(ctx context.Context, _ *backend.CheckHealthRequest) (*backend.CheckHealthResult, error)

func (*TwinMakerDatasource) Dispose

func (ds *TwinMakerDatasource) Dispose()

Dispose here tells plugin SDK that plugin wants to clean up resources when a new instance created. As soon as datasource settings change detected by SDK old datasource instance will be disposed and a new one will be created using NewTwinMakerDatasource factory function.

func (*TwinMakerDatasource) DoQuery

func (ds *TwinMakerDatasource) DoQuery(ctx context.Context, query models.TwinMakerQuery) backend.DataResponse

func (*TwinMakerDatasource) HandleBatchPutPropertyValues

func (ds *TwinMakerDatasource) HandleBatchPutPropertyValues(w http.ResponseWriter, r *http.Request)

func (*TwinMakerDatasource) HandleGetEntity

func (ds *TwinMakerDatasource) HandleGetEntity(w http.ResponseWriter, r *http.Request)

func (*TwinMakerDatasource) HandleGetToken

func (ds *TwinMakerDatasource) HandleGetToken(w http.ResponseWriter, r *http.Request)

func (*TwinMakerDatasource) HandleListEntityOptions

func (ds *TwinMakerDatasource) HandleListEntityOptions(w http.ResponseWriter, r *http.Request)

func (*TwinMakerDatasource) HandleListOptions

func (ds *TwinMakerDatasource) HandleListOptions(w http.ResponseWriter, r *http.Request)

func (*TwinMakerDatasource) HandleListScenes

func (ds *TwinMakerDatasource) HandleListScenes(w http.ResponseWriter, r *http.Request)

func (*TwinMakerDatasource) HandleListWorkspaces

func (ds *TwinMakerDatasource) HandleListWorkspaces(w http.ResponseWriter, r *http.Request)

func (*TwinMakerDatasource) PublishStream

func (ds *TwinMakerDatasource) PublishStream(_ context.Context, _ *backend.PublishStreamRequest) (*backend.PublishStreamResponse, error)

func (*TwinMakerDatasource) QueryData

func (ds *TwinMakerDatasource) QueryData(ctx context.Context, req *backend.QueryDataRequest) (*backend.QueryDataResponse, error)

func (*TwinMakerDatasource) RequestLoop

func (ds *TwinMakerDatasource) RequestLoop(ctx context.Context, query models.TwinMakerQuery, resChannel chan *backend.DataResponse)

func (*TwinMakerDatasource) RunStream

func (ds *TwinMakerDatasource) RunStream(ctx context.Context, req *backend.RunStreamRequest, sender *backend.StreamSender) error

func (*TwinMakerDatasource) ServeHTTP

func (d *TwinMakerDatasource) ServeHTTP(w http.ResponseWriter, r *http.Request)

func (*TwinMakerDatasource) SubscribeStream

func (ds *TwinMakerDatasource) SubscribeStream(_ context.Context, req *backend.SubscribeStreamRequest) (*backend.SubscribeStreamResponse, error)