polardbx

Documentation

Index

• func NewPolardbx(logger logger.Logger) bindings.OutputBinding
• type PolardbxOperations
  • func (polardbxOps *PolardbxOperations) ExecOps(ctx context.Context, req *bindings.InvokeRequest, ...) (OpsResult, error)
  • func (polardbxOps *PolardbxOperations) GetRole(ctx context.Context, request *bindings.InvokeRequest, ...) (string, error)
  • func (polardbxOps *PolardbxOperations) GetRunningPort() int
  • func (polardbxOps *PolardbxOperations) Init(metadata bindings.Metadata) error
  • func (polardbxOps *PolardbxOperations) QueryOps(ctx context.Context, req *bindings.InvokeRequest, ...) (OpsResult, error)
• type QueryRes

Functions

func NewPolardbx

func NewPolardbx(logger logger.Logger) bindings.OutputBinding

NewPolardbx returns a new polardbx output binding.

Types

type PolardbxOperations

type PolardbxOperations struct {
	BaseOperations
}

PolardbxOperations represents polardbx output bindings.

func (*PolardbxOperations) ExecOps

func (polardbxOps *PolardbxOperations) ExecOps(ctx context.Context, req *bindings.InvokeRequest, resp *bindings.InvokeResponse) (OpsResult, error)

func (*PolardbxOperations) GetRole

func (polardbxOps *PolardbxOperations) GetRole(ctx context.Context, request *bindings.InvokeRequest, response *bindings.InvokeResponse) (string, error)

func (*PolardbxOperations) GetRunningPort

func (polardbxOps *PolardbxOperations) GetRunningPort() int

func (*PolardbxOperations) Init

func (polardbxOps *PolardbxOperations) Init(metadata bindings.Metadata) error

Init initializes the polardbx binding.

func (*PolardbxOperations) QueryOps

func (polardbxOps *PolardbxOperations) QueryOps(ctx context.Context, req *bindings.InvokeRequest, resp *bindings.InvokeResponse) (OpsResult, error)

type QueryRes

type QueryRes []map[string]interface{}