daemon

package
v0.5.3 Latest Latest
Warning

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

 Go to latest Published: Jul 8, 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)
}

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

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

func (*UnimplementedDaemonServiceServer) ListBuffers(ctx context.Context, req *ListBuffersRequest) (*ListBuffersResponse, 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.