Versions in this module Expand all Collapse all v1 v1.0.1 Mar 6, 2022 Changes in this version + type Stats struct + func New(done <-chan bool, windowSize int, services func() []*registry.Service) (*Stats, error) + func (s *Stats) Read(ctx context.Context, req *stats.ReadRequest, rsp *stats.ReadResponse) error + func (s *Stats) Start(done <-chan bool) + func (s *Stats) Stream(ctx context.Context, req *stats.StreamRequest, rsp stats.Stats_StreamStream) error + func (s *Stats) Write(ctx context.Context, req *stats.WriteRequest, rsp *stats.WriteResponse) error
Go to main page