chassis

Apr 27, 2026

Changes in this version

type Runtime

+ func (c *Runtime) Logger() Logger

Oct 20, 2025

Changes in this version

type Config

+ LogLevel func() LogLevel

type Logger

+ Debugf func(format string, args ...any)

+ Errorf func(format string, args ...any)

+ Infof func(format string, args ...any)

+ Warnf func(format string, args ...any)

+ WithCallDepth func(depth int) Logger

Sep 14, 2024

Changes in this version

type Reader

+ SetDefault func(key string, value any)

Jun 20, 2024

Changes in this version

type Rpcer

+ EnableReflection func(string)

+ IsReflection func() bool

+ Logger func() Logger

Apr 19, 2025

Changes in this version

+ const ErrProcessRegistrationFailed

+ const FuseAddressBlueprintKey

+ const INTITIALIZE_LIMIT

+ const SYNC_INTERVAL

+ func Unwrap(err error) error

+ type BlueprintCluster struct

+ Nodes []*sdv1.Node

+ func (b *BlueprintCluster) NodeCount() int

+ func (b *BlueprintCluster) Pop() *sdv1.Node

+ type Broker interface

+ Close func(force bool) error

+ Open func(ctx context.Context, config Config) error

+ Publish func(ctx context.Context, options PublishOptions) error

+ Subscribe func(ctx context.Context, options SubscribeOptions) error

+ Unsubscribe func(ctx context.Context, options UnsubscribeOptions) error

+ type CloseChan = chan os.Signal

+ func Closer() CloseChan

+ type Config interface

+ Domain func() string

+ Entrypoint func() string

+ Env func() string

+ Name func() string

+ NodeID func() string

+ Title func() string

+ func GetConfig() Config

+ func LoadConfig() Config

+ type ConsensusKind int

+ const NullConsensusKind

+ const Raft

+ func (ck ConsensusKind) String() string

+ type ConsensusRegistrar interface

+ LeadershipChange func(log Logger, leader bool, address string)

+ RegisterConsensus func(interface{}) error

+ type Consumer interface

+ Consume func(ctx context.Context, event *events.CloudEvent) error

+ type Default interface

+ type Error struct

+ func Wrap(e error, f Fields) Error

+ func (r Error) Error() string

+ func (r Error) Fields() Fields

+ func (r Error) Unwrap() error

+ type Fields map[string]any

+ type LogLevel uint32

+ const DebugLevel

+ const ErrorLevel

+ const FatalLevel

+ const InfoLevel

+ const PanicLevel

+ const TraceLevel

+ const WarnLevel

+ func ParseLogLevel(level string) LogLevel

+ func (l LogLevel) String() string

+ type Logger interface

+ Debug func(msg string)

+ Error func(msg string)

+ Fatal func(msg string)

+ GetLevel func() LogLevel

+ Info func(msg string)

+ Panic func(msg string)

+ SetLevel func(level LogLevel)

+ Start func(config Config)

+ Trace func(msg string)

+ Warn func(msg string)

+ WithContext func(ctx context.Context) Logger

+ WithError func(err error) Logger

+ WithField func(key string, value any) Logger

+ WithFields func(fields Fields) Logger

+ Wrap func(error) error

+ WrappedError func(error, string)

+ type PublishOptions struct

+ Event *events.CloudEvent

+ Tags []string

+ type RPCHandlerKind int

+ const Grpc

+ const NullRPCHandlerKind

+ type RPCRegistrar interface

+ RegisterRPC func(server Rpcer)

+ type RaftController interface

+ GetClusterDetails func() raft.Configuration

+ Join func(ctx context.Context, nodeID, raftAddress string) error

+ Stats func(ctx context.Context) map[string]string

+ func NewRaftController(r *raft.Raft) RaftController

+ type RaftRPCHandler interface

+ func NewRaftRPCHandler(raftController RaftController) RaftRPCHandler

+ type Reader interface

+ Get func(key string) interface{}

+ GetBool func(key string) bool

+ GetDuration func(key string) time.Duration

+ GetFloat64 func(key string) float64

+ GetInt func(key string) int

+ GetInt32 func(key string) int32

+ GetInt64 func(key string) int64

+ GetIntSlice func(key string) []int

+ GetSizeInBytes func(key string) uint

+ GetString func(key string) string

+ GetStringMap func(key string) map[string]interface{}

+ GetStringMapString func(key string) map[string]string

+ GetStringMapStringSlice func(key string) map[string][]string

+ GetStringSlice func(key string) []string

+ GetTime func(key string) time.Time

+ GetUint func(key string) uint

+ GetUint16 func(key string) uint16

+ GetUint32 func(key string) uint32

+ GetUint64 func(key string) uint64

+ Unmarshal func(rawVal interface{}, opts ...viper.DecoderConfigOption) error

+ UnmarshalKey func(key string, rawVal interface{}, opts ...viper.DecoderConfigOption) error

+ type RegistrationOptions struct

+ Metadata map[string]string

+ Namespace string

+ type Repository interface

+ Close func(ctx context.Context) (err error)

+ Open func(ctx context.Context, config Config) (err error)

+ Ping func(ctx context.Context) (err error)

+ type Rpcer interface

+ AddHandler func(pattern string, handler http.Handler, enableReflection bool)

+ GetGrpcServer func() *grpc.Server

+ type Runtime struct

+ RaftController RaftController

+ func New(logger Logger) *Runtime

+ func (c *Runtime) DisableMux() *Runtime

+ func (c *Runtime) Register(options RegistrationOptions) *Runtime

+ func (c *Runtime) Start()

+ func (c *Runtime) WithBroker(plugin Broker) *Runtime

+ func (c *Runtime) WithClientApplication(files embed.FS, rootDir string) *Runtime

+ func (c *Runtime) WithConsensus(kind ConsensusKind, plugin ConsensusRegistrar) *Runtime

+ func (c *Runtime) WithRPCHandler(plugin RPCRegistrar) *Runtime

+ func (c *Runtime) WithRepository(plugin Repository) *Runtime

+ func (c *Runtime) WithRoute(route *ntv1.Route) *Runtime

+ func (c *Runtime) WithRunner(f func()) *Runtime

+ func (c *Runtime) WithSecretStore(plugin SecretStore) *Runtime

+ type SecretStore interface

+ Get func(ctx context.Context, key string) (value string, err error)

+ Open func(ctx context.Context, config Config) (err error)

+ type SubscribeOptions struct

+ Consumer Consumer

+ Event *events.CloudEvent

+ Group string

+ IgnoreType bool

+ Tags []string

+ type UnsubscribeOptions struct

+ Event *events.CloudEvent

+ IgnoreType bool

+ Tags []string

+ type Writer interface

+ Set func(key string, value any)

+ SetAndWrite func(key string, value any) error

+ SetDefault func(key string, value any)

+ WriteConfig func() error