apatelet

Documentation

Index

• Variables
• func RegisterApateletServer(s *grpc.Server, srv ApateletServer)
• func RegisterScenarioServer(s *grpc.Server, srv ScenarioServer)
• type ApateletClient
  • func NewApateletClient(cc grpc.ClientConnInterface) ApateletClient
• type ApateletScenario
  • func (*ApateletScenario) Descriptor() ([]byte, []int)
  • func (x *ApateletScenario) GetDisableWatchers() bool
  • func (x *ApateletScenario) GetStartTime() int64
  • func (*ApateletScenario) ProtoMessage()
  • func (x *ApateletScenario) ProtoReflect() protoreflect.Message
  • func (x *ApateletScenario) Reset()
  • func (x *ApateletScenario) String() string
• type ApateletServer
• type ScenarioClient
  • func NewScenarioClient(cc grpc.ClientConnInterface) ScenarioClient
• type ScenarioServer
• type UnimplementedApateletServer
  • func (*UnimplementedApateletServer) StopApatelet(context.Context, *empty.Empty) (*empty.Empty, error)
• type UnimplementedScenarioServer
  • func (*UnimplementedScenarioServer) StartScenario(context.Context, *ApateletScenario) (*empty.Empty, error)

Variables

var File_apatelet_apatelet_proto protoreflect.FileDescriptor

var File_apatelet_scenario_proto protoreflect.FileDescriptor

Functions

func RegisterApateletServer

func RegisterApateletServer(s *grpc.Server, srv ApateletServer)

func RegisterScenarioServer

func RegisterScenarioServer(s *grpc.Server, srv ScenarioServer)

Types

type ApateletClient

type ApateletClient interface {
	// This will signal that the apatelet should leave the cluster and stop
	StopApatelet(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*empty.Empty, error)
}

ApateletClient is the client API for Apatelet service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewApateletClient

func NewApateletClient(cc grpc.ClientConnInterface) ApateletClient

type ApateletScenario

type ApateletScenario struct {

	// The absolute timestamp at which the scenario will start
	StartTime int64 `protobuf:"varint,1,opt,name=start_time,json=startTime,proto3" json:"start_time,omitempty"`
	// Whether to disable watchers before starting the scenario.
	// This will reduce the overhead of the informers significantly.
	// Enabling this option will require a restart before the informers will work again
	DisableWatchers bool `protobuf:"varint,2,opt,name=disable_watchers,json=disableWatchers,proto3" json:"disable_watchers,omitempty"`
	// contains filtered or unexported fields
}

The top level object which defines how the different Apatelet will emulate certain deployments

func (*ApateletScenario) Descriptor

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

Deprecated: Use ApateletScenario.ProtoReflect.Descriptor instead.

func (*ApateletScenario) GetDisableWatchers

func (x *ApateletScenario) GetDisableWatchers() bool

func (*ApateletScenario) GetStartTime

func (x *ApateletScenario) GetStartTime() int64

func (*ApateletScenario) ProtoMessage

func (*ApateletScenario) ProtoMessage()

func (*ApateletScenario) ProtoReflect

func (x *ApateletScenario) ProtoReflect() protoreflect.Message

func (*ApateletScenario) Reset

func (x *ApateletScenario) Reset()

func (*ApateletScenario) String

func (x *ApateletScenario) String() string

type ApateletServer

type ApateletServer interface {
	// This will signal that the apatelet should leave the cluster and stop
	StopApatelet(context.Context, *empty.Empty) (*empty.Empty, error)
}

ApateletServer is the server API for Apatelet service.

type ScenarioClient

type ScenarioClient interface {
	// Starts a scenario on the current Apatelet
	// This will be called on every Apatelet
	StartScenario(ctx context.Context, in *ApateletScenario, opts ...grpc.CallOption) (*empty.Empty, error)
}

ScenarioClient is the client API for Scenario service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewScenarioClient

func NewScenarioClient(cc grpc.ClientConnInterface) ScenarioClient

type ScenarioServer

type ScenarioServer interface {
	// Starts a scenario on the current Apatelet
	// This will be called on every Apatelet
	StartScenario(context.Context, *ApateletScenario) (*empty.Empty, error)
}

ScenarioServer is the server API for Scenario service.

type UnimplementedApateletServer

type UnimplementedApateletServer struct {
}

UnimplementedApateletServer can be embedded to have forward compatible implementations.

func (*UnimplementedApateletServer) StopApatelet

func (*UnimplementedApateletServer) StopApatelet(context.Context, *empty.Empty) (*empty.Empty, error)

type UnimplementedScenarioServer

type UnimplementedScenarioServer struct {
}

UnimplementedScenarioServer can be embedded to have forward compatible implementations.

func (*UnimplementedScenarioServer) StartScenario

func (*UnimplementedScenarioServer) StartScenario(context.Context, *ApateletScenario) (*empty.Empty, error)