api

Documentation

Index

• func Call[T proto.Message, U proto.Message](ctx context.Context, con *nats.Conn, subject string, ...) error
• func CallReturnStream[T proto.Message, U proto.Message](ctx context.Context, con *nats.Conn, subject string, ...) error

Functions

func Call

func Call[T proto.Message, U proto.Message](ctx context.Context, con *nats.Conn, subject string, expectCompat *version2.Version, sendMiddleware []middleware.Send, command T, ret U) error

Call provides the functionality to call shar APIs

func CallReturnStream

func CallReturnStream[T proto.Message, U proto.Message](ctx context.Context, con *nats.Conn, subject string, expectCompat *version2.Version, sendMiddleware []middleware.Send, command T, container U, fn func(ret U) error) error

CallReturnStream provides the functionality to call shar APIs and receive a streaming response