event

package

v1.1.6 Latest Latest Go to latest Published: Jan 14, 2025 License: BSD-3-Clause Imports: 14 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/taubyte/tau

Documentation ¶

Index ¶

type Event
- func (e *Event) TypeU64() uint32
type Factory
- func New(i vm.Instance, helper helpers.Methods) *Factory
type P2PData

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Event ¶

type Event struct {
	Id   uint32
	Type common.EventType
	// contains filtered or unexported fields
}

func (*Event) TypeU64 ¶

func (e *Event) TypeU64() uint32

type Factory ¶

type Factory struct {
	helpers.Methods
	// contains filtered or unexported fields
}

func New ¶

func New(i vm.Instance, helper helpers.Methods) *Factory

func (*Factory) AttachEvent ¶

func (f *Factory) AttachEvent(e *Event)

func (*Factory) Close ¶

func (f *Factory) Close() error

func (*Factory) CreateHttpEvent ¶

func (f *Factory) CreateHttpEvent(w http.ResponseWriter, r *http.Request) *Event

func (*Factory) CreateP2PEvent ¶

func (f *Factory) CreateP2PEvent(cmd *command.Command, response res.Response) *Event

func (*Factory) CreatePubsubEvent ¶

func (f *Factory) CreatePubsubEvent(msg *pubsub.Message) *Event

func (*Factory) Load ¶

func (f *Factory) Load(hm vm.HostModule) error

func (*Factory) Name ¶

func (f *Factory) Name() string

func (*Factory) W_closeHttpEventBody ¶

func (f *Factory) W_closeHttpEventBody(ctx context.Context, module common.Module, eventId uint32) errno.Error

func (*Factory) W_eventHttpFlush ¶

func (f *Factory) W_eventHttpFlush(ctx context.Context, module common.Module, eventId uint32) (err errno.Error)

func (*Factory) W_eventHttpHeaderAdd ¶

func (f *Factory) W_eventHttpHeaderAdd(ctx context.Context, module common.Module, eventId uint32, keyPtr uint32, keyLen uint32, valPtr uint32, valLen uint32) errno.Error

func (*Factory) W_eventHttpRedirect ¶

func (f *Factory) W_eventHttpRedirect(ctx context.Context, module common.Module, eventId uint32, urlPtr uint32, urlLen uint32, code uint32) (err errno.Error)

func (*Factory) W_eventHttpRetCode ¶

func (f *Factory) W_eventHttpRetCode(ctx context.Context, module common.Module, eventId uint32, code uint32) errno.Error

func (*Factory) W_eventHttpWrite ¶

func (f *Factory) W_eventHttpWrite(ctx context.Context, module common.Module, eventId, bufPtr, bufSize, wroteN uint32) (err errno.Error)

func (*Factory) W_getEventType ¶

func (f *Factory) W_getEventType(ctx context.Context, module vmCommon.Module, eventId uint32, typeIdPtr uint32)

func (*Factory) W_getHttpEventHeaders ¶

func (f *Factory) W_getHttpEventHeaders(ctx context.Context, module common.Module, eventId uint32, keyPtr uint32, keyLen uint32, bufPtr uint32, bufSize uint32) errno.Error

func (*Factory) W_getHttpEventHeadersSize ¶

func (f *Factory) W_getHttpEventHeadersSize(ctx context.Context, module common.Module, eventId uint32, sizePtr uint32, keyPtr uint32, keyLen uint32) errno.Error

func (*Factory) W_getHttpEventHost ¶

func (f *Factory) W_getHttpEventHost(ctx context.Context, module common.Module, eventId uint32, bufPtr uint32, bufSize uint32) errno.Error

func (*Factory) W_getHttpEventHostSize ¶

func (f *Factory) W_getHttpEventHostSize(ctx context.Context, module common.Module, eventId uint32, sizePtr uint32) errno.Error

func (*Factory) W_getHttpEventMethod ¶

func (f *Factory) W_getHttpEventMethod(ctx context.Context, module common.Module, eventId uint32, bufPtr uint32, bufSize uint32) errno.Error

func (*Factory) W_getHttpEventMethodSize ¶

func (f *Factory) W_getHttpEventMethodSize(ctx context.Context, module common.Module, eventId uint32, sizePtr uint32) errno.Error

func (*Factory) W_getHttpEventPath ¶

func (f *Factory) W_getHttpEventPath(ctx context.Context, module common.Module, eventId uint32, bufPtr uint32, bufSize uint32) errno.Error

func (*Factory) W_getHttpEventPathSize ¶

func (f *Factory) W_getHttpEventPathSize(ctx context.Context, module common.Module, eventId uint32, sizePtr uint32) errno.Error

func (*Factory) W_getHttpEventQueryValueByName ¶

func (f *Factory) W_getHttpEventQueryValueByName(ctx context.Context, module common.Module, eventId uint32, keyPtr uint32, keyLen uint32, bufPtr uint32, bufSize uint32) errno.Error

func (*Factory) W_getHttpEventQueryValueByNameSize ¶

func (f *Factory) W_getHttpEventQueryValueByNameSize(ctx context.Context, module common.Module, eventId uint32, sizePtr uint32, keyPtr uint32, keyLen uint32) errno.Error

func (*Factory) W_getHttpEventRequestHeaderKeys ¶

func (f *Factory) W_getHttpEventRequestHeaderKeys(ctx context.Context, module common.Module, eventId uint32, bufPtr uint32, keyIdx uint32) errno.Error

func (*Factory) W_getHttpEventRequestHeaderKeysSize ¶

func (f *Factory) W_getHttpEventRequestHeaderKeysSize(ctx context.Context, module common.Module, eventId uint32, sizePtr uint32) errno.Error

func (*Factory) W_getHttpEventRequestQueryKeys ¶

func (f *Factory) W_getHttpEventRequestQueryKeys(ctx context.Context, module common.Module, eventId uint32, bufPtr uint32) errno.Error

func (*Factory) W_getHttpEventRequestQueryKeysSize ¶

func (f *Factory) W_getHttpEventRequestQueryKeysSize(ctx context.Context, module common.Module, eventId uint32, sizePtr uint32) errno.Error

func (*Factory) W_getHttpEventUserAgent ¶

func (f *Factory) W_getHttpEventUserAgent(ctx context.Context, module common.Module, eventId uint32, bufPtr uint32, bufSize uint32) errno.Error

func (*Factory) W_getHttpEventUserAgentSize ¶

func (f *Factory) W_getHttpEventUserAgentSize(ctx context.Context, module common.Module, eventId uint32, sizePtr uint32) errno.Error

func (*Factory) W_getMessageChannel ¶

func (f *Factory) W_getMessageChannel(ctx context.Context, module common.Module, eventId, channelPtr uint32) errno.Error

func (*Factory) W_getMessageChannelSize ¶

func (f *Factory) W_getMessageChannelSize(ctx context.Context, module common.Module, eventId, sizePtr uint32) errno.Error

func (*Factory) W_getMessageData ¶

func (f *Factory) W_getMessageData(ctx context.Context, module common.Module, eventId uint32, bufPtr uint32) errno.Error

func (*Factory) W_getMessageDataSize ¶

func (f *Factory) W_getMessageDataSize(ctx context.Context, module common.Module, eventId uint32, sizePtr uint32) errno.Error

func (*Factory) W_getP2PEventCommand ¶

func (f *Factory) W_getP2PEventCommand(ctx context.Context, module common.Module, eventId, dataPtr uint32) errno.Error

func (*Factory) W_getP2PEventCommandSize ¶

func (f *Factory) W_getP2PEventCommandSize(ctx context.Context, module common.Module, eventId, sizePtr uint32) errno.Error

func (*Factory) W_getP2PEventData ¶

func (f *Factory) W_getP2PEventData(ctx context.Context, module common.Module, eventId uint32, bufPtr uint32) errno.Error

func (*Factory) W_getP2PEventDataSize ¶

func (f *Factory) W_getP2PEventDataSize(ctx context.Context, module common.Module, eventId uint32, sizePtr uint32) errno.Error

func (*Factory) W_getP2PEventFrom ¶

func (f *Factory) W_getP2PEventFrom(ctx context.Context, module common.Module, eventId, cidPtr uint32) errno.Error

func (*Factory) W_getP2PEventProtocol ¶

func (f *Factory) W_getP2PEventProtocol(ctx context.Context, module common.Module, eventId, dataPtr uint32) errno.Error

func (*Factory) W_getP2PEventProtocolSize ¶

func (f *Factory) W_getP2PEventProtocolSize(ctx context.Context, module common.Module, eventId, sizePtr uint32) errno.Error

func (*Factory) W_getP2PEventTo ¶

func (f *Factory) W_getP2PEventTo(ctx context.Context, module common.Module, eventId, cidPtr uint32) errno.Error

func (*Factory) W_readHttpEventBody ¶

func (f *Factory) W_readHttpEventBody(ctx context.Context, module common.Module, eventId uint32, bufPtr uint32, bufSize uint32, countPtr uint32) (err errno.Error)

func (*Factory) W_writeP2PResponse ¶

func (f *Factory) W_writeP2PResponse(ctx context.Context, module common.Module, eventId, bufPtr, bufSize uint32) (err errno.Error)

type P2PData ¶

type P2PData struct {
	// contains filtered or unexported fields
}

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL

Documentation ¶

Index ¶

Constants ¶

Variables ¶

Functions ¶

Types ¶

type Event ¶

func (*Event) TypeU64 ¶

type Factory ¶

func New ¶

func (*Factory) AttachEvent ¶

func (*Factory) Close ¶

func (*Factory) CreateHttpEvent ¶

func (*Factory) CreateP2PEvent ¶

func (*Factory) CreatePubsubEvent ¶

func (*Factory) Load ¶

func (*Factory) Name ¶

func (*Factory) W_closeHttpEventBody ¶

func (*Factory) W_eventHttpFlush ¶

func (*Factory) W_eventHttpHeaderAdd ¶

func (*Factory) W_eventHttpRedirect ¶

func (*Factory) W_eventHttpRetCode ¶

func (*Factory) W_eventHttpWrite ¶

func (*Factory) W_getEventType ¶

func (*Factory) W_getHttpEventHeaders ¶

func (*Factory) W_getHttpEventHeadersSize ¶

func (*Factory) W_getHttpEventHost ¶

func (*Factory) W_getHttpEventHostSize ¶

func (*Factory) W_getHttpEventMethod ¶

func (*Factory) W_getHttpEventMethodSize ¶

func (*Factory) W_getHttpEventPath ¶

func (*Factory) W_getHttpEventPathSize ¶

func (*Factory) W_getHttpEventQueryValueByName ¶

func (*Factory) W_getHttpEventQueryValueByNameSize ¶

func (*Factory) W_getHttpEventRequestHeaderKeys ¶

func (*Factory) W_getHttpEventRequestHeaderKeysSize ¶

func (*Factory) W_getHttpEventRequestQueryKeys ¶

func (*Factory) W_getHttpEventRequestQueryKeysSize ¶

func (*Factory) W_getHttpEventUserAgent ¶

func (*Factory) W_getHttpEventUserAgentSize ¶

func (*Factory) W_getMessageChannel ¶

func (*Factory) W_getMessageChannelSize ¶

func (*Factory) W_getMessageData ¶

func (*Factory) W_getMessageDataSize ¶

func (*Factory) W_getP2PEventCommand ¶

func (*Factory) W_getP2PEventCommandSize ¶

func (*Factory) W_getP2PEventData ¶

func (*Factory) W_getP2PEventDataSize ¶

func (*Factory) W_getP2PEventFrom ¶

func (*Factory) W_getP2PEventProtocol ¶

func (*Factory) W_getP2PEventProtocolSize ¶

func (*Factory) W_getP2PEventTo ¶

func (*Factory) W_readHttpEventBody ¶

func (*Factory) W_writeP2PResponse ¶

type P2PData ¶

Source Files ¶