segment

package

Go to main page

Versions in this module

v0

v0.9.0

Sep 7, 2023

Changes in this version

type MockServer

+ func (m *MockServer) DescribeBlock(ctx context.Context, id vanus.ID) (*meta.SegmentHealthInfo, error)

type MockServerMockRecorder

+ func (mr *MockServerMockRecorder) DescribeBlock(ctx, id interface{}) *gomock.Call

type Server

+ DescribeBlock func(ctx context.Context, id vanus.ID) (*metapb.SegmentHealthInfo, error)

v0.8.0

Apr 17, 2023

Changes in this version

+ type MockReplica struct

+ func NewMockReplica(ctrl *gomock.Controller) *MockReplica

+ func (m *MockReplica) Append(ctx context.Context, entries []block.Entry, cb block.AppendCallback)

+ func (m *MockReplica) Bootstrap(ctx context.Context, blocks []block0.Peer) error

+ func (m *MockReplica) Close(ctx context.Context) error

+ func (m *MockReplica) Delete(ctx context.Context) error

+ func (m *MockReplica) EXPECT() *MockReplicaMockRecorder

+ func (m *MockReplica) ID() vanus.ID

+ func (m *MockReplica) IDStr() string

+ func (m *MockReplica) Read(ctx context.Context, seq int64, num int) ([]block.Entry, error)

+ func (m *MockReplica) Seek(ctx context.Context, index int64, key block.Entry, flag block.SeekKeyFlag) (int64, error)

+ func (m *MockReplica) Status() *meta.SegmentHealthInfo

+ type MockReplicaMockRecorder struct

+ func (mr *MockReplicaMockRecorder) Append(ctx, entries, cb interface{}) *gomock.Call

+ func (mr *MockReplicaMockRecorder) Bootstrap(ctx, blocks interface{}) *gomock.Call

+ func (mr *MockReplicaMockRecorder) Close(ctx interface{}) *gomock.Call

+ func (mr *MockReplicaMockRecorder) Delete(ctx interface{}) *gomock.Call

+ func (mr *MockReplicaMockRecorder) ID() *gomock.Call

+ func (mr *MockReplicaMockRecorder) IDStr() *gomock.Call

+ func (mr *MockReplicaMockRecorder) Read(ctx, seq, num interface{}) *gomock.Call

+ func (mr *MockReplicaMockRecorder) Seek(ctx, index, key, flag interface{}) *gomock.Call

+ func (mr *MockReplicaMockRecorder) Status() *gomock.Call

+ type MockServer struct

+ func NewMockServer(ctrl *gomock.Controller) *MockServer

+ func (m *MockServer) ActivateSegment(ctx context.Context, logID, segID vanus.ID, replicas map[vanus.ID]string) error

+ func (m *MockServer) AppendToBlock(ctx context.Context, id vanus.ID, events []*cloudevents.CloudEvent) ([]int64, error)

+ func (m *MockServer) CreateBlock(ctx context.Context, id vanus.ID, size int64) error

+ func (m *MockServer) EXPECT() *MockServerMockRecorder

+ func (m *MockServer) InactivateSegment(ctx context.Context) error

+ func (m *MockServer) Initialize(arg0 context.Context) error

+ func (m *MockServer) LookupOffsetInBlock(ctx context.Context, id vanus.ID, stime int64) (int64, error)

+ func (m *MockServer) ReadFromBlock(ctx context.Context, id vanus.ID, seq int64, num int, pollingTimeout uint32) ([]*cloudevents.CloudEvent, error)

+ func (m *MockServer) RegisterToController(ctx context.Context) error

+ func (m *MockServer) RemoveBlock(ctx context.Context, id vanus.ID) error

+ func (m *MockServer) Serve(lis net.Listener) error

+ func (m *MockServer) Start(ctx context.Context) error

+ func (m *MockServer) Status() primitive.ServerState

+ func (m *MockServer) Stop(ctx context.Context) error

+ type MockServerMockRecorder struct

+ func (mr *MockServerMockRecorder) ActivateSegment(ctx, logID, segID, replicas interface{}) *gomock.Call

+ func (mr *MockServerMockRecorder) AppendToBlock(ctx, id, events interface{}) *gomock.Call

+ func (mr *MockServerMockRecorder) CreateBlock(ctx, id, size interface{}) *gomock.Call

+ func (mr *MockServerMockRecorder) InactivateSegment(ctx interface{}) *gomock.Call

+ func (mr *MockServerMockRecorder) Initialize(arg0 interface{}) *gomock.Call

+ func (mr *MockServerMockRecorder) LookupOffsetInBlock(ctx, id, stime interface{}) *gomock.Call

+ func (mr *MockServerMockRecorder) ReadFromBlock(ctx, id, seq, num, pollingTimeout interface{}) *gomock.Call

+ func (mr *MockServerMockRecorder) RegisterToController(ctx interface{}) *gomock.Call

+ func (mr *MockServerMockRecorder) RemoveBlock(ctx, id interface{}) *gomock.Call

+ func (mr *MockServerMockRecorder) Serve(lis interface{}) *gomock.Call

+ func (mr *MockServerMockRecorder) Start(ctx interface{}) *gomock.Call

+ func (mr *MockServerMockRecorder) Status() *gomock.Call

+ func (mr *MockServerMockRecorder) Stop(ctx interface{}) *gomock.Call

+ type MockpollingManager struct

+ func NewMockpollingManager(ctrl *gomock.Controller) *MockpollingManager

+ func (m *MockpollingManager) Add(ctx context.Context, blockID vanus.ID) <-chan struct{}

+ func (m *MockpollingManager) Destroy()

+ func (m *MockpollingManager) EXPECT() *MockpollingManagerMockRecorder

+ func (m *MockpollingManager) NewMessageArrived(blockID vanus.ID)

+ type MockpollingManagerMockRecorder struct

+ func (mr *MockpollingManagerMockRecorder) Add(ctx, blockID interface{}) *gomock.Call

+ func (mr *MockpollingManagerMockRecorder) Destroy() *gomock.Call

+ func (mr *MockpollingManagerMockRecorder) NewMessageArrived(blockID interface{}) *gomock.Call

+ type Replica interface

+ Bootstrap func(ctx context.Context, blocks []raft.Peer) error

+ Close func(ctx context.Context) error

+ Delete func(ctx context.Context) error

+ IDStr func() string

+ Status func() *metapb.SegmentHealthInfo

+ type Server interface

+ ActivateSegment func(ctx context.Context, logID vanus.ID, segID vanus.ID, ...) error

+ AppendToBlock func(ctx context.Context, id vanus.ID, events []*cepb.CloudEvent) ([]int64, error)

+ CreateBlock func(ctx context.Context, id vanus.ID, size int64) error

+ InactivateSegment func(ctx context.Context) error

+ LookupOffsetInBlock func(ctx context.Context, id vanus.ID, stime int64) (int64, error)

+ ReadFromBlock func(ctx context.Context, id vanus.ID, seq int64, num int, pollingTimeout uint32) ([]*cepb.CloudEvent, error)

+ RegisterToController func(ctx context.Context) error

+ RemoveBlock func(ctx context.Context, id vanus.ID) error

+ Serve func(lis net.Listener) error

+ Start func(ctx context.Context) error

+ Status func() primitive.ServerState

+ Stop func(ctx context.Context) error

+ func NewServer(cfg store.Config) Server

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