pillow

Jan 12, 2025

Changes in this version

type FlyioHubAndSpoke

+ DisableClustering bool

type Option

+ func WithSystemUser(enable bool, username, password string) Option

Jan 10, 2025

Changes in this version

+ var ErrStartupTimedOut = errors.New("embedded nats server startup timed out")

type Option

+ func WithoutInProcessClient(enable bool) Option

type Server

+ func (s *Server) NATSClient() (*nats.Conn, error)

Jan 9, 2025

Changes in this version

type Server

+ NATSServer *server.Server

Jan 9, 2025

Changes in this version

+ const ClusterPort

+ const GatewayPort

+ const LeafNodePort

+ var Client *nats.Conn

+ var ErrEnvVarNotFound = errors.New("Platform ENV not found")

+ var ErrPlatformImplementationChanged = errors.New("Platform implementation changed")

+ type FlyioClustering struct

+ ClusterName string

+ func (c *FlyioClustering) Configure(ctx context.Context) Option

+ type FlyioHubAndSpoke struct

+ ClusterName string

+ func (c *FlyioHubAndSpoke) Configure(ctx context.Context) Option

+ type Option func(*options) error

+ func WithInProcessClient(b bool) Option

+ func WithJetStream(dir string) Option

+ func WithLogging(b bool) Option

+ func WithNATSServerOptions(natsServerOpts *server.Options) Option

+ func WithPlatformAdapter(ctx context.Context, enable bool, platformCfgr PlatformConfigurator) Option

+ func WithTimeout(t time.Duration) Option

+ type PlatformConfigurator interface

+ Configure func(context.Context) Option

+ type Server struct

+ NatsServer *server.Server

+ func Run(opts ...Option) (*nats.Conn, *Server, error)

+ func (s *Server) Shutdown(ctx context.Context) error