mock_pipelined

Documentation

Index

• Constants
• func AssertIDeleteMacFlow(t *testing.T, pipelined *MockPipelined)
• func AssertIPIXFlowUpdate(t *testing.T, pipelined *MockPipelined)
• func AssertMacFlowInstall(t *testing.T, pipelined *MockPipelined)
• func AssertReceivedApMacAndAddress(t *testing.T, pipelined *MockPipelined, expectedApMac string, ...)
• type Action
• type MockPipelined
  • func NewRunningPipelined(t *testing.T) *MockPipelined
  • func (c *MockPipelined) AddUEMacFlow(ctx context.Context, req *protos.UEMacFlowRequest) (*protos.FlowResponse, error)
  • func (c *MockPipelined) ClearActions()
  • func (c *MockPipelined) DeleteUEMacFlow(ctx context.Context, req *protos.UEMacFlowRequest) (*protos.FlowResponse, error)
  • func (c *MockPipelined) GetLastAction() (*Action, error)
  • func (c *MockPipelined) UpdateIPFIXFlow(ctx context.Context, req *protos.UEMacFlowRequest) (*protos.FlowResponse, error)

Constants

const (
	AddUEMacFlowCommand    = 1
	UpdateIPFIXFlowCommand = 2
	DeleteUEMacFlowCommand = 3
)

Functions

func AssertIDeleteMacFlow

func AssertIDeleteMacFlow(t *testing.T, pipelined *MockPipelined)

func AssertIPIXFlowUpdate

func AssertIPIXFlowUpdate(t *testing.T, pipelined *MockPipelined)

func AssertMacFlowInstall

func AssertMacFlowInstall(t *testing.T, pipelined *MockPipelined)

helper assert functions for testing

func AssertReceivedApMacAndAddress

func AssertReceivedApMacAndAddress(t *testing.T,
	pipelined *MockPipelined, expectedApMac string, expectedApName string)

Types

type Action

type Action struct {
	Request         *protos.UEMacFlowRequest
	ExecutedCommand int
	Response        *protos.FlowResponse
	Err             error
}

records all the requests, responses and errors done to the client

type MockPipelined

type MockPipelined struct {
	*protos.UnimplementedPipelinedServer
	Actions []*Action
}

SessionManager test sessiond implementation

func NewRunningPipelined

func NewRunningPipelined(t *testing.T) *MockPipelined

func (*MockPipelined) AddUEMacFlow

func (c *MockPipelined) AddUEMacFlow(ctx context.Context, req *protos.UEMacFlowRequest) (*protos.FlowResponse, error)

func (*MockPipelined) ClearActions

func (c *MockPipelined) ClearActions()

func (*MockPipelined) DeleteUEMacFlow

func (c *MockPipelined) DeleteUEMacFlow(ctx context.Context, req *protos.UEMacFlowRequest) (*protos.FlowResponse, error)

func (*MockPipelined) GetLastAction

func (c *MockPipelined) GetLastAction() (*Action, error)

func (*MockPipelined) UpdateIPFIXFlow

func (c *MockPipelined) UpdateIPFIXFlow(ctx context.Context, req *protos.UEMacFlowRequest) (*protos.FlowResponse, error)