logspb

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Mar 6, 2026 License: AGPL-3.0 Imports: 13 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	LogPlugin_GetSupportedResources_FullMethodName = "/omniview.sdk.logs.v1.LogPlugin/GetSupportedResources"
	LogPlugin_CreateSession_FullMethodName         = "/omniview.sdk.logs.v1.LogPlugin/CreateSession"
	LogPlugin_GetSession_FullMethodName            = "/omniview.sdk.logs.v1.LogPlugin/GetSession"
	LogPlugin_ListSessions_FullMethodName          = "/omniview.sdk.logs.v1.LogPlugin/ListSessions"
	LogPlugin_CloseSession_FullMethodName          = "/omniview.sdk.logs.v1.LogPlugin/CloseSession"
	LogPlugin_UpdateSessionOptions_FullMethodName  = "/omniview.sdk.logs.v1.LogPlugin/UpdateSessionOptions"
	LogPlugin_Stream_FullMethodName                = "/omniview.sdk.logs.v1.LogPlugin/Stream"
)

Variables

View Source 
var (
	LogLineOrigin_name = map[int32]string{
		0: "LOG_LINE_ORIGIN_CURRENT",
		1: "LOG_LINE_ORIGIN_PREVIOUS",
		2: "LOG_LINE_ORIGIN_SYSTEM",
	}
	LogLineOrigin_value = map[string]int32{
		"LOG_LINE_ORIGIN_CURRENT":  0,
		"LOG_LINE_ORIGIN_PREVIOUS": 1,
		"LOG_LINE_ORIGIN_SYSTEM":   2,
	}
)

Enum value maps for LogLineOrigin.

View Source 
var (
	LogStreamEventType_name = map[int32]string{
		0: "LOG_STREAM_EVENT_SOURCE_ADDED",
		1: "LOG_STREAM_EVENT_SOURCE_REMOVED",
		2: "LOG_STREAM_EVENT_STREAM_ERROR",
		3: "LOG_STREAM_EVENT_RECONNECTING",
		4: "LOG_STREAM_EVENT_RECONNECTED",
		5: "LOG_STREAM_EVENT_STREAM_ENDED",
		6: "LOG_STREAM_EVENT_SESSION_READY",
	}
	LogStreamEventType_value = map[string]int32{
		"LOG_STREAM_EVENT_SOURCE_ADDED":   0,
		"LOG_STREAM_EVENT_SOURCE_REMOVED": 1,
		"LOG_STREAM_EVENT_STREAM_ERROR":   2,
		"LOG_STREAM_EVENT_RECONNECTING":   3,
		"LOG_STREAM_EVENT_RECONNECTED":    4,
		"LOG_STREAM_EVENT_STREAM_ENDED":   5,
		"LOG_STREAM_EVENT_SESSION_READY":  6,
	}
)

Enum value maps for LogStreamEventType.

View Source 
var (
	LogStreamCommand_name = map[int32]string{
		0: "LOG_STREAM_COMMAND_PAUSE",
		1: "LOG_STREAM_COMMAND_RESUME",
		2: "LOG_STREAM_COMMAND_CLOSE",
	}
	LogStreamCommand_value = map[string]int32{
		"LOG_STREAM_COMMAND_PAUSE":  0,
		"LOG_STREAM_COMMAND_RESUME": 1,
		"LOG_STREAM_COMMAND_CLOSE":  2,
	}
)

Enum value maps for LogStreamCommand.

View Source 
var (
	LogSessionStatus_name = map[int32]string{
		0: "LOG_SESSION_STATUS_ACTIVE",
		1: "LOG_SESSION_STATUS_PAUSED",
		2: "LOG_SESSION_STATUS_CLOSED",
		3: "LOG_SESSION_STATUS_ERROR",
		4: "LOG_SESSION_STATUS_CONNECTING",
		5: "LOG_SESSION_STATUS_INITIALIZING",
	}
	LogSessionStatus_value = map[string]int32{
		"LOG_SESSION_STATUS_ACTIVE":       0,
		"LOG_SESSION_STATUS_PAUSED":       1,
		"LOG_SESSION_STATUS_CLOSED":       2,
		"LOG_SESSION_STATUS_ERROR":        3,
		"LOG_SESSION_STATUS_CONNECTING":   4,
		"LOG_SESSION_STATUS_INITIALIZING": 5,
	}
)

Enum value maps for LogSessionStatus.

View Source 
var (
	LogLevel_name = map[int32]string{
		0: "LOG_LEVEL_UNSPECIFIED",
		1: "LOG_LEVEL_TRACE",
		2: "LOG_LEVEL_DEBUG",
		3: "LOG_LEVEL_INFO",
		4: "LOG_LEVEL_WARN",
		5: "LOG_LEVEL_ERROR",
		6: "LOG_LEVEL_FATAL",
	}
	LogLevel_value = map[string]int32{
		"LOG_LEVEL_UNSPECIFIED": 0,
		"LOG_LEVEL_TRACE":       1,
		"LOG_LEVEL_DEBUG":       2,
		"LOG_LEVEL_INFO":        3,
		"LOG_LEVEL_WARN":        4,
		"LOG_LEVEL_ERROR":       5,
		"LOG_LEVEL_FATAL":       6,
	}
)

Enum value maps for LogLevel.

View Source 
var File_proto_v1_logs_logs_proto protoreflect.FileDescriptor
View Source 
var LogPlugin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "omniview.sdk.logs.v1.LogPlugin",
	HandlerType: (*LogPluginServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetSupportedResources",
			Handler:    _LogPlugin_GetSupportedResources_Handler,
		},
		{
			MethodName: "CreateSession",
			Handler:    _LogPlugin_CreateSession_Handler,
		},
		{
			MethodName: "GetSession",
			Handler:    _LogPlugin_GetSession_Handler,
		},
		{
			MethodName: "ListSessions",
			Handler:    _LogPlugin_ListSessions_Handler,
		},
		{
			MethodName: "CloseSession",
			Handler:    _LogPlugin_CloseSession_Handler,
		},
		{
			MethodName: "UpdateSessionOptions",
			Handler:    _LogPlugin_UpdateSessionOptions_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Stream",
			Handler:       _LogPlugin_Stream_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "proto/v1/logs/logs.proto",
}

LogPlugin_ServiceDesc is the grpc.ServiceDesc for LogPlugin service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterLogPluginServer 

func RegisterLogPluginServer(s grpc.ServiceRegistrar, srv LogPluginServer)

Types

type CloseLogSessionResponse 

type CloseLogSessionResponse struct {
	Success bool   `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
	Error   string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseLogSessionResponse) Descriptor deprecated 

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

Deprecated: Use CloseLogSessionResponse.ProtoReflect.Descriptor instead.

func (*CloseLogSessionResponse) GetError 

func (x *CloseLogSessionResponse) GetError() string

func (*CloseLogSessionResponse) GetSuccess 

func (x *CloseLogSessionResponse) GetSuccess() bool

func (*CloseLogSessionResponse) ProtoMessage 

func (*CloseLogSessionResponse) ProtoMessage()

func (*CloseLogSessionResponse) ProtoReflect 

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

func (*CloseLogSessionResponse) Reset 

func (x *CloseLogSessionResponse) Reset()

func (*CloseLogSessionResponse) String 

func (x *CloseLogSessionResponse) String() string

type CreateLogSessionRequest 

type CreateLogSessionRequest struct {
	ResourceKey  string             `protobuf:"bytes,1,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	ResourceId   string             `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	ResourceData *structpb.Struct   `protobuf:"bytes,3,opt,name=resource_data,json=resourceData,proto3" json:"resource_data,omitempty"`
	Options      *LogSessionOptions `protobuf:"bytes,4,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateLogSessionRequest) Descriptor deprecated 

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

Deprecated: Use CreateLogSessionRequest.ProtoReflect.Descriptor instead.

func (*CreateLogSessionRequest) GetOptions 

func (x *CreateLogSessionRequest) GetOptions() *LogSessionOptions

func (*CreateLogSessionRequest) GetResourceData 

func (x *CreateLogSessionRequest) GetResourceData() *structpb.Struct

func (*CreateLogSessionRequest) GetResourceId 

func (x *CreateLogSessionRequest) GetResourceId() string

func (*CreateLogSessionRequest) GetResourceKey 

func (x *CreateLogSessionRequest) GetResourceKey() string

func (*CreateLogSessionRequest) ProtoMessage 

func (*CreateLogSessionRequest) ProtoMessage()

func (*CreateLogSessionRequest) ProtoReflect 

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

func (*CreateLogSessionRequest) Reset 

func (x *CreateLogSessionRequest) Reset()

func (*CreateLogSessionRequest) String 

func (x *CreateLogSessionRequest) String() string

type CreateLogSessionResponse 

type CreateLogSessionResponse struct {
	Session *LogSession `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Success bool        `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Error   string      `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateLogSessionResponse) Descriptor deprecated 

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

Deprecated: Use CreateLogSessionResponse.ProtoReflect.Descriptor instead.

func (*CreateLogSessionResponse) GetError 

func (x *CreateLogSessionResponse) GetError() string

func (*CreateLogSessionResponse) GetSession 

func (x *CreateLogSessionResponse) GetSession() *LogSession

func (*CreateLogSessionResponse) GetSuccess 

func (x *CreateLogSessionResponse) GetSuccess() bool

func (*CreateLogSessionResponse) ProtoMessage 

func (*CreateLogSessionResponse) ProtoMessage()

func (*CreateLogSessionResponse) ProtoReflect 

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

func (*CreateLogSessionResponse) Reset 

func (x *CreateLogSessionResponse) Reset()

func (*CreateLogSessionResponse) String 

func (x *CreateLogSessionResponse) String() string

type GetSupportedLogResourcesResponse 

type GetSupportedLogResourcesResponse struct {
	Handlers []*LogHandler `protobuf:"bytes,1,rep,name=handlers,proto3" json:"handlers,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSupportedLogResourcesResponse) Descriptor deprecated 

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

Deprecated: Use GetSupportedLogResourcesResponse.ProtoReflect.Descriptor instead.

func (*GetSupportedLogResourcesResponse) GetHandlers 

func (x *GetSupportedLogResourcesResponse) GetHandlers() []*LogHandler

func (*GetSupportedLogResourcesResponse) ProtoMessage 

func (*GetSupportedLogResourcesResponse) ProtoMessage()

func (*GetSupportedLogResourcesResponse) ProtoReflect 

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

func (*GetSupportedLogResourcesResponse) Reset 

func (x *GetSupportedLogResourcesResponse) Reset()

func (*GetSupportedLogResourcesResponse) String 

func (x *GetSupportedLogResourcesResponse) String() string

type ListLogSessionsResponse 

type ListLogSessionsResponse struct {
	Sessions []*LogSession `protobuf:"bytes,1,rep,name=sessions,proto3" json:"sessions,omitempty"`
	Success  bool          `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Error    string        `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*ListLogSessionsResponse) Descriptor deprecated 

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

Deprecated: Use ListLogSessionsResponse.ProtoReflect.Descriptor instead.

func (*ListLogSessionsResponse) GetError 

func (x *ListLogSessionsResponse) GetError() string

func (*ListLogSessionsResponse) GetSessions 

func (x *ListLogSessionsResponse) GetSessions() []*LogSession

func (*ListLogSessionsResponse) GetSuccess 

func (x *ListLogSessionsResponse) GetSuccess() bool

func (*ListLogSessionsResponse) ProtoMessage 

func (*ListLogSessionsResponse) ProtoMessage()

func (*ListLogSessionsResponse) ProtoReflect 

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

func (*ListLogSessionsResponse) Reset 

func (x *ListLogSessionsResponse) Reset()

func (*ListLogSessionsResponse) String 

func (x *ListLogSessionsResponse) String() string

type LogHandler 

type LogHandler struct {
	Plugin        string                      `protobuf:"bytes,1,opt,name=plugin,proto3" json:"plugin,omitempty"`
	Resource      string                      `protobuf:"bytes,2,opt,name=resource,proto3" json:"resource,omitempty"`
	TargetBuilder *common.ActionTargetBuilder `protobuf:"bytes,3,opt,name=target_builder,json=targetBuilder,proto3" json:"target_builder,omitempty"`
	// contains filtered or unexported fields
}

func (*LogHandler) Descriptor deprecated 

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

Deprecated: Use LogHandler.ProtoReflect.Descriptor instead.

func (*LogHandler) GetPlugin 

func (x *LogHandler) GetPlugin() string

func (*LogHandler) GetResource 

func (x *LogHandler) GetResource() string

func (*LogHandler) GetTargetBuilder 

func (x *LogHandler) GetTargetBuilder() *common.ActionTargetBuilder

func (*LogHandler) ProtoMessage 

func (*LogHandler) ProtoMessage()

func (*LogHandler) ProtoReflect 

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

func (*LogHandler) Reset 

func (x *LogHandler) Reset()

func (*LogHandler) String 

func (x *LogHandler) String() string

type LogLevel 

type LogLevel int32
const (
	LogLevel_LOG_LEVEL_UNSPECIFIED LogLevel = 0
	LogLevel_LOG_LEVEL_TRACE       LogLevel = 1
	LogLevel_LOG_LEVEL_DEBUG       LogLevel = 2
	LogLevel_LOG_LEVEL_INFO        LogLevel = 3
	LogLevel_LOG_LEVEL_WARN        LogLevel = 4
	LogLevel_LOG_LEVEL_ERROR       LogLevel = 5
	LogLevel_LOG_LEVEL_FATAL       LogLevel = 6
)

func (LogLevel) Descriptor 

func (LogLevel) Descriptor() protoreflect.EnumDescriptor

func (LogLevel) Enum 

func (x LogLevel) Enum() *LogLevel

func (LogLevel) EnumDescriptor deprecated 

func (LogLevel) EnumDescriptor() ([]byte, []int)

Deprecated: Use LogLevel.Descriptor instead.

func (LogLevel) Number 

func (x LogLevel) Number() protoreflect.EnumNumber

func (LogLevel) String 

func (x LogLevel) String() string

func (LogLevel) Type 

func (LogLevel) Type() protoreflect.EnumType

type LogLine 

type LogLine struct {
	SessionId string                 `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	SourceId  string                 `protobuf:"bytes,2,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`
	Labels    map[string]string      `` /* 139-byte string literal not displayed */
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Content   []byte                 `protobuf:"bytes,5,opt,name=content,proto3" json:"content,omitempty"`
	Origin    LogLineOrigin          `protobuf:"varint,6,opt,name=origin,proto3,enum=omniview.sdk.logs.v1.LogLineOrigin" json:"origin,omitempty"`
	Level     LogLevel               `protobuf:"varint,7,opt,name=level,proto3,enum=omniview.sdk.logs.v1.LogLevel" json:"level,omitempty"`
	// contains filtered or unexported fields
}

func (*LogLine) Descriptor deprecated 

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

Deprecated: Use LogLine.ProtoReflect.Descriptor instead.

func (*LogLine) GetContent 

func (x *LogLine) GetContent() []byte

func (*LogLine) GetLabels 

func (x *LogLine) GetLabels() map[string]string

func (*LogLine) GetLevel 

func (x *LogLine) GetLevel() LogLevel

func (*LogLine) GetOrigin 

func (x *LogLine) GetOrigin() LogLineOrigin

func (*LogLine) GetSessionId 

func (x *LogLine) GetSessionId() string

func (*LogLine) GetSourceId 

func (x *LogLine) GetSourceId() string

func (*LogLine) GetTimestamp 

func (x *LogLine) GetTimestamp() *timestamppb.Timestamp

func (*LogLine) ProtoMessage 

func (*LogLine) ProtoMessage()

func (*LogLine) ProtoReflect 

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

func (*LogLine) Reset 

func (x *LogLine) Reset()

func (*LogLine) String 

func (x *LogLine) String() string

type LogLineOrigin 

type LogLineOrigin int32
const (
	LogLineOrigin_LOG_LINE_ORIGIN_CURRENT  LogLineOrigin = 0
	LogLineOrigin_LOG_LINE_ORIGIN_PREVIOUS LogLineOrigin = 1
	LogLineOrigin_LOG_LINE_ORIGIN_SYSTEM   LogLineOrigin = 2
)

func (LogLineOrigin) Descriptor 

func (LogLineOrigin) Descriptor() protoreflect.EnumDescriptor

func (LogLineOrigin) Enum 

func (x LogLineOrigin) Enum() *LogLineOrigin

func (LogLineOrigin) EnumDescriptor deprecated 

func (LogLineOrigin) EnumDescriptor() ([]byte, []int)

Deprecated: Use LogLineOrigin.Descriptor instead.

func (LogLineOrigin) Number 

func (x LogLineOrigin) Number() protoreflect.EnumNumber

func (LogLineOrigin) String 

func (x LogLineOrigin) String() string

func (LogLineOrigin) Type 

func (LogLineOrigin) Type() protoreflect.EnumType

type LogPluginClient 

type LogPluginClient interface {
	GetSupportedResources(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*GetSupportedLogResourcesResponse, error)
	CreateSession(ctx context.Context, in *CreateLogSessionRequest, opts ...grpc.CallOption) (*CreateLogSessionResponse, error)
	GetSession(ctx context.Context, in *LogSessionByIdRequest, opts ...grpc.CallOption) (*LogSessionByIdResponse, error)
	ListSessions(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*ListLogSessionsResponse, error)
	CloseSession(ctx context.Context, in *LogSessionByIdRequest, opts ...grpc.CallOption) (*CloseLogSessionResponse, error)
	UpdateSessionOptions(ctx context.Context, in *UpdateLogSessionOptionsRequest, opts ...grpc.CallOption) (*LogSessionByIdResponse, error)
	Stream(ctx context.Context, opts ...grpc.CallOption) (LogPlugin_StreamClient, error)
}

LogPluginClient is the client API for LogPlugin service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewLogPluginClient 

func NewLogPluginClient(cc grpc.ClientConnInterface) LogPluginClient

type LogPluginServer 

type LogPluginServer interface {
	GetSupportedResources(context.Context, *emptypb.Empty) (*GetSupportedLogResourcesResponse, error)
	CreateSession(context.Context, *CreateLogSessionRequest) (*CreateLogSessionResponse, error)
	GetSession(context.Context, *LogSessionByIdRequest) (*LogSessionByIdResponse, error)
	ListSessions(context.Context, *emptypb.Empty) (*ListLogSessionsResponse, error)
	CloseSession(context.Context, *LogSessionByIdRequest) (*CloseLogSessionResponse, error)
	UpdateSessionOptions(context.Context, *UpdateLogSessionOptionsRequest) (*LogSessionByIdResponse, error)
	Stream(LogPlugin_StreamServer) error
}

LogPluginServer is the server API for LogPlugin service. All implementations should embed UnimplementedLogPluginServer for forward compatibility

type LogPlugin_StreamClient 

type LogPlugin_StreamClient interface {
	Send(*LogStreamInput) error
	Recv() (*LogStreamOutput, error)
	grpc.ClientStream
}

type LogPlugin_StreamServer 

type LogPlugin_StreamServer interface {
	Send(*LogStreamOutput) error
	Recv() (*LogStreamInput, error)
	grpc.ServerStream
}

type LogSession 

type LogSession struct {
	Id            string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	PluginId      string                 `protobuf:"bytes,2,opt,name=plugin_id,json=pluginId,proto3" json:"plugin_id,omitempty"`
	ConnectionId  string                 `protobuf:"bytes,3,opt,name=connection_id,json=connectionId,proto3" json:"connection_id,omitempty"`
	ResourceKey   string                 `protobuf:"bytes,4,opt,name=resource_key,json=resourceKey,proto3" json:"resource_key,omitempty"`
	ResourceId    string                 `protobuf:"bytes,5,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	Options       *LogSessionOptions     `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"`
	Status        LogSessionStatus       `protobuf:"varint,7,opt,name=status,proto3,enum=omniview.sdk.logs.v1.LogSessionStatus" json:"status,omitempty"`
	ActiveSources []*LogSource           `protobuf:"bytes,8,rep,name=active_sources,json=activeSources,proto3" json:"active_sources,omitempty"`
	CreatedAt     *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*LogSession) Descriptor deprecated 

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

Deprecated: Use LogSession.ProtoReflect.Descriptor instead.

func (*LogSession) GetActiveSources 

func (x *LogSession) GetActiveSources() []*LogSource

func (*LogSession) GetConnectionId 

func (x *LogSession) GetConnectionId() string

func (*LogSession) GetCreatedAt 

func (x *LogSession) GetCreatedAt() *timestamppb.Timestamp

func (*LogSession) GetId 

func (x *LogSession) GetId() string

func (*LogSession) GetOptions 

func (x *LogSession) GetOptions() *LogSessionOptions

func (*LogSession) GetPluginId 

func (x *LogSession) GetPluginId() string

func (*LogSession) GetResourceId 

func (x *LogSession) GetResourceId() string

func (*LogSession) GetResourceKey 

func (x *LogSession) GetResourceKey() string

func (*LogSession) GetStatus 

func (x *LogSession) GetStatus() LogSessionStatus

func (*LogSession) ProtoMessage 

func (*LogSession) ProtoMessage()

func (*LogSession) ProtoReflect 

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

func (*LogSession) Reset 

func (x *LogSession) Reset()

func (*LogSession) String 

func (x *LogSession) String() string

type LogSessionByIdRequest 

type LogSessionByIdRequest struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

func (*LogSessionByIdRequest) Descriptor deprecated 

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

Deprecated: Use LogSessionByIdRequest.ProtoReflect.Descriptor instead.

func (*LogSessionByIdRequest) GetSessionId 

func (x *LogSessionByIdRequest) GetSessionId() string

func (*LogSessionByIdRequest) ProtoMessage 

func (*LogSessionByIdRequest) ProtoMessage()

func (*LogSessionByIdRequest) ProtoReflect 

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

func (*LogSessionByIdRequest) Reset 

func (x *LogSessionByIdRequest) Reset()

func (*LogSessionByIdRequest) String 

func (x *LogSessionByIdRequest) String() string

type LogSessionByIdResponse 

type LogSessionByIdResponse struct {
	Session *LogSession `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	Success bool        `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	Error   string      `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

func (*LogSessionByIdResponse) Descriptor deprecated 

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

Deprecated: Use LogSessionByIdResponse.ProtoReflect.Descriptor instead.

func (*LogSessionByIdResponse) GetError 

func (x *LogSessionByIdResponse) GetError() string

func (*LogSessionByIdResponse) GetSession 

func (x *LogSessionByIdResponse) GetSession() *LogSession

func (*LogSessionByIdResponse) GetSuccess 

func (x *LogSessionByIdResponse) GetSuccess() bool

func (*LogSessionByIdResponse) ProtoMessage 

func (*LogSessionByIdResponse) ProtoMessage()

func (*LogSessionByIdResponse) ProtoReflect 

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

func (*LogSessionByIdResponse) Reset 

func (x *LogSessionByIdResponse) Reset()

func (*LogSessionByIdResponse) String 

func (x *LogSessionByIdResponse) String() string

type LogSessionOptions 

type LogSessionOptions struct {
	Target              string                 `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	Follow              bool                   `protobuf:"varint,2,opt,name=follow,proto3" json:"follow,omitempty"`
	IncludePrevious     bool                   `protobuf:"varint,3,opt,name=include_previous,json=includePrevious,proto3" json:"include_previous,omitempty"`
	IncludeTimestamps   bool                   `protobuf:"varint,4,opt,name=include_timestamps,json=includeTimestamps,proto3" json:"include_timestamps,omitempty"`
	TailLines           int64                  `protobuf:"varint,5,opt,name=tail_lines,json=tailLines,proto3" json:"tail_lines,omitempty"`
	SinceSeconds        int64                  `protobuf:"varint,6,opt,name=since_seconds,json=sinceSeconds,proto3" json:"since_seconds,omitempty"`
	SinceTime           *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=since_time,json=sinceTime,proto3" json:"since_time,omitempty"`
	LimitBytes          int64                  `protobuf:"varint,8,opt,name=limit_bytes,json=limitBytes,proto3" json:"limit_bytes,omitempty"`
	IncludeSourceEvents bool                   `protobuf:"varint,9,opt,name=include_source_events,json=includeSourceEvents,proto3" json:"include_source_events,omitempty"`
	Params              map[string]string      `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LogSessionOptions) Descriptor deprecated 

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

Deprecated: Use LogSessionOptions.ProtoReflect.Descriptor instead.

func (*LogSessionOptions) GetFollow 

func (x *LogSessionOptions) GetFollow() bool

func (*LogSessionOptions) GetIncludePrevious 

func (x *LogSessionOptions) GetIncludePrevious() bool

func (*LogSessionOptions) GetIncludeSourceEvents 

func (x *LogSessionOptions) GetIncludeSourceEvents() bool

func (*LogSessionOptions) GetIncludeTimestamps 

func (x *LogSessionOptions) GetIncludeTimestamps() bool

func (*LogSessionOptions) GetLimitBytes 

func (x *LogSessionOptions) GetLimitBytes() int64

func (*LogSessionOptions) GetParams 

func (x *LogSessionOptions) GetParams() map[string]string

func (*LogSessionOptions) GetSinceSeconds 

func (x *LogSessionOptions) GetSinceSeconds() int64

func (*LogSessionOptions) GetSinceTime 

func (x *LogSessionOptions) GetSinceTime() *timestamppb.Timestamp

func (*LogSessionOptions) GetTailLines 

func (x *LogSessionOptions) GetTailLines() int64

func (*LogSessionOptions) GetTarget 

func (x *LogSessionOptions) GetTarget() string

func (*LogSessionOptions) ProtoMessage 

func (*LogSessionOptions) ProtoMessage()

func (*LogSessionOptions) ProtoReflect 

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

func (*LogSessionOptions) Reset 

func (x *LogSessionOptions) Reset()

func (*LogSessionOptions) String 

func (x *LogSessionOptions) String() string

type LogSessionStatus 

type LogSessionStatus int32
const (
	LogSessionStatus_LOG_SESSION_STATUS_ACTIVE       LogSessionStatus = 0
	LogSessionStatus_LOG_SESSION_STATUS_PAUSED       LogSessionStatus = 1
	LogSessionStatus_LOG_SESSION_STATUS_CLOSED       LogSessionStatus = 2
	LogSessionStatus_LOG_SESSION_STATUS_ERROR        LogSessionStatus = 3
	LogSessionStatus_LOG_SESSION_STATUS_CONNECTING   LogSessionStatus = 4
	LogSessionStatus_LOG_SESSION_STATUS_INITIALIZING LogSessionStatus = 5
)

func (LogSessionStatus) Descriptor 

func (LogSessionStatus) Descriptor() protoreflect.EnumDescriptor

func (LogSessionStatus) Enum 

func (x LogSessionStatus) Enum() *LogSessionStatus

func (LogSessionStatus) EnumDescriptor deprecated 

func (LogSessionStatus) EnumDescriptor() ([]byte, []int)

Deprecated: Use LogSessionStatus.Descriptor instead.

func (LogSessionStatus) Number 

func (x LogSessionStatus) Number() protoreflect.EnumNumber

func (LogSessionStatus) String 

func (x LogSessionStatus) String() string

func (LogSessionStatus) Type 

func (LogSessionStatus) Type() protoreflect.EnumType

type LogSource 

type LogSource struct {
	Id     string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Labels map[string]string `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*LogSource) Descriptor deprecated 

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

Deprecated: Use LogSource.ProtoReflect.Descriptor instead.

func (*LogSource) GetId 

func (x *LogSource) GetId() string

func (*LogSource) GetLabels 

func (x *LogSource) GetLabels() map[string]string

func (*LogSource) ProtoMessage 

func (*LogSource) ProtoMessage()

func (*LogSource) ProtoReflect 

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

func (*LogSource) Reset 

func (x *LogSource) Reset()

func (*LogSource) String 

func (x *LogSource) String() string

type LogStreamCommand 

type LogStreamCommand int32
const (
	LogStreamCommand_LOG_STREAM_COMMAND_PAUSE  LogStreamCommand = 0
	LogStreamCommand_LOG_STREAM_COMMAND_RESUME LogStreamCommand = 1
	LogStreamCommand_LOG_STREAM_COMMAND_CLOSE  LogStreamCommand = 2
)

func (LogStreamCommand) Descriptor 

func (LogStreamCommand) Descriptor() protoreflect.EnumDescriptor

func (LogStreamCommand) Enum 

func (x LogStreamCommand) Enum() *LogStreamCommand

func (LogStreamCommand) EnumDescriptor deprecated 

func (LogStreamCommand) EnumDescriptor() ([]byte, []int)

Deprecated: Use LogStreamCommand.Descriptor instead.

func (LogStreamCommand) Number 

func (x LogStreamCommand) Number() protoreflect.EnumNumber

func (LogStreamCommand) String 

func (x LogStreamCommand) String() string

func (LogStreamCommand) Type 

func (LogStreamCommand) Type() protoreflect.EnumType

type LogStreamEvent 

type LogStreamEvent struct {
	Type      LogStreamEventType     `protobuf:"varint,1,opt,name=type,proto3,enum=omniview.sdk.logs.v1.LogStreamEventType" json:"type,omitempty"`
	SourceId  string                 `protobuf:"bytes,2,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`
	Message   string                 `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*LogStreamEvent) Descriptor deprecated 

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

Deprecated: Use LogStreamEvent.ProtoReflect.Descriptor instead.

func (*LogStreamEvent) GetMessage 

func (x *LogStreamEvent) GetMessage() string

func (*LogStreamEvent) GetSourceId 

func (x *LogStreamEvent) GetSourceId() string

func (*LogStreamEvent) GetTimestamp 

func (x *LogStreamEvent) GetTimestamp() *timestamppb.Timestamp

func (*LogStreamEvent) GetType 

func (x *LogStreamEvent) GetType() LogStreamEventType

func (*LogStreamEvent) ProtoMessage 

func (*LogStreamEvent) ProtoMessage()

func (*LogStreamEvent) ProtoReflect 

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

func (*LogStreamEvent) Reset 

func (x *LogStreamEvent) Reset()

func (*LogStreamEvent) String 

func (x *LogStreamEvent) String() string

type LogStreamEventType 

type LogStreamEventType int32
const (
	LogStreamEventType_LOG_STREAM_EVENT_SOURCE_ADDED   LogStreamEventType = 0
	LogStreamEventType_LOG_STREAM_EVENT_SOURCE_REMOVED LogStreamEventType = 1
	LogStreamEventType_LOG_STREAM_EVENT_STREAM_ERROR   LogStreamEventType = 2
	LogStreamEventType_LOG_STREAM_EVENT_RECONNECTING   LogStreamEventType = 3
	LogStreamEventType_LOG_STREAM_EVENT_RECONNECTED    LogStreamEventType = 4
	LogStreamEventType_LOG_STREAM_EVENT_STREAM_ENDED   LogStreamEventType = 5
	LogStreamEventType_LOG_STREAM_EVENT_SESSION_READY  LogStreamEventType = 6
)

func (LogStreamEventType) Descriptor 

func (LogStreamEventType) Descriptor() protoreflect.EnumDescriptor

func (LogStreamEventType) Enum 

func (x LogStreamEventType) Enum() *LogStreamEventType

func (LogStreamEventType) EnumDescriptor deprecated 

func (LogStreamEventType) EnumDescriptor() ([]byte, []int)

Deprecated: Use LogStreamEventType.Descriptor instead.

func (LogStreamEventType) Number 

func (x LogStreamEventType) Number() protoreflect.EnumNumber

func (LogStreamEventType) String 

func (x LogStreamEventType) String() string

func (LogStreamEventType) Type 

func (LogStreamEventType) Type() protoreflect.EnumType

type LogStreamInput 

type LogStreamInput struct {
	SessionId string           `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Command   LogStreamCommand `protobuf:"varint,2,opt,name=command,proto3,enum=omniview.sdk.logs.v1.LogStreamCommand" json:"command,omitempty"`
	// contains filtered or unexported fields
}

func (*LogStreamInput) Descriptor deprecated 

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

Deprecated: Use LogStreamInput.ProtoReflect.Descriptor instead.

func (*LogStreamInput) GetCommand 

func (x *LogStreamInput) GetCommand() LogStreamCommand

func (*LogStreamInput) GetSessionId 

func (x *LogStreamInput) GetSessionId() string

func (*LogStreamInput) ProtoMessage 

func (*LogStreamInput) ProtoMessage()

func (*LogStreamInput) ProtoReflect 

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

func (*LogStreamInput) Reset 

func (x *LogStreamInput) Reset()

func (*LogStreamInput) String 

func (x *LogStreamInput) String() string

type LogStreamOutput 

type LogStreamOutput struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// Types that are valid to be assigned to Payload:
	//
	//	*LogStreamOutput_Line
	//	*LogStreamOutput_Event
	Payload isLogStreamOutput_Payload `protobuf_oneof:"payload"`
	// contains filtered or unexported fields
}

func (*LogStreamOutput) Descriptor deprecated 

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

Deprecated: Use LogStreamOutput.ProtoReflect.Descriptor instead.

func (*LogStreamOutput) GetEvent 

func (x *LogStreamOutput) GetEvent() *LogStreamEvent

func (*LogStreamOutput) GetLine 

func (x *LogStreamOutput) GetLine() *LogLine

func (*LogStreamOutput) GetPayload 

func (x *LogStreamOutput) GetPayload() isLogStreamOutput_Payload

func (*LogStreamOutput) GetSessionId 

func (x *LogStreamOutput) GetSessionId() string

func (*LogStreamOutput) ProtoMessage 

func (*LogStreamOutput) ProtoMessage()

func (*LogStreamOutput) ProtoReflect 

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

func (*LogStreamOutput) Reset 

func (x *LogStreamOutput) Reset()

func (*LogStreamOutput) String 

func (x *LogStreamOutput) String() string

type LogStreamOutput_Event 

type LogStreamOutput_Event struct {
	Event *LogStreamEvent `protobuf:"bytes,3,opt,name=event,proto3,oneof"`
}

type LogStreamOutput_Line 

type LogStreamOutput_Line struct {
	Line *LogLine `protobuf:"bytes,2,opt,name=line,proto3,oneof"`
}

type UnimplementedLogPluginServer 

type UnimplementedLogPluginServer struct {
}

UnimplementedLogPluginServer should be embedded to have forward compatible implementations.

func (UnimplementedLogPluginServer) CloseSession 

func (UnimplementedLogPluginServer) CloseSession(context.Context, *LogSessionByIdRequest) (*CloseLogSessionResponse, error)

func (UnimplementedLogPluginServer) CreateSession 

func (UnimplementedLogPluginServer) CreateSession(context.Context, *CreateLogSessionRequest) (*CreateLogSessionResponse, error)

func (UnimplementedLogPluginServer) GetSession 

func (UnimplementedLogPluginServer) GetSession(context.Context, *LogSessionByIdRequest) (*LogSessionByIdResponse, error)

func (UnimplementedLogPluginServer) GetSupportedResources 

func (UnimplementedLogPluginServer) GetSupportedResources(context.Context, *emptypb.Empty) (*GetSupportedLogResourcesResponse, error)

func (UnimplementedLogPluginServer) ListSessions 

func (UnimplementedLogPluginServer) ListSessions(context.Context, *emptypb.Empty) (*ListLogSessionsResponse, error)

func (UnimplementedLogPluginServer) Stream 

func (UnimplementedLogPluginServer) Stream(LogPlugin_StreamServer) error

func (UnimplementedLogPluginServer) UpdateSessionOptions 

func (UnimplementedLogPluginServer) UpdateSessionOptions(context.Context, *UpdateLogSessionOptionsRequest) (*LogSessionByIdResponse, error)

type UnsafeLogPluginServer 

type UnsafeLogPluginServer interface {
	// contains filtered or unexported methods
}

UnsafeLogPluginServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LogPluginServer will result in compilation errors.

type UpdateLogSessionOptionsRequest 

type UpdateLogSessionOptionsRequest struct {
	SessionId string             `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Options   *LogSessionOptions `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateLogSessionOptionsRequest) Descriptor deprecated 

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

Deprecated: Use UpdateLogSessionOptionsRequest.ProtoReflect.Descriptor instead.

func (*UpdateLogSessionOptionsRequest) GetOptions 

func (x *UpdateLogSessionOptionsRequest) GetOptions() *LogSessionOptions

func (*UpdateLogSessionOptionsRequest) GetSessionId 

func (x *UpdateLogSessionOptionsRequest) GetSessionId() string

func (*UpdateLogSessionOptionsRequest) ProtoMessage 

func (*UpdateLogSessionOptionsRequest) ProtoMessage()

func (*UpdateLogSessionOptionsRequest) ProtoReflect 

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

func (*UpdateLogSessionOptionsRequest) Reset 

func (x *UpdateLogSessionOptionsRequest) Reset()

func (*UpdateLogSessionOptionsRequest) String 

func (x *UpdateLogSessionOptionsRequest) String() string

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.