socket

Documentation

Index

• Variables
• type REST
  • func NewREST(socketConnection bool, ec *exchanger.Exchanger) *REST
  • func (r *REST) Categories() []string
  • func (r *REST) Connect(ctx context.Context, id string, opts runtime.Object, responder rest.Responder) (http.Handler, error)
  • func (r *REST) ConnectMethods() []string
  • func (r *REST) Destroy()
  • func (r *REST) GetSingularName() string
  • func (r *REST) NamespaceScoped() bool
  • func (r *REST) New() runtime.Object
  • func (r *REST) NewConnectOptions() (runtime.Object, bool, string)
  • func (r *REST) ShortNames() []string

Variables

var (
	ConnectionCount = compbasemetrics.NewGauge(&compbasemetrics.GaugeOpts{
		Namespace:      category,
		Subsystem:      metricSubsystem,
		Name:           "count",
		Help:           "Number of socket connections",
		StabilityLevel: compbasemetrics.ALPHA,
	})

	ConnectionDurationSeconds = compbasemetrics.NewHistogram(
		&compbasemetrics.HistogramOpts{
			Namespace:      category,
			Subsystem:      metricSubsystem,
			Name:           "duration_seconds",
			Help:           "Active socket connection duration in seconds",
			Buckets:        compbasemetrics.ExponentialBuckets(60, 4, 8),
			StabilityLevel: compbasemetrics.ALPHA,
		},
	)
)

Types

type REST

type REST struct {
	Exchanger *exchanger.Exchanger
	// contains filtered or unexported fields
}

REST implements a RESTStorage for Proxies API

func NewREST

func NewREST(socketConnection bool, ec *exchanger.Exchanger) *REST

NewREST returns a RESTStorage object that will work against API services.

func (*REST) Categories

func (r *REST) Categories() []string

func (*REST) Connect

func (r *REST) Connect(ctx context.Context, id string, opts runtime.Object, responder rest.Responder) (http.Handler, error)

Connect returns a handler for the websocket connection

func (*REST) ConnectMethods

func (r *REST) ConnectMethods() []string

ConnectMethods returns the list of HTTP methods that can be proxied

func (*REST) Destroy

func (r *REST) Destroy()

func (*REST) GetSingularName

func (r *REST) GetSingularName() string

func (*REST) NamespaceScoped

func (r *REST) NamespaceScoped() bool

func (*REST) New

func (r *REST) New() runtime.Object

func (*REST) NewConnectOptions

func (r *REST) NewConnectOptions() (runtime.Object, bool, string)

NewConnectOptions returns versioned resource that represents proxy parameters

func (*REST) ShortNames

func (r *REST) ShortNames() []string