dapr

Documentation

Index

• Constants
• func DeleteState(storeName, key string) error
• func GetState(storeName, key string) ([]byte, error)
• 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
• func SaveState(storeName, key string, data interface{}) error

Constants

const ContentTypeJson = "application/json"

Functions

func DeleteState

func DeleteState(storeName, key string) error

DeleteState 删除状态

func GetState

func GetState(storeName, key string) ([]byte, error)

GetState 保存状态

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

func SaveState

func SaveState(storeName, key string, data interface{}) error

SaveState 保存状态