oteleport

package module

Go to main page

Versions in this module

v0

v0.2.3

Nov 6, 2024

v0.2.2

Nov 6, 2024

Changes in this version

type APIHTTPConfig

+ Prefix string

type OTLPHTTPConfig

+ Prefix string

v0.2.1

Nov 6, 2024

v0.2.0

Nov 1, 2024

Changes in this version

+ func ClientCLI(ctx context.Context, parse ClientCLIParseFunc) (int, error)

+ type ClientApp struct

+ func NewClientApp(p *Profile) (*ClientApp, error)

+ func (a *ClientApp) FetchLogsData(ctx context.Context, opts *ClientLogsCommandOptions) error

+ func (a *ClientApp) FetchMetricsData(ctx context.Context, opts *ClientMetricsCommandOptions) error

+ func (a *ClientApp) FetchTracesData(ctx context.Context, opts *ClientTracesCommandOptions) error

+ type ClientCLIOptions struct

+ AccessKey string

+ AccessKeyHeader string

+ Color bool

+ Endpoint string

+ ExtCode map[string]string

+ ExtStr map[string]string

+ LogLevel string

+ Logs ClientLogsCommandOptions

+ Metrics ClientMetricsCommandOptions

+ ProfilePath string

+ Traces ClientTracesCommandOptions

+ Version struct{}

+ func ParseClientCLI(args []string) (string, *ClientCLIOptions, func(), error)

+ type ClientCLIParseFunc func([]string) (string, *ClientCLIOptions, func(), error)

+ type ClientLogsCommandOptions struct

+ type ClientMetricsCommandOptions struct

+ type ClientSignalOutputOptions struct

+ OtelExporterOTLPCompression string

+ OtelExporterOTLPEndpoint string

+ OtelExporterOTLPHeaders map[string]string

+ OtelExporterOTLPLogsCompression string

+ OtelExporterOTLPLogsEndpoint string

+ OtelExporterOTLPLogsHeaders map[string]string

+ OtelExporterOTLPLogsProtocol string

+ OtelExporterOTLPLogsTimeout time.Duration

+ OtelExporterOTLPMetricsCompression string

+ OtelExporterOTLPMetricsEndpoint string

+ OtelExporterOTLPMetricsHeaders map[string]string

+ OtelExporterOTLPMetricsProtocol string

+ OtelExporterOTLPMetricsTimeout time.Duration

+ OtelExporterOTLPProtocol string

+ OtelExporterOTLPTimeout time.Duration

+ OtelExporterOTLPTracesCompression string

+ OtelExporterOTLPTracesEndpoint string

+ OtelExporterOTLPTracesHeaders map[string]string

+ OtelExporterOTLPTracesProtocol string

+ OtelExporterOTLPTracesTimeout time.Duration

+ func (o ClientSignalOutputOptions) OTLPClientOptions() []otlp.ClientOption

+ type ClientTimeRangeOptions struct

+ EndTime *time.Time

+ Since string

+ StartTime *time.Time

+ Until string

+ func (o *ClientTimeRangeOptions) TimeRangeUnixNano() (int64, int64)

+ type ClientTracesCommandOptions struct

+ type Profile struct

+ Output ClientSignalOutputOptions

+ func (p *Profile) Load(path string, opts *LoadOptions) error

+ func (p *Profile) Validate() error

type StorageConfig

+ Flatten *bool

v0.1.0

Oct 23, 2024

Changes in this version

+ var EnvNativeFunction = &jsonnet.NativeFunction

+ var JsonescapeNativeFunction = &jsonnet.NativeFunction

+ var MastEnvNativeFunction = &jsonnet.NativeFunction

+ var NativeFunctions = []*jsonnet.NativeFunction

+ var Version = "v0.1.0"

+ func Coalasce[T any](v ...*T) *T

+ func MakeVM(ctx context.Context) (*jsonnet.VM, error)

+ func Pointer[T any](v T) *T

+ func RandomString(n int) string

+ func ServerCLI(ctx context.Context, parse ServerCLIParseFunc) (int, error)

+ type APIConfig struct

+ Enable *bool

+ GRPC APIGRPCConfig

+ HTTP APIHTTPConfig

+ func (c *APIConfig) Validate() error

+ type APIGRPCConfig struct

+ Address string

+ Enable *bool

+ Listener net.Listener

+ type APIHTTPConfig struct

+ Address string

+ Enable *bool

+ Listener net.Listener

+ func (c *APIHTTPConfig) Validate(parent *APIConfig) error

+ type AccessKeyConfig struct

+ KeyID string

+ SecretKey string

+ func (c *AccessKeyConfig) UnmarshalJSON(data []byte) error

+ type LoadOptions struct

+ ExtCodes map[string]string

+ ExtVars map[string]string

+ type OTLPConfig struct

+ Enable *bool

+ GRPC OTLPGRPCConfig

+ HTTP OTLPHTTPConfig

+ func (c *OTLPConfig) Validate() error

+ type OTLPGRPCConfig struct

+ Address string

+ Enable *bool

+ Listener net.Listener

+ func (c *OTLPGRPCConfig) Validate(parent *OTLPConfig) error

+ type OTLPHTTPConfig struct

+ Address string

+ Enable *bool

+ Listener net.Listener

+ func (c *OTLPHTTPConfig) Validate(parent *OTLPConfig) error

+ type S3SignalRepository struct

+ func (r *S3SignalRepository) FetchLogsData(ctx context.Context, input *oteleportpb.FetchLogsDataRequest) (*oteleportpb.FetchLogsDataResponse, error)

+ func (r *S3SignalRepository) FetchMetricsData(ctx context.Context, input *oteleportpb.FetchMetricsDataRequest) (*oteleportpb.FetchMetricsDataResponse, error)

+ func (r *S3SignalRepository) FetchTracesData(ctx context.Context, input *oteleportpb.FetchTracesDataRequest) (*oteleportpb.FetchTracesDataResponse, error)

+ func (r *S3SignalRepository) PushLogsData(ctx context.Context, data *oteleportpb.LogsData) error

+ func (r *S3SignalRepository) PushMetricsData(ctx context.Context, data *oteleportpb.MetricsData) error

+ func (r *S3SignalRepository) PushTracesData(ctx context.Context, data *oteleportpb.TracesData) error

+ type Server struct

+ TermHandler func()

+ func NewServer(cfg *ServerConfig) (*Server, error)

+ func (s *Server) Run(ctx context.Context) error

+ type ServerCLIOptions struct

+ Color bool

+ ConfigPath string

+ ExtCode map[string]string

+ ExtStr map[string]string

+ LogLevel string

+ Serve struct{}

+ Version struct{}

+ func ParseServerCLI(args []string) (string, *ServerCLIOptions, func(), error)

+ type ServerCLIParseFunc func([]string) (string, *ServerCLIOptions, func(), error)

+ type ServerConfig struct

+ API APIConfig

+ AccessKeyHeader string

+ AccessKeys []*AccessKeyConfig

+ OTLP OTLPConfig

+ Storage StorageConfig

+ func DefaultServerConfig() *ServerConfig

+ func (c *ServerConfig) EnableAuth() bool

+ func (c *ServerConfig) Load(path string, opts *LoadOptions) error

+ func (c *ServerConfig) Validate() error

+ type SignalRepository interface

+ FetchLogsData func(ctx context.Context, input *oteleportpb.FetchLogsDataRequest) (*oteleportpb.FetchLogsDataResponse, error)

+ FetchMetricsData func(ctx context.Context, input *oteleportpb.FetchMetricsDataRequest) (*oteleportpb.FetchMetricsDataResponse, error)

+ FetchTracesData func(ctx context.Context, input *oteleportpb.FetchTracesDataRequest) (*oteleportpb.FetchTracesDataResponse, error)

+ PushLogsData func(ctx context.Context, data *oteleportpb.LogsData) error

+ PushMetricsData func(ctx context.Context, data *oteleportpb.MetricsData) error

+ PushTracesData func(ctx context.Context, data *oteleportpb.TracesData) error

+ func NewSignalRepository(cfg *StorageConfig) (SignalRepository, error)

+ type StorageAWSConfig struct

+ Credentials *StorageAWSCredentialsConfig

+ Endpoint string

+ Region string

+ UseS3PathStyle bool

+ func (c *StorageAWSConfig) Validate() error

+ type StorageAWSCredentialsConfig struct

+ AccessKeyID string

+ SecretAccessKey string

+ SessionToken string

+ type StorageConfig struct

+ AWS StorageAWSConfig

+ CursorEncryptionKey []byte

+ GZip *bool

+ Location string

+ func (c *StorageConfig) Validate(parent *ServerConfig) error

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