Versions in this module Expand all Collapse all v0 v0.5.0 Apr 16, 2020 Changes in this version + var ErrIntOverflowRegister = fmt.Errorf("proto: integer overflow") + var ErrIntOverflowSimulator = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthRegister = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrInvalidLengthSimulator = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupRegister = fmt.Errorf("proto: unexpected end of group") + var ErrUnexpectedEndOfGroupSimulator = fmt.Errorf("proto: unexpected end of group") + func GetCommand() *cobra.Command + func Main() + func RegisterRegisterServiceServer(s *grpc.Server, srv RegisterServiceServer) + func RegisterSimulatorServiceServer(s *grpc.Server, srv SimulatorServiceServer) + func Run() error + type Arg struct + func (a *Arg) Int(def int) int + func (a *Arg) String(def string) string + type Config struct + Args map[string]string + Duration time.Duration + Env map[string]string + ID string + Image string + ImagePullPolicy corev1.PullPolicy + Jitter map[string]float64 + Model string + Rates map[string]time.Duration + Simulation string + Simulators int + func GetConfigFromEnv() *Config + func (c *Config) ToEnv() map[string]string + type Coordinator struct + func (c *Coordinator) Run() error + type Register interface + Trace func(value struct{}) error + TraceFields func(fieldsAndValues ...interface{}) error + TraceValues func(values ...interface{}) error + type RegisterServiceClient interface + Trace func(ctx context.Context, in *TraceRequest, opts ...grpc.CallOption) (*TraceResponse, error) + func NewRegisterServiceClient(cc *grpc.ClientConn) RegisterServiceClient + type RegisterServiceServer interface + Trace func(context.Context, *TraceRequest) (*TraceResponse, error) + type ScheduleSimulator interface + ScheduleSimulator func(s *Simulator) + type SetupSimulation interface + SetupSimulation func(s *Simulator) error + type SetupSimulator interface + SetupSimulator func(s *Simulator) error + type SimulatingSuite interface + type SimulationLifecycleRequest struct + Args map[string]string + Simulation string + func (*SimulationLifecycleRequest) Descriptor() ([]byte, []int) + func (*SimulationLifecycleRequest) ProtoMessage() + func (m *SimulationLifecycleRequest) GetArgs() map[string]string + func (m *SimulationLifecycleRequest) GetSimulation() string + func (m *SimulationLifecycleRequest) Marshal() (dAtA []byte, err error) + func (m *SimulationLifecycleRequest) MarshalTo(dAtA []byte) (int, error) + func (m *SimulationLifecycleRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SimulationLifecycleRequest) Reset() + func (m *SimulationLifecycleRequest) Size() (n int) + func (m *SimulationLifecycleRequest) String() string + func (m *SimulationLifecycleRequest) Unmarshal(dAtA []byte) error + func (m *SimulationLifecycleRequest) XXX_DiscardUnknown() + func (m *SimulationLifecycleRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SimulationLifecycleRequest) XXX_Merge(src proto.Message) + func (m *SimulationLifecycleRequest) XXX_Size() int + func (m *SimulationLifecycleRequest) XXX_Unmarshal(b []byte) error + type SimulationLifecycleResponse struct + func (*SimulationLifecycleResponse) Descriptor() ([]byte, []int) + func (*SimulationLifecycleResponse) ProtoMessage() + func (m *SimulationLifecycleResponse) Marshal() (dAtA []byte, err error) + func (m *SimulationLifecycleResponse) MarshalTo(dAtA []byte) (int, error) + func (m *SimulationLifecycleResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SimulationLifecycleResponse) Reset() + func (m *SimulationLifecycleResponse) Size() (n int) + func (m *SimulationLifecycleResponse) String() string + func (m *SimulationLifecycleResponse) Unmarshal(dAtA []byte) error + func (m *SimulationLifecycleResponse) XXX_DiscardUnknown() + func (m *SimulationLifecycleResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SimulationLifecycleResponse) XXX_Merge(src proto.Message) + func (m *SimulationLifecycleResponse) XXX_Size() int + func (m *SimulationLifecycleResponse) XXX_Unmarshal(b []byte) error + type Simulator struct + Name string + Process int + func (s *Simulator) Arg(name string) *Arg + func (s *Simulator) Schedule(name string, f func(*Simulator) error, rate time.Duration, jitter float64) + func (s *Simulator) Trace(value struct{}) error + func (s *Simulator) TraceFields(fieldsAndValues ...interface{}) error + func (s *Simulator) TraceValues(values ...interface{}) error + type SimulatorRequest struct + Register string + Simulation string + func (*SimulatorRequest) Descriptor() ([]byte, []int) + func (*SimulatorRequest) ProtoMessage() + func (m *SimulatorRequest) GetRegister() string + func (m *SimulatorRequest) GetSimulation() string + func (m *SimulatorRequest) Marshal() (dAtA []byte, err error) + func (m *SimulatorRequest) MarshalTo(dAtA []byte) (int, error) + func (m *SimulatorRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SimulatorRequest) Reset() + func (m *SimulatorRequest) Size() (n int) + func (m *SimulatorRequest) String() string + func (m *SimulatorRequest) Unmarshal(dAtA []byte) error + func (m *SimulatorRequest) XXX_DiscardUnknown() + func (m *SimulatorRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SimulatorRequest) XXX_Merge(src proto.Message) + func (m *SimulatorRequest) XXX_Size() int + func (m *SimulatorRequest) XXX_Unmarshal(b []byte) error + type SimulatorResponse struct + Error string + func (*SimulatorResponse) Descriptor() ([]byte, []int) + func (*SimulatorResponse) ProtoMessage() + func (m *SimulatorResponse) GetError() string + func (m *SimulatorResponse) Marshal() (dAtA []byte, err error) + func (m *SimulatorResponse) MarshalTo(dAtA []byte) (int, error) + func (m *SimulatorResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *SimulatorResponse) Reset() + func (m *SimulatorResponse) Size() (n int) + func (m *SimulatorResponse) String() string + func (m *SimulatorResponse) Unmarshal(dAtA []byte) error + func (m *SimulatorResponse) XXX_DiscardUnknown() + func (m *SimulatorResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *SimulatorResponse) XXX_Merge(src proto.Message) + func (m *SimulatorResponse) XXX_Size() int + func (m *SimulatorResponse) XXX_Unmarshal(b []byte) error + type SimulatorServiceClient interface + SetupSimulation func(ctx context.Context, in *SimulationLifecycleRequest, opts ...grpc.CallOption) (*SimulationLifecycleResponse, error) + SetupSimulator func(ctx context.Context, in *SimulationLifecycleRequest, opts ...grpc.CallOption) (*SimulationLifecycleResponse, error) + StartSimulator func(ctx context.Context, in *SimulatorRequest, opts ...grpc.CallOption) (*SimulatorResponse, error) + StopSimulator func(ctx context.Context, in *SimulatorRequest, opts ...grpc.CallOption) (*SimulatorResponse, error) + TearDownSimulation func(ctx context.Context, in *SimulationLifecycleRequest, opts ...grpc.CallOption) (*SimulationLifecycleResponse, error) + TearDownSimulator func(ctx context.Context, in *SimulationLifecycleRequest, opts ...grpc.CallOption) (*SimulationLifecycleResponse, error) + func NewSimulatorServiceClient(cc *grpc.ClientConn) SimulatorServiceClient + type SimulatorServiceServer interface + SetupSimulation func(context.Context, *SimulationLifecycleRequest) (*SimulationLifecycleResponse, error) + SetupSimulator func(context.Context, *SimulationLifecycleRequest) (*SimulationLifecycleResponse, error) + StartSimulator func(context.Context, *SimulatorRequest) (*SimulatorResponse, error) + StopSimulator func(context.Context, *SimulatorRequest) (*SimulatorResponse, error) + TearDownSimulation func(context.Context, *SimulationLifecycleRequest) (*SimulationLifecycleResponse, error) + TearDownSimulator func(context.Context, *SimulationLifecycleRequest) (*SimulationLifecycleResponse, error) + type Suite struct + type TearDownSimulation interface + TearDownSimulation func(s *Simulator) error + type TearDownSimulator interface + TearDownSimulator func(s *Simulator) error + type TraceRequest struct + Error string + Simulation string + Trace *model.Trace + func (*TraceRequest) Descriptor() ([]byte, []int) + func (*TraceRequest) ProtoMessage() + func (m *TraceRequest) GetError() string + func (m *TraceRequest) GetSimulation() string + func (m *TraceRequest) GetTrace() *model.Trace + func (m *TraceRequest) Marshal() (dAtA []byte, err error) + func (m *TraceRequest) MarshalTo(dAtA []byte) (int, error) + func (m *TraceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TraceRequest) Reset() + func (m *TraceRequest) Size() (n int) + func (m *TraceRequest) String() string + func (m *TraceRequest) Unmarshal(dAtA []byte) error + func (m *TraceRequest) XXX_DiscardUnknown() + func (m *TraceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TraceRequest) XXX_Merge(src proto.Message) + func (m *TraceRequest) XXX_Size() int + func (m *TraceRequest) XXX_Unmarshal(b []byte) error + type TraceResponse struct + func (*TraceResponse) Descriptor() ([]byte, []int) + func (*TraceResponse) ProtoMessage() + func (m *TraceResponse) Marshal() (dAtA []byte, err error) + func (m *TraceResponse) MarshalTo(dAtA []byte) (int, error) + func (m *TraceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *TraceResponse) Reset() + func (m *TraceResponse) Size() (n int) + func (m *TraceResponse) String() string + func (m *TraceResponse) Unmarshal(dAtA []byte) error + func (m *TraceResponse) XXX_DiscardUnknown() + func (m *TraceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *TraceResponse) XXX_Merge(src proto.Message) + func (m *TraceResponse) XXX_Size() int + func (m *TraceResponse) XXX_Unmarshal(b []byte) error + type UnimplementedRegisterServiceServer struct + func (*UnimplementedRegisterServiceServer) Trace(ctx context.Context, req *TraceRequest) (*TraceResponse, error) + type UnimplementedSimulatorServiceServer struct + func (*UnimplementedSimulatorServiceServer) SetupSimulation(ctx context.Context, req *SimulationLifecycleRequest) (*SimulationLifecycleResponse, error) + func (*UnimplementedSimulatorServiceServer) SetupSimulator(ctx context.Context, req *SimulationLifecycleRequest) (*SimulationLifecycleResponse, error) + func (*UnimplementedSimulatorServiceServer) StartSimulator(ctx context.Context, req *SimulatorRequest) (*SimulatorResponse, error) + func (*UnimplementedSimulatorServiceServer) StopSimulator(ctx context.Context, req *SimulatorRequest) (*SimulatorResponse, error) + func (*UnimplementedSimulatorServiceServer) TearDownSimulation(ctx context.Context, req *SimulationLifecycleRequest) (*SimulationLifecycleResponse, error) + func (*UnimplementedSimulatorServiceServer) TearDownSimulator(ctx context.Context, req *SimulationLifecycleRequest) (*SimulationLifecycleResponse, error) + type WorkerTask struct + func (t *WorkerTask) Run() (int, error)
Go to main page