Versions in this module Expand all Collapse all v0 v0.2.0 Oct 3, 2026 v0.1.0 Oct 1, 2026 Changes in this version + type MockObjectStoreManager struct + func NewMockObjectStoreManager(ctrl *gomock.Controller) *MockObjectStoreManager + func NewPlainMockObjectStoreManager(ctrl *gomock.Controller) *MockObjectStoreManager + func (m *MockObjectStoreManager) Delete(ctx context.Context, name string) error + func (m *MockObjectStoreManager) EXPECT() *MockObjectStoreManagerMockRecorder + func (m *MockObjectStoreManager) GetBytes(ctx context.Context, name string, opts ...jetstream.GetObjectOpt) ([]byte, error) + func (m *MockObjectStoreManager) GetInfo(ctx context.Context, name string, opts ...jetstream.GetObjectInfoOpt) (*jetstream.ObjectInfo, error) + func (m *MockObjectStoreManager) List(ctx context.Context, opts ...jetstream.ListObjectsOpt) ([]*jetstream.ObjectInfo, error) + func (m *MockObjectStoreManager) Put(ctx context.Context, meta jetstream.ObjectMeta, reader io.Reader) (*jetstream.ObjectInfo, error) + func (m *MockObjectStoreManager) PutBytes(ctx context.Context, name string, data []byte) (*jetstream.ObjectInfo, error) + type MockObjectStoreManagerMockRecorder struct + func (mr *MockObjectStoreManagerMockRecorder) Delete(ctx, name any) *gomock.Call + func (mr *MockObjectStoreManagerMockRecorder) GetBytes(ctx, name any, opts ...any) *gomock.Call + func (mr *MockObjectStoreManagerMockRecorder) GetInfo(ctx, name any, opts ...any) *gomock.Call + func (mr *MockObjectStoreManagerMockRecorder) List(ctx any, opts ...any) *gomock.Call + func (mr *MockObjectStoreManagerMockRecorder) Put(ctx, meta, reader any) *gomock.Call + func (mr *MockObjectStoreManagerMockRecorder) PutBytes(ctx, name, data any) *gomock.Call + type MockStateKeyValue struct + func NewMockStateKeyValue(ctrl *gomock.Controller) *MockStateKeyValue + func (m *MockStateKeyValue) EXPECT() *MockStateKeyValueMockRecorder + func (m *MockStateKeyValue) Get(ctx context.Context, key string) (jetstream.KeyValueEntry, error) + func (m *MockStateKeyValue) Keys(ctx context.Context, opts ...jetstream.WatchOpt) ([]string, error) + type MockStateKeyValueMockRecorder struct + func (mr *MockStateKeyValueMockRecorder) Get(ctx, key any) *gomock.Call + func (mr *MockStateKeyValueMockRecorder) Keys(ctx any, opts ...any) *gomock.Call
Go to main page