rony

Jan 8, 2024

Changes in this version

type ServerOption

+ func WithDisableHeaderNamesNormalizing() ServerOption

Jan 3, 2024

Changes in this version

type UnaryOption

+ func ALL(path string, opt ...UnarySelectorOption) UnaryOption

Nov 15, 2023

Changes in this version

+ type NodeSelectorFunc = kit.EdgeSelectorFunc

type SetupOption

+ func WithCoordinator[S State[A], A Action](sel NodeSelectorFunc) SetupOption[S, A]

Nov 12, 2023

Changes in this version

type BaseCtx

+ func (c *BaseCtx[S, A]) Exists(key string) bool

+ func (c *BaseCtx[S, A]) Get(key string) any

+ func (c *BaseCtx[S, A]) GetInHdr(key string) string

+ func (c *BaseCtx[S, A]) GetInputHeader(key string) string

+ func (c *BaseCtx[S, A]) Set(key string, value any)

+ func (c *BaseCtx[S, A]) Walk(f func(key string, val any) bool)

+ func (c *BaseCtx[S, A]) WalkInHdr(f func(key string, val string) bool)

+ func (c *BaseCtx[S, A]) WalkInputHeader(f func(key string, val string) bool)

type Server

+ func (s *Server) ExportDesc() []desc.ServiceDesc

type UnaryCtx

+ func (c *UnaryCtx[S, A]) SetOutHdr(key, value string)

+ func (c *UnaryCtx[S, A]) SetOutHdrMap(kv map[string]string)

+ func (c *UnaryCtx[S, A]) SetOutputHeader(key, value string)

+ func (c *UnaryCtx[S, A]) SetOutputHeaderMap(kv map[string]string)

Nov 9, 2023

Changes in this version

type BaseCtx

+ func (c *BaseCtx[S, A]) KitCtx() *kit.Context

type SetupOption

+ func WithContract[S State[A], A Action](contract *desc.Contract) SetupOption[S, A]

Nov 5, 2023

Changes in this version

type ServerOption

+ func WithGlobalHandlers(handlers ...kit.HandlerFunc) ServerOption

+ func WithLogger(logger kit.Logger) ServerOption

+ func WithPrefork() ServerOption

+ func WithShutdownTimeout(timeout time.Duration) ServerOption

+ func WithTracer(tracer kit.Tracer) ServerOption

+ type StatefulMiddleware func(ctx *BaseCtx[S, A])

Nov 5, 2023

Changes in this version

+ type BaseCtx struct

+ func (c *BaseCtx[S, A]) Conn() kit.Conn

+ func (c *BaseCtx[S, A]) Context() context.Context

+ func (c *BaseCtx[S, A]) Next()

+ func (c *BaseCtx[S, A]) ReduceState(action A, fn func(s S, err error) error) (err error)

+ func (c *BaseCtx[S, A]) Route() string

+ func (c *BaseCtx[S, A]) SetUserContext(userCtx context.Context)

+ func (c *BaseCtx[S, A]) State() S

+ func (c *BaseCtx[S, A]) StopExecution()

+ type EMPTY struct

+ func (EMPTY) Reduce(action NOP) error

+ func (e EMPTY) Name() string

type InitState

+ func EmptyState() InitState[EMPTY, NOP]

+ type Middleware func(ctx *BaseCtx[S, A]) error

+ type NOP struct

+ type SetupOption func(ctx *SetupContext[S, A])

+ func WithMiddleware[S State[A], A Action](h ...StatelessMiddleware) SetupOption[S, A]

+ func WithStream[S State[A], A Action, IN, OUT Message](h StreamHandler[S, A, IN, OUT], opt ...StreamOption) SetupOption[S, A]

+ func WithUnary[S State[A], A Action, IN, OUT Message](h UnaryHandler[S, A, IN, OUT], opt ...UnaryOption) SetupOption[S, A]

+ type StatelessMiddleware = kit.HandlerFunc

Nov 4, 2023

Changes in this version

+ func RegisterStream[IN, OUT Message, S State[A], A Action](setupCtx *SetupContext[S, A], h StreamHandler[S, A, IN, OUT], ...)

+ func RegisterUnary[IN, OUT Message, S State[A], A Action](setupCtx *SetupContext[S, A], h UnaryHandler[S, A, IN, OUT], ...)

+ type Action comparable

+ type CORSConfig = fasthttp.CORSConfig

+ type CompressionLevel = fasthttp.CompressionLevel

+ const CompressionLevelBestCompression

+ const CompressionLevelBestSpeed

+ const CompressionLevelDefault

+ const CompressionLevelDisabled

+ type DecoderFunc func(bag RESTParams, data []byte) (kit.Message, error)

+ type Error struct

+ func NewError(err error) Error

+ func (e Error) Error() string

+ func (e Error) GetCode() int

+ func (e Error) GetItem() string

+ func (e Error) SetCode(code int) Error

+ func (e Error) SetItem(item string) Error

+ type InitState func() S

+ func ToInitiateState[S State[A], A Action](s S) InitState[S, A]

+ type Message kit.Message

+ type PushOpt func(e *kit.Envelope)

+ func WithHdr(key, value string) PushOpt

+ func WithHdrMap(hdr map[string]string) PushOpt

+ type RESTParam = fasthttp.Param

+ type RESTParams = fasthttp.Params

+ type Selector kit.RouteSelector

+ type Server struct

+ func NewServer(opts ...ServerOption) *Server

+ func (s *Server) PostmanCollection(filename string) error

+ func (s *Server) Run(ctx context.Context, signals ...os.Signal) error

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

+ func (s *Server) Stop(ctx context.Context, signals ...os.Signal)

+ func (s *Server) SwaggerAPI(filename string) error

+ type ServerOption func(cfg *serverConfig)

+ func Listen(addr string) ServerOption

+ func WithCORS(cors CORSConfig) ServerOption

+ func WithCompression(lvl CompressionLevel) ServerOption

+ func WithCustomRPC(in kit.IncomingRPCFactory, out kit.OutgoingRPCFactory) ServerOption

+ func WithPredicateKey(key string) ServerOption

+ func WithServerName(name string) ServerOption

+ func WithWebsocketEndpoint(endpoint string) ServerOption

+ type SetupContext struct

+ func Setup[S State[A], A Action](srv *Server, stateFactory InitState[S, A]) *SetupContext[S, A]

+ type State interface

+ Name func() string

+ Reduce func(action A)

+ type StreamCtx struct

+ func (c *StreamCtx) Conn() kit.Conn

+ func (c *StreamCtx) Context() context.Context

+ func (c *StreamCtx) Next()

+ func (c *StreamCtx) ReduceState(action A, fn func(s S) error) (err error)

+ func (c *StreamCtx) Route() string

+ func (c *StreamCtx) SetUserContext(userCtx context.Context)

+ func (c *StreamCtx) State() S

+ func (c *StreamCtx[S, A, M]) Push(m M, opt ...PushOpt) S

+ func (c *StreamCtx[S, A, M]) PushTo(conn kit.Conn, m M, opt ...PushOpt)

+ type StreamHandler func(ctx *StreamCtx[S, A, OUT], in IN) error

+ type StreamOption = stream.Option

+ func RPC(predicate string, opt ...StreamSelectorOption) StreamOption

+ type StreamSelectorOption = stream.SelectorOption

+ func StreamDecoder(decoder DecoderFunc) StreamSelectorOption

+ type UnaryCtx struct

+ func (c *UnaryCtx) Conn() kit.Conn

+ func (c *UnaryCtx) Context() context.Context

+ func (c *UnaryCtx) Next()

+ func (c *UnaryCtx) ReduceState(action A, fn func(s S) error) (err error)

+ func (c *UnaryCtx) Route() string

+ func (c *UnaryCtx) SetUserContext(userCtx context.Context)

+ func (c *UnaryCtx) State() S

+ func (c *UnaryCtx[S, A]) RESTConn() (kit.RESTConn, bool)

+ type UnaryHandler func(ctx *UnaryCtx[S, A], in IN) (*OUT, error)

+ type UnaryOption = unary.Option

+ func DELETE(path string, opt ...UnarySelectorOption) UnaryOption

+ func GET(path string, opt ...UnarySelectorOption) UnaryOption

+ func HEAD(path string, opt ...UnarySelectorOption) UnaryOption

+ func OPTIONS(path string, opt ...UnarySelectorOption) UnaryOption

+ func PATCH(path string, opt ...UnarySelectorOption) UnaryOption

+ func POST(path string, opt ...UnarySelectorOption) UnaryOption

+ func PUT(path string, opt ...UnarySelectorOption) UnaryOption

+ func REST(method, path string, opt ...UnarySelectorOption) UnaryOption

+ type UnarySelectorOption = unary.SelectorOption

+ func UnaryDecoder(decoder DecoderFunc) UnarySelectorOption

+ func UnaryName(name string) UnarySelectorOption