twirper

type EchoReq struct {
	// Message will be echoed back in the EchoResp
	Message string `protobuf:"bytes,1,opt,name=Message" json:"Message,omitempty"`
}

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

type RepeatReq struct {
	// Message to be repeated
	Message string `protobuf:"bytes,1,opt,name=Message" json:"Message,omitempty"`
	// The number of times to repeat the message
	NumRepeats int32 `protobuf:"varint,2,opt,name=NumRepeats" json:"NumRepeats,omitempty"`
	// Milliseconds to wait between repeats
	DelayMs int64 `protobuf:"varint,3,opt,name=DelayMs" json:"DelayMs,omitempty"`
	// Send an error after this many messages (no errors if ErrAfter<=0)
	ErrAfter int32 `protobuf:"varint,4,opt,name=ErrAfter" json:"ErrAfter,omitempty"`
}

type RepeatResp struct {
	// Repeated is how many times the message has already been repeated
	// (i.e. on first resp Repeated is 0, last of n is n - 1)
	ID int32 `protobuf:"varint,3,opt,name=ID" json:"ID,omitempty"`
	// The same message as from the request
	Message string `protobuf:"bytes,1,opt,name=Message" json:"Message,omitempty"`
	// DelayedMs is how many milliseconds the delay actually took
	DelayedMs int64 `protobuf:"varint,2,opt,name=DelayedMs" json:"DelayedMs,omitempty"`
}

type RepeatRespOrError struct {
	Msg *RepeatResp
	Err error
}

type TwirpServer interface {
	http.Handler
	// ServiceDescriptor returns gzipped bytes describing the .proto file that
	// this service was generated from. Once unzipped, the bytes can be
	// unmarshalled as a
	// github.com/golang/protobuf/protoc-gen-go/descriptor.FileDescriptorProto.
	//
	// The returned integer is the index of this particular service within that
	// FileDescriptorProto's 'Service' slice of ServiceDescriptorProtos. This is a
	// low-level field, expected to be used for reflection.
	ServiceDescriptor() ([]byte, int)
	// ProtocGenTwirpVersion is the semantic version string of the version of
	// twirp used to generate this file.
	ProtocGenTwirpVersion() string
}

type Twirper interface {
	// Echo sends back what it received
	Echo(ctx context.Context, in *EchoReq) (*EchoReq, error)

	// Repeat returns a stream of repeated messages
	Repeat(ctx context.Context, in *RepeatReq) (<-chan RepeatRespOrError, error)
}