daemon

package
v0.9.1 Latest Latest
Warning

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

 Go to latest Published: Aug 11, 2023 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Overview

Package daemon is a reverse proxy.

It translates gRPC into RESTful JSON APIs.

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthDaemon        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDaemon          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDaemon = fmt.Errorf("proto: unexpected end of group")
)

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.Server, srv DaemonServiceServer)

Types

type BufferInfo 

type BufferInfo struct {
	Pipeline        *string `protobuf:"bytes,1,req,name=pipeline" json:"pipeline,omitempty"`
	BufferName      *string `protobuf:"bytes,2,req,name=bufferName" json:"bufferName,omitempty"`
	PendingCount    *int64  `protobuf:"varint,3,req,name=pendingCount" json:"pendingCount,omitempty"`
	AckPendingCount *int64  `protobuf:"varint,4,req,name=ackPendingCount" json:"ackPendingCount,omitempty"`
	// Total messages existing in the buffer, including pending, ackPending and acked.
	TotalMessages        *int64   `protobuf:"varint,5,req,name=totalMessages" json:"totalMessages,omitempty"`
	BufferLength         *int64   `protobuf:"varint,6,req,name=bufferLength" json:"bufferLength,omitempty"`
	BufferUsageLimit     *float64 `protobuf:"fixed64,7,req,name=bufferUsageLimit" json:"bufferUsageLimit,omitempty"`
	BufferUsage          *float64 `protobuf:"fixed64,8,req,name=bufferUsage" json:"bufferUsage,omitempty"`
	IsFull               *bool    `protobuf:"varint,9,req,name=isFull" json:"isFull,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

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 

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

func (*BufferInfo) GetAckPendingCount 

func (m *BufferInfo) GetAckPendingCount() int64

func (*BufferInfo) GetBufferLength 

func (m *BufferInfo) GetBufferLength() int64

func (*BufferInfo) GetBufferName 

func (m *BufferInfo) GetBufferName() string

func (*BufferInfo) GetBufferUsage 

func (m *BufferInfo) GetBufferUsage() float64

func (*BufferInfo) GetBufferUsageLimit 

func (m *BufferInfo) GetBufferUsageLimit() float64

func (*BufferInfo) GetIsFull 

func (m *BufferInfo) GetIsFull() bool

func (*BufferInfo) GetPendingCount 

func (m *BufferInfo) GetPendingCount() int64

func (*BufferInfo) GetPipeline 

func (m *BufferInfo) GetPipeline() string

func (*BufferInfo) GetTotalMessages 

func (m *BufferInfo) GetTotalMessages() int64

func (*BufferInfo) Marshal 

func (m *BufferInfo) Marshal() (dAtA []byte, err error)

func (*BufferInfo) MarshalTo 

func (m *BufferInfo) MarshalTo(dAtA []byte) (int, error)

func (*BufferInfo) MarshalToSizedBuffer 

func (m *BufferInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*BufferInfo) ProtoMessage 

func (*BufferInfo) ProtoMessage()

func (*BufferInfo) Reset 

func (m *BufferInfo) Reset()

func (*BufferInfo) Size 

func (m *BufferInfo) Size() (n int)

func (*BufferInfo) String 

func (m *BufferInfo) String() string

func (*BufferInfo) Unmarshal 

func (m *BufferInfo) Unmarshal(dAtA []byte) error

func (*BufferInfo) XXX_DiscardUnknown 

func (m *BufferInfo) XXX_DiscardUnknown()

func (*BufferInfo) XXX_Marshal 

func (m *BufferInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BufferInfo) XXX_Merge 

func (m *BufferInfo) XXX_Merge(src proto.Message)

func (*BufferInfo) XXX_Size 

func (m *BufferInfo) XXX_Size() int

func (*BufferInfo) XXX_Unmarshal 

func (m *BufferInfo) XXX_Unmarshal(b []byte) error

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://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewDaemonServiceClient 

func NewDaemonServiceClient(cc *grpc.ClientConn) 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)
}

DaemonServiceServer is the server API for DaemonService service.

type EdgeWatermark added in v0.7.2 

type EdgeWatermark struct {
	Pipeline             *string  `protobuf:"bytes,1,req,name=pipeline" json:"pipeline,omitempty"`
	Edge                 *string  `protobuf:"bytes,2,req,name=edge" json:"edge,omitempty"`
	Watermarks           []int64  `protobuf:"varint,3,rep,name=watermarks" json:"watermarks,omitempty"`
	IsWatermarkEnabled   *bool    `protobuf:"varint,4,req,name=isWatermarkEnabled" json:"isWatermarkEnabled,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

EdgeWatermark has edge to watermark mapping.

func (*EdgeWatermark) Descriptor added in v0.7.2 

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

func (*EdgeWatermark) GetEdge added in v0.7.2 

func (m *EdgeWatermark) GetEdge() string

func (*EdgeWatermark) GetIsWatermarkEnabled added in v0.7.2 

func (m *EdgeWatermark) GetIsWatermarkEnabled() bool

func (*EdgeWatermark) GetPipeline added in v0.7.2 

func (m *EdgeWatermark) GetPipeline() string

func (*EdgeWatermark) GetWatermarks added in v0.7.2 

func (m *EdgeWatermark) GetWatermarks() []int64

func (*EdgeWatermark) Marshal added in v0.7.2 

func (m *EdgeWatermark) Marshal() (dAtA []byte, err error)

func (*EdgeWatermark) MarshalTo added in v0.7.2 

func (m *EdgeWatermark) MarshalTo(dAtA []byte) (int, error)

func (*EdgeWatermark) MarshalToSizedBuffer added in v0.7.2 

func (m *EdgeWatermark) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*EdgeWatermark) ProtoMessage added in v0.7.2 

func (*EdgeWatermark) ProtoMessage()

func (*EdgeWatermark) Reset added in v0.7.2 

func (m *EdgeWatermark) Reset()

func (*EdgeWatermark) Size added in v0.7.2 

func (m *EdgeWatermark) Size() (n int)

func (*EdgeWatermark) String added in v0.7.2 

func (m *EdgeWatermark) String() string

func (*EdgeWatermark) Unmarshal added in v0.7.2 

func (m *EdgeWatermark) Unmarshal(dAtA []byte) error

func (*EdgeWatermark) XXX_DiscardUnknown added in v0.7.2 

func (m *EdgeWatermark) XXX_DiscardUnknown()

func (*EdgeWatermark) XXX_Marshal added in v0.7.2 

func (m *EdgeWatermark) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EdgeWatermark) XXX_Merge added in v0.7.2 

func (m *EdgeWatermark) XXX_Merge(src proto.Message)

func (*EdgeWatermark) XXX_Size added in v0.7.2 

func (m *EdgeWatermark) XXX_Size() int

func (*EdgeWatermark) XXX_Unmarshal added in v0.7.2 

func (m *EdgeWatermark) XXX_Unmarshal(b []byte) error

type GetBufferRequest 

type GetBufferRequest struct {
	Pipeline             *string  `protobuf:"bytes,1,req,name=pipeline" json:"pipeline,omitempty"`
	Buffer               *string  `protobuf:"bytes,2,req,name=buffer" json:"buffer,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetBufferRequest) Descriptor 

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

func (*GetBufferRequest) GetBuffer 

func (m *GetBufferRequest) GetBuffer() string

func (*GetBufferRequest) GetPipeline 

func (m *GetBufferRequest) GetPipeline() string

func (*GetBufferRequest) Marshal 

func (m *GetBufferRequest) Marshal() (dAtA []byte, err error)

func (*GetBufferRequest) MarshalTo 

func (m *GetBufferRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetBufferRequest) MarshalToSizedBuffer 

func (m *GetBufferRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetBufferRequest) ProtoMessage 

func (*GetBufferRequest) ProtoMessage()

func (*GetBufferRequest) Reset 

func (m *GetBufferRequest) Reset()

func (*GetBufferRequest) Size 

func (m *GetBufferRequest) Size() (n int)

func (*GetBufferRequest) String 

func (m *GetBufferRequest) String() string

func (*GetBufferRequest) Unmarshal 

func (m *GetBufferRequest) Unmarshal(dAtA []byte) error

func (*GetBufferRequest) XXX_DiscardUnknown 

func (m *GetBufferRequest) XXX_DiscardUnknown()

func (*GetBufferRequest) XXX_Marshal 

func (m *GetBufferRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetBufferRequest) XXX_Merge 

func (m *GetBufferRequest) XXX_Merge(src proto.Message)

func (*GetBufferRequest) XXX_Size 

func (m *GetBufferRequest) XXX_Size() int

func (*GetBufferRequest) XXX_Unmarshal 

func (m *GetBufferRequest) XXX_Unmarshal(b []byte) error

type GetBufferResponse 

type GetBufferResponse struct {
	Buffer               *BufferInfo `protobuf:"bytes,1,req,name=buffer" json:"buffer,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*GetBufferResponse) Descriptor 

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

func (*GetBufferResponse) GetBuffer 

func (m *GetBufferResponse) GetBuffer() *BufferInfo

func (*GetBufferResponse) Marshal 

func (m *GetBufferResponse) Marshal() (dAtA []byte, err error)

func (*GetBufferResponse) MarshalTo 

func (m *GetBufferResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetBufferResponse) MarshalToSizedBuffer 

func (m *GetBufferResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetBufferResponse) ProtoMessage 

func (*GetBufferResponse) ProtoMessage()

func (*GetBufferResponse) Reset 

func (m *GetBufferResponse) Reset()

func (*GetBufferResponse) Size 

func (m *GetBufferResponse) Size() (n int)

func (*GetBufferResponse) String 

func (m *GetBufferResponse) String() string

func (*GetBufferResponse) Unmarshal 

func (m *GetBufferResponse) Unmarshal(dAtA []byte) error

func (*GetBufferResponse) XXX_DiscardUnknown 

func (m *GetBufferResponse) XXX_DiscardUnknown()

func (*GetBufferResponse) XXX_Marshal 

func (m *GetBufferResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetBufferResponse) XXX_Merge 

func (m *GetBufferResponse) XXX_Merge(src proto.Message)

func (*GetBufferResponse) XXX_Size 

func (m *GetBufferResponse) XXX_Size() int

func (*GetBufferResponse) XXX_Unmarshal 

func (m *GetBufferResponse) XXX_Unmarshal(b []byte) error

type GetPipelineStatusRequest added in v0.7.3 

type GetPipelineStatusRequest struct {
	Pipeline             *string  `protobuf:"bytes,1,req,name=pipeline" json:"pipeline,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetPipelineStatusRequest) Descriptor added in v0.7.3 

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

func (*GetPipelineStatusRequest) GetPipeline added in v0.7.3 

func (m *GetPipelineStatusRequest) GetPipeline() string

func (*GetPipelineStatusRequest) Marshal added in v0.7.3 

func (m *GetPipelineStatusRequest) Marshal() (dAtA []byte, err error)

func (*GetPipelineStatusRequest) MarshalTo added in v0.7.3 

func (m *GetPipelineStatusRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetPipelineStatusRequest) MarshalToSizedBuffer added in v0.7.3 

func (m *GetPipelineStatusRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetPipelineStatusRequest) ProtoMessage added in v0.7.3 

func (*GetPipelineStatusRequest) ProtoMessage()

func (*GetPipelineStatusRequest) Reset added in v0.7.3 

func (m *GetPipelineStatusRequest) Reset()

func (*GetPipelineStatusRequest) Size added in v0.7.3 

func (m *GetPipelineStatusRequest) Size() (n int)

func (*GetPipelineStatusRequest) String added in v0.7.3 

func (m *GetPipelineStatusRequest) String() string

func (*GetPipelineStatusRequest) Unmarshal added in v0.7.3 

func (m *GetPipelineStatusRequest) Unmarshal(dAtA []byte) error

func (*GetPipelineStatusRequest) XXX_DiscardUnknown added in v0.7.3 

func (m *GetPipelineStatusRequest) XXX_DiscardUnknown()

func (*GetPipelineStatusRequest) XXX_Marshal added in v0.7.3 

func (m *GetPipelineStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPipelineStatusRequest) XXX_Merge added in v0.7.3 

func (m *GetPipelineStatusRequest) XXX_Merge(src proto.Message)

func (*GetPipelineStatusRequest) XXX_Size added in v0.7.3 

func (m *GetPipelineStatusRequest) XXX_Size() int

func (*GetPipelineStatusRequest) XXX_Unmarshal added in v0.7.3 

func (m *GetPipelineStatusRequest) XXX_Unmarshal(b []byte) error

type GetPipelineStatusResponse added in v0.7.3 

type GetPipelineStatusResponse struct {
	Status               *PipelineStatus `protobuf:"bytes,1,req,name=status" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}        `json:"-"`
	XXX_unrecognized     []byte          `json:"-"`
	XXX_sizecache        int32           `json:"-"`
}

func (*GetPipelineStatusResponse) Descriptor added in v0.7.3 

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

func (*GetPipelineStatusResponse) GetStatus added in v0.7.3 

func (m *GetPipelineStatusResponse) GetStatus() *PipelineStatus

func (*GetPipelineStatusResponse) Marshal added in v0.7.3 

func (m *GetPipelineStatusResponse) Marshal() (dAtA []byte, err error)

func (*GetPipelineStatusResponse) MarshalTo added in v0.7.3 

func (m *GetPipelineStatusResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetPipelineStatusResponse) MarshalToSizedBuffer added in v0.7.3 

func (m *GetPipelineStatusResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetPipelineStatusResponse) ProtoMessage added in v0.7.3 

func (*GetPipelineStatusResponse) ProtoMessage()

func (*GetPipelineStatusResponse) Reset added in v0.7.3 

func (m *GetPipelineStatusResponse) Reset()

func (*GetPipelineStatusResponse) Size added in v0.7.3 

func (m *GetPipelineStatusResponse) Size() (n int)

func (*GetPipelineStatusResponse) String added in v0.7.3 

func (m *GetPipelineStatusResponse) String() string

func (*GetPipelineStatusResponse) Unmarshal added in v0.7.3 

func (m *GetPipelineStatusResponse) Unmarshal(dAtA []byte) error

func (*GetPipelineStatusResponse) XXX_DiscardUnknown added in v0.7.3 

func (m *GetPipelineStatusResponse) XXX_DiscardUnknown()

func (*GetPipelineStatusResponse) XXX_Marshal added in v0.7.3 

func (m *GetPipelineStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPipelineStatusResponse) XXX_Merge added in v0.7.3 

func (m *GetPipelineStatusResponse) XXX_Merge(src proto.Message)

func (*GetPipelineStatusResponse) XXX_Size added in v0.7.3 

func (m *GetPipelineStatusResponse) XXX_Size() int

func (*GetPipelineStatusResponse) XXX_Unmarshal added in v0.7.3 

func (m *GetPipelineStatusResponse) XXX_Unmarshal(b []byte) error

type GetPipelineWatermarksRequest added in v0.7.0 

type GetPipelineWatermarksRequest struct {
	Pipeline             *string  `protobuf:"bytes,1,req,name=pipeline" json:"pipeline,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

GetPipelineWatermarksRequest requests for the watermark for a pipeline.

func (*GetPipelineWatermarksRequest) Descriptor added in v0.7.0 

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

func (*GetPipelineWatermarksRequest) GetPipeline added in v0.7.0 

func (m *GetPipelineWatermarksRequest) GetPipeline() string

func (*GetPipelineWatermarksRequest) Marshal added in v0.7.0 

func (m *GetPipelineWatermarksRequest) Marshal() (dAtA []byte, err error)

func (*GetPipelineWatermarksRequest) MarshalTo added in v0.7.0 

func (m *GetPipelineWatermarksRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetPipelineWatermarksRequest) MarshalToSizedBuffer added in v0.7.0 

func (m *GetPipelineWatermarksRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetPipelineWatermarksRequest) ProtoMessage added in v0.7.0 

func (*GetPipelineWatermarksRequest) ProtoMessage()

func (*GetPipelineWatermarksRequest) Reset added in v0.7.0 

func (m *GetPipelineWatermarksRequest) Reset()

func (*GetPipelineWatermarksRequest) Size added in v0.7.0 

func (m *GetPipelineWatermarksRequest) Size() (n int)

func (*GetPipelineWatermarksRequest) String added in v0.7.0 

func (m *GetPipelineWatermarksRequest) String() string

func (*GetPipelineWatermarksRequest) Unmarshal added in v0.7.0 

func (m *GetPipelineWatermarksRequest) Unmarshal(dAtA []byte) error

func (*GetPipelineWatermarksRequest) XXX_DiscardUnknown added in v0.7.0 

func (m *GetPipelineWatermarksRequest) XXX_DiscardUnknown()

func (*GetPipelineWatermarksRequest) XXX_Marshal added in v0.7.0 

func (m *GetPipelineWatermarksRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPipelineWatermarksRequest) XXX_Merge added in v0.7.0 

func (m *GetPipelineWatermarksRequest) XXX_Merge(src proto.Message)

func (*GetPipelineWatermarksRequest) XXX_Size added in v0.7.0 

func (m *GetPipelineWatermarksRequest) XXX_Size() int

func (*GetPipelineWatermarksRequest) XXX_Unmarshal added in v0.7.0 

func (m *GetPipelineWatermarksRequest) XXX_Unmarshal(b []byte) error

type GetPipelineWatermarksResponse added in v0.7.0 

type GetPipelineWatermarksResponse struct {
	PipelineWatermarks   []*EdgeWatermark `protobuf:"bytes,1,rep,name=pipelineWatermarks" json:"pipelineWatermarks,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*GetPipelineWatermarksResponse) Descriptor added in v0.7.0 

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

func (*GetPipelineWatermarksResponse) GetPipelineWatermarks added in v0.7.0 

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

func (*GetPipelineWatermarksResponse) Marshal added in v0.7.0 

func (m *GetPipelineWatermarksResponse) Marshal() (dAtA []byte, err error)

func (*GetPipelineWatermarksResponse) MarshalTo added in v0.7.0 

func (m *GetPipelineWatermarksResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetPipelineWatermarksResponse) MarshalToSizedBuffer added in v0.7.0 

func (m *GetPipelineWatermarksResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetPipelineWatermarksResponse) ProtoMessage added in v0.7.0 

func (*GetPipelineWatermarksResponse) ProtoMessage()

func (*GetPipelineWatermarksResponse) Reset added in v0.7.0 

func (m *GetPipelineWatermarksResponse) Reset()

func (*GetPipelineWatermarksResponse) Size added in v0.7.0 

func (m *GetPipelineWatermarksResponse) Size() (n int)

func (*GetPipelineWatermarksResponse) String added in v0.7.0 

func (m *GetPipelineWatermarksResponse) String() string

func (*GetPipelineWatermarksResponse) Unmarshal added in v0.7.0 

func (m *GetPipelineWatermarksResponse) Unmarshal(dAtA []byte) error

func (*GetPipelineWatermarksResponse) XXX_DiscardUnknown added in v0.7.0 

func (m *GetPipelineWatermarksResponse) XXX_DiscardUnknown()

func (*GetPipelineWatermarksResponse) XXX_Marshal added in v0.7.0 

func (m *GetPipelineWatermarksResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetPipelineWatermarksResponse) XXX_Merge added in v0.7.0 

func (m *GetPipelineWatermarksResponse) XXX_Merge(src proto.Message)

func (*GetPipelineWatermarksResponse) XXX_Size added in v0.7.0 

func (m *GetPipelineWatermarksResponse) XXX_Size() int

func (*GetPipelineWatermarksResponse) XXX_Unmarshal added in v0.7.0 

func (m *GetPipelineWatermarksResponse) XXX_Unmarshal(b []byte) error

type GetVertexMetricsRequest added in v0.5.4 

type GetVertexMetricsRequest struct {
	Pipeline             *string  `protobuf:"bytes,2,req,name=pipeline" json:"pipeline,omitempty"`
	Vertex               *string  `protobuf:"bytes,3,req,name=vertex" json:"vertex,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetVertexMetricsRequest) Descriptor added in v0.5.4 

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

func (*GetVertexMetricsRequest) GetPipeline added in v0.5.4 

func (m *GetVertexMetricsRequest) GetPipeline() string

func (*GetVertexMetricsRequest) GetVertex added in v0.5.4 

func (m *GetVertexMetricsRequest) GetVertex() string

func (*GetVertexMetricsRequest) Marshal added in v0.5.4 

func (m *GetVertexMetricsRequest) Marshal() (dAtA []byte, err error)

func (*GetVertexMetricsRequest) MarshalTo added in v0.5.4 

func (m *GetVertexMetricsRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetVertexMetricsRequest) MarshalToSizedBuffer added in v0.5.4 

func (m *GetVertexMetricsRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetVertexMetricsRequest) ProtoMessage added in v0.5.4 

func (*GetVertexMetricsRequest) ProtoMessage()

func (*GetVertexMetricsRequest) Reset added in v0.5.4 

func (m *GetVertexMetricsRequest) Reset()

func (*GetVertexMetricsRequest) Size added in v0.5.4 

func (m *GetVertexMetricsRequest) Size() (n int)

func (*GetVertexMetricsRequest) String added in v0.5.4 

func (m *GetVertexMetricsRequest) String() string

func (*GetVertexMetricsRequest) Unmarshal added in v0.5.4 

func (m *GetVertexMetricsRequest) Unmarshal(dAtA []byte) error

func (*GetVertexMetricsRequest) XXX_DiscardUnknown added in v0.5.4 

func (m *GetVertexMetricsRequest) XXX_DiscardUnknown()

func (*GetVertexMetricsRequest) XXX_Marshal added in v0.5.4 

func (m *GetVertexMetricsRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetVertexMetricsRequest) XXX_Merge added in v0.5.4 

func (m *GetVertexMetricsRequest) XXX_Merge(src proto.Message)

func (*GetVertexMetricsRequest) XXX_Size added in v0.5.4 

func (m *GetVertexMetricsRequest) XXX_Size() int

func (*GetVertexMetricsRequest) XXX_Unmarshal added in v0.5.4 

func (m *GetVertexMetricsRequest) XXX_Unmarshal(b []byte) error

type GetVertexMetricsResponse added in v0.5.4 

type GetVertexMetricsResponse struct {
	VertexMetrics        []*VertexMetrics `protobuf:"bytes,1,rep,name=vertexMetrics" json:"vertexMetrics,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*GetVertexMetricsResponse) Descriptor added in v0.5.4 

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

func (*GetVertexMetricsResponse) GetVertexMetrics added in v0.7.1 

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

func (*GetVertexMetricsResponse) Marshal added in v0.5.4 

func (m *GetVertexMetricsResponse) Marshal() (dAtA []byte, err error)

func (*GetVertexMetricsResponse) MarshalTo added in v0.5.4 

func (m *GetVertexMetricsResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetVertexMetricsResponse) MarshalToSizedBuffer added in v0.5.4 

func (m *GetVertexMetricsResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetVertexMetricsResponse) ProtoMessage added in v0.5.4 

func (*GetVertexMetricsResponse) ProtoMessage()

func (*GetVertexMetricsResponse) Reset added in v0.5.4 

func (m *GetVertexMetricsResponse) Reset()

func (*GetVertexMetricsResponse) Size added in v0.5.4 

func (m *GetVertexMetricsResponse) Size() (n int)

func (*GetVertexMetricsResponse) String added in v0.5.4 

func (m *GetVertexMetricsResponse) String() string

func (*GetVertexMetricsResponse) Unmarshal added in v0.5.4 

func (m *GetVertexMetricsResponse) Unmarshal(dAtA []byte) error

func (*GetVertexMetricsResponse) XXX_DiscardUnknown added in v0.5.4 

func (m *GetVertexMetricsResponse) XXX_DiscardUnknown()

func (*GetVertexMetricsResponse) XXX_Marshal added in v0.5.4 

func (m *GetVertexMetricsResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetVertexMetricsResponse) XXX_Merge added in v0.5.4 

func (m *GetVertexMetricsResponse) XXX_Merge(src proto.Message)

func (*GetVertexMetricsResponse) XXX_Size added in v0.5.4 

func (m *GetVertexMetricsResponse) XXX_Size() int

func (*GetVertexMetricsResponse) XXX_Unmarshal added in v0.5.4 

func (m *GetVertexMetricsResponse) XXX_Unmarshal(b []byte) error

type ListBuffersRequest 

type ListBuffersRequest struct {
	Pipeline             *string  `protobuf:"bytes,1,req,name=pipeline" json:"pipeline,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListBuffersRequest) Descriptor 

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

func (*ListBuffersRequest) GetPipeline 

func (m *ListBuffersRequest) GetPipeline() string

func (*ListBuffersRequest) Marshal 

func (m *ListBuffersRequest) Marshal() (dAtA []byte, err error)

func (*ListBuffersRequest) MarshalTo 

func (m *ListBuffersRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListBuffersRequest) MarshalToSizedBuffer 

func (m *ListBuffersRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListBuffersRequest) ProtoMessage 

func (*ListBuffersRequest) ProtoMessage()

func (*ListBuffersRequest) Reset 

func (m *ListBuffersRequest) Reset()

func (*ListBuffersRequest) Size 

func (m *ListBuffersRequest) Size() (n int)

func (*ListBuffersRequest) String 

func (m *ListBuffersRequest) String() string

func (*ListBuffersRequest) Unmarshal 

func (m *ListBuffersRequest) Unmarshal(dAtA []byte) error

func (*ListBuffersRequest) XXX_DiscardUnknown 

func (m *ListBuffersRequest) XXX_DiscardUnknown()

func (*ListBuffersRequest) XXX_Marshal 

func (m *ListBuffersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListBuffersRequest) XXX_Merge 

func (m *ListBuffersRequest) XXX_Merge(src proto.Message)

func (*ListBuffersRequest) XXX_Size 

func (m *ListBuffersRequest) XXX_Size() int

func (*ListBuffersRequest) XXX_Unmarshal 

func (m *ListBuffersRequest) XXX_Unmarshal(b []byte) error

type ListBuffersResponse 

type ListBuffersResponse struct {
	Buffers              []*BufferInfo `protobuf:"bytes,1,rep,name=buffers" json:"buffers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}      `json:"-"`
	XXX_unrecognized     []byte        `json:"-"`
	XXX_sizecache        int32         `json:"-"`
}

func (*ListBuffersResponse) Descriptor 

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

func (*ListBuffersResponse) GetBuffers 

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

func (*ListBuffersResponse) Marshal 

func (m *ListBuffersResponse) Marshal() (dAtA []byte, err error)

func (*ListBuffersResponse) MarshalTo 

func (m *ListBuffersResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListBuffersResponse) MarshalToSizedBuffer 

func (m *ListBuffersResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListBuffersResponse) ProtoMessage 

func (*ListBuffersResponse) ProtoMessage()

func (*ListBuffersResponse) Reset 

func (m *ListBuffersResponse) Reset()

func (*ListBuffersResponse) Size 

func (m *ListBuffersResponse) Size() (n int)

func (*ListBuffersResponse) String 

func (m *ListBuffersResponse) String() string

func (*ListBuffersResponse) Unmarshal 

func (m *ListBuffersResponse) Unmarshal(dAtA []byte) error

func (*ListBuffersResponse) XXX_DiscardUnknown 

func (m *ListBuffersResponse) XXX_DiscardUnknown()

func (*ListBuffersResponse) XXX_Marshal 

func (m *ListBuffersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListBuffersResponse) XXX_Merge 

func (m *ListBuffersResponse) XXX_Merge(src proto.Message)

func (*ListBuffersResponse) XXX_Size 

func (m *ListBuffersResponse) XXX_Size() int

func (*ListBuffersResponse) XXX_Unmarshal 

func (m *ListBuffersResponse) XXX_Unmarshal(b []byte) error

type PipelineStatus added in v0.7.3 

type PipelineStatus struct {
	Status               *string  `protobuf:"bytes,1,req,name=status" json:"status,omitempty"`
	Message              *string  `protobuf:"bytes,2,req,name=message" json:"message,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

PipelineStatus

func (*PipelineStatus) Descriptor added in v0.7.3 

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

func (*PipelineStatus) GetMessage added in v0.7.3 

func (m *PipelineStatus) GetMessage() string

func (*PipelineStatus) GetStatus added in v0.7.3 

func (m *PipelineStatus) GetStatus() string

func (*PipelineStatus) Marshal added in v0.7.3 

func (m *PipelineStatus) Marshal() (dAtA []byte, err error)

func (*PipelineStatus) MarshalTo added in v0.7.3 

func (m *PipelineStatus) MarshalTo(dAtA []byte) (int, error)

func (*PipelineStatus) MarshalToSizedBuffer added in v0.7.3 

func (m *PipelineStatus) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PipelineStatus) ProtoMessage added in v0.7.3 

func (*PipelineStatus) ProtoMessage()

func (*PipelineStatus) Reset added in v0.7.3 

func (m *PipelineStatus) Reset()

func (*PipelineStatus) Size added in v0.7.3 

func (m *PipelineStatus) Size() (n int)

func (*PipelineStatus) String added in v0.7.3 

func (m *PipelineStatus) String() string

func (*PipelineStatus) Unmarshal added in v0.7.3 

func (m *PipelineStatus) Unmarshal(dAtA []byte) error

func (*PipelineStatus) XXX_DiscardUnknown added in v0.7.3 

func (m *PipelineStatus) XXX_DiscardUnknown()

func (*PipelineStatus) XXX_Marshal added in v0.7.3 

func (m *PipelineStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PipelineStatus) XXX_Merge added in v0.7.3 

func (m *PipelineStatus) XXX_Merge(src proto.Message)

func (*PipelineStatus) XXX_Size added in v0.7.3 

func (m *PipelineStatus) XXX_Size() int

func (*PipelineStatus) XXX_Unmarshal added in v0.7.3 

func (m *PipelineStatus) XXX_Unmarshal(b []byte) error

type UnimplementedDaemonServiceServer 

type UnimplementedDaemonServiceServer struct {
}

UnimplementedDaemonServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedDaemonServiceServer) GetBuffer 

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

func (*UnimplementedDaemonServiceServer) GetPipelineStatus added in v0.7.3 

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

func (*UnimplementedDaemonServiceServer) GetPipelineWatermarks added in v0.7.0 

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

func (*UnimplementedDaemonServiceServer) GetVertexMetrics added in v0.5.4 

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

func (*UnimplementedDaemonServiceServer) ListBuffers 

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

type VertexMetrics added in v0.5.4 

type VertexMetrics struct {
	Pipeline             *string            `protobuf:"bytes,1,req,name=pipeline" json:"pipeline,omitempty"`
	Vertex               *string            `protobuf:"bytes,2,req,name=vertex" json:"vertex,omitempty"`
	ProcessingRates      map[string]float64 `` /* 152-byte string literal not displayed */
	Pendings             map[string]int64   `` /* 137-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

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

func (*VertexMetrics) Descriptor added in v0.5.4 

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

func (*VertexMetrics) GetPendings added in v0.5.4 

func (m *VertexMetrics) GetPendings() map[string]int64

func (*VertexMetrics) GetPipeline added in v0.5.4 

func (m *VertexMetrics) GetPipeline() string

func (*VertexMetrics) GetProcessingRates added in v0.5.4 

func (m *VertexMetrics) GetProcessingRates() map[string]float64

func (*VertexMetrics) GetVertex added in v0.5.4 

func (m *VertexMetrics) GetVertex() string

func (*VertexMetrics) Marshal added in v0.5.4 

func (m *VertexMetrics) Marshal() (dAtA []byte, err error)

func (*VertexMetrics) MarshalTo added in v0.5.4 

func (m *VertexMetrics) MarshalTo(dAtA []byte) (int, error)

func (*VertexMetrics) MarshalToSizedBuffer added in v0.5.4 

func (m *VertexMetrics) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*VertexMetrics) ProtoMessage added in v0.5.4 

func (*VertexMetrics) ProtoMessage()

func (*VertexMetrics) Reset added in v0.5.4 

func (m *VertexMetrics) Reset()

func (*VertexMetrics) Size added in v0.5.4 

func (m *VertexMetrics) Size() (n int)

func (*VertexMetrics) String added in v0.5.4 

func (m *VertexMetrics) String() string

func (*VertexMetrics) Unmarshal added in v0.5.4 

func (m *VertexMetrics) Unmarshal(dAtA []byte) error

func (*VertexMetrics) XXX_DiscardUnknown added in v0.5.4 

func (m *VertexMetrics) XXX_DiscardUnknown()

func (*VertexMetrics) XXX_Marshal added in v0.5.4 

func (m *VertexMetrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VertexMetrics) XXX_Merge added in v0.5.4 

func (m *VertexMetrics) XXX_Merge(src proto.Message)

func (*VertexMetrics) XXX_Size added in v0.5.4 

func (m *VertexMetrics) XXX_Size() int

func (*VertexMetrics) XXX_Unmarshal added in v0.5.4 

func (m *VertexMetrics) XXX_Unmarshal(b []byte) error

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.