messages

package
v0.0.0-...-bd70b13 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 2, 2019 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthLoadtest = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowLoadtest   = fmt.Errorf("proto: integer overflow")
)

Functions

This section is empty.

Types

type CheckAllSlavesConnected 

type CheckAllSlavesConnected struct {
	Sender *actor.PID `protobuf:"bytes,1,opt,name=Sender,proto3" json:"Sender,omitempty"`
}

CheckAllSlavesConnected is sent by the master to itself after a preconfigured timeout period to ensure that all slaves are connected. If we are missing slaves at this time, the master will fail and shut down.

func (*CheckAllSlavesConnected) Descriptor 

func (*CheckAllSlavesConnected) Descriptor() ([]byte, []int)

func (*CheckAllSlavesConnected) Equal 

func (this *CheckAllSlavesConnected) Equal(that interface{}) bool

func (*CheckAllSlavesConnected) GetSender 

func (m *CheckAllSlavesConnected) GetSender() *actor.PID

func (*CheckAllSlavesConnected) GoString 

func (this *CheckAllSlavesConnected) GoString() string

func (*CheckAllSlavesConnected) Marshal 

func (m *CheckAllSlavesConnected) Marshal() (dAtA []byte, err error)

func (*CheckAllSlavesConnected) MarshalTo 

func (m *CheckAllSlavesConnected) MarshalTo(dAtA []byte) (int, error)

func (*CheckAllSlavesConnected) ProtoMessage 

func (*CheckAllSlavesConnected) ProtoMessage()

func (*CheckAllSlavesConnected) Reset 

func (m *CheckAllSlavesConnected) Reset()

func (*CheckAllSlavesConnected) Size 

func (m *CheckAllSlavesConnected) Size() (n int)

func (*CheckAllSlavesConnected) String 

func (this *CheckAllSlavesConnected) String() string

func (*CheckAllSlavesConnected) Unmarshal 

func (m *CheckAllSlavesConnected) Unmarshal(dAtA []byte) error

func (*CheckAllSlavesConnected) XXX_DiscardUnknown 

func (m *CheckAllSlavesConnected) XXX_DiscardUnknown()

func (*CheckAllSlavesConnected) XXX_Marshal 

func (m *CheckAllSlavesConnected) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CheckAllSlavesConnected) XXX_Merge 

func (m *CheckAllSlavesConnected) XXX_Merge(src proto.Message)

func (*CheckAllSlavesConnected) XXX_Size 

func (m *CheckAllSlavesConnected) XXX_Size() int

func (*CheckAllSlavesConnected) XXX_Unmarshal 

func (m *CheckAllSlavesConnected) XXX_Unmarshal(b []byte) error

type CombinedStats 

type CombinedStats struct {
	TotalTestTime int64                    `protobuf:"varint,1,opt,name=TotalTestTime,proto3" json:"TotalTestTime,omitempty"`
	Interactions  *SummaryStats            `protobuf:"bytes,2,opt,name=Interactions,proto3" json:"Interactions,omitempty"`
	Requests      map[string]*SummaryStats `` /* 157-byte string literal not displayed */
}

CombinedStats encapsulates the statistics we receive from a slave node during/after testing for both interactions and requests.

func (*CombinedStats) Descriptor 

func (*CombinedStats) Descriptor() ([]byte, []int)

func (*CombinedStats) Equal 

func (this *CombinedStats) Equal(that interface{}) bool

func (*CombinedStats) GetInteractions 

func (m *CombinedStats) GetInteractions() *SummaryStats

func (*CombinedStats) GetRequests 

func (m *CombinedStats) GetRequests() map[string]*SummaryStats

func (*CombinedStats) GetTotalTestTime 

func (m *CombinedStats) GetTotalTestTime() int64

func (*CombinedStats) GoString 

func (this *CombinedStats) GoString() string

func (*CombinedStats) Marshal 

func (m *CombinedStats) Marshal() (dAtA []byte, err error)

func (*CombinedStats) MarshalTo 

func (m *CombinedStats) MarshalTo(dAtA []byte) (int, error)

func (*CombinedStats) ProtoMessage 

func (*CombinedStats) ProtoMessage()

func (*CombinedStats) Reset 

func (m *CombinedStats) Reset()

func (*CombinedStats) Size 

func (m *CombinedStats) Size() (n int)

func (*CombinedStats) String 

func (this *CombinedStats) String() string

func (*CombinedStats) Unmarshal 

func (m *CombinedStats) Unmarshal(dAtA []byte) error

func (*CombinedStats) XXX_DiscardUnknown 

func (m *CombinedStats) XXX_DiscardUnknown()

func (*CombinedStats) XXX_Marshal 

func (m *CombinedStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CombinedStats) XXX_Merge 

func (m *CombinedStats) XXX_Merge(src proto.Message)

func (*CombinedStats) XXX_Size 

func (m *CombinedStats) XXX_Size() int

func (*CombinedStats) XXX_Unmarshal 

func (m *CombinedStats) XXX_Unmarshal(b []byte) error

type Kill 

type Kill struct {
	Sender *actor.PID `protobuf:"bytes,1,opt,name=Sender,proto3" json:"Sender,omitempty"`
}

Kill is an internal message for terminating a node when SIGTERM or SIGINT is received.

func (*Kill) Descriptor 

func (*Kill) Descriptor() ([]byte, []int)

func (*Kill) Equal 

func (this *Kill) Equal(that interface{}) bool

func (*Kill) GetSender 

func (m *Kill) GetSender() *actor.PID

func (*Kill) GoString 

func (this *Kill) GoString() string

func (*Kill) Marshal 

func (m *Kill) Marshal() (dAtA []byte, err error)

func (*Kill) MarshalTo 

func (m *Kill) MarshalTo(dAtA []byte) (int, error)

func (*Kill) ProtoMessage 

func (*Kill) ProtoMessage()

func (*Kill) Reset 

func (m *Kill) Reset()

func (*Kill) Size 

func (m *Kill) Size() (n int)

func (*Kill) String 

func (this *Kill) String() string

func (*Kill) Unmarshal 

func (m *Kill) Unmarshal(dAtA []byte) error

func (*Kill) XXX_DiscardUnknown 

func (m *Kill) XXX_DiscardUnknown()

func (*Kill) XXX_Marshal 

func (m *Kill) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Kill) XXX_Merge 

func (m *Kill) XXX_Merge(src proto.Message)

func (*Kill) XXX_Size 

func (m *Kill) XXX_Size() int

func (*Kill) XXX_Unmarshal 

func (m *Kill) XXX_Unmarshal(b []byte) error

type LoadTestUnderway 

type LoadTestUnderway struct {
	Sender *actor.PID `protobuf:"bytes,1,opt,name=Sender,proto3" json:"Sender,omitempty"`
}

LoadTestUnderway is sent by slaves on a regular basis from the instant that load testing starts. This acts as a notification to the master that the slaves are, in fact, testing, as well as a form of health check/heartbeat to ensure that the load testing completes effectively.

func (*LoadTestUnderway) Descriptor 

func (*LoadTestUnderway) Descriptor() ([]byte, []int)

func (*LoadTestUnderway) Equal 

func (this *LoadTestUnderway) Equal(that interface{}) bool

func (*LoadTestUnderway) GetSender 

func (m *LoadTestUnderway) GetSender() *actor.PID

func (*LoadTestUnderway) GoString 

func (this *LoadTestUnderway) GoString() string

func (*LoadTestUnderway) Marshal 

func (m *LoadTestUnderway) Marshal() (dAtA []byte, err error)

func (*LoadTestUnderway) MarshalTo 

func (m *LoadTestUnderway) MarshalTo(dAtA []byte) (int, error)

func (*LoadTestUnderway) ProtoMessage 

func (*LoadTestUnderway) ProtoMessage()

func (*LoadTestUnderway) Reset 

func (m *LoadTestUnderway) Reset()

func (*LoadTestUnderway) Size 

func (m *LoadTestUnderway) Size() (n int)

func (*LoadTestUnderway) String 

func (this *LoadTestUnderway) String() string

func (*LoadTestUnderway) Unmarshal 

func (m *LoadTestUnderway) Unmarshal(dAtA []byte) error

func (*LoadTestUnderway) XXX_DiscardUnknown 

func (m *LoadTestUnderway) XXX_DiscardUnknown()

func (*LoadTestUnderway) XXX_Marshal 

func (m *LoadTestUnderway) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LoadTestUnderway) XXX_Merge 

func (m *LoadTestUnderway) XXX_Merge(src proto.Message)

func (*LoadTestUnderway) XXX_Size 

func (m *LoadTestUnderway) XXX_Size() int

func (*LoadTestUnderway) XXX_Unmarshal 

func (m *LoadTestUnderway) XXX_Unmarshal(b []byte) error

type MasterFailed 

type MasterFailed struct {
	Sender *actor.PID `protobuf:"bytes,1,opt,name=Sender,proto3" json:"Sender,omitempty"`
	Reason string     `protobuf:"bytes,2,opt,name=Reason,proto3" json:"Reason,omitempty"`
}

MasterFailed is sent by the master node to the slaves if the master node encounters an error from which it cannot recover.

func (*MasterFailed) Descriptor 

func (*MasterFailed) Descriptor() ([]byte, []int)

func (*MasterFailed) Equal 

func (this *MasterFailed) Equal(that interface{}) bool

func (*MasterFailed) GetReason 

func (m *MasterFailed) GetReason() string

func (*MasterFailed) GetSender 

func (m *MasterFailed) GetSender() *actor.PID

func (*MasterFailed) GoString 

func (this *MasterFailed) GoString() string

func (*MasterFailed) Marshal 

func (m *MasterFailed) Marshal() (dAtA []byte, err error)

func (*MasterFailed) MarshalTo 

func (m *MasterFailed) MarshalTo(dAtA []byte) (int, error)

func (*MasterFailed) ProtoMessage 

func (*MasterFailed) ProtoMessage()

func (*MasterFailed) Reset 

func (m *MasterFailed) Reset()

func (*MasterFailed) Size 

func (m *MasterFailed) Size() (n int)

func (*MasterFailed) String 

func (this *MasterFailed) String() string

func (*MasterFailed) Unmarshal 

func (m *MasterFailed) Unmarshal(dAtA []byte) error

func (*MasterFailed) XXX_DiscardUnknown 

func (m *MasterFailed) XXX_DiscardUnknown()

func (*MasterFailed) XXX_Marshal 

func (m *MasterFailed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MasterFailed) XXX_Merge 

func (m *MasterFailed) XXX_Merge(src proto.Message)

func (*MasterFailed) XXX_Size 

func (m *MasterFailed) XXX_Size() int

func (*MasterFailed) XXX_Unmarshal 

func (m *MasterFailed) XXX_Unmarshal(b []byte) error

type ResponseTimeHistogram 

type ResponseTimeHistogram struct {
	Timeout  int64           `protobuf:"varint,1,opt,name=Timeout,proto3" json:"Timeout,omitempty"`
	BinSize  int64           `protobuf:"varint,2,opt,name=BinSize,proto3" json:"BinSize,omitempty"`
	BinCount int64           `protobuf:"varint,3,opt,name=BinCount,proto3" json:"BinCount,omitempty"`
	TimeBins map[int64]int64 `` /* 159-byte string literal not displayed */
}

ResponseTimeHistogram allows us to plot the range of different interaction/response times during a particular load test.

func (*ResponseTimeHistogram) Descriptor 

func (*ResponseTimeHistogram) Descriptor() ([]byte, []int)

func (*ResponseTimeHistogram) Equal 

func (this *ResponseTimeHistogram) Equal(that interface{}) bool

func (*ResponseTimeHistogram) GetBinCount 

func (m *ResponseTimeHistogram) GetBinCount() int64

func (*ResponseTimeHistogram) GetBinSize 

func (m *ResponseTimeHistogram) GetBinSize() int64

func (*ResponseTimeHistogram) GetTimeBins 

func (m *ResponseTimeHistogram) GetTimeBins() map[int64]int64

func (*ResponseTimeHistogram) GetTimeout 

func (m *ResponseTimeHistogram) GetTimeout() int64

func (*ResponseTimeHistogram) GoString 

func (this *ResponseTimeHistogram) GoString() string

func (*ResponseTimeHistogram) Marshal 

func (m *ResponseTimeHistogram) Marshal() (dAtA []byte, err error)

func (*ResponseTimeHistogram) MarshalTo 

func (m *ResponseTimeHistogram) MarshalTo(dAtA []byte) (int, error)

func (*ResponseTimeHistogram) ProtoMessage 

func (*ResponseTimeHistogram) ProtoMessage()

func (*ResponseTimeHistogram) Reset 

func (m *ResponseTimeHistogram) Reset()

func (*ResponseTimeHistogram) Size 

func (m *ResponseTimeHistogram) Size() (n int)

func (*ResponseTimeHistogram) String 

func (this *ResponseTimeHistogram) String() string

func (*ResponseTimeHistogram) Unmarshal 

func (m *ResponseTimeHistogram) Unmarshal(dAtA []byte) error

func (*ResponseTimeHistogram) XXX_DiscardUnknown 

func (m *ResponseTimeHistogram) XXX_DiscardUnknown()

func (*ResponseTimeHistogram) XXX_Marshal 

func (m *ResponseTimeHistogram) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResponseTimeHistogram) XXX_Merge 

func (m *ResponseTimeHistogram) XXX_Merge(src proto.Message)

func (*ResponseTimeHistogram) XXX_Size 

func (m *ResponseTimeHistogram) XXX_Size() int

func (*ResponseTimeHistogram) XXX_Unmarshal 

func (m *ResponseTimeHistogram) XXX_Unmarshal(b []byte) error

type SlaveAccepted 

type SlaveAccepted struct {
	Sender *actor.PID `protobuf:"bytes,1,opt,name=Sender,proto3" json:"Sender,omitempty"`
}

SlaveAccepted is sent by the master to a slave to indicate that it's been accepted for load testing.

func (*SlaveAccepted) Descriptor 

func (*SlaveAccepted) Descriptor() ([]byte, []int)

func (*SlaveAccepted) Equal 

func (this *SlaveAccepted) Equal(that interface{}) bool

func (*SlaveAccepted) GetSender 

func (m *SlaveAccepted) GetSender() *actor.PID

func (*SlaveAccepted) GoString 

func (this *SlaveAccepted) GoString() string

func (*SlaveAccepted) Marshal 

func (m *SlaveAccepted) Marshal() (dAtA []byte, err error)

func (*SlaveAccepted) MarshalTo 

func (m *SlaveAccepted) MarshalTo(dAtA []byte) (int, error)

func (*SlaveAccepted) ProtoMessage 

func (*SlaveAccepted) ProtoMessage()

func (*SlaveAccepted) Reset 

func (m *SlaveAccepted) Reset()

func (*SlaveAccepted) Size 

func (m *SlaveAccepted) Size() (n int)

func (*SlaveAccepted) String 

func (this *SlaveAccepted) String() string

func (*SlaveAccepted) Unmarshal 

func (m *SlaveAccepted) Unmarshal(dAtA []byte) error

func (*SlaveAccepted) XXX_DiscardUnknown 

func (m *SlaveAccepted) XXX_DiscardUnknown()

func (*SlaveAccepted) XXX_Marshal 

func (m *SlaveAccepted) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SlaveAccepted) XXX_Merge 

func (m *SlaveAccepted) XXX_Merge(src proto.Message)

func (*SlaveAccepted) XXX_Size 

func (m *SlaveAccepted) XXX_Size() int

func (*SlaveAccepted) XXX_Unmarshal 

func (m *SlaveAccepted) XXX_Unmarshal(b []byte) error

type SlaveFailed 

type SlaveFailed struct {
	Sender *actor.PID `protobuf:"bytes,1,opt,name=Sender,proto3" json:"Sender,omitempty"`
	Reason string     `protobuf:"bytes,2,opt,name=Reason,proto3" json:"Reason,omitempty"`
}

SlaveFailed is sent by a slave if testing fails for any reason.

func (*SlaveFailed) Descriptor 

func (*SlaveFailed) Descriptor() ([]byte, []int)

func (*SlaveFailed) Equal 

func (this *SlaveFailed) Equal(that interface{}) bool

func (*SlaveFailed) GetReason 

func (m *SlaveFailed) GetReason() string

func (*SlaveFailed) GetSender 

func (m *SlaveFailed) GetSender() *actor.PID

func (*SlaveFailed) GoString 

func (this *SlaveFailed) GoString() string

func (*SlaveFailed) Marshal 

func (m *SlaveFailed) Marshal() (dAtA []byte, err error)

func (*SlaveFailed) MarshalTo 

func (m *SlaveFailed) MarshalTo(dAtA []byte) (int, error)

func (*SlaveFailed) ProtoMessage 

func (*SlaveFailed) ProtoMessage()

func (*SlaveFailed) Reset 

func (m *SlaveFailed) Reset()

func (*SlaveFailed) Size 

func (m *SlaveFailed) Size() (n int)

func (*SlaveFailed) String 

func (this *SlaveFailed) String() string

func (*SlaveFailed) Unmarshal 

func (m *SlaveFailed) Unmarshal(dAtA []byte) error

func (*SlaveFailed) XXX_DiscardUnknown 

func (m *SlaveFailed) XXX_DiscardUnknown()

func (*SlaveFailed) XXX_Marshal 

func (m *SlaveFailed) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SlaveFailed) XXX_Merge 

func (m *SlaveFailed) XXX_Merge(src proto.Message)

func (*SlaveFailed) XXX_Size 

func (m *SlaveFailed) XXX_Size() int

func (*SlaveFailed) XXX_Unmarshal 

func (m *SlaveFailed) XXX_Unmarshal(b []byte) error

type SlaveFinished 

type SlaveFinished struct {
	Sender *actor.PID     `protobuf:"bytes,1,opt,name=Sender,proto3" json:"Sender,omitempty"`
	Stats  *CombinedStats `protobuf:"bytes,2,opt,name=Stats,proto3" json:"Stats,omitempty"`
}

SlaveFinished is sent by a slave when it successfully finishes its load testing.

func (*SlaveFinished) Descriptor 

func (*SlaveFinished) Descriptor() ([]byte, []int)

func (*SlaveFinished) Equal 

func (this *SlaveFinished) Equal(that interface{}) bool

func (*SlaveFinished) GetSender 

func (m *SlaveFinished) GetSender() *actor.PID

func (*SlaveFinished) GetStats 

func (m *SlaveFinished) GetStats() *CombinedStats

func (*SlaveFinished) GoString 

func (this *SlaveFinished) GoString() string

func (*SlaveFinished) Marshal 

func (m *SlaveFinished) Marshal() (dAtA []byte, err error)

func (*SlaveFinished) MarshalTo 

func (m *SlaveFinished) MarshalTo(dAtA []byte) (int, error)

func (*SlaveFinished) ProtoMessage 

func (*SlaveFinished) ProtoMessage()

func (*SlaveFinished) Reset 

func (m *SlaveFinished) Reset()

func (*SlaveFinished) Size 

func (m *SlaveFinished) Size() (n int)

func (*SlaveFinished) String 

func (this *SlaveFinished) String() string

func (*SlaveFinished) Unmarshal 

func (m *SlaveFinished) Unmarshal(dAtA []byte) error

func (*SlaveFinished) XXX_DiscardUnknown 

func (m *SlaveFinished) XXX_DiscardUnknown()

func (*SlaveFinished) XXX_Marshal 

func (m *SlaveFinished) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SlaveFinished) XXX_Merge 

func (m *SlaveFinished) XXX_Merge(src proto.Message)

func (*SlaveFinished) XXX_Size 

func (m *SlaveFinished) XXX_Size() int

func (*SlaveFinished) XXX_Unmarshal 

func (m *SlaveFinished) XXX_Unmarshal(b []byte) error

type SlaveReady 

type SlaveReady struct {
	Sender *actor.PID `protobuf:"bytes,1,opt,name=Sender,proto3" json:"Sender,omitempty"`
}

SlaveReady is sent by a slave when it's ready to start load testing.

func (*SlaveReady) Descriptor 

func (*SlaveReady) Descriptor() ([]byte, []int)

func (*SlaveReady) Equal 

func (this *SlaveReady) Equal(that interface{}) bool

func (*SlaveReady) GetSender 

func (m *SlaveReady) GetSender() *actor.PID

func (*SlaveReady) GoString 

func (this *SlaveReady) GoString() string

func (*SlaveReady) Marshal 

func (m *SlaveReady) Marshal() (dAtA []byte, err error)

func (*SlaveReady) MarshalTo 

func (m *SlaveReady) MarshalTo(dAtA []byte) (int, error)

func (*SlaveReady) ProtoMessage 

func (*SlaveReady) ProtoMessage()

func (*SlaveReady) Reset 

func (m *SlaveReady) Reset()

func (*SlaveReady) Size 

func (m *SlaveReady) Size() (n int)

func (*SlaveReady) String 

func (this *SlaveReady) String() string

func (*SlaveReady) Unmarshal 

func (m *SlaveReady) Unmarshal(dAtA []byte) error

func (*SlaveReady) XXX_DiscardUnknown 

func (m *SlaveReady) XXX_DiscardUnknown()

func (*SlaveReady) XXX_Marshal 

func (m *SlaveReady) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SlaveReady) XXX_Merge 

func (m *SlaveReady) XXX_Merge(src proto.Message)

func (*SlaveReady) XXX_Size 

func (m *SlaveReady) XXX_Size() int

func (*SlaveReady) XXX_Unmarshal 

func (m *SlaveReady) XXX_Unmarshal(b []byte) error

type SlaveRejected 

type SlaveRejected struct {
	Sender *actor.PID `protobuf:"bytes,1,opt,name=Sender,proto3" json:"Sender,omitempty"`
	Reason string     `protobuf:"bytes,2,opt,name=Reason,proto3" json:"Reason,omitempty"`
}

SlaveRejected is sent by the master to a slave when it already has too many connected slaves, or it has seen a slave with the same ID before.

func (*SlaveRejected) Descriptor 

func (*SlaveRejected) Descriptor() ([]byte, []int)

func (*SlaveRejected) Equal 

func (this *SlaveRejected) Equal(that interface{}) bool

func (*SlaveRejected) GetReason 

func (m *SlaveRejected) GetReason() string

func (*SlaveRejected) GetSender 

func (m *SlaveRejected) GetSender() *actor.PID

func (*SlaveRejected) GoString 

func (this *SlaveRejected) GoString() string

func (*SlaveRejected) Marshal 

func (m *SlaveRejected) Marshal() (dAtA []byte, err error)

func (*SlaveRejected) MarshalTo 

func (m *SlaveRejected) MarshalTo(dAtA []byte) (int, error)

func (*SlaveRejected) ProtoMessage 

func (*SlaveRejected) ProtoMessage()

func (*SlaveRejected) Reset 

func (m *SlaveRejected) Reset()

func (*SlaveRejected) Size 

func (m *SlaveRejected) Size() (n int)

func (*SlaveRejected) String 

func (this *SlaveRejected) String() string

func (*SlaveRejected) Unmarshal 

func (m *SlaveRejected) Unmarshal(dAtA []byte) error

func (*SlaveRejected) XXX_DiscardUnknown 

func (m *SlaveRejected) XXX_DiscardUnknown()

func (*SlaveRejected) XXX_Marshal 

func (m *SlaveRejected) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SlaveRejected) XXX_Merge 

func (m *SlaveRejected) XXX_Merge(src proto.Message)

func (*SlaveRejected) XXX_Size 

func (m *SlaveRejected) XXX_Size() int

func (*SlaveRejected) XXX_Unmarshal 

func (m *SlaveRejected) XXX_Unmarshal(b []byte) error

type SlaveUpdate 

type SlaveUpdate struct {
	Sender           *actor.PID `protobuf:"bytes,1,opt,name=Sender,proto3" json:"Sender,omitempty"`
	InteractionCount int64      `protobuf:"varint,2,opt,name=InteractionCount,proto3" json:"InteractionCount,omitempty"`
}

SlaveUpdate is an intermediate update message from a slave to the master during load testing.

func (*SlaveUpdate) Descriptor 

func (*SlaveUpdate) Descriptor() ([]byte, []int)

func (*SlaveUpdate) Equal 

func (this *SlaveUpdate) Equal(that interface{}) bool

func (*SlaveUpdate) GetInteractionCount 

func (m *SlaveUpdate) GetInteractionCount() int64

func (*SlaveUpdate) GetSender 

func (m *SlaveUpdate) GetSender() *actor.PID

func (*SlaveUpdate) GoString 

func (this *SlaveUpdate) GoString() string

func (*SlaveUpdate) Marshal 

func (m *SlaveUpdate) Marshal() (dAtA []byte, err error)

func (*SlaveUpdate) MarshalTo 

func (m *SlaveUpdate) MarshalTo(dAtA []byte) (int, error)

func (*SlaveUpdate) ProtoMessage 

func (*SlaveUpdate) ProtoMessage()

func (*SlaveUpdate) Reset 

func (m *SlaveUpdate) Reset()

func (*SlaveUpdate) Size 

func (m *SlaveUpdate) Size() (n int)

func (*SlaveUpdate) String 

func (this *SlaveUpdate) String() string

func (*SlaveUpdate) Unmarshal 

func (m *SlaveUpdate) Unmarshal(dAtA []byte) error

func (*SlaveUpdate) XXX_DiscardUnknown 

func (m *SlaveUpdate) XXX_DiscardUnknown()

func (*SlaveUpdate) XXX_Marshal 

func (m *SlaveUpdate) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SlaveUpdate) XXX_Merge 

func (m *SlaveUpdate) XXX_Merge(src proto.Message)

func (*SlaveUpdate) XXX_Size 

func (m *SlaveUpdate) XXX_Size() int

func (*SlaveUpdate) XXX_Unmarshal 

func (m *SlaveUpdate) XXX_Unmarshal(b []byte) error

type StartLoadTest 

type StartLoadTest struct {
	Sender *actor.PID `protobuf:"bytes,1,opt,name=Sender,proto3" json:"Sender,omitempty"`
}

StartLoadTest is sent by the master to the slaves to kick off the testing.

func (*StartLoadTest) Descriptor 

func (*StartLoadTest) Descriptor() ([]byte, []int)

func (*StartLoadTest) Equal 

func (this *StartLoadTest) Equal(that interface{}) bool

func (*StartLoadTest) GetSender 

func (m *StartLoadTest) GetSender() *actor.PID

func (*StartLoadTest) GoString 

func (this *StartLoadTest) GoString() string

func (*StartLoadTest) Marshal 

func (m *StartLoadTest) Marshal() (dAtA []byte, err error)

func (*StartLoadTest) MarshalTo 

func (m *StartLoadTest) MarshalTo(dAtA []byte) (int, error)

func (*StartLoadTest) ProtoMessage 

func (*StartLoadTest) ProtoMessage()

func (*StartLoadTest) Reset 

func (m *StartLoadTest) Reset()

func (*StartLoadTest) Size 

func (m *StartLoadTest) Size() (n int)

func (*StartLoadTest) String 

func (this *StartLoadTest) String() string

func (*StartLoadTest) Unmarshal 

func (m *StartLoadTest) Unmarshal(dAtA []byte) error

func (*StartLoadTest) XXX_DiscardUnknown 

func (m *StartLoadTest) XXX_DiscardUnknown()

func (*StartLoadTest) XXX_Marshal 

func (m *StartLoadTest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartLoadTest) XXX_Merge 

func (m *StartLoadTest) XXX_Merge(src proto.Message)

func (*StartLoadTest) XXX_Size 

func (m *StartLoadTest) XXX_Size() int

func (*StartLoadTest) XXX_Unmarshal 

func (m *StartLoadTest) XXX_Unmarshal(b []byte) error

type SummaryStats 

type SummaryStats struct {
	Count        int64 `protobuf:"varint,1,opt,name=Count,proto3" json:"Count,omitempty"`
	Errors       int64 `protobuf:"varint,2,opt,name=Errors,proto3" json:"Errors,omitempty"`
	TotalTime    int64 `protobuf:"varint,3,opt,name=TotalTime,proto3" json:"TotalTime,omitempty"`
	MinTime      int64 `protobuf:"varint,4,opt,name=MinTime,proto3" json:"MinTime,omitempty"`
	MaxTime      int64 `protobuf:"varint,5,opt,name=MaxTime,proto3" json:"MaxTime,omitempty"`
	TotalClients int64 `protobuf:"varint,6,opt,name=TotalClients,proto3" json:"TotalClients,omitempty"`
	// For keeping track of the different kinds of errors that occurred, as well
	// as the number of times each error occurred.
	ErrorsByType map[string]int64 `` /* 166-byte string literal not displayed */
	// Allows us to plot a summary picture of the range of response times during
	// our interactions/requests.
	ResponseTimes *ResponseTimeHistogram `protobuf:"bytes,8,opt,name=ResponseTimes,proto3" json:"ResponseTimes,omitempty"`
}

SummaryStats is a collection of statistics across a number of interactions or requests.

func (*SummaryStats) Descriptor 

func (*SummaryStats) Descriptor() ([]byte, []int)

func (*SummaryStats) Equal 

func (this *SummaryStats) Equal(that interface{}) bool

func (*SummaryStats) GetCount 

func (m *SummaryStats) GetCount() int64

func (*SummaryStats) GetErrors 

func (m *SummaryStats) GetErrors() int64

func (*SummaryStats) GetErrorsByType 

func (m *SummaryStats) GetErrorsByType() map[string]int64

func (*SummaryStats) GetMaxTime 

func (m *SummaryStats) GetMaxTime() int64

func (*SummaryStats) GetMinTime 

func (m *SummaryStats) GetMinTime() int64

func (*SummaryStats) GetResponseTimes 

func (m *SummaryStats) GetResponseTimes() *ResponseTimeHistogram

func (*SummaryStats) GetTotalClients 

func (m *SummaryStats) GetTotalClients() int64

func (*SummaryStats) GetTotalTime 

func (m *SummaryStats) GetTotalTime() int64

func (*SummaryStats) GoString 

func (this *SummaryStats) GoString() string

func (*SummaryStats) Marshal 

func (m *SummaryStats) Marshal() (dAtA []byte, err error)

func (*SummaryStats) MarshalTo 

func (m *SummaryStats) MarshalTo(dAtA []byte) (int, error)

func (*SummaryStats) ProtoMessage 

func (*SummaryStats) ProtoMessage()

func (*SummaryStats) Reset 

func (m *SummaryStats) Reset()

func (*SummaryStats) Size 

func (m *SummaryStats) Size() (n int)

func (*SummaryStats) String 

func (this *SummaryStats) String() string

func (*SummaryStats) Unmarshal 

func (m *SummaryStats) Unmarshal(dAtA []byte) error

func (*SummaryStats) XXX_DiscardUnknown 

func (m *SummaryStats) XXX_DiscardUnknown()

func (*SummaryStats) XXX_Marshal 

func (m *SummaryStats) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SummaryStats) XXX_Merge 

func (m *SummaryStats) XXX_Merge(src proto.Message)

func (*SummaryStats) XXX_Size 

func (m *SummaryStats) XXX_Size() int

func (*SummaryStats) XXX_Unmarshal 

func (m *SummaryStats) XXX_Unmarshal(b []byte) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.