transactioncounter

package

v0.0.0-...-d8b4333 Latest Latest Go to latest Published: Mar 4, 2018 License: Apache-2.0 Imports: 7 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/Hyperpilotio/k8sconntrack

Documentation ¶

Index ¶

type EndpointAbsCounter
type EndpointCounter
type Transaction
- func (this *Transaction) GetEndpointsCounterMap() map[string]EndpointCounter
type TransactionCounter
- func NewTransactionCounter(conntrack *conntrack.ConnTrack) *TransactionCounter

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type EndpointAbsCounter ¶

type EndpointAbsCounter struct {
	Counts  uint64 `json:"count,omitempty"`
	Bytes   uint64 `json:"bytes"`
	Packets uint64 `json:"packets"`
	Role    string `json:"role,omitempty"`
}

type EndpointCounter ¶

type EndpointCounter struct {
	Counts  float64 `json:"count,omitempty"`
	Bytes   float64 `json:"bytes"`
	Packets float64 `json:"packets"`
	Role    string  `json:"role,omitempty"`
}

type Transaction ¶

type Transaction struct {
	ServiceId           string                        `json:"serviceID,omitempty"`
	EndpointsCounterMap map[string]EndpointCounter    `json:"endpointCounter,omitempty"`
	EpCountAbs          map[string]EndpointAbsCounter `json:"endpointAbs,omitempty"`
}

func (*Transaction) GetEndpointsCounterMap ¶

func (this *Transaction) GetEndpointsCounterMap() map[string]EndpointCounter

type TransactionCounter ¶

type TransactionCounter struct {
	// contains filtered or unexported fields
}

func NewTransactionCounter ¶

func NewTransactionCounter(conntrack *conntrack.ConnTrack) *TransactionCounter

func (*TransactionCounter) Count ¶

func (tc *TransactionCounter) Count(infos []*countInfo)

Increment the transaction count for a single endpoint. Transaction counter map uses serviceName as key and endpoint map as value. In endpoint map, key is endpoint IP address, value is the number of transaction happened on the endpoint.

func (*TransactionCounter) GetAllTransactions ¶

func (tc *TransactionCounter) GetAllTransactions() []*Transaction

func (*TransactionCounter) OnEndpointsUpdate ¶

func (this *TransactionCounter) OnEndpointsUpdate(allEndpoints []api.Endpoints)

Implement k8s.io/pkg/proxy/config/EndpointsConfigHandler Interface.

func (*TransactionCounter) ProcessConntrackConnections ¶

func (this *TransactionCounter) ProcessConntrackConnections()

Get all the current Established TCP connections from conntrack and add count to transaction counter.

func (*TransactionCounter) Reset ¶

func (tc *TransactionCounter) Reset()

Clear the transaction counter map.

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL