ping

Documentation

Index

• type PingServer
  • func NewPingServer(logger slog.Logger) *PingServer
  • func (server *PingServer) Count(ctx context.Context, ...) (err error)
  • func (server *PingServer) Generate(ctx context.Context, req *connect.Request[pingv1.GenerateRequest], ...) (err error)
  • func (server *PingServer) HardFail(ctx context.Context, req *connect.Request[pingv1.HardFailRequest]) (resp *connect.Response[pingv1.HardFailResponse], err error)
  • func (server *PingServer) Ping(ctx context.Context, req *connect.Request[pingv1.PingRequest]) (resp *connect.Response[pingv1.PingResponse], err error)
  • func (server *PingServer) Sum(ctx context.Context, reqStream *connect.ClientStream[pingv1.SumRequest]) (resp *connect.Response[pingv1.SumResponse], err error)

Types

type PingServer

type PingServer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

PingServer is used to encapsulate a Ping Server implementation state using connectrpc receivers

func NewPingServer

func NewPingServer(logger slog.Logger) *PingServer

NewPingServer returns a new PingServer instance

func (*PingServer) Count

func (server *PingServer) Count(ctx context.Context, stream *connect.BidiStream[pingv1.CountRequest, pingv1.CountResponse]) (err error)

Count returns a stream of the numbers 1+total -> recieved.addition+total for every received message on the clients stream

func (*PingServer) Generate

func (server *PingServer) Generate(ctx context.Context, req *connect.Request[pingv1.GenerateRequest],
	respStream *connect.ServerStream[pingv1.GenerateResponse]) (err error)

Generate returns a stream of the numbers total -> total+addition up to the given limit specified in the request

func (*PingServer) HardFail

func (server *PingServer) HardFail(ctx context.Context, req *connect.Request[pingv1.HardFailRequest],
) (resp *connect.Response[pingv1.HardFailResponse], err error)

HardFail generates an error and returns it to the client when invoked

func (*PingServer) Ping

func (server *PingServer) Ping(ctx context.Context, req *connect.Request[pingv1.PingRequest],
) (resp *connect.Response[pingv1.PingResponse], err error)

Ping receives a client ping for the server to determine if it's reachable and will return the sum from previous requests

func (*PingServer) Sum

func (server *PingServer) Sum(ctx context.Context, reqStream *connect.ClientStream[pingv1.SumRequest],
) (resp *connect.Response[pingv1.SumResponse], err error)

Sum returns the sum of the numbers sent on the SumRequest stream and returns a single total that represents the previous sum plus the SumRequest sum