sqlchannel

Documentation

Index

• func GetMapKeyFromRequest(req *dapr.InvokeBindingRequest) string
• type OperationClient
  • func NewClientWithPod(pod *corev1.Pod, characterType string) (*OperationClient, error)
  • func (cli *OperationClient) GetRole() (string, error)
  • func (cli *OperationClient) InvokeComponent(ctxWithReconcileTimeout context.Context, req *dapr.InvokeBindingRequest, ...)
  • func (cli *OperationClient) InvokeComponentInRoutine(ctxWithReconcileTimeout context.Context, req *dapr.InvokeBindingRequest) (*dapr.BindingEvent, error)
• type OperationHTTPClient
  • func NewHTTPClientWithChannelPod(pod *corev1.Pod, characterType string) (*OperationHTTPClient, error)
  • func (cli *OperationHTTPClient) SendRequest(exec *exec.ExecOptions, request SQLChannelRequest) (SQLChannelResponse, error)
• type OperationResult
• type Order

Functions

func GetMapKeyFromRequest

func GetMapKeyFromRequest(req *dapr.InvokeBindingRequest) string

Types

type OperationClient

type OperationClient struct {
	dapr.Client
	CharacterType string

	CacheTTL         time.Duration
	ReconcileTimeout time.Duration
	RequestTimeout   time.Duration
	// contains filtered or unexported fields
}

func NewClientWithPod

func NewClientWithPod(pod *corev1.Pod, characterType string) (*OperationClient, error)

func (*OperationClient) GetRole

func (cli *OperationClient) GetRole() (string, error)

func (*OperationClient) InvokeComponent

func (cli *OperationClient) InvokeComponent(ctxWithReconcileTimeout context.Context, req *dapr.InvokeBindingRequest, ch chan *OperationResult)

func (*OperationClient) InvokeComponentInRoutine

func (cli *OperationClient) InvokeComponentInRoutine(ctxWithReconcileTimeout context.Context, req *dapr.InvokeBindingRequest) (*dapr.BindingEvent, error)

type OperationHTTPClient

type OperationHTTPClient struct {
	RequestTimeout time.Duration
	// contains filtered or unexported fields
}

OperationHTTPClient is a mock client for operation, mainly used to hide curl command details.

func NewHTTPClientWithChannelPod

func NewHTTPClientWithChannelPod(pod *corev1.Pod, characterType string) (*OperationHTTPClient, error)

NewHTTPClientWithChannelPod create a new OperationHTTPClient with sqlchannel container

func (*OperationHTTPClient) SendRequest

func (cli *OperationHTTPClient) SendRequest(exec *exec.ExecOptions, request SQLChannelRequest) (SQLChannelResponse, error)

SendRequest exec sql operation, this is a blocking operation and it will use pod EXEC subresource to send an http request to the probe pod

type OperationResult

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

type Order

type Order struct {
	OrderID  int     `json:"orderid"`
	Customer string  `json:"customer"`
	Price    float64 `json:"price"`
}