server

Documentation

Overview

Package mock_api is a generated GoMock package.

Index

• func NewGRPCServer(opts ...Option) (*grpcServer, error)
• type CommitLog
• type Config
• type MockLog_ProduceStreamServer
  • func NewMockLog_ProduceStreamServer(ctrl *gomock.Controller) *MockLog_ProduceStreamServer
  • func (m *MockLog_ProduceStreamServer) Context() context.Context
  • func (m *MockLog_ProduceStreamServer) EXPECT() *MockLog_ProduceStreamServerMockRecorder
  • func (m *MockLog_ProduceStreamServer) Recv() (*record.ProduceRequest, error)
  • func (m *MockLog_ProduceStreamServer) RecvMsg(arg0 any) error
  • func (m *MockLog_ProduceStreamServer) Send(arg0 *record.ProduceResponse) error
  • func (m *MockLog_ProduceStreamServer) SendHeader(arg0 metadata.MD) error
  • func (m *MockLog_ProduceStreamServer) SendMsg(arg0 any) error
  • func (m *MockLog_ProduceStreamServer) SetHeader(arg0 metadata.MD) error
  • func (m *MockLog_ProduceStreamServer) SetTrailer(arg0 metadata.MD)
• type MockLog_ProduceStreamServerMockRecorder
  • func (mr *MockLog_ProduceStreamServerMockRecorder) Context() *gomock.Call
  • func (mr *MockLog_ProduceStreamServerMockRecorder) Recv() *gomock.Call
  • func (mr *MockLog_ProduceStreamServerMockRecorder) RecvMsg(arg0 any) *gomock.Call
  • func (mr *MockLog_ProduceStreamServerMockRecorder) Send(arg0 any) *gomock.Call
  • func (mr *MockLog_ProduceStreamServerMockRecorder) SendHeader(arg0 any) *gomock.Call
  • func (mr *MockLog_ProduceStreamServerMockRecorder) SendMsg(arg0 any) *gomock.Call
  • func (mr *MockLog_ProduceStreamServerMockRecorder) SetHeader(arg0 any) *gomock.Call
  • func (mr *MockLog_ProduceStreamServerMockRecorder) SetTrailer(arg0 any) *gomock.Call
• type Option
  • func WithCommitLog(cl CommitLog) Option

Functions

func NewGRPCServer

func NewGRPCServer(opts ...Option) (*grpcServer, error)

NewGRPCServer initializes and returns a new grpcServer instance. It takes functional options that modify its configuration.

Types

type CommitLog

type CommitLog interface {
	// Append adds a new record to the log and returns the offset
	// at which the record was stored. This offset can be used to
	// retrieve the record later. An error is returned if the append
	// operation fails.
	Append(*api.Record) (uint64, error)

	// Read retrieves a record from the log at the specified offset.
	// It returns the record if found or an error if the read operation
	// fails, including if the offset does not correspond to an existing
	// record.
	Read(uint64) (*api.Record, error)
}

CommitLog defines the interface for a commit log system. It's designed to abstract the underlying operations of appending to and reading from a log, allowing for different implementations that could optimize for various use cases (e.g., performance, durability).

type Config

type Config struct {
	CommitLog CommitLog
}

Config represents the configuration for the server

type MockLog_ProduceStreamServer

type MockLog_ProduceStreamServer struct {
	// contains filtered or unexported fields
}

MockLog_ProduceStreamServer is a mock of Log_ProduceStreamServer interface.

func NewMockLog_ProduceStreamServer

func NewMockLog_ProduceStreamServer(ctrl *gomock.Controller) *MockLog_ProduceStreamServer

NewMockLog_ProduceStreamServer creates a new mock instance.

func (*MockLog_ProduceStreamServer) Context

func (m *MockLog_ProduceStreamServer) Context() context.Context

Context mocks base method.

func (*MockLog_ProduceStreamServer) EXPECT

func (m *MockLog_ProduceStreamServer) EXPECT() *MockLog_ProduceStreamServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockLog_ProduceStreamServer) Recv

func (m *MockLog_ProduceStreamServer) Recv() (*record.ProduceRequest, error)

Recv mocks base method.

func (*MockLog_ProduceStreamServer) RecvMsg

func (m *MockLog_ProduceStreamServer) RecvMsg(arg0 any) error

RecvMsg mocks base method.

func (*MockLog_ProduceStreamServer) Send

func (m *MockLog_ProduceStreamServer) Send(arg0 *record.ProduceResponse) error

Send mocks base method.

func (*MockLog_ProduceStreamServer) SendHeader

func (m *MockLog_ProduceStreamServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method.

func (*MockLog_ProduceStreamServer) SendMsg

func (m *MockLog_ProduceStreamServer) SendMsg(arg0 any) error

SendMsg mocks base method.

func (*MockLog_ProduceStreamServer) SetHeader

func (m *MockLog_ProduceStreamServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method.

func (*MockLog_ProduceStreamServer) SetTrailer

func (m *MockLog_ProduceStreamServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method.

type MockLog_ProduceStreamServerMockRecorder

type MockLog_ProduceStreamServerMockRecorder struct {
	// contains filtered or unexported fields
}

MockLog_ProduceStreamServerMockRecorder is the mock recorder for MockLog_ProduceStreamServer.

func (*MockLog_ProduceStreamServerMockRecorder) Context

func (mr *MockLog_ProduceStreamServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockLog_ProduceStreamServerMockRecorder) Recv

func (mr *MockLog_ProduceStreamServerMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockLog_ProduceStreamServerMockRecorder) RecvMsg

func (mr *MockLog_ProduceStreamServerMockRecorder) RecvMsg(arg0 any) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockLog_ProduceStreamServerMockRecorder) Send

func (mr *MockLog_ProduceStreamServerMockRecorder) Send(arg0 any) *gomock.Call

Send indicates an expected call of Send.

func (*MockLog_ProduceStreamServerMockRecorder) SendHeader

func (mr *MockLog_ProduceStreamServerMockRecorder) SendHeader(arg0 any) *gomock.Call

SendHeader indicates an expected call of SendHeader.

func (*MockLog_ProduceStreamServerMockRecorder) SendMsg

func (mr *MockLog_ProduceStreamServerMockRecorder) SendMsg(arg0 any) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockLog_ProduceStreamServerMockRecorder) SetHeader

func (mr *MockLog_ProduceStreamServerMockRecorder) SetHeader(arg0 any) *gomock.Call

SetHeader indicates an expected call of SetHeader.

func (*MockLog_ProduceStreamServerMockRecorder) SetTrailer

func (mr *MockLog_ProduceStreamServerMockRecorder) SetTrailer(arg0 any) *gomock.Call

SetTrailer indicates an expected call of SetTrailer.

type Option

type Option func(*grpcServer) error

Option defines a function signature for configuring the grpcServer

func WithCommitLog

func WithCommitLog(cl CommitLog) Option

Configures the server to use a specific CommitLog implementation. This option allows the server's behavior to be modified based on the provided commit log.