dapr

Documentation

Index

• Constants
• func InvokeService(appId, methodName string, data interface{}) ([]byte, error)
• func InvokeServiceWithClient(daprClient client.Client, appId, methodName string, data interface{}) ([]byte, error)
• func Publish(pubSubName, topic string, data interface{}) error
• func Reply(event *common.InvocationEvent, resp interface{}) *common.Content

Constants

const ContentTypeJson = "application/json"

Functions

func InvokeService

func InvokeService(appId, methodName string, data interface{}) ([]byte, error)

InvokeService 调用dapr服务

func InvokeServiceWithClient

func InvokeServiceWithClient(daprClient client.Client, appId, methodName string, data interface{}) ([]byte, error)

InvokeServiceWithClient 需要传入daprClient去调用

func Publish

func Publish(pubSubName, topic string, data interface{}) error

Publish 发布消息

func Reply

func Reply(event *common.InvocationEvent, resp interface{}) *common.Content

Reply dapr reply