daemon

Aug 19, 2024

Changes in this version

+ const DaemonService_GetBuffer_FullMethodName

+ const DaemonService_GetPipelineStatus_FullMethodName

+ const DaemonService_GetPipelineWatermarks_FullMethodName

+ const DaemonService_GetVertexMetrics_FullMethodName

+ const DaemonService_ListBuffers_FullMethodName

+ var DaemonService_ServiceDesc = grpc.ServiceDesc

+ var File_pkg_apis_proto_daemon_daemon_proto protoreflect.FileDescriptor

type BufferInfo

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

type EdgeWatermark

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

type GetBufferRequest

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

type GetBufferResponse

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

type GetPipelineStatusRequest

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

type GetPipelineStatusResponse

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

type GetPipelineWatermarksRequest

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

type GetPipelineWatermarksResponse

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

type GetVertexMetricsRequest

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

type GetVertexMetricsResponse

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

type ListBuffersRequest

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

type ListBuffersResponse

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

type PipelineStatus

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

+ type UnsafeDaemonServiceServer interface

type VertexMetrics

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

May 3, 2024

Changes in this version

type PipelineStatus

+ Code *string

+ func (m *PipelineStatus) GetCode() string

Oct 13, 2023

Changes in this version

type EdgeWatermark

+ From *string

+ To *string

+ func (m *EdgeWatermark) GetFrom() string

+ func (m *EdgeWatermark) GetTo() string

Apr 3, 2023

Changes in this version

type DaemonServiceClient

+ GetPipelineStatus func(ctx context.Context, in *GetPipelineStatusRequest, opts ...grpc.CallOption) (*GetPipelineStatusResponse, error)

type DaemonServiceServer

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

+ type GetPipelineStatusRequest struct

+ Pipeline *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetPipelineStatusRequest) ProtoMessage()

+ func (m *GetPipelineStatusRequest) GetPipeline() string

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

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

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

+ func (m *GetPipelineStatusRequest) Reset()

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

+ func (m *GetPipelineStatusRequest) String() string

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

+ func (m *GetPipelineStatusRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetPipelineStatusRequest) XXX_Size() int

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

+ type GetPipelineStatusResponse struct

+ Status *PipelineStatus

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetPipelineStatusResponse) ProtoMessage()

+ func (m *GetPipelineStatusResponse) GetStatus() *PipelineStatus

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

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

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

+ func (m *GetPipelineStatusResponse) Reset()

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

+ func (m *GetPipelineStatusResponse) String() string

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

+ func (m *GetPipelineStatusResponse) XXX_DiscardUnknown()

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

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

+ func (m *GetPipelineStatusResponse) XXX_Size() int

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

+ type PipelineStatus struct

+ Message *string

+ Status *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*PipelineStatus) ProtoMessage()

+ func (m *PipelineStatus) GetMessage() string

+ func (m *PipelineStatus) GetStatus() string

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

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

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

+ func (m *PipelineStatus) Reset()

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

+ func (m *PipelineStatus) String() string

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

+ func (m *PipelineStatus) XXX_DiscardUnknown()

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

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

+ func (m *PipelineStatus) XXX_Size() int

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

type UnimplementedDaemonServiceServer

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

Mar 13, 2023

Changes in this version

+ type EdgeWatermark struct

+ Edge *string

+ IsWatermarkEnabled *bool

+ Pipeline *string

+ Watermarks []int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*EdgeWatermark) ProtoMessage()

+ func (m *EdgeWatermark) GetEdge() string

+ func (m *EdgeWatermark) GetIsWatermarkEnabled() bool

+ func (m *EdgeWatermark) GetPipeline() string

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

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

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

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

+ func (m *EdgeWatermark) Reset()

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

+ func (m *EdgeWatermark) String() string

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

+ func (m *EdgeWatermark) XXX_DiscardUnknown()

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

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

+ func (m *EdgeWatermark) XXX_Size() int

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

Feb 14, 2023

Changes in this version

type GetVertexMetricsResponse

+ VertexMetrics []*VertexMetrics

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

Jan 13, 2023

Changes in this version

type DaemonServiceClient

+ GetPipelineWatermarks func(ctx context.Context, in *GetPipelineWatermarksRequest, opts ...grpc.CallOption) (*GetPipelineWatermarksResponse, error)

type DaemonServiceServer

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

+ type GetPipelineWatermarksRequest struct

+ Pipeline *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetPipelineWatermarksRequest) ProtoMessage()

+ func (m *GetPipelineWatermarksRequest) GetPipeline() string

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

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

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

+ func (m *GetPipelineWatermarksRequest) Reset()

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

+ func (m *GetPipelineWatermarksRequest) String() string

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

+ func (m *GetPipelineWatermarksRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetPipelineWatermarksRequest) XXX_Size() int

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

+ type GetPipelineWatermarksResponse struct

+ PipelineWatermarks []*VertexWatermark

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetPipelineWatermarksResponse) ProtoMessage()

+ func (m *GetPipelineWatermarksResponse) GetPipelineWatermarks() []*VertexWatermark

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

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

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

+ func (m *GetPipelineWatermarksResponse) Reset()

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

+ func (m *GetPipelineWatermarksResponse) String() string

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

+ func (m *GetPipelineWatermarksResponse) XXX_DiscardUnknown()

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

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

+ func (m *GetPipelineWatermarksResponse) XXX_Size() int

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

type UnimplementedDaemonServiceServer

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

Aug 6, 2022

Changes in this version

type DaemonServiceClient

+ GetVertexMetrics func(ctx context.Context, in *GetVertexMetricsRequest, opts ...grpc.CallOption) (*GetVertexMetricsResponse, error)

+ GetVertexWatermark func(ctx context.Context, in *GetVertexWatermarkRequest, opts ...grpc.CallOption) (*GetVertexWatermarkResponse, error)

type DaemonServiceServer

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

+ GetVertexWatermark func(context.Context, *GetVertexWatermarkRequest) (*GetVertexWatermarkResponse, error)

+ type GetVertexMetricsRequest struct

+ Pipeline *string

+ Vertex *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetVertexMetricsRequest) ProtoMessage()

+ func (m *GetVertexMetricsRequest) GetPipeline() string

+ func (m *GetVertexMetricsRequest) GetVertex() string

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

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

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

+ func (m *GetVertexMetricsRequest) Reset()

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

+ func (m *GetVertexMetricsRequest) String() string

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

+ func (m *GetVertexMetricsRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetVertexMetricsRequest) XXX_Size() int

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

+ type GetVertexMetricsResponse struct

+ Vertex *VertexMetrics

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetVertexMetricsResponse) ProtoMessage()

+ func (m *GetVertexMetricsResponse) GetVertex() *VertexMetrics

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

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

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

+ func (m *GetVertexMetricsResponse) Reset()

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

+ func (m *GetVertexMetricsResponse) String() string

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

+ func (m *GetVertexMetricsResponse) XXX_DiscardUnknown()

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

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

+ func (m *GetVertexMetricsResponse) XXX_Size() int

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

+ type GetVertexWatermarkRequest struct

+ Pipeline *string

+ Vertex *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetVertexWatermarkRequest) ProtoMessage()

+ func (m *GetVertexWatermarkRequest) GetPipeline() string

+ func (m *GetVertexWatermarkRequest) GetVertex() string

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

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

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

+ func (m *GetVertexWatermarkRequest) Reset()

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

+ func (m *GetVertexWatermarkRequest) String() string

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

+ func (m *GetVertexWatermarkRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetVertexWatermarkRequest) XXX_Size() int

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

+ type GetVertexWatermarkResponse struct

+ VertexWatermark *VertexWatermark

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetVertexWatermarkResponse) ProtoMessage()

+ func (m *GetVertexWatermarkResponse) GetVertexWatermark() *VertexWatermark

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

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

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

+ func (m *GetVertexWatermarkResponse) Reset()

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

+ func (m *GetVertexWatermarkResponse) String() string

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

+ func (m *GetVertexWatermarkResponse) XXX_DiscardUnknown()

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

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

+ func (m *GetVertexWatermarkResponse) XXX_Size() int

+ func (m *GetVertexWatermarkResponse) XXX_Unmarshal(b []byte) error

type UnimplementedDaemonServiceServer

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

+ func (*UnimplementedDaemonServiceServer) GetVertexWatermark(ctx context.Context, req *GetVertexWatermarkRequest) (*GetVertexWatermarkResponse, error)

+ type VertexMetrics struct

+ Pendings map[string]int64

+ Pipeline *string

+ ProcessingRates map[string]float64

+ Vertex *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*VertexMetrics) ProtoMessage()

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

+ func (m *VertexMetrics) GetPipeline() string

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

+ func (m *VertexMetrics) GetVertex() string

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

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

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

+ func (m *VertexMetrics) Reset()

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

+ func (m *VertexMetrics) String() string

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

+ func (m *VertexMetrics) XXX_DiscardUnknown()

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

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

+ func (m *VertexMetrics) XXX_Size() int

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

+ type VertexWatermark struct

+ IsWatermarkEnabled *bool

+ Pipeline *string

+ Vertex *string

+ Watermark *int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*VertexWatermark) ProtoMessage()

+ func (m *VertexWatermark) GetIsWatermarkEnabled() bool

+ func (m *VertexWatermark) GetPipeline() string

+ func (m *VertexWatermark) GetVertex() string

+ func (m *VertexWatermark) GetWatermark() int64

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

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

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

+ func (m *VertexWatermark) Reset()

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

+ func (m *VertexWatermark) String() string

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

+ func (m *VertexWatermark) XXX_DiscardUnknown()

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

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

+ func (m *VertexWatermark) XXX_Size() int

+ func (m *VertexWatermark) XXX_Unmarshal(b []byte) error

Jun 1, 2022

Changes in this version

+ var ErrIntOverflowDaemon = fmt.Errorf("proto: integer overflow")

+ var ErrInvalidLengthDaemon = fmt.Errorf("proto: negative length found during unmarshaling")

+ var ErrUnexpectedEndOfGroupDaemon = fmt.Errorf("proto: unexpected end of group")

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

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

+ func RegisterDaemonServiceHandlerFromEndpoint(ctx context.Context, mux *runtime.ServeMux, endpoint string, ...) (err error)

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

+ func RegisterDaemonServiceServer(s *grpc.Server, srv DaemonServiceServer)

+ type BufferInfo struct

+ AckPendingCount *int64

+ BufferLength *int64

+ BufferName *string

+ BufferUsage *float64

+ BufferUsageLimit *float64

+ FromVertex *string

+ IsFull *bool

+ PendingCount *int64

+ Pipeline *string

+ ToVertex *string

+ TotalMessages *int64

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*BufferInfo) ProtoMessage()

+ func (m *BufferInfo) GetAckPendingCount() int64

+ func (m *BufferInfo) GetBufferLength() int64

+ func (m *BufferInfo) GetBufferName() string

+ func (m *BufferInfo) GetBufferUsage() float64

+ func (m *BufferInfo) GetBufferUsageLimit() float64

+ func (m *BufferInfo) GetFromVertex() string

+ func (m *BufferInfo) GetIsFull() bool

+ func (m *BufferInfo) GetPendingCount() int64

+ func (m *BufferInfo) GetPipeline() string

+ func (m *BufferInfo) GetToVertex() string

+ func (m *BufferInfo) GetTotalMessages() int64

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

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

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

+ func (m *BufferInfo) Reset()

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

+ func (m *BufferInfo) String() string

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

+ func (m *BufferInfo) XXX_DiscardUnknown()

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

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

+ func (m *BufferInfo) XXX_Size() int

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

+ type DaemonServiceClient interface

+ GetBuffer func(ctx context.Context, in *GetBufferRequest, opts ...grpc.CallOption) (*GetBufferResponse, error)

+ ListBuffers func(ctx context.Context, in *ListBuffersRequest, opts ...grpc.CallOption) (*ListBuffersResponse, error)

+ func NewDaemonServiceClient(cc *grpc.ClientConn) DaemonServiceClient

+ type DaemonServiceServer interface

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

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

+ type GetBufferRequest struct

+ Buffer *string

+ Pipeline *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetBufferRequest) ProtoMessage()

+ func (m *GetBufferRequest) GetBuffer() string

+ func (m *GetBufferRequest) GetPipeline() string

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

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

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

+ func (m *GetBufferRequest) Reset()

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

+ func (m *GetBufferRequest) String() string

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

+ func (m *GetBufferRequest) XXX_DiscardUnknown()

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

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

+ func (m *GetBufferRequest) XXX_Size() int

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

+ type GetBufferResponse struct

+ Buffer *BufferInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*GetBufferResponse) ProtoMessage()

+ func (m *GetBufferResponse) GetBuffer() *BufferInfo

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

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

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

+ func (m *GetBufferResponse) Reset()

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

+ func (m *GetBufferResponse) String() string

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

+ func (m *GetBufferResponse) XXX_DiscardUnknown()

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

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

+ func (m *GetBufferResponse) XXX_Size() int

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

+ type ListBuffersRequest struct

+ Pipeline *string

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListBuffersRequest) ProtoMessage()

+ func (m *ListBuffersRequest) GetPipeline() string

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

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

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

+ func (m *ListBuffersRequest) Reset()

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

+ func (m *ListBuffersRequest) String() string

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

+ func (m *ListBuffersRequest) XXX_DiscardUnknown()

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

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

+ func (m *ListBuffersRequest) XXX_Size() int

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

+ type ListBuffersResponse struct

+ Buffers []*BufferInfo

+ XXX_NoUnkeyedLiteral struct{}

+ XXX_sizecache int32

+ XXX_unrecognized []byte

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

+ func (*ListBuffersResponse) ProtoMessage()

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

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

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

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

+ func (m *ListBuffersResponse) Reset()

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

+ func (m *ListBuffersResponse) String() string

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

+ func (m *ListBuffersResponse) XXX_DiscardUnknown()

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

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

+ func (m *ListBuffersResponse) XXX_Size() int

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

+ type UnimplementedDaemonServiceServer struct

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

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