func AddService(name string)
func Ctx2TestLookupID() string
func CtxTestLookupID() string
func EasyOpsLookupID() string
func EasyOpsTestLookupID() string
func EchoServiceLookupID() string
func EchoStreamServiceLookupID() string
func IsHealthy() (bool, error)
func RegisterCtx2TestServer(s *grpc.Server, srv Ctx2TestServer)
func RegisterCtxTestServer(s *grpc.Server, srv CtxTestServer)
func RegisterEasyOpsServer(s *grpc.Server, srv EasyOpsServer)
func RegisterEasyOpsTestServer(s *grpc.Server, srv EasyOpsTestServer)
func RegisterEchoServiceServer(s *grpc.Server, srv EchoServiceServer)
func RegisterEchoStreamServiceServer(s *grpc.Server, srv EchoStreamServiceServer)
for internal testing only
type AuthResponse struct {
Valid bool `protobuf:"varint,1,opt,name=Valid" json:"Valid,omitempty"`
User *auth.User `protobuf:"bytes,2,opt,name=User" json:"User,omitempty"`
}
func (*AuthResponse) Descriptor() ([]byte, []int)
func (m *AuthResponse) GetUser() *auth.User
func (m *AuthResponse) GetValid() bool
func (*AuthResponse) ProtoMessage()
func (m *AuthResponse) Reset()
func (m *AuthResponse) String() string
type Call struct {
Position int32 `protobuf:"varint,1,opt,name=Position" json:"Position,omitempty"`
UserID string `protobuf:"bytes,2,opt,name=UserID" json:"UserID,omitempty"`
ServiceID string `protobuf:"bytes,3,opt,name=ServiceID" json:"ServiceID,omitempty"`
RequestID string `protobuf:"bytes,4,opt,name=RequestID" json:"RequestID,omitempty"`
}
func (*Call) Descriptor() ([]byte, []int)
func (m *Call) GetPosition() int32
func (m *Call) GetRequestID() string
func (m *Call) GetServiceID() string
func (m *Call) GetUserID() string
func (*Call) ProtoMessage()
func (m *Call) Reset()
func (m *Call) String() string
type Chain struct {
Position int32 `protobuf:"varint,1,opt,name=Position" json:"Position,omitempty"`
Calls []*Call `protobuf:"bytes,2,rep,name=Calls" json:"Calls,omitempty"`
}
func (*Chain) Descriptor() ([]byte, []int)
func (m *Chain) GetCalls() []*Call
func (m *Chain) GetPosition() int32
func (*Chain) ProtoMessage()
func (m *Chain) Reset()
func (m *Chain) String() string
type Count struct {
Count uint32 `protobuf:"varint,1,opt,name=Count" json:"Count,omitempty"`
}
func (*Count) Descriptor() ([]byte, []int)
func (m *Count) GetCount() uint32
func (*Count) ProtoMessage()
func (m *Count) Reset()
func (m *Count) String() string
type Ctx2TestClient interface {
TriggerRPC(ctx context.Context, in *TriggerRPCRequest, opts ...grpc.CallOption) (*common.Void, error)
}
func GetCtx2TestClient() Ctx2TestClient
func NewCtx2TestClient(cc *grpc.ClientConn) Ctx2TestClient
type Ctx2TestServer interface {
TriggerRPC(context.Context, *TriggerRPCRequest) (*common.Void, error)
}
type CtxTestClient interface {
TestFork(ctx context.Context, in *RequiredContext, opts ...grpc.CallOption) (*common.Void, error)
TestDeSer(ctx context.Context, in *RequiredContext, opts ...grpc.CallOption) (*SerialisedContext, error)
TestStream(ctx context.Context, in *RequiredContext, opts ...grpc.CallOption) (CtxTest_TestStreamClient, error)
TestUnary(ctx context.Context, in *RequiredContext, opts ...grpc.CallOption) (*common.Void, error)
CallUnaryFromStream(ctx context.Context, in *RequiredContext, opts ...grpc.CallOption) (CtxTest_CallUnaryFromStreamClient, error)
CallUnaryFromUnary(ctx context.Context, in *RequiredContext, opts ...grpc.CallOption) (*common.Void, error)
CallStreamFromStream(ctx context.Context, in *RequiredContext, opts ...grpc.CallOption) (CtxTest_CallStreamFromStreamClient, error)
CallStreamFromUnary(ctx context.Context, in *RequiredContext, opts ...grpc.CallOption) (*common.Void, error)
Sleep(ctx context.Context, in *SleepRequest, opts ...grpc.CallOption) (*common.Void, error)
}
func GetCtxTestClient() CtxTestClient
func NewCtxTestClient(cc *grpc.ClientConn) CtxTestClient
type CtxTestServer interface {
TestFork(context.Context, *RequiredContext) (*common.Void, error)
TestDeSer(context.Context, *RequiredContext) (*SerialisedContext, error)
TestStream(*RequiredContext, CtxTest_TestStreamServer) error
TestUnary(context.Context, *RequiredContext) (*common.Void, error)
CallUnaryFromStream(*RequiredContext, CtxTest_CallUnaryFromStreamServer) error
CallUnaryFromUnary(context.Context, *RequiredContext) (*common.Void, error)
CallStreamFromStream(*RequiredContext, CtxTest_CallStreamFromStreamServer) error
CallStreamFromUnary(context.Context, *RequiredContext) (*common.Void, error)
Sleep(context.Context, *SleepRequest) (*common.Void, error)
}
type CtxTest_CallStreamFromStreamClient interface {
Recv() (*common.Void, error)
grpc.ClientStream
}
type CtxTest_CallStreamFromStreamServer interface {
Send(*common.Void) error
grpc.ServerStream
}
type CtxTest_CallUnaryFromStreamClient interface {
Recv() (*common.Void, error)
grpc.ClientStream
}
type CtxTest_CallUnaryFromStreamServer interface {
Send(*common.Void) error
grpc.ServerStream
}
type CtxTest_TestStreamClient interface {
Recv() (*common.Void, error)
grpc.ClientStream
}
type CtxTest_TestStreamServer interface {
Send(*common.Void) error
grpc.ServerStream
}
type EasyOpsClient interface {
FindService(ctx context.Context, in *FindServiceRequest, opts ...grpc.CallOption) (*FindServiceResponse, error)
UserByLogin(ctx context.Context, in *UserByLoginRequest, opts ...grpc.CallOption) (*AuthResponse, error)
UserByToken(ctx context.Context, in *UserByTokenRequest, opts ...grpc.CallOption) (*AuthResponse, error)
}
func GetEasyOpsClient() EasyOpsClient
func NewEasyOpsClient(cc *grpc.ClientConn) EasyOpsClient
type EasyOpsServer interface {
FindService(context.Context, *FindServiceRequest) (*FindServiceResponse, error)
UserByLogin(context.Context, *UserByLoginRequest) (*AuthResponse, error)
UserByToken(context.Context, *UserByTokenRequest) (*AuthResponse, error)
}
type EasyOpsTestClient interface {
CheckSerialisation(ctx context.Context, in *Count, opts ...grpc.CallOption) (*common.Void, error)
Ping(ctx context.Context, in *Chain, opts ...grpc.CallOption) (*Chain, error)
// does exactly nothing
SimplePing(ctx context.Context, in *common.Void, opts ...grpc.CallOption) (*common.Void, error)
}
func GetEasyOpsTestClient() EasyOpsTestClient
func NewEasyOpsTestClient(cc *grpc.ClientConn) EasyOpsTestClient
type EasyOpsTestServer interface {
CheckSerialisation(context.Context, *Count) (*common.Void, error)
Ping(context.Context, *Chain) (*Chain, error)
// does exactly nothing
SimplePing(context.Context, *common.Void) (*common.Void, error)
}
type EchoServiceClient interface {
Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
}
func GetEchoClient() EchoServiceClient
func GetEchoServiceClient() EchoServiceClient
func NewEchoServiceClient(cc *grpc.ClientConn) EchoServiceClient
type EchoServiceServer interface {
Ping(context.Context, *PingRequest) (*PingResponse, error)
}
type EchoStreamServiceClient interface {
SendToServer(ctx context.Context, opts ...grpc.CallOption) (EchoStreamService_SendToServerClient, error)
}
func GetEchoStreamClient() EchoStreamServiceClient
func GetEchoStreamServiceClient() EchoStreamServiceClient
func NewEchoStreamServiceClient(cc *grpc.ClientConn) EchoStreamServiceClient
type EchoStreamServiceServer interface {
SendToServer(EchoStreamService_SendToServerServer) error
}
type EchoStreamService_SendToServerClient interface {
Send(*PingRequest) error
CloseAndRecv() (*PingResponse, error)
grpc.ClientStream
}
type EchoStreamService_SendToServerServer interface {
SendAndClose(*PingResponse) error
Recv() (*PingRequest, error)
grpc.ServerStream
}
for internal testing only
type FindServiceRequest struct {
Name string `protobuf:"bytes,1,opt,name=Name" json:"Name,omitempty"`
}
func (*FindServiceRequest) Descriptor() ([]byte, []int)
func (m *FindServiceRequest) GetName() string
func (*FindServiceRequest) ProtoMessage()
func (m *FindServiceRequest) Reset()
func (m *FindServiceRequest) String() string
for internal testing only
type FindServiceResponse struct {
Targets []*Target `protobuf:"bytes,1,rep,name=Targets" json:"Targets,omitempty"`
}
func (*FindServiceResponse) Descriptor() ([]byte, []int)
func (m *FindServiceResponse) GetTargets() []*Target
func (*FindServiceResponse) ProtoMessage()
func (m *FindServiceResponse) Reset()
func (m *FindServiceResponse) String() string
type PingRequest struct {
SequenceNumber uint32 `protobuf:"varint,1,opt,name=SequenceNumber" json:"SequenceNumber,omitempty"`
Payload string `protobuf:"bytes,2,opt,name=Payload" json:"Payload,omitempty"`
TTL uint32 `protobuf:"varint,3,opt,name=TTL" json:"TTL,omitempty"`
PleaseFail bool `protobuf:"varint,4,opt,name=PleaseFail" json:"PleaseFail,omitempty"`
}
func (*PingRequest) Descriptor() ([]byte, []int)
func (m *PingRequest) GetPayload() string
func (m *PingRequest) GetPleaseFail() bool
func (m *PingRequest) GetSequenceNumber() uint32
func (m *PingRequest) GetTTL() uint32
func (*PingRequest) ProtoMessage()
func (m *PingRequest) Reset()
func (m *PingRequest) String() string
type PingResponse struct {
Response *PingRequest `protobuf:"bytes,1,opt,name=Response" json:"Response,omitempty"`
ServerTags map[string]string `protobuf:"bytes,2,rep,name=ServerTags" json:"ServerTags,omitempty" protobuf_key:"bytes,1,opt,name=key" protobuf_val:"bytes,2,opt,name=value"`
}
func (*PingResponse) Descriptor() ([]byte, []int)
func (m *PingResponse) GetResponse() *PingRequest
func (m *PingResponse) GetServerTags() map[string]string
func (*PingResponse) ProtoMessage()
func (m *PingResponse) Reset()
func (m *PingResponse) String() string
type RequiredContext struct {
User *auth.SignedUser `protobuf:"bytes,3,opt,name=User" json:"User,omitempty"`
Service *auth.SignedUser `protobuf:"bytes,4,opt,name=Service" json:"Service,omitempty"`
}
func (*RequiredContext) Descriptor() ([]byte, []int)
func (m *RequiredContext) GetService() *auth.SignedUser
func (m *RequiredContext) GetUser() *auth.SignedUser
func (*RequiredContext) ProtoMessage()
func (m *RequiredContext) Reset()
func (m *RequiredContext) String() string
type SerialisedContext struct {
Data []byte `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"`
SData string `protobuf:"bytes,2,opt,name=SData" json:"SData,omitempty"`
User *auth.SignedUser `protobuf:"bytes,3,opt,name=User" json:"User,omitempty"`
Service *auth.SignedUser `protobuf:"bytes,4,opt,name=Service" json:"Service,omitempty"`
}
func (*SerialisedContext) Descriptor() ([]byte, []int)
func (m *SerialisedContext) GetData() []byte
func (m *SerialisedContext) GetSData() string
func (m *SerialisedContext) GetService() *auth.SignedUser
func (m *SerialisedContext) GetUser() *auth.SignedUser
func (*SerialisedContext) ProtoMessage()
func (m *SerialisedContext) Reset()
func (m *SerialisedContext) String() string
type SleepRequest struct {
Seconds float64 `protobuf:"fixed64,1,opt,name=Seconds" json:"Seconds,omitempty"`
}
func (*SleepRequest) Descriptor() ([]byte, []int)
func (m *SleepRequest) GetSeconds() float64
func (*SleepRequest) ProtoMessage()
func (m *SleepRequest) Reset()
func (m *SleepRequest) String() string
for internal testing only
type Target struct {
IP string `protobuf:"bytes,1,opt,name=IP" json:"IP,omitempty"`
Port uint32 `protobuf:"varint,2,opt,name=Port" json:"Port,omitempty"`
}
func (*Target) Descriptor() ([]byte, []int)
func (m *Target) GetIP() string
func (m *Target) GetPort() uint32
func (*Target) ProtoMessage()
func (m *Target) Reset()
func (m *Target) String() string
type TriggerRPCRequest struct {
Action uint32 `protobuf:"varint,1,opt,name=Action" json:"Action,omitempty"`
Counter uint32 `protobuf:"varint,2,opt,name=Counter" json:"Counter,omitempty"`
}
func (*TriggerRPCRequest) Descriptor() ([]byte, []int)
func (m *TriggerRPCRequest) GetAction() uint32
func (m *TriggerRPCRequest) GetCounter() uint32
func (*TriggerRPCRequest) ProtoMessage()
func (m *TriggerRPCRequest) Reset()
func (m *TriggerRPCRequest) String() string
for internal testing only
type UserByLoginRequest struct {
Username string `protobuf:"bytes,1,opt,name=Username" json:"Username,omitempty"`
Password string `protobuf:"bytes,2,opt,name=Password" json:"Password,omitempty"`
}
func (*UserByLoginRequest) Descriptor() ([]byte, []int)
func (m *UserByLoginRequest) GetPassword() string
func (m *UserByLoginRequest) GetUsername() string
func (*UserByLoginRequest) ProtoMessage()
func (m *UserByLoginRequest) Reset()
func (m *UserByLoginRequest) String() string
for internal testing only
type UserByTokenRequest struct {
Token string `protobuf:"bytes,1,opt,name=Token" json:"Token,omitempty"`
}
func (*UserByTokenRequest) Descriptor() ([]byte, []int)
func (m *UserByTokenRequest) GetToken() string
func (*UserByTokenRequest) ProtoMessage()
func (m *UserByTokenRequest) Reset()
func (m *UserByTokenRequest) String() string