system

package

v0.0.0-...-fae6323 Latest Latest Go to latest Published: Mar 19, 2026 License: MIT Imports: 20 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/bd878/gallery

Links

Open Source Insights

Documentation ¶

Index ¶

type Config
type Service
type System
- func NewSystem(cfg Config) (*System, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	RpcAddr        string
	NodeName       string
	LogLevel       string
	SkipCaller     int
	NatsAddr       string
	PGConn         string
	GooseTableName string
}

type Service ¶

type Service interface {
	DB() *sql.DB
	Config() Config
	Pool() *pgxpool.Pool
	Mux() cmux.CMux
	Nats() *nats.Conn
	RPC() *grpc.Server
	Waiter() waiter.Waiter
	Logger() *logger.Logger
	RaftListener() net.Listener
}

type System ¶

type System struct {
	// contains filtered or unexported fields
}

func NewSystem ¶

func NewSystem(cfg Config) (*System, error)

func (*System) Addr ¶

func (s *System) Addr() string

func (*System) Config ¶

func (s *System) Config() Config

func (*System) DB ¶

func (s *System) DB() *sql.DB

func (*System) Listener ¶

func (s *System) Listener() net.Listener

func (*System) Logger ¶

func (s *System) Logger() *logger.Logger

func (*System) MigrateDB ¶

func (s *System) MigrateDB(fs fs.FS) error

func (*System) Mux ¶

func (s *System) Mux() cmux.CMux

func (*System) Nats ¶

func (s *System) Nats() *nats.Conn

func (*System) Pool ¶

func (s *System) Pool() *pgxpool.Pool

func (*System) RPC ¶

func (s *System) RPC() *grpc.Server

func (*System) RaftListener ¶

func (s *System) RaftListener() net.Listener

func (*System) ResetDB ¶

func (s *System) ResetDB() error

func (*System) WaitForMux ¶

func (s *System) WaitForMux(ctx context.Context) (err error)

func (*System) WaitForPool ¶

func (s *System) WaitForPool(ctx context.Context) (err error)

func (*System) WaitForRPC ¶

func (s *System) WaitForRPC(ctx context.Context) (err error)

func (*System) WaitForStream ¶

func (s *System) WaitForStream(ctx context.Context) error

func (*System) Waiter ¶

func (s *System) Waiter() waiter.Waiter

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL