kasapp

package
v14.4.0 Latest Latest
Warning

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

Go to latest
Published: Oct 13, 2021 License: MIT Imports: 89 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var File_cmd_kas_kasapp_kasapp_proto protoreflect.FileDescriptor

Functions

func ApplyDefaultsToKasConfigurationFile

func ApplyDefaultsToKasConfigurationFile(cfg *kascfg.ConfigurationFile)

func LoadConfigurationFile

func LoadConfigurationFile(configFile string) (*kascfg.ConfigurationFile, error)

func NewCommand added in v14.1.0

func NewCommand() *cobra.Command

Types

type App

type App struct {
	ConfigurationFile string
}

func (*App) Run

func (a *App) Run(ctx context.Context) (retErr error)

type ClientConnInterface

type ClientConnInterface interface {
	grpc.ClientConnInterface
	io.Closer
}

type ConfiguredApp

type ConfiguredApp struct {
	Log           *zap.Logger
	Configuration *kascfg.ConfigurationFile
}

func (*ConfiguredApp) Run

func (a *ConfiguredApp) Run(ctx context.Context) (retErr error)

type GatewayKasResponse

type GatewayKasResponse struct {

	// Types that are assignable to Msg:
	//	*GatewayKasResponse_TunnelReady_
	//	*GatewayKasResponse_Header_
	//	*GatewayKasResponse_Message_
	//	*GatewayKasResponse_Trailer_
	//	*GatewayKasResponse_Error_
	Msg isGatewayKasResponse_Msg `protobuf_oneof:"msg"`
	// contains filtered or unexported fields
}

func (*GatewayKasResponse) Descriptor deprecated

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

Deprecated: Use GatewayKasResponse.ProtoReflect.Descriptor instead.

func (*GatewayKasResponse) GetError

func (*GatewayKasResponse) GetHeader

func (*GatewayKasResponse) GetMessage

func (*GatewayKasResponse) GetMsg

func (m *GatewayKasResponse) GetMsg() isGatewayKasResponse_Msg

func (*GatewayKasResponse) GetTrailer

func (*GatewayKasResponse) GetTunnelReady

func (*GatewayKasResponse) ProtoMessage

func (*GatewayKasResponse) ProtoMessage()

func (*GatewayKasResponse) ProtoReflect

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

func (*GatewayKasResponse) Reset

func (x *GatewayKasResponse) Reset()

func (*GatewayKasResponse) String

func (x *GatewayKasResponse) String() string

func (*GatewayKasResponse) Validate

func (m *GatewayKasResponse) Validate() error

Validate checks the field values on GatewayKasResponse with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type GatewayKasResponseValidationError

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

GatewayKasResponseValidationError is the validation error returned by GatewayKasResponse.Validate if the designated constraints aren't met.

func (GatewayKasResponseValidationError) Cause

Cause function returns cause value.

func (GatewayKasResponseValidationError) Error

Error satisfies the builtin error interface

func (GatewayKasResponseValidationError) ErrorName

ErrorName returns error name.

func (GatewayKasResponseValidationError) Field

Field function returns field value.

func (GatewayKasResponseValidationError) Key

Key function returns key value.

func (GatewayKasResponseValidationError) Reason

Reason function returns reason value.

type GatewayKasResponse_Error

type GatewayKasResponse_Error struct {
	Status *status.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GatewayKasResponse_Error) Descriptor deprecated

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

Deprecated: Use GatewayKasResponse_Error.ProtoReflect.Descriptor instead.

func (*GatewayKasResponse_Error) GetStatus

func (x *GatewayKasResponse_Error) GetStatus() *status.Status

func (*GatewayKasResponse_Error) ProtoMessage

func (*GatewayKasResponse_Error) ProtoMessage()

func (*GatewayKasResponse_Error) ProtoReflect

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

func (*GatewayKasResponse_Error) Reset

func (x *GatewayKasResponse_Error) Reset()

func (*GatewayKasResponse_Error) String

func (x *GatewayKasResponse_Error) String() string

func (*GatewayKasResponse_Error) Validate

func (m *GatewayKasResponse_Error) Validate() error

Validate checks the field values on GatewayKasResponse_Error with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type GatewayKasResponse_ErrorValidationError

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

GatewayKasResponse_ErrorValidationError is the validation error returned by GatewayKasResponse_Error.Validate if the designated constraints aren't met.

func (GatewayKasResponse_ErrorValidationError) Cause

Cause function returns cause value.

func (GatewayKasResponse_ErrorValidationError) Error

Error satisfies the builtin error interface

func (GatewayKasResponse_ErrorValidationError) ErrorName

ErrorName returns error name.

func (GatewayKasResponse_ErrorValidationError) Field

Field function returns field value.

func (GatewayKasResponse_ErrorValidationError) Key

Key function returns key value.

func (GatewayKasResponse_ErrorValidationError) Reason

Reason function returns reason value.

type GatewayKasResponse_Error_

type GatewayKasResponse_Error_ struct {
	Error *GatewayKasResponse_Error `protobuf:"bytes,5,opt,name=error,proto3,oneof"`
}

type GatewayKasResponse_Header

type GatewayKasResponse_Header struct {
	Meta map[string]*prototool.Values `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GatewayKasResponse_Header) Descriptor deprecated

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

Deprecated: Use GatewayKasResponse_Header.ProtoReflect.Descriptor instead.

func (*GatewayKasResponse_Header) GetMeta

func (*GatewayKasResponse_Header) Metadata

func (x *GatewayKasResponse_Header) Metadata() metadata.MD

func (*GatewayKasResponse_Header) ProtoMessage

func (*GatewayKasResponse_Header) ProtoMessage()

func (*GatewayKasResponse_Header) ProtoReflect

func (*GatewayKasResponse_Header) Reset

func (x *GatewayKasResponse_Header) Reset()

func (*GatewayKasResponse_Header) String

func (x *GatewayKasResponse_Header) String() string

func (*GatewayKasResponse_Header) Validate

func (m *GatewayKasResponse_Header) Validate() error

Validate checks the field values on GatewayKasResponse_Header with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type GatewayKasResponse_HeaderValidationError

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

GatewayKasResponse_HeaderValidationError is the validation error returned by GatewayKasResponse_Header.Validate if the designated constraints aren't met.

func (GatewayKasResponse_HeaderValidationError) Cause

Cause function returns cause value.

func (GatewayKasResponse_HeaderValidationError) Error

Error satisfies the builtin error interface

func (GatewayKasResponse_HeaderValidationError) ErrorName

ErrorName returns error name.

func (GatewayKasResponse_HeaderValidationError) Field

Field function returns field value.

func (GatewayKasResponse_HeaderValidationError) Key

Key function returns key value.

func (GatewayKasResponse_HeaderValidationError) Reason

Reason function returns reason value.

type GatewayKasResponse_Header_

type GatewayKasResponse_Header_ struct {
	Header *GatewayKasResponse_Header `protobuf:"bytes,2,opt,name=header,proto3,oneof"`
}

type GatewayKasResponse_Message

type GatewayKasResponse_Message struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*GatewayKasResponse_Message) Descriptor deprecated

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

Deprecated: Use GatewayKasResponse_Message.ProtoReflect.Descriptor instead.

func (*GatewayKasResponse_Message) GetData

func (x *GatewayKasResponse_Message) GetData() []byte

func (*GatewayKasResponse_Message) ProtoMessage

func (*GatewayKasResponse_Message) ProtoMessage()

func (*GatewayKasResponse_Message) ProtoReflect

func (*GatewayKasResponse_Message) Reset

func (x *GatewayKasResponse_Message) Reset()

func (*GatewayKasResponse_Message) String

func (x *GatewayKasResponse_Message) String() string

func (*GatewayKasResponse_Message) Validate

func (m *GatewayKasResponse_Message) Validate() error

Validate checks the field values on GatewayKasResponse_Message with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type GatewayKasResponse_MessageValidationError

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

GatewayKasResponse_MessageValidationError is the validation error returned by GatewayKasResponse_Message.Validate if the designated constraints aren't met.

func (GatewayKasResponse_MessageValidationError) Cause

Cause function returns cause value.

func (GatewayKasResponse_MessageValidationError) Error

Error satisfies the builtin error interface

func (GatewayKasResponse_MessageValidationError) ErrorName

ErrorName returns error name.

func (GatewayKasResponse_MessageValidationError) Field

Field function returns field value.

func (GatewayKasResponse_MessageValidationError) Key

Key function returns key value.

func (GatewayKasResponse_MessageValidationError) Reason

Reason function returns reason value.

type GatewayKasResponse_Message_

type GatewayKasResponse_Message_ struct {
	Message *GatewayKasResponse_Message `protobuf:"bytes,3,opt,name=message,proto3,oneof"`
}

type GatewayKasResponse_Trailer

type GatewayKasResponse_Trailer struct {
	Meta map[string]*prototool.Values `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*GatewayKasResponse_Trailer) Descriptor deprecated

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

Deprecated: Use GatewayKasResponse_Trailer.ProtoReflect.Descriptor instead.

func (*GatewayKasResponse_Trailer) GetMeta

func (*GatewayKasResponse_Trailer) Metadata

func (x *GatewayKasResponse_Trailer) Metadata() metadata.MD

func (*GatewayKasResponse_Trailer) ProtoMessage

func (*GatewayKasResponse_Trailer) ProtoMessage()

func (*GatewayKasResponse_Trailer) ProtoReflect

func (*GatewayKasResponse_Trailer) Reset

func (x *GatewayKasResponse_Trailer) Reset()

func (*GatewayKasResponse_Trailer) String

func (x *GatewayKasResponse_Trailer) String() string

func (*GatewayKasResponse_Trailer) Validate

func (m *GatewayKasResponse_Trailer) Validate() error

Validate checks the field values on GatewayKasResponse_Trailer with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type GatewayKasResponse_TrailerValidationError

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

GatewayKasResponse_TrailerValidationError is the validation error returned by GatewayKasResponse_Trailer.Validate if the designated constraints aren't met.

func (GatewayKasResponse_TrailerValidationError) Cause

Cause function returns cause value.

func (GatewayKasResponse_TrailerValidationError) Error

Error satisfies the builtin error interface

func (GatewayKasResponse_TrailerValidationError) ErrorName

ErrorName returns error name.

func (GatewayKasResponse_TrailerValidationError) Field

Field function returns field value.

func (GatewayKasResponse_TrailerValidationError) Key

Key function returns key value.

func (GatewayKasResponse_TrailerValidationError) Reason

Reason function returns reason value.

type GatewayKasResponse_Trailer_

type GatewayKasResponse_Trailer_ struct {
	Trailer *GatewayKasResponse_Trailer `protobuf:"bytes,4,opt,name=trailer,proto3,oneof"`
}

type GatewayKasResponse_TunnelReady

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

func (*GatewayKasResponse_TunnelReady) Descriptor deprecated

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

Deprecated: Use GatewayKasResponse_TunnelReady.ProtoReflect.Descriptor instead.

func (*GatewayKasResponse_TunnelReady) ProtoMessage

func (*GatewayKasResponse_TunnelReady) ProtoMessage()

func (*GatewayKasResponse_TunnelReady) ProtoReflect

func (*GatewayKasResponse_TunnelReady) Reset

func (x *GatewayKasResponse_TunnelReady) Reset()

func (*GatewayKasResponse_TunnelReady) String

func (*GatewayKasResponse_TunnelReady) Validate

func (m *GatewayKasResponse_TunnelReady) Validate() error

Validate checks the field values on GatewayKasResponse_TunnelReady with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type GatewayKasResponse_TunnelReadyValidationError

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

GatewayKasResponse_TunnelReadyValidationError is the validation error returned by GatewayKasResponse_TunnelReady.Validate if the designated constraints aren't met.

func (GatewayKasResponse_TunnelReadyValidationError) Cause

Cause function returns cause value.

func (GatewayKasResponse_TunnelReadyValidationError) Error

Error satisfies the builtin error interface

func (GatewayKasResponse_TunnelReadyValidationError) ErrorName

ErrorName returns error name.

func (GatewayKasResponse_TunnelReadyValidationError) Field

Field function returns field value.

func (GatewayKasResponse_TunnelReadyValidationError) Key

Key function returns key value.

func (GatewayKasResponse_TunnelReadyValidationError) Reason

Reason function returns reason value.

type GatewayKasResponse_TunnelReady_

type GatewayKasResponse_TunnelReady_ struct {
	TunnelReady *GatewayKasResponse_TunnelReady `protobuf:"bytes,1,opt,name=tunnel_ready,json=tunnelReady,proto3,oneof"`
}

type KasPool

type KasPool interface {
	Dial(ctx context.Context, target string) (ClientConnInterface, error)
}

type SentryHub added in v14.2.0

type SentryHub interface {
	CaptureEvent(event *sentry.Event) *sentry.EventID
}

type StartStreaming

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

func (*StartStreaming) Descriptor deprecated

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

Deprecated: Use StartStreaming.ProtoReflect.Descriptor instead.

func (*StartStreaming) ProtoMessage

func (*StartStreaming) ProtoMessage()

func (*StartStreaming) ProtoReflect

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

func (*StartStreaming) Reset

func (x *StartStreaming) Reset()

func (*StartStreaming) String

func (x *StartStreaming) String() string

func (*StartStreaming) Validate

func (m *StartStreaming) Validate() error

Validate checks the field values on StartStreaming with the rules defined in the proto definition for this message. If any rules are violated, an error is returned.

type StartStreamingValidationError

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

StartStreamingValidationError is the validation error returned by StartStreaming.Validate if the designated constraints aren't met.

func (StartStreamingValidationError) Cause

Cause function returns cause value.

func (StartStreamingValidationError) Error

Error satisfies the builtin error interface

func (StartStreamingValidationError) ErrorName

func (e StartStreamingValidationError) ErrorName() string

ErrorName returns error name.

func (StartStreamingValidationError) Field

Field function returns field value.

func (StartStreamingValidationError) Key

Key function returns key value.

func (StartStreamingValidationError) Reason

Reason function returns reason value.

Jump to

Keyboard shortcuts

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