mirror

package
v1.0.13 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jan 5, 2022 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	Method_name = map[int32]string{
		0: "GET",
		1: "HEAD",
		2: "POST",
		3: "PUT",
		4: "PATCH",
		5: "DELETE",
		6: "CONNECT",
		7: "OPTIONS",
		8: "TRACE",
	}
	Method_value = map[string]int32{
		"GET":     0,
		"HEAD":    1,
		"POST":    2,
		"PUT":     3,
		"PATCH":   4,
		"DELETE":  5,
		"CONNECT": 6,
		"OPTIONS": 7,
		"TRACE":   8,
	}
)

Enum value maps for Method.

View Source 
var (
	HTTPVersion_name = map[int32]string{
		0: "HTTP1_0",
		1: "HTTP1_1",
		2: "HTTP2",
	}
	HTTPVersion_value = map[string]int32{
		"HTTP1_0": 0,
		"HTTP1_1": 1,
		"HTTP2":   2,
	}
)

Enum value maps for HTTPVersion.

View Source 
var File_request_proto protoreflect.FileDescriptor
View Source 
var (
	RequestsTotal = promauto.NewCounterVec(prometheus.CounterOpts{
		Name: "requets_total",
		Help: "The total number of requets handled by the module",
	}, []string{"module"})
)

Functions

This section is empty.

Types

type HTTPVersion 

type HTTPVersion int32
const (
	HTTPVersion_HTTP1_0 HTTPVersion = 0
	HTTPVersion_HTTP1_1 HTTPVersion = 1
	HTTPVersion_HTTP2   HTTPVersion = 2
)

func (HTTPVersion) Descriptor added in v1.0.12 

func (HTTPVersion) Descriptor() protoreflect.EnumDescriptor

func (HTTPVersion) Enum added in v1.0.12 

func (x HTTPVersion) Enum() *HTTPVersion

func (HTTPVersion) EnumDescriptor deprecated 

func (HTTPVersion) EnumDescriptor() ([]byte, []int)

Deprecated: Use HTTPVersion.Descriptor instead.

func (HTTPVersion) Number added in v1.0.12 

func (x HTTPVersion) Number() protoreflect.EnumNumber

func (HTTPVersion) String 

func (x HTTPVersion) String() string

func (HTTPVersion) Type added in v1.0.12 

func (HTTPVersion) Type() protoreflect.EnumType

type HeaderValue 

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

func (*HeaderValue) Descriptor deprecated 

func (*HeaderValue) Descriptor() ([]byte, []int)

Deprecated: Use HeaderValue.ProtoReflect.Descriptor instead.

func (*HeaderValue) GetValues 

func (x *HeaderValue) GetValues() []string

func (*HeaderValue) ProtoMessage 

func (*HeaderValue) ProtoMessage()

func (*HeaderValue) ProtoReflect added in v1.0.12 

func (x *HeaderValue) ProtoReflect() protoreflect.Message

func (*HeaderValue) Reset 

func (x *HeaderValue) Reset()

func (*HeaderValue) String 

func (x *HeaderValue) String() string

type MetaValue 

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
}

func (*MetaValue) Descriptor deprecated 

func (*MetaValue) Descriptor() ([]byte, []int)

Deprecated: Use MetaValue.ProtoReflect.Descriptor instead.

func (*MetaValue) GetBool 

func (x *MetaValue) GetBool() bool

func (*MetaValue) GetInt 

func (x *MetaValue) GetInt() int64

func (*MetaValue) GetString_ 

func (x *MetaValue) GetString_() string

func (*MetaValue) GetValue 

func (m *MetaValue) GetValue() isMetaValue_Value

func (*MetaValue) ProtoMessage 

func (*MetaValue) ProtoMessage()

func (*MetaValue) ProtoReflect added in v1.0.12 

func (x *MetaValue) ProtoReflect() protoreflect.Message

func (*MetaValue) Reset 

func (x *MetaValue) Reset()

func (*MetaValue) String 

func (x *MetaValue) String() string

type MetaValue_Bool 

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

type MetaValue_Int 

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

type MetaValue_String_ 

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

type Method 

type Method int32
const (
	Method_GET     Method = 0
	Method_HEAD    Method = 1
	Method_POST    Method = 2
	Method_PUT     Method = 3
	Method_PATCH   Method = 4
	Method_DELETE  Method = 5
	Method_CONNECT Method = 6
	Method_OPTIONS Method = 7
	Method_TRACE   Method = 8
)

func (Method) Descriptor added in v1.0.12 

func (Method) Descriptor() protoreflect.EnumDescriptor

func (Method) Enum added in v1.0.12 

func (x Method) Enum() *Method

func (Method) EnumDescriptor deprecated 

func (Method) EnumDescriptor() ([]byte, []int)

Deprecated: Use Method.Descriptor instead.

func (Method) Number added in v1.0.12 

func (x Method) Number() protoreflect.EnumNumber

func (Method) String 

func (x Method) String() string

func (Method) Type added in v1.0.12 

func (Method) Type() protoreflect.EnumType

type Module 

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

type ModuleContext 

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

func (*ModuleContext) HandledRequest 

func (c *ModuleContext) HandledRequest()

func (*ModuleContext) Role 

func (c *ModuleContext) Role() string

func (*ModuleContext) Run 

func (c *ModuleContext) Run()

type Request 

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
}

func (*Request) Descriptor deprecated 

func (*Request) Descriptor() ([]byte, []int)

Deprecated: Use Request.ProtoReflect.Descriptor instead.

func (*Request) GetBody 

func (x *Request) GetBody() []byte

func (*Request) GetHeaders 

func (x *Request) GetHeaders() map[string]*HeaderValue

func (*Request) GetHttpVersion 

func (x *Request) GetHttpVersion() HTTPVersion

func (*Request) GetMeta 

func (x *Request) GetMeta() map[string]*MetaValue

func (*Request) GetMethod 

func (x *Request) GetMethod() Method

func (*Request) GetPath 

func (x *Request) GetPath() string

func (*Request) GetTime 

func (x *Request) GetTime() *timestamppb.Timestamp

func (*Request) ProtoMessage 

func (*Request) ProtoMessage()

func (*Request) ProtoReflect added in v1.0.12 

func (x *Request) ProtoReflect() protoreflect.Message

func (*Request) Reset 

func (x *Request) Reset()

func (*Request) String 

func (x *Request) String() string

Source Files

View all Source files

Directories

Path Synopsis
modules
control
sink
source
statik

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.