nats

Apr 1, 2019

Changes in this version

+ func EmptyResponse(messageContext messageContext, requestContext context.Context) (bytes []byte, e error)

+ func NBBBuildResponse(messageContext messageContext, requestContext context.Context) ([]byte, error)

+ func NBBTransformMessage(messageContext messageContext, requestContext context.Context, ...) ([]byte, error)

+ func NoTransformation(messageContext messageContext, requestContext context.Context, ...) (bytes []byte, e error)

+ type Option func(Config) Config

+ func Logger(logger log.Logger) Option

Mar 29, 2019

Changes in this version

+ const CharismaIdClaimKey

+ const CharismaUserIdKey

+ const CommandIdKey

+ const CorrelationIdKey

+ const CreationDateKey

+ const MessageIdKey

+ const MetadataKey

+ const PublishTimeKey

+ const SourceKey

+ const UserIdClaimKey

+ const UserIdKey

+ func BuildResponse(messageContext map[string]interface{}, requestContext context.Context) ([]byte, error)

+ func TransformMessage(payloadBytes []byte, messageContext map[string]interface{}, ...) ([]byte, error)

+ type BuildResponseFunc func(messageContext map[string]interface{}, requestContext context.Context) ([]byte, error)

+ type CloseConnectionFunc func() error

+ func NewNatsPublisher(config Config, transformMessageFunc TransformMessageFunc, ...) (handler.Func, CloseConnectionFunc, error)

+ type CommandResult struct

+ CommandId uuid.UUID

+ CorrelationId uuid.UUID

+ type Config struct

+ ClientId string

+ Cluster string

+ DurableName string

+ NatsUrl string

+ QGroup string

+ Source string

+ TopicPrefix string

+ type EndpointConfig struct

+ Topic string

+ type Message struct

+ Headers map[string]interface{}

+ Payload map[string]interface{}

+ type TransformMessageFunc func(payloadBytes []byte, messageContext map[string]interface{}, ...) ([]byte, error)