daemon

package
v0.5.6 Latest Latest
Warning

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

 Go to latest Published: Sep 20, 2022 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"`
	FromVertex      *string `protobuf:"bytes,2,req,name=fromVertex" json:"fromVertex,omitempty"`
	ToVertex        *string `protobuf:"bytes,3,req,name=toVertex" json:"toVertex,omitempty"`
	BufferName      *string `protobuf:"bytes,4,req,name=bufferName" json:"bufferName,omitempty"`
	PendingCount    *int64  `protobuf:"varint,5,req,name=pendingCount" json:"pendingCount,omitempty"`
	AckPendingCount *int64  `protobuf:"varint,6,req,name=ackPendingCount" json:"ackPendingCount,omitempty"`
	// Total messages existing in the buffer, including pending, ackPending and acked.
	TotalMessages        *int64   `protobuf:"varint,7,req,name=totalMessages" json:"totalMessages,omitempty"`
	BufferLength         *int64   `protobuf:"varint,8,req,name=bufferLength" json:"bufferLength,omitempty"`
	BufferUsageLimit     *float64 `protobuf:"fixed64,9,req,name=bufferUsageLimit" json:"bufferUsageLimit,omitempty"`
	BufferUsage          *float64 `protobuf:"fixed64,10,req,name=bufferUsage" json:"bufferUsage,omitempty"`
	IsFull               *bool    `protobuf:"varint,11,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) GetFromVertex 

func (m *BufferInfo) GetFromVertex() string

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) GetToVertex 

func (m *BufferInfo) GetToVertex() 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)
	// GetVertexWatermark return the watermark of the given vertex based on the incoming edge buffer
	GetVertexWatermark(ctx context.Context, in *GetVertexWatermarkRequest, opts ...grpc.CallOption) (*GetVertexWatermarkResponse, 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)
	// GetVertexWatermark return the watermark of the given vertex based on the incoming edge buffer
	GetVertexWatermark(context.Context, *GetVertexWatermarkRequest) (*GetVertexWatermarkResponse, error)
}

DaemonServiceServer is the server API for DaemonService service.

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 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 {
	Vertex               *VertexMetrics `protobuf:"bytes,1,req,name=vertex" json:"vertex,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) GetVertex added in v0.5.4 

func (m *GetVertexMetricsResponse) GetVertex() *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 GetVertexWatermarkRequest added in v0.5.4 

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

GetVertexWatermarksRequest requests for the watermark for a pipeline's vertex.

func (*GetVertexWatermarkRequest) Descriptor added in v0.5.4 

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

func (*GetVertexWatermarkRequest) GetPipeline added in v0.5.4 

func (m *GetVertexWatermarkRequest) GetPipeline() string

func (*GetVertexWatermarkRequest) GetVertex added in v0.5.4 

func (m *GetVertexWatermarkRequest) GetVertex() string

func (*GetVertexWatermarkRequest) Marshal added in v0.5.4 

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

func (*GetVertexWatermarkRequest) MarshalTo added in v0.5.4 

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

func (*GetVertexWatermarkRequest) MarshalToSizedBuffer added in v0.5.4 

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

func (*GetVertexWatermarkRequest) ProtoMessage added in v0.5.4 

func (*GetVertexWatermarkRequest) ProtoMessage()

func (*GetVertexWatermarkRequest) Reset added in v0.5.4 

func (m *GetVertexWatermarkRequest) Reset()

func (*GetVertexWatermarkRequest) Size added in v0.5.4 

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

func (*GetVertexWatermarkRequest) String added in v0.5.4 

func (m *GetVertexWatermarkRequest) String() string

func (*GetVertexWatermarkRequest) Unmarshal added in v0.5.4 

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

func (*GetVertexWatermarkRequest) XXX_DiscardUnknown added in v0.5.4 

func (m *GetVertexWatermarkRequest) XXX_DiscardUnknown()

func (*GetVertexWatermarkRequest) XXX_Marshal added in v0.5.4 

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

func (*GetVertexWatermarkRequest) XXX_Merge added in v0.5.4 

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

func (*GetVertexWatermarkRequest) XXX_Size added in v0.5.4 

func (m *GetVertexWatermarkRequest) XXX_Size() int

func (*GetVertexWatermarkRequest) XXX_Unmarshal added in v0.5.4 

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

type GetVertexWatermarkResponse added in v0.5.4 

type GetVertexWatermarkResponse struct {
	VertexWatermark      *VertexWatermark `protobuf:"bytes,1,req,name=vertexWatermark" json:"vertexWatermark,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*GetVertexWatermarkResponse) Descriptor added in v0.5.4 

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

func (*GetVertexWatermarkResponse) GetVertexWatermark added in v0.5.4 

func (m *GetVertexWatermarkResponse) GetVertexWatermark() *VertexWatermark

func (*GetVertexWatermarkResponse) Marshal added in v0.5.4 

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

func (*GetVertexWatermarkResponse) MarshalTo added in v0.5.4 

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

func (*GetVertexWatermarkResponse) MarshalToSizedBuffer added in v0.5.4 

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

func (*GetVertexWatermarkResponse) ProtoMessage added in v0.5.4 

func (*GetVertexWatermarkResponse) ProtoMessage()

func (*GetVertexWatermarkResponse) Reset added in v0.5.4 

func (m *GetVertexWatermarkResponse) Reset()

func (*GetVertexWatermarkResponse) Size added in v0.5.4 

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

func (*GetVertexWatermarkResponse) String added in v0.5.4 

func (m *GetVertexWatermarkResponse) String() string

func (*GetVertexWatermarkResponse) Unmarshal added in v0.5.4 

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

func (*GetVertexWatermarkResponse) XXX_DiscardUnknown added in v0.5.4 

func (m *GetVertexWatermarkResponse) XXX_DiscardUnknown()

func (*GetVertexWatermarkResponse) XXX_Marshal added in v0.5.4 

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

func (*GetVertexWatermarkResponse) XXX_Merge added in v0.5.4 

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

func (*GetVertexWatermarkResponse) XXX_Size added in v0.5.4 

func (m *GetVertexWatermarkResponse) XXX_Size() int

func (*GetVertexWatermarkResponse) XXX_Unmarshal added in v0.5.4 

func (m *GetVertexWatermarkResponse) 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 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) GetVertexMetrics added in v0.5.4 

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

func (*UnimplementedDaemonServiceServer) GetVertexWatermark added in v0.5.4 

func (*UnimplementedDaemonServiceServer) GetVertexWatermark(ctx context.Context, req *GetVertexWatermarkRequest) (*GetVertexWatermarkResponse, 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

type VertexWatermark added in v0.5.4 

type VertexWatermark struct {
	Pipeline             *string  `protobuf:"bytes,1,req,name=pipeline" json:"pipeline,omitempty"`
	Vertex               *string  `protobuf:"bytes,2,req,name=vertex" json:"vertex,omitempty"`
	Watermark            *int64   `protobuf:"varint,3,req,name=watermark" json:"watermark,omitempty"`
	IsWatermarkEnabled   *bool    `protobuf:"varint,4,req,name=isWatermarkEnabled" json:"isWatermarkEnabled,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

VertexWatermark has vertex to watermark mapping.

func (*VertexWatermark) Descriptor added in v0.5.4 

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

func (*VertexWatermark) GetIsWatermarkEnabled added in v0.5.4 

func (m *VertexWatermark) GetIsWatermarkEnabled() bool

func (*VertexWatermark) GetPipeline added in v0.5.4 

func (m *VertexWatermark) GetPipeline() string

func (*VertexWatermark) GetVertex added in v0.5.4 

func (m *VertexWatermark) GetVertex() string

func (*VertexWatermark) GetWatermark added in v0.5.4 

func (m *VertexWatermark) GetWatermark() int64

func (*VertexWatermark) Marshal added in v0.5.4 

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

func (*VertexWatermark) MarshalTo added in v0.5.4 

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

func (*VertexWatermark) MarshalToSizedBuffer added in v0.5.4 

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

func (*VertexWatermark) ProtoMessage added in v0.5.4 

func (*VertexWatermark) ProtoMessage()

func (*VertexWatermark) Reset added in v0.5.4 

func (m *VertexWatermark) Reset()

func (*VertexWatermark) Size added in v0.5.4 

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

func (*VertexWatermark) String added in v0.5.4 

func (m *VertexWatermark) String() string

func (*VertexWatermark) Unmarshal added in v0.5.4 

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

func (*VertexWatermark) XXX_DiscardUnknown added in v0.5.4 

func (m *VertexWatermark) XXX_DiscardUnknown()

func (*VertexWatermark) XXX_Marshal added in v0.5.4 

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

func (*VertexWatermark) XXX_Merge added in v0.5.4 

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

func (*VertexWatermark) XXX_Size added in v0.5.4 

func (m *VertexWatermark) XXX_Size() int

func (*VertexWatermark) XXX_Unmarshal added in v0.5.4 

func (m *VertexWatermark) 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.