-
Notifications
You must be signed in to change notification settings - Fork 2k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
tabletserver: Move QueryService fakes into subpackage.
Moved StreamHealthQueryService fake out of wait_for_drain_test.go and use it in other tests as well.
- Loading branch information
1 parent
4aa8402
commit 442e30e
Showing
10 changed files
with
245 additions
and
268 deletions.
There are no files selected for viewing
93 changes: 93 additions & 0 deletions
93
go/vt/tabletserver/queryservice/fakes/error_query_service.go
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,93 @@ | ||
| package fakes | ||
|
|
||
| import ( | ||
| "fmt" | ||
|
|
||
| "github.com/youtube/vitess/go/sqltypes" | ||
| "github.com/youtube/vitess/go/vt/tabletserver/queryservice" | ||
| "github.com/youtube/vitess/go/vt/tabletserver/querytypes" | ||
| "golang.org/x/net/context" | ||
|
|
||
| querypb "github.com/youtube/vitess/go/vt/proto/query" | ||
| ) | ||
|
|
||
| // ErrorQueryService is an implementation of QueryService that returns a | ||
| // configurable error for some of its methods. | ||
| // | ||
| // It is used as base for other, more specialised QueryService fakes e.g. | ||
| // StreamHealthQueryService. | ||
| type ErrorQueryService struct { | ||
| GetSessionIdError error | ||
| } | ||
|
|
||
| // GetSessionId is part of QueryService interface | ||
| func (e *ErrorQueryService) GetSessionId(keyspace, shard string) (int64, error) { | ||
| return 0, e.GetSessionIdError | ||
| } | ||
|
|
||
| // Begin is part of QueryService interface | ||
| func (e *ErrorQueryService) Begin(ctx context.Context, target *querypb.Target, sessionID int64) (int64, error) { | ||
| return 0, fmt.Errorf("ErrorQueryService does not implement any method") | ||
| } | ||
|
|
||
| // Commit is part of QueryService interface | ||
| func (e *ErrorQueryService) Commit(ctx context.Context, target *querypb.Target, sessionID, transactionID int64) error { | ||
| return fmt.Errorf("ErrorQueryService does not implement any method") | ||
| } | ||
|
|
||
| // Rollback is part of QueryService interface | ||
| func (e *ErrorQueryService) Rollback(ctx context.Context, target *querypb.Target, sessionID, transactionID int64) error { | ||
| return fmt.Errorf("ErrorQueryService does not implement any method") | ||
| } | ||
|
|
||
| // Execute is part of QueryService interface | ||
| func (e *ErrorQueryService) Execute(ctx context.Context, target *querypb.Target, sql string, bindVariables map[string]interface{}, sessionID, transactionID int64) (*sqltypes.Result, error) { | ||
| return nil, fmt.Errorf("ErrorQueryService does not implement any method") | ||
| } | ||
|
|
||
| // StreamExecute is part of QueryService interface | ||
| func (e *ErrorQueryService) StreamExecute(ctx context.Context, target *querypb.Target, sql string, bindVariables map[string]interface{}, sessionID int64, sendReply func(*sqltypes.Result) error) error { | ||
| return fmt.Errorf("ErrorQueryService does not implement any method") | ||
| } | ||
|
|
||
| // ExecuteBatch is part of QueryService interface | ||
| func (e *ErrorQueryService) ExecuteBatch(ctx context.Context, target *querypb.Target, queries []querytypes.BoundQuery, sessionID int64, asTransaction bool, transactionID int64) ([]sqltypes.Result, error) { | ||
| return nil, fmt.Errorf("ErrorQueryService does not implement any method") | ||
| } | ||
|
|
||
| // SplitQuery is part of QueryService interface | ||
| // TODO(erez): Remove once the migration to SplitQuery V2 is done. | ||
| func (e *ErrorQueryService) SplitQuery(ctx context.Context, target *querypb.Target, sql string, bindVariables map[string]interface{}, splitColumn string, splitCount int64, sessionID int64) ([]querytypes.QuerySplit, error) { | ||
| return nil, fmt.Errorf("ErrorQueryService does not implement any method") | ||
| } | ||
|
|
||
| // SplitQueryV2 is part of QueryService interface | ||
| func (e *ErrorQueryService) SplitQueryV2( | ||
| ctx context.Context, | ||
| target *querypb.Target, | ||
| sql string, | ||
| bindVariables map[string]interface{}, | ||
| splitColumns []string, | ||
| splitCount int64, | ||
| numRowsPerQueryPart int64, | ||
| algorithm querypb.SplitQueryRequest_Algorithm, | ||
| sessionID int64) ([]querytypes.QuerySplit, error) { | ||
| return nil, fmt.Errorf("ErrorQueryService does not implement any method") | ||
| } | ||
|
|
||
| // StreamHealthRegister is part of QueryService interface | ||
| func (e *ErrorQueryService) StreamHealthRegister(chan<- *querypb.StreamHealthResponse) (int, error) { | ||
| return 0, fmt.Errorf("ErrorQueryService does not implement any method") | ||
| } | ||
|
|
||
| // StreamHealthUnregister is part of QueryService interface | ||
| func (e *ErrorQueryService) StreamHealthUnregister(int) error { | ||
| return fmt.Errorf("ErrorQueryService does not implement any method") | ||
| } | ||
|
|
||
| // HandlePanic is part of QueryService interface | ||
| func (e *ErrorQueryService) HandlePanic(*error) { | ||
| } | ||
|
|
||
| // make sure ErrorQueryService implements QueryService | ||
| var _ queryservice.QueryService = &ErrorQueryService{} |
78 changes: 78 additions & 0 deletions
78
go/vt/tabletserver/queryservice/fakes/stream_health_query_service.go
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,78 @@ | ||
| package fakes | ||
|
|
||
| import ( | ||
| "github.com/golang/protobuf/proto" | ||
|
|
||
| querypb "github.com/youtube/vitess/go/vt/proto/query" | ||
| topodatapb "github.com/youtube/vitess/go/vt/proto/topodata" | ||
| ) | ||
|
|
||
| const ( | ||
| // DefaultSecondsBehindMaster is the default MySQL replication lag which is | ||
| // reported in all faked stream health responses. | ||
| DefaultSecondsBehindMaster uint32 = 1 | ||
| ) | ||
|
|
||
| // StreamHealthQueryService is a QueryService implementation which allows to | ||
| // send custom StreamHealthResponse messages by adding them to a channel. | ||
| // Note that it only works with one connected client because messages going | ||
| // into "healthResponses" are not duplicated to all clients. | ||
| // | ||
| // If you want to override other QueryService methods, embed this struct | ||
| // as anonymous field in your own QueryService fake. | ||
| type StreamHealthQueryService struct { | ||
| ErrorQueryService | ||
| healthResponses chan *querypb.StreamHealthResponse | ||
| target querypb.Target | ||
| } | ||
|
|
||
| // NewStreamHealthQueryService creates a new fake query service for the target. | ||
| func NewStreamHealthQueryService(target querypb.Target) *StreamHealthQueryService { | ||
| return &StreamHealthQueryService{ | ||
| healthResponses: make(chan *querypb.StreamHealthResponse, 10), | ||
| target: target, | ||
| } | ||
| } | ||
|
|
||
| // StreamHealthRegister implements the QueryService interface. | ||
| // It sends all queued and future healthResponses to the connected client e.g. | ||
| // the healthcheck module. | ||
| func (q *StreamHealthQueryService) StreamHealthRegister(c chan<- *querypb.StreamHealthResponse) (int, error) { | ||
| go func() { | ||
| for shr := range q.healthResponses { | ||
| c <- shr | ||
| } | ||
| }() | ||
| return 0, nil | ||
| } | ||
|
|
||
| // AddDefaultHealthResponse adds a faked health response to the buffer channel. | ||
| // The response will have default values typical for a healthy tablet. | ||
| func (q *StreamHealthQueryService) AddDefaultHealthResponse() { | ||
| q.healthResponses <- &querypb.StreamHealthResponse{ | ||
| Target: proto.Clone(&q.target).(*querypb.Target), | ||
| Serving: true, | ||
| RealtimeStats: &querypb.RealtimeStats{ | ||
| SecondsBehindMaster: DefaultSecondsBehindMaster, | ||
| }, | ||
| } | ||
| } | ||
|
|
||
| // AddHealthResponseWithQPS adds a faked health response to the buffer channel. | ||
| // Only "qps" is different in this message. | ||
| func (q *StreamHealthQueryService) AddHealthResponseWithQPS(qps float64) { | ||
| q.healthResponses <- &querypb.StreamHealthResponse{ | ||
| Target: proto.Clone(&q.target).(*querypb.Target), | ||
| Serving: true, | ||
| RealtimeStats: &querypb.RealtimeStats{ | ||
| Qps: qps, | ||
| SecondsBehindMaster: DefaultSecondsBehindMaster, | ||
| }, | ||
| } | ||
| } | ||
|
|
||
| // UpdateType changes the type of the query service. | ||
| // Only newly sent health messages will use the new type. | ||
| func (q *StreamHealthQueryService) UpdateType(tabletType topodatapb.TabletType) { | ||
| q.target.TabletType = tabletType | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.