observe

package
v0.0.0-...-3322147 Latest Latest
Warning

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

 Go to latest Published: Dec 30, 2022 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	LogChannelType_name = map[int32]string{
		0: "CHANNEL_STDOUT",
		1: "CHANNEL_STDERR",
	}
	LogChannelType_value = map[string]int32{
		"CHANNEL_STDOUT": 0,
		"CHANNEL_STDERR": 1,
	}
)

Enum value maps for LogChannelType.

View Source 
var File_observe_proto protoreflect.FileDescriptor
View Source 
var Observe_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "observe.Observe",
	HandlerType: (*ObserveServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Status",
			Handler:    _Observe_Status_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "GetAuraeDaemonLogStream",
			Handler:       _Observe_GetAuraeDaemonLogStream_Handler,
			ServerStreams: true,
		},
		{
			StreamName:    "GetSubProcessStream",
			Handler:       _Observe_GetSubProcessStream_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "observe.proto",
}

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

Functions

func RegisterObserveServer 

func RegisterObserveServer(s grpc.ServiceRegistrar, srv ObserveServer)

Types

type GetAuraeDaemonLogStreamRequest 

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

func (*GetAuraeDaemonLogStreamRequest) Descriptor deprecated 

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

Deprecated: Use GetAuraeDaemonLogStreamRequest.ProtoReflect.Descriptor instead.

func (*GetAuraeDaemonLogStreamRequest) ProtoMessage 

func (*GetAuraeDaemonLogStreamRequest) ProtoMessage()

func (*GetAuraeDaemonLogStreamRequest) ProtoReflect 

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

func (*GetAuraeDaemonLogStreamRequest) Reset 

func (x *GetAuraeDaemonLogStreamRequest) Reset()

func (*GetAuraeDaemonLogStreamRequest) String 

func (x *GetAuraeDaemonLogStreamRequest) String() string

type GetSubProcessStreamRequest 

type GetSubProcessStreamRequest struct {
	ChannelType LogChannelType `protobuf:"varint,1,opt,name=channel_type,json=channelType,proto3,enum=observe.LogChannelType" json:"channel_type,omitempty"`
	ProcessId   int64          `protobuf:"varint,2,opt,name=process_id,json=processId,proto3" json:"process_id,omitempty"`
	// contains filtered or unexported fields
}

TODO: not implemented

func (*GetSubProcessStreamRequest) Descriptor deprecated 

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

Deprecated: Use GetSubProcessStreamRequest.ProtoReflect.Descriptor instead.

func (*GetSubProcessStreamRequest) GetChannelType 

func (x *GetSubProcessStreamRequest) GetChannelType() LogChannelType

func (*GetSubProcessStreamRequest) GetProcessId 

func (x *GetSubProcessStreamRequest) GetProcessId() int64

func (*GetSubProcessStreamRequest) ProtoMessage 

func (*GetSubProcessStreamRequest) ProtoMessage()

func (*GetSubProcessStreamRequest) ProtoReflect 

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

func (*GetSubProcessStreamRequest) Reset 

func (x *GetSubProcessStreamRequest) Reset()

func (*GetSubProcessStreamRequest) String 

func (x *GetSubProcessStreamRequest) String() string

type LogChannelType 

type LogChannelType int32
const (
	LogChannelType_CHANNEL_STDOUT LogChannelType = 0
	LogChannelType_CHANNEL_STDERR LogChannelType = 1
)

func (LogChannelType) Descriptor 

func (LogChannelType) Descriptor() protoreflect.EnumDescriptor

func (LogChannelType) Enum 

func (x LogChannelType) Enum() *LogChannelType

func (LogChannelType) EnumDescriptor deprecated 

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

Deprecated: Use LogChannelType.Descriptor instead.

func (LogChannelType) Number 

func (x LogChannelType) Number() protoreflect.EnumNumber

func (LogChannelType) String 

func (x LogChannelType) String() string

func (LogChannelType) Type 

func (LogChannelType) Type() protoreflect.EnumType

type LogItem 

type LogItem struct {
	Channel   string `protobuf:"bytes,1,opt,name=channel,proto3" json:"channel,omitempty"`
	Line      string `protobuf:"bytes,2,opt,name=line,proto3" json:"line,omitempty"`
	Timestamp int64  `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// contains filtered or unexported fields
}

func (*LogItem) Descriptor deprecated 

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

Deprecated: Use LogItem.ProtoReflect.Descriptor instead.

func (*LogItem) GetChannel 

func (x *LogItem) GetChannel() string

func (*LogItem) GetLine 

func (x *LogItem) GetLine() string

func (*LogItem) GetTimestamp 

func (x *LogItem) GetTimestamp() int64

func (*LogItem) ProtoMessage 

func (*LogItem) ProtoMessage()

func (*LogItem) ProtoReflect 

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

func (*LogItem) Reset 

func (x *LogItem) Reset()

func (*LogItem) String 

func (x *LogItem) String() string

type ObserveClient 

type ObserveClient interface {
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	// request log stream for aurae. everything logged via log macros in aurae (info!, error!, trace!, ... ).
	GetAuraeDaemonLogStream(ctx context.Context, in *GetAuraeDaemonLogStreamRequest, opts ...grpc.CallOption) (Observe_GetAuraeDaemonLogStreamClient, error)
	// TODO: request log stream for a sub process
	GetSubProcessStream(ctx context.Context, in *GetSubProcessStreamRequest, opts ...grpc.CallOption) (Observe_GetSubProcessStreamClient, error)
}

ObserveClient is the client API for Observe 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 NewObserveClient 

func NewObserveClient(cc grpc.ClientConnInterface) ObserveClient

type ObserveServer 

type ObserveServer interface {
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	// request log stream for aurae. everything logged via log macros in aurae (info!, error!, trace!, ... ).
	GetAuraeDaemonLogStream(*GetAuraeDaemonLogStreamRequest, Observe_GetAuraeDaemonLogStreamServer) error
	// TODO: request log stream for a sub process
	GetSubProcessStream(*GetSubProcessStreamRequest, Observe_GetSubProcessStreamServer) error
	// contains filtered or unexported methods
}

ObserveServer is the server API for Observe service. All implementations must embed UnimplementedObserveServer for forward compatibility

type Observe_GetAuraeDaemonLogStreamClient 

type Observe_GetAuraeDaemonLogStreamClient interface {
	Recv() (*LogItem, error)
	grpc.ClientStream
}

type Observe_GetAuraeDaemonLogStreamServer 

type Observe_GetAuraeDaemonLogStreamServer interface {
	Send(*LogItem) error
	grpc.ServerStream
}

type Observe_GetSubProcessStreamClient 

type Observe_GetSubProcessStreamClient interface {
	Recv() (*LogItem, error)
	grpc.ClientStream
}

type Observe_GetSubProcessStreamServer 

type Observe_GetSubProcessStreamServer interface {
	Send(*LogItem) error
	grpc.ServerStream
}

type StatusRequest 

type StatusRequest struct {
	Meta *meta.AuraeMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusRequest) Descriptor deprecated 

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

Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.

func (*StatusRequest) GetMeta 

func (x *StatusRequest) GetMeta() *meta.AuraeMeta

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) ProtoReflect 

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

func (*StatusRequest) Reset 

func (x *StatusRequest) Reset()

func (*StatusRequest) String 

func (x *StatusRequest) String() string

type StatusResponse 

type StatusResponse struct {
	Meta *meta.AuraeMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

func (*StatusResponse) Descriptor deprecated 

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

Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.

func (*StatusResponse) GetMeta 

func (x *StatusResponse) GetMeta() *meta.AuraeMeta

func (*StatusResponse) ProtoMessage 

func (*StatusResponse) ProtoMessage()

func (*StatusResponse) ProtoReflect 

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

func (*StatusResponse) Reset 

func (x *StatusResponse) Reset()

func (*StatusResponse) String 

func (x *StatusResponse) String() string

type UnimplementedObserveServer 

type UnimplementedObserveServer struct {
}

UnimplementedObserveServer must be embedded to have forward compatible implementations.

func (UnimplementedObserveServer) GetAuraeDaemonLogStream 

func (UnimplementedObserveServer) GetAuraeDaemonLogStream(*GetAuraeDaemonLogStreamRequest, Observe_GetAuraeDaemonLogStreamServer) error

func (UnimplementedObserveServer) GetSubProcessStream 

func (UnimplementedObserveServer) GetSubProcessStream(*GetSubProcessStreamRequest, Observe_GetSubProcessStreamServer) error

func (UnimplementedObserveServer) Status 

func (UnimplementedObserveServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)

type UnsafeObserveServer 

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

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

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.