daemon

package
v1.4.1 Latest Latest
Warning

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

 Go to latest Published: Dec 5, 2024 License: Apache-2.0 Imports: 18 Imported by: 0

Documentation

Overview

Package daemon is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

View Source 
const (
	DaemonService_ListBuffers_FullMethodName           = "/daemon.DaemonService/ListBuffers"
	DaemonService_GetBuffer_FullMethodName             = "/daemon.DaemonService/GetBuffer"
	DaemonService_GetVertexMetrics_FullMethodName      = "/daemon.DaemonService/GetVertexMetrics"
	DaemonService_GetPipelineWatermarks_FullMethodName = "/daemon.DaemonService/GetPipelineWatermarks"
	DaemonService_GetPipelineStatus_FullMethodName     = "/daemon.DaemonService/GetPipelineStatus"
)

Variables

View Source 
var DaemonService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "daemon.DaemonService",
	HandlerType: (*DaemonServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListBuffers",
			Handler:    _DaemonService_ListBuffers_Handler,
		},
		{
			MethodName: "GetBuffer",
			Handler:    _DaemonService_GetBuffer_Handler,
		},
		{
			MethodName: "GetVertexMetrics",
			Handler:    _DaemonService_GetVertexMetrics_Handler,
		},
		{
			MethodName: "GetPipelineWatermarks",
			Handler:    _DaemonService_GetPipelineWatermarks_Handler,
		},
		{
			MethodName: "GetPipelineStatus",
			Handler:    _DaemonService_GetPipelineStatus_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/apis/proto/daemon/daemon.proto",
}

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

View Source 
var File_pkg_apis_proto_daemon_daemon_proto protoreflect.FileDescriptor

Functions

func RegisterDaemonServiceHandler 

func RegisterDaemonServiceHandler(ctx context.Context, mux *runtime.ServeMux, conn *grpc.ClientConn) error

RegisterDaemonServiceHandler registers the http handlers for service DaemonService to "mux". The handlers forward requests to the grpc endpoint over "conn".

func RegisterDaemonServiceHandlerClient 

func RegisterDaemonServiceHandlerClient(ctx context.Context, mux *runtime.ServeMux, client DaemonServiceClient) error

RegisterDaemonServiceHandlerClient registers the http handlers for service DaemonService to "mux". The handlers forward requests to the grpc endpoint over the given implementation of "DaemonServiceClient". Note: the gRPC framework executes interceptors within the gRPC handler. If the passed in "DaemonServiceClient" doesn't go through the normal gRPC flow (creating a gRPC client etc.) then it will be up to the passed in "DaemonServiceClient" to call the correct interceptors.

func RegisterDaemonServiceHandlerFromEndpoint 

func RegisterDaemonServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, opts []grpc.DialOption) (err error)

RegisterDaemonServiceHandlerFromEndpoint is same as RegisterDaemonServiceHandler but automatically dials to "endpoint" and closes the connection when "ctx" gets done.

func RegisterDaemonServiceHandlerServer 

func RegisterDaemonServiceHandlerServer(ctx context.Context, mux *runtime.ServeMux, server DaemonServiceServer) error

RegisterDaemonServiceHandlerServer registers the http handlers for service DaemonService to "mux". UnaryRPC :call DaemonServiceServer directly. StreamingRPC :currently unsupported pending https://github.com/grpc/grpc-go/issues/906. Note that using this registration option will cause many gRPC library features to stop working. Consider using RegisterDaemonServiceHandlerFromEndpoint instead.

func RegisterDaemonServiceServer 

func RegisterDaemonServiceServer(s grpc.ServiceRegistrar, srv DaemonServiceServer)

Types

type BufferInfo 

type BufferInfo struct {
	Pipeline        string                 `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	BufferName      string                 `protobuf:"bytes,2,opt,name=bufferName,proto3" json:"bufferName,omitempty"`
	PendingCount    *wrapperspb.Int64Value `protobuf:"bytes,3,opt,name=pendingCount,proto3" json:"pendingCount,omitempty"`
	AckPendingCount *wrapperspb.Int64Value `protobuf:"bytes,4,opt,name=ackPendingCount,proto3" json:"ackPendingCount,omitempty"`
	// Total messages existing in the buffer, including pending, ackPending and acked.
	// Using Int64Value to solve the problem of int64 in proto3 being serialized to string when converting to JSON.
	TotalMessages    *wrapperspb.Int64Value  `protobuf:"bytes,5,opt,name=totalMessages,proto3" json:"totalMessages,omitempty"`
	BufferLength     *wrapperspb.Int64Value  `protobuf:"bytes,6,opt,name=bufferLength,proto3" json:"bufferLength,omitempty"`
	BufferUsageLimit *wrapperspb.DoubleValue `protobuf:"bytes,7,opt,name=bufferUsageLimit,proto3" json:"bufferUsageLimit,omitempty"`
	BufferUsage      *wrapperspb.DoubleValue `protobuf:"bytes,8,opt,name=bufferUsage,proto3" json:"bufferUsage,omitempty"`
	IsFull           *wrapperspb.BoolValue   `protobuf:"bytes,9,opt,name=isFull,proto3" json:"isFull,omitempty"`
	// contains filtered or unexported fields
}

BufferInfo is used to provide information about the buffer including pending messages count, if it has unprocessed data etc which helps in pipeline/buffer deletion etc

func (*BufferInfo) Descriptor deprecated 

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

Deprecated: Use BufferInfo.ProtoReflect.Descriptor instead.

func (*BufferInfo) GetAckPendingCount 

func (x *BufferInfo) GetAckPendingCount() *wrapperspb.Int64Value

func (*BufferInfo) GetBufferLength 

func (x *BufferInfo) GetBufferLength() *wrapperspb.Int64Value

func (*BufferInfo) GetBufferName 

func (x *BufferInfo) GetBufferName() string

func (*BufferInfo) GetBufferUsage 

func (x *BufferInfo) GetBufferUsage() *wrapperspb.DoubleValue

func (*BufferInfo) GetBufferUsageLimit 

func (x *BufferInfo) GetBufferUsageLimit() *wrapperspb.DoubleValue

func (*BufferInfo) GetIsFull 

func (x *BufferInfo) GetIsFull() *wrapperspb.BoolValue

func (*BufferInfo) GetPendingCount 

func (x *BufferInfo) GetPendingCount() *wrapperspb.Int64Value

func (*BufferInfo) GetPipeline 

func (x *BufferInfo) GetPipeline() string

func (*BufferInfo) GetTotalMessages 

func (x *BufferInfo) GetTotalMessages() *wrapperspb.Int64Value

func (*BufferInfo) ProtoMessage 

func (*BufferInfo) ProtoMessage()

func (*BufferInfo) ProtoReflect added in v1.3.0 

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

func (*BufferInfo) Reset 

func (x *BufferInfo) Reset()

func (*BufferInfo) String 

func (x *BufferInfo) String() string

type DaemonServiceClient 

type DaemonServiceClient interface {
	ListBuffers(ctx context.Context, in *ListBuffersRequest, opts ...grpc.CallOption) (*ListBuffersResponse, error)
	GetBuffer(ctx context.Context, in *GetBufferRequest, opts ...grpc.CallOption) (*GetBufferResponse, error)
	GetVertexMetrics(ctx context.Context, in *GetVertexMetricsRequest, opts ...grpc.CallOption) (*GetVertexMetricsResponse, error)
	// GetPipelineWatermarks return the watermark of the given pipeline
	GetPipelineWatermarks(ctx context.Context, in *GetPipelineWatermarksRequest, opts ...grpc.CallOption) (*GetPipelineWatermarksResponse, error)
	GetPipelineStatus(ctx context.Context, in *GetPipelineStatusRequest, opts ...grpc.CallOption) (*GetPipelineStatusResponse, error)
}

DaemonServiceClient is the client API for DaemonService 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.

DaemonService is a grpc service that is used to provide APIs for giving any pipeline information.

func NewDaemonServiceClient 

func NewDaemonServiceClient(cc grpc.ClientConnInterface) DaemonServiceClient

type DaemonServiceServer 

type DaemonServiceServer interface {
	ListBuffers(context.Context, *ListBuffersRequest) (*ListBuffersResponse, error)
	GetBuffer(context.Context, *GetBufferRequest) (*GetBufferResponse, error)
	GetVertexMetrics(context.Context, *GetVertexMetricsRequest) (*GetVertexMetricsResponse, error)
	// GetPipelineWatermarks return the watermark of the given pipeline
	GetPipelineWatermarks(context.Context, *GetPipelineWatermarksRequest) (*GetPipelineWatermarksResponse, error)
	GetPipelineStatus(context.Context, *GetPipelineStatusRequest) (*GetPipelineStatusResponse, error)
	// contains filtered or unexported methods
}

DaemonServiceServer is the server API for DaemonService service. All implementations must embed UnimplementedDaemonServiceServer for forward compatibility

DaemonService is a grpc service that is used to provide APIs for giving any pipeline information.

type EdgeWatermark added in v0.7.2 

type EdgeWatermark struct {
	Pipeline           string                   `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Edge               string                   `protobuf:"bytes,2,opt,name=edge,proto3" json:"edge,omitempty"`
	Watermarks         []*wrapperspb.Int64Value `protobuf:"bytes,3,rep,name=watermarks,proto3" json:"watermarks,omitempty"`
	IsWatermarkEnabled *wrapperspb.BoolValue    `protobuf:"bytes,4,opt,name=isWatermarkEnabled,proto3" json:"isWatermarkEnabled,omitempty"`
	From               string                   `protobuf:"bytes,5,opt,name=from,proto3" json:"from,omitempty"`
	To                 string                   `protobuf:"bytes,6,opt,name=to,proto3" json:"to,omitempty"`
	// contains filtered or unexported fields
}

EdgeWatermark has edge to watermark mapping.

func (*EdgeWatermark) Descriptor deprecated added in v0.7.2 

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

Deprecated: Use EdgeWatermark.ProtoReflect.Descriptor instead.

func (*EdgeWatermark) GetEdge added in v0.7.2 

func (x *EdgeWatermark) GetEdge() string

func (*EdgeWatermark) GetFrom added in v0.11.0 

func (x *EdgeWatermark) GetFrom() string

func (*EdgeWatermark) GetIsWatermarkEnabled added in v0.7.2 

func (x *EdgeWatermark) GetIsWatermarkEnabled() *wrapperspb.BoolValue

func (*EdgeWatermark) GetPipeline added in v0.7.2 

func (x *EdgeWatermark) GetPipeline() string

func (*EdgeWatermark) GetTo added in v0.11.0 

func (x *EdgeWatermark) GetTo() string

func (*EdgeWatermark) GetWatermarks added in v0.7.2 

func (x *EdgeWatermark) GetWatermarks() []*wrapperspb.Int64Value

func (*EdgeWatermark) ProtoMessage added in v0.7.2 

func (*EdgeWatermark) ProtoMessage()

func (*EdgeWatermark) ProtoReflect added in v1.3.0 

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

func (*EdgeWatermark) Reset added in v0.7.2 

func (x *EdgeWatermark) Reset()

func (*EdgeWatermark) String added in v0.7.2 

func (x *EdgeWatermark) String() string

type GetBufferRequest 

type GetBufferRequest struct {
	Pipeline string `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Buffer   string `protobuf:"bytes,2,opt,name=buffer,proto3" json:"buffer,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBufferRequest) Descriptor deprecated 

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

Deprecated: Use GetBufferRequest.ProtoReflect.Descriptor instead.

func (*GetBufferRequest) GetBuffer 

func (x *GetBufferRequest) GetBuffer() string

func (*GetBufferRequest) GetPipeline 

func (x *GetBufferRequest) GetPipeline() string

func (*GetBufferRequest) ProtoMessage 

func (*GetBufferRequest) ProtoMessage()

func (*GetBufferRequest) ProtoReflect added in v1.3.0 

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

func (*GetBufferRequest) Reset 

func (x *GetBufferRequest) Reset()

func (*GetBufferRequest) String 

func (x *GetBufferRequest) String() string

type GetBufferResponse 

type GetBufferResponse struct {
	Buffer *BufferInfo `protobuf:"bytes,1,opt,name=buffer,proto3" json:"buffer,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBufferResponse) Descriptor deprecated 

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

Deprecated: Use GetBufferResponse.ProtoReflect.Descriptor instead.

func (*GetBufferResponse) GetBuffer 

func (x *GetBufferResponse) GetBuffer() *BufferInfo

func (*GetBufferResponse) ProtoMessage 

func (*GetBufferResponse) ProtoMessage()

func (*GetBufferResponse) ProtoReflect added in v1.3.0 

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

func (*GetBufferResponse) Reset 

func (x *GetBufferResponse) Reset()

func (*GetBufferResponse) String 

func (x *GetBufferResponse) String() string

type GetPipelineStatusRequest added in v0.7.3 

type GetPipelineStatusRequest struct {
	Pipeline string `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPipelineStatusRequest) Descriptor deprecated added in v0.7.3 

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

Deprecated: Use GetPipelineStatusRequest.ProtoReflect.Descriptor instead.

func (*GetPipelineStatusRequest) GetPipeline added in v0.7.3 

func (x *GetPipelineStatusRequest) GetPipeline() string

func (*GetPipelineStatusRequest) ProtoMessage added in v0.7.3 

func (*GetPipelineStatusRequest) ProtoMessage()

func (*GetPipelineStatusRequest) ProtoReflect added in v1.3.0 

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

func (*GetPipelineStatusRequest) Reset added in v0.7.3 

func (x *GetPipelineStatusRequest) Reset()

func (*GetPipelineStatusRequest) String added in v0.7.3 

func (x *GetPipelineStatusRequest) String() string

type GetPipelineStatusResponse added in v0.7.3 

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

func (*GetPipelineStatusResponse) Descriptor deprecated added in v0.7.3 

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

Deprecated: Use GetPipelineStatusResponse.ProtoReflect.Descriptor instead.

func (*GetPipelineStatusResponse) GetStatus added in v0.7.3 

func (x *GetPipelineStatusResponse) GetStatus() *PipelineStatus

func (*GetPipelineStatusResponse) ProtoMessage added in v0.7.3 

func (*GetPipelineStatusResponse) ProtoMessage()

func (*GetPipelineStatusResponse) ProtoReflect added in v1.3.0 

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

func (*GetPipelineStatusResponse) Reset added in v0.7.3 

func (x *GetPipelineStatusResponse) Reset()

func (*GetPipelineStatusResponse) String added in v0.7.3 

func (x *GetPipelineStatusResponse) String() string

type GetPipelineWatermarksRequest added in v0.7.0 

type GetPipelineWatermarksRequest struct {
	Pipeline string `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

GetPipelineWatermarksRequest requests for the watermark for a pipeline.

func (*GetPipelineWatermarksRequest) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use GetPipelineWatermarksRequest.ProtoReflect.Descriptor instead.

func (*GetPipelineWatermarksRequest) GetPipeline added in v0.7.0 

func (x *GetPipelineWatermarksRequest) GetPipeline() string

func (*GetPipelineWatermarksRequest) ProtoMessage added in v0.7.0 

func (*GetPipelineWatermarksRequest) ProtoMessage()

func (*GetPipelineWatermarksRequest) ProtoReflect added in v1.3.0 

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

func (*GetPipelineWatermarksRequest) Reset added in v0.7.0 

func (x *GetPipelineWatermarksRequest) Reset()

func (*GetPipelineWatermarksRequest) String added in v0.7.0 

func (x *GetPipelineWatermarksRequest) String() string

type GetPipelineWatermarksResponse added in v0.7.0 

type GetPipelineWatermarksResponse struct {
	PipelineWatermarks []*EdgeWatermark `protobuf:"bytes,1,rep,name=pipelineWatermarks,proto3" json:"pipelineWatermarks,omitempty"`
	// contains filtered or unexported fields
}

func (*GetPipelineWatermarksResponse) Descriptor deprecated added in v0.7.0 

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

Deprecated: Use GetPipelineWatermarksResponse.ProtoReflect.Descriptor instead.

func (*GetPipelineWatermarksResponse) GetPipelineWatermarks added in v0.7.0 

func (x *GetPipelineWatermarksResponse) GetPipelineWatermarks() []*EdgeWatermark

func (*GetPipelineWatermarksResponse) ProtoMessage added in v0.7.0 

func (*GetPipelineWatermarksResponse) ProtoMessage()

func (*GetPipelineWatermarksResponse) ProtoReflect added in v1.3.0 

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

func (*GetPipelineWatermarksResponse) Reset added in v0.7.0 

func (x *GetPipelineWatermarksResponse) Reset()

func (*GetPipelineWatermarksResponse) String added in v0.7.0 

func (x *GetPipelineWatermarksResponse) String() string

type GetVertexMetricsRequest added in v0.5.4 

type GetVertexMetricsRequest struct {
	Pipeline string `protobuf:"bytes,2,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Vertex   string `protobuf:"bytes,3,opt,name=vertex,proto3" json:"vertex,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVertexMetricsRequest) Descriptor deprecated added in v0.5.4 

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

Deprecated: Use GetVertexMetricsRequest.ProtoReflect.Descriptor instead.

func (*GetVertexMetricsRequest) GetPipeline added in v0.5.4 

func (x *GetVertexMetricsRequest) GetPipeline() string

func (*GetVertexMetricsRequest) GetVertex added in v0.5.4 

func (x *GetVertexMetricsRequest) GetVertex() string

func (*GetVertexMetricsRequest) ProtoMessage added in v0.5.4 

func (*GetVertexMetricsRequest) ProtoMessage()

func (*GetVertexMetricsRequest) ProtoReflect added in v1.3.0 

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

func (*GetVertexMetricsRequest) Reset added in v0.5.4 

func (x *GetVertexMetricsRequest) Reset()

func (*GetVertexMetricsRequest) String added in v0.5.4 

func (x *GetVertexMetricsRequest) String() string

type GetVertexMetricsResponse added in v0.5.4 

type GetVertexMetricsResponse struct {
	VertexMetrics []*VertexMetrics `protobuf:"bytes,1,rep,name=vertexMetrics,proto3" json:"vertexMetrics,omitempty"`
	// contains filtered or unexported fields
}

func (*GetVertexMetricsResponse) Descriptor deprecated added in v0.5.4 

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

Deprecated: Use GetVertexMetricsResponse.ProtoReflect.Descriptor instead.

func (*GetVertexMetricsResponse) GetVertexMetrics added in v0.7.1 

func (x *GetVertexMetricsResponse) GetVertexMetrics() []*VertexMetrics

func (*GetVertexMetricsResponse) ProtoMessage added in v0.5.4 

func (*GetVertexMetricsResponse) ProtoMessage()

func (*GetVertexMetricsResponse) ProtoReflect added in v1.3.0 

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

func (*GetVertexMetricsResponse) Reset added in v0.5.4 

func (x *GetVertexMetricsResponse) Reset()

func (*GetVertexMetricsResponse) String added in v0.5.4 

func (x *GetVertexMetricsResponse) String() string

type ListBuffersRequest 

type ListBuffersRequest struct {
	Pipeline string `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBuffersRequest) Descriptor deprecated 

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

Deprecated: Use ListBuffersRequest.ProtoReflect.Descriptor instead.

func (*ListBuffersRequest) GetPipeline 

func (x *ListBuffersRequest) GetPipeline() string

func (*ListBuffersRequest) ProtoMessage 

func (*ListBuffersRequest) ProtoMessage()

func (*ListBuffersRequest) ProtoReflect added in v1.3.0 

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

func (*ListBuffersRequest) Reset 

func (x *ListBuffersRequest) Reset()

func (*ListBuffersRequest) String 

func (x *ListBuffersRequest) String() string

type ListBuffersResponse 

type ListBuffersResponse struct {
	Buffers []*BufferInfo `protobuf:"bytes,1,rep,name=buffers,proto3" json:"buffers,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBuffersResponse) Descriptor deprecated 

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

Deprecated: Use ListBuffersResponse.ProtoReflect.Descriptor instead.

func (*ListBuffersResponse) GetBuffers 

func (x *ListBuffersResponse) GetBuffers() []*BufferInfo

func (*ListBuffersResponse) ProtoMessage 

func (*ListBuffersResponse) ProtoMessage()

func (*ListBuffersResponse) ProtoReflect added in v1.3.0 

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

func (*ListBuffersResponse) Reset 

func (x *ListBuffersResponse) Reset()

func (*ListBuffersResponse) String 

func (x *ListBuffersResponse) String() string

type PipelineStatus added in v0.7.3 

type PipelineStatus struct {
	Status  string `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Code    string `protobuf:"bytes,3,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

PipelineStatus

func (*PipelineStatus) Descriptor deprecated added in v0.7.3 

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

Deprecated: Use PipelineStatus.ProtoReflect.Descriptor instead.

func (*PipelineStatus) GetCode added in v1.2.0 

func (x *PipelineStatus) GetCode() string

func (*PipelineStatus) GetMessage added in v0.7.3 

func (x *PipelineStatus) GetMessage() string

func (*PipelineStatus) GetStatus added in v0.7.3 

func (x *PipelineStatus) GetStatus() string

func (*PipelineStatus) ProtoMessage added in v0.7.3 

func (*PipelineStatus) ProtoMessage()

func (*PipelineStatus) ProtoReflect added in v1.3.0 

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

func (*PipelineStatus) Reset added in v0.7.3 

func (x *PipelineStatus) Reset()

func (*PipelineStatus) String added in v0.7.3 

func (x *PipelineStatus) String() string

type UnimplementedDaemonServiceServer 

type UnimplementedDaemonServiceServer struct {
}

UnimplementedDaemonServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedDaemonServiceServer) GetBuffer 

func (UnimplementedDaemonServiceServer) GetBuffer(context.Context, *GetBufferRequest) (*GetBufferResponse, error)

func (UnimplementedDaemonServiceServer) GetPipelineStatus added in v0.7.3 

func (UnimplementedDaemonServiceServer) GetPipelineStatus(context.Context, *GetPipelineStatusRequest) (*GetPipelineStatusResponse, error)

func (UnimplementedDaemonServiceServer) GetPipelineWatermarks added in v0.7.0 

func (UnimplementedDaemonServiceServer) GetPipelineWatermarks(context.Context, *GetPipelineWatermarksRequest) (*GetPipelineWatermarksResponse, error)

func (UnimplementedDaemonServiceServer) GetVertexMetrics added in v0.5.4 

func (UnimplementedDaemonServiceServer) GetVertexMetrics(context.Context, *GetVertexMetricsRequest) (*GetVertexMetricsResponse, error)

func (UnimplementedDaemonServiceServer) ListBuffers 

func (UnimplementedDaemonServiceServer) ListBuffers(context.Context, *ListBuffersRequest) (*ListBuffersResponse, error)

type UnsafeDaemonServiceServer added in v1.3.0 

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

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

type VertexMetrics added in v0.5.4 

type VertexMetrics struct {
	Pipeline        string                             `protobuf:"bytes,1,opt,name=pipeline,proto3" json:"pipeline,omitempty"`
	Vertex          string                             `protobuf:"bytes,2,opt,name=vertex,proto3" json:"vertex,omitempty"`
	ProcessingRates map[string]*wrapperspb.DoubleValue `` /* 171-byte string literal not displayed */
	Pendings        map[string]*wrapperspb.Int64Value  `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

VertexMetrics is used to provide information about the vertex including processing rate.

func (*VertexMetrics) Descriptor deprecated added in v0.5.4 

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

Deprecated: Use VertexMetrics.ProtoReflect.Descriptor instead.

func (*VertexMetrics) GetPendings added in v0.5.4 

func (x *VertexMetrics) GetPendings() map[string]*wrapperspb.Int64Value

func (*VertexMetrics) GetPipeline added in v0.5.4 

func (x *VertexMetrics) GetPipeline() string

func (*VertexMetrics) GetProcessingRates added in v0.5.4 

func (x *VertexMetrics) GetProcessingRates() map[string]*wrapperspb.DoubleValue

func (*VertexMetrics) GetVertex added in v0.5.4 

func (x *VertexMetrics) GetVertex() string

func (*VertexMetrics) ProtoMessage added in v0.5.4 

func (*VertexMetrics) ProtoMessage()

func (*VertexMetrics) ProtoReflect added in v1.3.0 

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

func (*VertexMetrics) Reset added in v0.5.4 

func (x *VertexMetrics) Reset()

func (*VertexMetrics) String added in v0.5.4 

func (x *VertexMetrics) 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.