devices

Documentation

Index

• func ApiConnect(ip string, port string) (bbsim.BBSimClient, *grpc.ClientConn)
• func Connect(ip string, port string) (openolt.OpenoltClient, *grpc.ClientConn)
• func ValidateAndClose(olt *OltMock)
• type MockStream
  • func (*MockStream) Context() context.Context
  • func (*MockStream) Send(ind *openolt.Indication) error
• type OltMock
  • func (o *OltMock) Start()

Functions

func ApiConnect

func ApiConnect(ip string, port string) (bbsim.BBSimClient, *grpc.ClientConn)

func Connect

func Connect(ip string, port string) (openolt.OpenoltClient, *grpc.ClientConn)

TODO Move in a different file

func ValidateAndClose

func ValidateAndClose(olt *OltMock)

Types

type MockStream

type MockStream struct {
	grpc.ServerStream
}

func (*MockStream) Context

func (*MockStream) Context() context.Context

func (*MockStream) Send

func (*MockStream) Send(ind *openolt.Indication) error

type OltMock

type OltMock struct {
	LastUsedOnuId map[uint32]uint32
	Olt           *devices.OltDevice
	BBSimIp       string
	BBSimPort     string
	BBSimApiPort  string

	Client *openolt.OpenoltClient

	TargetOnus    int
	CompletedOnus int // Number of ONUs that have received a DHCPAck
	// contains filtered or unexported fields
}

func (*OltMock) Start

func (o *OltMock) Start()

trigger an enable call and start the same listeners on the gRPC stream that VOLTHA would create this method is blocking