| 40 | ) |
| 41 | |
| 42 | type server struct { |
| 43 | proto.UnimplementedStateStoreServer |
| 44 | proto.UnimplementedTransactionalStateStoreServer |
| 45 | initCalled atomic.Int64 |
| 46 | featuresCalled atomic.Int64 |
| 47 | deleteCalled atomic.Int64 |
| 48 | onDeleteCalled func(*proto.DeleteRequest) |
| 49 | deleteErr error |
| 50 | getCalled atomic.Int64 |
| 51 | onGetCalled func(*proto.GetRequest) |
| 52 | getErr error |
| 53 | getResponse *proto.GetResponse |
| 54 | setCalled atomic.Int64 |
| 55 | onSetCalled func(*proto.SetRequest) |
| 56 | setErr error |
| 57 | pingCalled atomic.Int64 |
| 58 | pingErr error |
| 59 | bulkDeleteCalled atomic.Int64 |
| 60 | onBulkDeleteCalled func(*proto.BulkDeleteRequest) |
| 61 | bulkDeleteErr error |
| 62 | bulkGetCalled atomic.Int64 |
| 63 | onBulkGetCalled func(*proto.BulkGetRequest) |
| 64 | bulkGetErr error |
| 65 | bulkGetResponse *proto.BulkGetResponse |
| 66 | bulkSetCalled atomic.Int64 |
| 67 | onBulkSetCalled func(*proto.BulkSetRequest) |
| 68 | bulkSetErr error |
| 69 | transactCalled atomic.Int64 |
| 70 | onTransactCalled func(*proto.TransactionalStateRequest) |
| 71 | transactErr error |
| 72 | queryCalled atomic.Int64 |
| 73 | onQueryCalled func(*proto.QueryRequest) |
| 74 | queryResp *proto.QueryResponse |
| 75 | queryErr error |
| 76 | } |
| 77 | |
| 78 | func (s *server) Query(_ context.Context, req *proto.QueryRequest) (*proto.QueryResponse, error) { |
| 79 | s.queryCalled.Add(1) |
nothing calls this directly
no outgoing calls
no test coverage detected