daprdriver

README

dtmdriver-gozero

go-zero driver for supporting dtm

Documentation

Index

• Constants
• func AddrForGrpc(appid string, method string) string
• func AddrForHTTP(appid string, method string) string
• func AddrForProxiedGrpc(appid string, pathAndQuery string) string
• func AddrForProxiedHTTP(appid string, pathAndQuery string) string
• func NewDaprGrpcOldURL(service string, grpcPath string) string
• func NewDaprGrpcURL(service string, method string) string
• func PayloadForGrpc(data []byte) *pb.InvokeServiceRequest
• func Use()
• type DaprAddr
  • func ParseDaprUrl(uri string) (DaprAddr, error)

Constants

const (
	DriverName = "dtm-driver-dapr"

	SchemaHTTP        = "daprhttp"
	SchemaProxiedHTTP = "daprphttp"
	SchemaGrpc        = "daprgrpc"
	SchemaProxiedGrpc = "daprpgrpc"
)

Functions

func AddrForGrpc

func AddrForGrpc(appid string, method string) string

func AddrForHTTP

func AddrForHTTP(appid string, method string) string

func AddrForProxiedGrpc

func AddrForProxiedGrpc(appid string, pathAndQuery string) string

func AddrForProxiedHTTP

func AddrForProxiedHTTP(appid string, pathAndQuery string) string

func NewDaprGrpcOldURL

func NewDaprGrpcOldURL(service string, grpcPath string) string

func NewDaprGrpcURL

func NewDaprGrpcURL(service string, method string) string

func PayloadForGrpc

func PayloadForGrpc(data []byte) *pb.InvokeServiceRequest

func Use

func Use()

Types

type DaprAddr

type DaprAddr struct {
	Schema     string
	Host       string
	Appid      string
	MethodName string // method name of dapr, or path of url without preceeding '/'
}

func ParseDaprUrl

func ParseDaprUrl(uri string) (DaprAddr, error)