bridge

Documentation

Overview

Used internally for the RPC protocol.

Index

• func ReturnTypeError(expected string) error
• func UnwrapHeaders(st *structpb.Struct) map[string][]string
• func WrapHeaders(h map[string][]string) (*structpb.Struct, error)
• func WrapString(s string) *kong_plugin_protocol.String
• type PdkBridge
  • func New(conn net.Conn) PdkBridge
  • func (b PdkBridge) Ask(method string, args proto.Message, out proto.Message) error
  • func (b PdkBridge) AskInt(method string, args proto.Message) (int, error)
  • func (b PdkBridge) AskNumber(method string, args proto.Message) (float64, error)
  • func (b PdkBridge) AskString(method string, args proto.Message) (string, error)
  • func (b PdkBridge) AskValue(method string, args proto.Message) (interface{}, error)
  • func (b PdkBridge) Close() error
• type StepData

Functions

func ReturnTypeError

func ReturnTypeError(expected string) error

func UnwrapHeaders

func UnwrapHeaders(st *structpb.Struct) map[string][]string

func WrapHeaders

func WrapHeaders(h map[string][]string) (*structpb.Struct, error)

func WrapString

func WrapString(s string) *kong_plugin_protocol.String

Types

type PdkBridge

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

func New

func New(conn net.Conn) PdkBridge

func (PdkBridge) Ask

func (b PdkBridge) Ask(method string, args proto.Message, out proto.Message) error

func (PdkBridge) AskInt

func (b PdkBridge) AskInt(method string, args proto.Message) (int, error)

func (PdkBridge) AskNumber

func (b PdkBridge) AskNumber(method string, args proto.Message) (float64, error)

func (PdkBridge) AskString

func (b PdkBridge) AskString(method string, args proto.Message) (string, error)

func (PdkBridge) AskValue

func (b PdkBridge) AskValue(method string, args proto.Message) (interface{}, error)

func (PdkBridge) Close

func (b PdkBridge) Close() error

type StepData

type StepData struct {
	Method string
	Args   []interface{}
}