mirror

type HTTPVersion int32

type HeaderValue struct {
	Values []string `protobuf:"bytes,2,rep,name=values,proto3" json:"values,omitempty"`
	// contains filtered or unexported fields
}

type MetaValue struct {

	// Types that are assignable to Value:
	//	*MetaValue_String_
	//	*MetaValue_Int
	//	*MetaValue_Bool
	Value isMetaValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

type MetaValue_Bool struct {
	Bool bool `protobuf:"varint,3,opt,name=bool,proto3,oneof"`
}

type MetaValue_Int struct {
	Int int64 `protobuf:"varint,2,opt,name=int,proto3,oneof"`
}

type MetaValue_String_ struct {
	String_ string `protobuf:"bytes,1,opt,name=string,proto3,oneof"`
}

type Method int32

type Module interface {
	Context() *ModuleContext
	SetInput(<-chan Request)
	Output() <-chan Request
	Children() [][]Module
}

type ModuleContext struct {
	Type string
	Name string
	RPS  int
	// contains filtered or unexported fields
}

type Request struct {
	Time        *timestamppb.Timestamp  `protobuf:"bytes,1,opt,name=time,proto3" json:"time,omitempty"`
	Method      Method                  `protobuf:"varint,2,opt,name=method,proto3,enum=mirror.Method" json:"method,omitempty"`
	Path        string                  `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
	HttpVersion HTTPVersion             `protobuf:"varint,4,opt,name=http_version,json=httpVersion,proto3,enum=mirror.HTTPVersion" json:"http_version,omitempty"`
	Headers     map[string]*HeaderValue `` /* 155-byte string literal not displayed */
	Body        []byte                  `protobuf:"bytes,6,opt,name=body,proto3" json:"body,omitempty"`
	Meta        map[string]*MetaValue   `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}