cmdhandler

package

v0.0.0-...-7fad99f Latest Latest Go to latest Published: Jun 28, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ntail-io/streams

Documentation ¶

Index ¶

Constants
Variables
type Handler
- func NewHandler(ctx context.Context, service *SegmentService) *Handler
type SegmentService
- func NewSegmentService(topic types.Topic, hashRange types.HashRange, props SegmentServiceProps) *SegmentService
type SegmentServiceProps

Constants ¶

View Source

const (
	MaxBufSize          = 1<<20*10 - 1024 // Just under 10MB
	MaxBufferedCommands = 40_000
)

Variables ¶

View Source

var (
	ErrSegmentClosed = errors.New("segment closed")
	ErrCancelled     = errors.New("command cancelled")
)

View Source

var (
	ErrInvalidSegmentAddress = errors.New("invalid segment address")
	ErrBufferSizeExceeded    = errors.New("buffer size exceeded")
	ErrSegmentFinished       = errors.New("segment finished")
)

Functions ¶

This section is empty.

Types ¶

type Handler ¶

type Handler struct {
	Ctx     context.Context
	CmdCh   chan commands.Command
	Service *SegmentService
	Conn    *bq.BigQueryConn
	Next    *SegmentService

	AppendCh         chan struct{}
	AppendFinishedCh chan error
	// contains filtered or unexported fields
}

func NewHandler ¶

func NewHandler(ctx context.Context, service *SegmentService) *Handler

func (*Handler) Close ¶

func (h *Handler) Close()

func (*Handler) Handle ¶

func (h *Handler) Handle(cmd commands.Command)

func (*Handler) Run ¶

func (h *Handler) Run()

type SegmentService ¶

type SegmentService struct {
	SegmentServiceProps
	Segment            domain.Segment
	CmdCh              chan commands.Command
	Initialized        bool
	UncommittedAppends chan *commands.Append
	Writer             *bq.BatchWriter
}

func NewSegmentService ¶

func NewSegmentService(topic types.Topic, hashRange types.HashRange, props SegmentServiceProps) *SegmentService

func (*SegmentService) Append ¶

func (s *SegmentService) Append(cmd *commands.Append) error

func (*SegmentService) Finish ¶

func (s *SegmentService) Finish()

func (*SegmentService) Get ¶

func (s *SegmentService) Get(key types.Key) (msgId uuid.UUID, data []byte, ok bool, err error)

func (*SegmentService) Poll ¶

func (s *SegmentService) Poll(addr buftypes.SegmentAddress, from time.Time, fromMsgId uuid.UUID) (domain.PollResult, error)

TODO We might want the poll result to be a channel and get notified if append is called. TODO If we are at the end of the segment, segment is not finished, and we have no messages, we should wait for a message to be appended. TODO We need to be notified if: client ctx is Done, segment is finished, segment is closed, and message is appended.

func (*SegmentService) String ¶

func (s *SegmentService) String() string

type SegmentServiceProps ¶

type SegmentServiceProps struct {
	Ctx          context.Context
	Router       *buffer.Router
	Repo         *repo.SegmentRepo
	Conn         *bq.BigQueryConn
	FlushEnabled bool
}

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL