dapr

Documentation

Index

• Constants
• func DeleteState(storeName, key string) error
• func Error(err error) (*common.Content, error)
• func GetMetaValue(ctx context.Context, key string) string
• func GetMetaValues(ctx context.Context, key string) []string
• func GetServiceInvocationName(version int, namespace, method string) string
• func GetState(storeName, key string) ([]byte, error)
• func Invoke(appId string, version int, namespace, method string, data interface{}, ...) ([]byte, error)
• func Lock(lockStore, lockOwner, resource string, expiryInSeconds int) error
• func Publish(pubSubName, topic string, data interface{}, args ...bool) error
• func SaveState(storeName, key string, value interface{}) error
• func Success(event *common.InvocationEvent, resp any) (*common.Content, error)
• func Unlock(lockStore, lockOwner, resource string) error
• type Event
  • func GetEvent(pubsubName, topic string, handler common.TopicEventHandler, args ...bool) Event

Constants

const ContentTypeJson = "application/json"

Functions

func DeleteState

func DeleteState(storeName, key string) error

DeleteState 删除状态

func Error

func Error(err error) (*common.Content, error)

func GetMetaValue

func GetMetaValue(ctx context.Context, key string) string

GetMetaValue get the first grpc meta value

func GetMetaValues

func GetMetaValues(ctx context.Context, key string) []string

GetMetaValues get grpc meta values

func GetServiceInvocationName

func GetServiceInvocationName(version int, namespace, method string) string

GetServiceInvocationName 构造version:namespace:realMethod的方法名

func GetState

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

GetState 保存状态

func Invoke

func Invoke(appId string, version int, namespace, method string, data interface{}, args ...string) ([]byte, error)

Invoke 调用dapr服务

func Lock

func Lock(lockStore, lockOwner, resource string, expiryInSeconds int) error

Lock 锁

func Publish

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

Publish 发布消息 isRawPayLoad 发送原始的消息，非cloudevent message

func SaveState

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

SaveState 保存状态

func Success

func Success(event *common.InvocationEvent, resp any) (*common.Content, error)

func Unlock

func Unlock(lockStore, lockOwner, resource string) error

Unlock 取消锁

Types

type Event

type Event struct {
	Subscription *common.Subscription
	Handler      common.TopicEventHandler
}

func GetEvent

func GetEvent(pubsubName, topic string, handler common.TopicEventHandler, args ...bool) Event