atprotocol.go

package addresstranslator

import (
	"gitlab.com/akita/akita"
)

// An AddressTranslatorFlushReq asks the AT to clear its ports and any buffers.
// It will also not block all incoming and outgoing ports
type AddressTranslatorFlushReq struct {
	akita.MsgMeta
}

// Meta returns the meta data associated with the message.
func (r *AddressTranslatorFlushReq) Meta() *akita.MsgMeta {
	return &r.MsgMeta
}

// AddressTranslatorFlushReqBuilder can build AT flush requests
type AddressTranslatorFlushReqBuilder struct {
	sendTime akita.VTimeInSec
	src, dst akita.Port
}

// WithSendTime sets the send time of the request to build.:w
func (b AddressTranslatorFlushReqBuilder) WithSendTime(
	t akita.VTimeInSec,
) AddressTranslatorFlushReqBuilder {
	b.sendTime = t
	return b
}

// WithSrc sets the source of the request to build.
func (b AddressTranslatorFlushReqBuilder) WithSrc(src akita.Port) AddressTranslatorFlushReqBuilder {
	b.src = src
	return b
}

// WithDst sets the destination of the request to build.
func (b AddressTranslatorFlushReqBuilder) WithDst(dst akita.Port) AddressTranslatorFlushReqBuilder {
	b.dst = dst
	return b
}

// Build creats a new AddressTranslatorFlushReq
func (b AddressTranslatorFlushReqBuilder) Build() *AddressTranslatorFlushReq {
	r := &AddressTranslatorFlushReq{}
	r.ID = akita.GetIDGenerator().Generate()
	r.Src = b.src
	r.Dst = b.dst
	r.SendTime = b.sendTime

	return r
}

// A AddressTranslatorFlushRsp is a response from AT indicating flush is complete
type AddressTranslatorFlushRsp struct {
	akita.MsgMeta
}

// Meta returns the meta data associated with the message.
func (r *AddressTranslatorFlushRsp) Meta() *akita.MsgMeta {
	return &r.MsgMeta
}

// AddressTranslatorFlushRspBuilder can build AT flush rsp
type AddressTranslatorFlushRspBuilder struct {
	sendTime akita.VTimeInSec
	src, dst akita.Port
}