Versions in this module Expand all Collapse all v0 v0.2.0 Oct 3, 2026 v0.1.0 Oct 1, 2026 Changes in this version + func Execute() + type NATSClient interface + Close func() + Connect func() error + ConnectedServerVersion func() string + ConnectedURL func() string + ConsumeMessages func(ctx context.Context, streamName string, consumerName string, ...) error + CreateOrUpdateConsumerWithConfig func(ctx context.Context, streamName string, ...) error + CreateOrUpdateKVBucket func(ctx context.Context, bucketName string) (jetstream.KeyValue, error) + CreateOrUpdateKVBucketWithConfig func(ctx context.Context, config jetstream.KeyValueConfig) (jetstream.KeyValue, error) + CreateOrUpdateObjectStore func(ctx context.Context, cfg jetstream.ObjectStoreConfig) (jetstream.ObjectStore, error) + CreateOrUpdateStreamWithConfig func(ctx context.Context, streamConfig jetstream.StreamConfig) error + GetStreamInfo func(ctx context.Context, streamName string) (*jetstream.StreamInfo, error) + KVPut func(bucket string, key string, value []byte) error + KeyValue func(ctx context.Context, bucket string) (jetstream.KeyValue, error) + ObjectStore func(ctx context.Context, name string) (jetstream.ObjectStore, error) + Publish func(ctx context.Context, subject string, data []byte) error + PublishCore func(subject string, data []byte) error + Stream func(ctx context.Context, name string) (jetstream.Stream, error) + Subscribe func(subject string, handler nats.MsgHandler) (*nats.Subscription, error) + type ServerManager interface + RegisterHandlers func(handlers []func(e *echo.Echo)) + type TokenGenerator interface + Generate func(signingKey string, roles []string, subject string, permissions []string) (string, error) + type TokenValidator interface + Validate func(tokenString string, signingKey string) (*authtoken.CustomClaims, error)
Go to main page