model

package
v0.5.0 Latest Latest
Warning

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

 Go to latest Published: Apr 16, 2020 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

View Source 
const CheckerPort = 6000

CheckerPort is the model checker port

View Source 
const DataPath = "/etc/model-checker/data"

DataPath is the path to which model data is stored

View Source 
const ModelsPath = "/etc/model-checker/models"

ModelsPath is the path to which models are stored

Variables

View Source 
var (
	ErrInvalidLengthModel        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowModel          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupModel = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ModelCheckerState_name = map[int32]string{
	0: "RUNNING",
	1: "PASSED",
	2: "FAILED",
}
View Source 
var ModelCheckerState_value = map[string]int32{
	"RUNNING": 0,
	"PASSED":  1,
	"FAILED":  2,
}

Functions

func RegisterModelCheckerServiceServer 

func RegisterModelCheckerServiceServer(s *grpc.Server, srv ModelCheckerServiceServer)

Types

type Checker 

type Checker interface {
	// CheckModel checks the given model against the given traces
	CheckModel(model *Model, traces []*Trace) error
}

Checker is a model checker

func NewChecker 

func NewChecker() (Checker, error)

NewChecker gets a model checker client

type Model 

type Model struct {
	// Name is the name of the model
	Name string
	// contains filtered or unexported fields
}

Model is a model to check

func NewModel 

func NewModel(name string) *Model

NewModel gets a new model

type ModelCheckRequest 

type ModelCheckRequest struct {
	// model is the model to check
	Model string `protobuf:"bytes,1,opt,name=model,proto3" json:"model,omitempty"`
	// trace is the trace to check
	Trace string `protobuf:"bytes,2,opt,name=trace,proto3" json:"trace,omitempty"`
	// timeout is the model checker timeout
	Timeout *types.Duration `protobuf:"bytes,3,opt,name=timeout,proto3" json:"timeout,omitempty"`
}

ModelCheckRequest is a model check request

func (*ModelCheckRequest) Descriptor 

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

func (*ModelCheckRequest) GetModel 

func (m *ModelCheckRequest) GetModel() string

func (*ModelCheckRequest) GetTimeout 

func (m *ModelCheckRequest) GetTimeout() *types.Duration

func (*ModelCheckRequest) GetTrace 

func (m *ModelCheckRequest) GetTrace() string

func (*ModelCheckRequest) Marshal 

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

func (*ModelCheckRequest) MarshalTo 

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

func (*ModelCheckRequest) MarshalToSizedBuffer 

func (m *ModelCheckRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ModelCheckRequest) ProtoMessage 

func (*ModelCheckRequest) ProtoMessage()

func (*ModelCheckRequest) Reset 

func (m *ModelCheckRequest) Reset()

func (*ModelCheckRequest) Size 

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

func (*ModelCheckRequest) String 

func (m *ModelCheckRequest) String() string

func (*ModelCheckRequest) Unmarshal 

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

func (*ModelCheckRequest) XXX_DiscardUnknown 

func (m *ModelCheckRequest) XXX_DiscardUnknown()

func (*ModelCheckRequest) XXX_Marshal 

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

func (*ModelCheckRequest) XXX_Merge 

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

func (*ModelCheckRequest) XXX_Size 

func (m *ModelCheckRequest) XXX_Size() int

func (*ModelCheckRequest) XXX_Unmarshal 

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

type ModelCheckResponse 

type ModelCheckResponse struct {
	// state is the model checker state
	State ModelCheckerState `protobuf:"varint,1,opt,name=state,proto3,enum=onos.test.model.ModelCheckerState" json:"state,omitempty"`
	// message is the model checker message
	Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
}

ModelCheckResponse is a model check response

func (*ModelCheckResponse) Descriptor 

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

func (*ModelCheckResponse) GetMessage 

func (m *ModelCheckResponse) GetMessage() string

func (*ModelCheckResponse) GetState 

func (m *ModelCheckResponse) GetState() ModelCheckerState

func (*ModelCheckResponse) Marshal 

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

func (*ModelCheckResponse) MarshalTo 

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

func (*ModelCheckResponse) MarshalToSizedBuffer 

func (m *ModelCheckResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ModelCheckResponse) ProtoMessage 

func (*ModelCheckResponse) ProtoMessage()

func (*ModelCheckResponse) Reset 

func (m *ModelCheckResponse) Reset()

func (*ModelCheckResponse) Size 

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

func (*ModelCheckResponse) String 

func (m *ModelCheckResponse) String() string

func (*ModelCheckResponse) Unmarshal 

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

func (*ModelCheckResponse) XXX_DiscardUnknown 

func (m *ModelCheckResponse) XXX_DiscardUnknown()

func (*ModelCheckResponse) XXX_Marshal 

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

func (*ModelCheckResponse) XXX_Merge 

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

func (*ModelCheckResponse) XXX_Size 

func (m *ModelCheckResponse) XXX_Size() int

func (*ModelCheckResponse) XXX_Unmarshal 

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

type ModelCheckerServiceClient 

type ModelCheckerServiceClient interface {
	CheckModel(ctx context.Context, in *ModelCheckRequest, opts ...grpc.CallOption) (ModelCheckerService_CheckModelClient, error)
}

ModelCheckerServiceClient is the client API for ModelCheckerService service.

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

func NewModelCheckerServiceClient 

func NewModelCheckerServiceClient(cc *grpc.ClientConn) ModelCheckerServiceClient

type ModelCheckerServiceServer 

type ModelCheckerServiceServer interface {
	CheckModel(*ModelCheckRequest, ModelCheckerService_CheckModelServer) error
}

ModelCheckerServiceServer is the server API for ModelCheckerService service.

type ModelCheckerService_CheckModelClient 

type ModelCheckerService_CheckModelClient interface {
	Recv() (*ModelCheckResponse, error)
	grpc.ClientStream
}

type ModelCheckerService_CheckModelServer 

type ModelCheckerService_CheckModelServer interface {
	Send(*ModelCheckResponse) error
	grpc.ServerStream
}

type ModelCheckerState 

type ModelCheckerState int32

ModelCheckState is the state if a model check 

const (
	ModelCheckerState_RUNNING ModelCheckerState = 0
	ModelCheckerState_PASSED  ModelCheckerState = 1
	ModelCheckerState_FAILED  ModelCheckerState = 2
)

func (ModelCheckerState) EnumDescriptor 

func (ModelCheckerState) EnumDescriptor() ([]byte, []int)

func (ModelCheckerState) String 

func (x ModelCheckerState) String() string

type Service 

type Service struct {
}

Service is a model checker service

func NewService 

func NewService() *Service

NewService returns a new model checker service

func (*Service) Start 

func (s *Service) Start() error

Start starts the server

type Trace 

type Trace struct {
	// bytes is the trace bytes
	Bytes []byte `protobuf:"bytes,1,opt,name=bytes,proto3" json:"bytes,omitempty"`
}

Trace is a trace entry

func NewTrace 

func NewTrace(object interface{}) (*Trace, error)

NewTrace returns a new model trace for the given object

func NewTraceFields 

func NewTraceFields(fieldsAndValues ...interface{}) (*Trace, error)

NewTraceFields returns a new model Trace for the given fields and values

func NewTraceValues 

func NewTraceValues(values ...interface{}) (*Trace, error)

NewTraceValues returns a new model Trace from the given values

func (*Trace) Descriptor 

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

func (*Trace) GetBytes 

func (m *Trace) GetBytes() []byte

func (*Trace) Marshal 

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

func (*Trace) MarshalTo 

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

func (*Trace) MarshalToSizedBuffer 

func (m *Trace) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Trace) ProtoMessage 

func (*Trace) ProtoMessage()

func (*Trace) Reset 

func (m *Trace) Reset()

func (*Trace) Size 

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

func (*Trace) String 

func (m *Trace) String() string

func (*Trace) Unmarshal 

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

func (*Trace) XXX_DiscardUnknown 

func (m *Trace) XXX_DiscardUnknown()

func (*Trace) XXX_Marshal 

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

func (*Trace) XXX_Merge 

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

func (*Trace) XXX_Size 

func (m *Trace) XXX_Size() int

func (*Trace) XXX_Unmarshal 

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

type UnimplementedModelCheckerServiceServer 

type UnimplementedModelCheckerServiceServer struct {
}

UnimplementedModelCheckerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedModelCheckerServiceServer) CheckModel 

func (*UnimplementedModelCheckerServiceServer) CheckModel(req *ModelCheckRequest, srv ModelCheckerService_CheckModelServer) 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.