kasapp

package
v14.0.0 Latest Latest
Warning

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

 Go to latest Published: Jun 11, 2021 License: MIT Imports: 87 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 NewFromFlags 

func NewFromFlags(flagset *pflag.FlagSet, programName string, arguments []string) (cmd.Runnable, error)

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 (x *GatewayKasResponse) GetError() *GatewayKasResponse_Error

func (*GatewayKasResponse) GetHeader 

func (x *GatewayKasResponse) GetHeader() *GatewayKasResponse_Header

func (*GatewayKasResponse) GetMessage 

func (x *GatewayKasResponse) GetMessage() *GatewayKasResponse_Message

func (*GatewayKasResponse) GetMsg 

func (m *GatewayKasResponse) GetMsg() isGatewayKasResponse_Msg

func (*GatewayKasResponse) GetTrailer 

func (x *GatewayKasResponse) GetTrailer() *GatewayKasResponse_Trailer

func (*GatewayKasResponse) GetTunnelReady 

func (x *GatewayKasResponse) GetTunnelReady() *GatewayKasResponse_TunnelReady

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 

func (e GatewayKasResponseValidationError) Cause() error

Cause function returns cause value.

func (GatewayKasResponseValidationError) Error 

func (e GatewayKasResponseValidationError) Error() string

Error satisfies the builtin error interface

func (GatewayKasResponseValidationError) ErrorName 

func (e GatewayKasResponseValidationError) ErrorName() string

ErrorName returns error name.

func (GatewayKasResponseValidationError) Field 

func (e GatewayKasResponseValidationError) Field() string

Field function returns field value.

func (GatewayKasResponseValidationError) Key 

func (e GatewayKasResponseValidationError) Key() bool

Key function returns key value.

func (GatewayKasResponseValidationError) Reason 

func (e GatewayKasResponseValidationError) Reason() string

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 

func (e GatewayKasResponse_ErrorValidationError) Cause() error

Cause function returns cause value.

func (GatewayKasResponse_ErrorValidationError) Error 

func (e GatewayKasResponse_ErrorValidationError) Error() string

Error satisfies the builtin error interface

func (GatewayKasResponse_ErrorValidationError) ErrorName 

func (e GatewayKasResponse_ErrorValidationError) ErrorName() string

ErrorName returns error name.

func (GatewayKasResponse_ErrorValidationError) Field 

func (e GatewayKasResponse_ErrorValidationError) Field() string

Field function returns field value.

func (GatewayKasResponse_ErrorValidationError) Key 

func (e GatewayKasResponse_ErrorValidationError) Key() bool

Key function returns key value.

func (GatewayKasResponse_ErrorValidationError) Reason 

func (e GatewayKasResponse_ErrorValidationError) Reason() string

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 (x *GatewayKasResponse_Header) GetMeta() map[string]*prototool.Values

func (*GatewayKasResponse_Header) Metadata 

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

func (*GatewayKasResponse_Header) ProtoMessage 

func (*GatewayKasResponse_Header) ProtoMessage()

func (*GatewayKasResponse_Header) ProtoReflect 

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

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 

func (e GatewayKasResponse_HeaderValidationError) Cause() error

Cause function returns cause value.

func (GatewayKasResponse_HeaderValidationError) Error 

func (e GatewayKasResponse_HeaderValidationError) Error() string

Error satisfies the builtin error interface

func (GatewayKasResponse_HeaderValidationError) ErrorName 

func (e GatewayKasResponse_HeaderValidationError) ErrorName() string

ErrorName returns error name.

func (GatewayKasResponse_HeaderValidationError) Field 

func (e GatewayKasResponse_HeaderValidationError) Field() string

Field function returns field value.

func (GatewayKasResponse_HeaderValidationError) Key 

func (e GatewayKasResponse_HeaderValidationError) Key() bool

Key function returns key value.

func (GatewayKasResponse_HeaderValidationError) Reason 

func (e GatewayKasResponse_HeaderValidationError) Reason() string

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 (x *GatewayKasResponse_Message) ProtoReflect() protoreflect.Message

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 

func (e GatewayKasResponse_MessageValidationError) Cause() error

Cause function returns cause value.

func (GatewayKasResponse_MessageValidationError) Error 

func (e GatewayKasResponse_MessageValidationError) Error() string

Error satisfies the builtin error interface

func (GatewayKasResponse_MessageValidationError) ErrorName 

func (e GatewayKasResponse_MessageValidationError) ErrorName() string

ErrorName returns error name.

func (GatewayKasResponse_MessageValidationError) Field 

func (e GatewayKasResponse_MessageValidationError) Field() string

Field function returns field value.

func (GatewayKasResponse_MessageValidationError) Key 

func (e GatewayKasResponse_MessageValidationError) Key() bool

Key function returns key value.

func (GatewayKasResponse_MessageValidationError) Reason 

func (e GatewayKasResponse_MessageValidationError) Reason() string

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 (x *GatewayKasResponse_Trailer) GetMeta() map[string]*prototool.Values

func (*GatewayKasResponse_Trailer) Metadata 

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

func (*GatewayKasResponse_Trailer) ProtoMessage 

func (*GatewayKasResponse_Trailer) ProtoMessage()

func (*GatewayKasResponse_Trailer) ProtoReflect 

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

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 

func (e GatewayKasResponse_TrailerValidationError) Cause() error

Cause function returns cause value.

func (GatewayKasResponse_TrailerValidationError) Error 

func (e GatewayKasResponse_TrailerValidationError) Error() string

Error satisfies the builtin error interface

func (GatewayKasResponse_TrailerValidationError) ErrorName 

func (e GatewayKasResponse_TrailerValidationError) ErrorName() string

ErrorName returns error name.

func (GatewayKasResponse_TrailerValidationError) Field 

func (e GatewayKasResponse_TrailerValidationError) Field() string

Field function returns field value.

func (GatewayKasResponse_TrailerValidationError) Key 

func (e GatewayKasResponse_TrailerValidationError) Key() bool

Key function returns key value.

func (GatewayKasResponse_TrailerValidationError) Reason 

func (e GatewayKasResponse_TrailerValidationError) Reason() string

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 (x *GatewayKasResponse_TunnelReady) ProtoReflect() protoreflect.Message

func (*GatewayKasResponse_TunnelReady) Reset 

func (x *GatewayKasResponse_TunnelReady) Reset()

func (*GatewayKasResponse_TunnelReady) String 

func (x *GatewayKasResponse_TunnelReady) String() 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 

func (e GatewayKasResponse_TunnelReadyValidationError) Cause() error

Cause function returns cause value.

func (GatewayKasResponse_TunnelReadyValidationError) Error 

func (e GatewayKasResponse_TunnelReadyValidationError) Error() string

Error satisfies the builtin error interface

func (GatewayKasResponse_TunnelReadyValidationError) ErrorName 

func (e GatewayKasResponse_TunnelReadyValidationError) ErrorName() string

ErrorName returns error name.

func (GatewayKasResponse_TunnelReadyValidationError) Field 

func (e GatewayKasResponse_TunnelReadyValidationError) Field() string

Field function returns field value.

func (GatewayKasResponse_TunnelReadyValidationError) Key 

func (e GatewayKasResponse_TunnelReadyValidationError) Key() bool

Key function returns key value.

func (GatewayKasResponse_TunnelReadyValidationError) Reason 

func (e GatewayKasResponse_TunnelReadyValidationError) Reason() string

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 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 

func (e StartStreamingValidationError) Cause() error

Cause function returns cause value.

func (StartStreamingValidationError) Error 

func (e StartStreamingValidationError) Error() string

Error satisfies the builtin error interface

func (StartStreamingValidationError) ErrorName 

func (e StartStreamingValidationError) ErrorName() string

ErrorName returns error name.

func (StartStreamingValidationError) Field 

func (e StartStreamingValidationError) Field() string

Field function returns field value.

func (StartStreamingValidationError) Key 

func (e StartStreamingValidationError) Key() bool

Key function returns key value.

func (StartStreamingValidationError) Reason 

func (e StartStreamingValidationError) Reason() string

Reason function returns reason value.

Source Files

View all Source files

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.