daprInvoke

Documentation

Index

• func AddServiceInvocationHandler(name string, ...) error
• func AddTopicEventHandler(topic string, ...) error
• func InitClient(port string) (err error)
• func InitServer(port string) (err error)
• func InvokeMethod(serviceAppId, methodName string, data []byte) ([]byte, error)
• func MakeOutputContent(in *common.InvocationEvent, resp interface{}) (out *common.Content, err error)
• func PubSubEventCall(topic string, jsonString string, expire grpc.EventExpire) error
• func Start() error
• func Stop()

Functions

func AddServiceInvocationHandler

func AddServiceInvocationHandler(
	name string,
	f func(context.Context, *common.InvocationEvent) (*common.Content, error),
) error

func AddTopicEventHandler

func AddTopicEventHandler(topic string,
	fn func(ctx context.Context, e *common.TopicEvent) (retry bool, err error),
) error

func InitClient

func InitClient(port string) (err error)

func InitServer

func InitServer(port string) (err error)

func InvokeMethod

func InvokeMethod(serviceAppId, methodName string, data []byte) ([]byte, error)

func MakeOutputContent

func MakeOutputContent(in *common.InvocationEvent, resp interface{}) (out *common.Content, err error)

func PubSubEventCall

func PubSubEventCall(topic string, jsonString string, expire grpc.EventExpire) error

func Start

func Start() error

func Stop

func Stop()