Versions in this module Expand all Collapse all v0 v0.1.0 May 12, 2026 Changes in this version + type Config struct + Encode Encoder[V] + Monoid monoid.Monoid[V] + Now func() time.Time + Pipeline string + Recorder metrics.Recorder + Store state.Store[V] + Window *windowed.Config + type Encoder func(V) []byte + func BytesIdentity() Encoder[[]byte] + func Int64LE() Encoder[int64] + type Server struct + func NewServer[V any](cfg Config[V]) *Server[V] + func (s *Server[V]) Get(ctx context.Context, req *connect.Request[pb.GetRequest]) (*connect.Response[pb.GetResponse], error) + func (s *Server[V]) GetMany(ctx context.Context, req *connect.Request[pb.GetManyRequest]) (*connect.Response[pb.GetManyResponse], error) + func (s *Server[V]) GetRange(ctx context.Context, req *connect.Request[pb.GetRangeRequest]) (*connect.Response[pb.GetRangeResponse], error) + func (s *Server[V]) GetRangeMany(ctx context.Context, req *connect.Request[pb.GetRangeManyRequest]) (*connect.Response[pb.GetRangeManyResponse], error) + func (s *Server[V]) GetTrailing(ctx context.Context, req *connect.Request[pb.GetTrailingRequest]) (*connect.Response[pb.GetTrailingResponse], error) + func (s *Server[V]) GetTrailingMany(ctx context.Context, req *connect.Request[pb.GetTrailingManyRequest]) (*connect.Response[pb.GetTrailingManyResponse], error) + func (s *Server[V]) GetWindow(ctx context.Context, req *connect.Request[pb.GetWindowRequest]) (*connect.Response[pb.GetWindowResponse], error) + func (s *Server[V]) GetWindowMany(ctx context.Context, req *connect.Request[pb.GetWindowManyRequest]) (*connect.Response[pb.GetWindowManyResponse], error) + func (s *Server[V]) Handler() (string, http.Handler)
Go to main page