itransactionstream

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Apr 30, 2024 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	// ITransactionStream interface identifier 97199110-db2e-11d1-a251-0000f805ca53
	TransactionStreamIID = &dcom.IID{Data1: 0x97199110, Data2: 0xdb2e, Data3: 0x11d1, Data4: []byte{0xa2, 0x51, 0x00, 0x00, 0xf8, 0x05, 0xca, 0x53}}
	// Syntax UUID
	TransactionStreamSyntaxUUID = &uuid.UUID{TimeLow: 0x97199110, TimeMid: 0xdb2e, TimeHiAndVersion: 0x11d1, ClockSeqHiAndReserved: 0xa2, ClockSeqLow: 0x51, Node: [6]uint8{0x0, 0x0, 0xf8, 0x5, 0xca, 0x53}}
	// Syntax ID
	TransactionStreamSyntaxV0_0 = &dcerpc.SyntaxID{IfUUID: TransactionStreamSyntaxUUID, IfVersionMajor: 0, IfVersionMinor: 0}
)
View Source 
var (
	// import guard
	GoPackage = "dcom/com"
)

Functions

func NewTransactionStreamServerHandle 

func NewTransactionStreamServerHandle(o TransactionStreamServer) dcerpc.ServerHandle

func RegisterTransactionStreamServer 

func RegisterTransactionStreamServer(conn dcerpc.Conn, o TransactionStreamServer, opts ...dcerpc.Option)

func TransactionStreamServerHandle 

func TransactionStreamServerHandle(ctx context.Context, o TransactionStreamServer, opNum int, r ndr.Reader) (dcerpc.Operation, error)

Types

type GetSeqAndTxViaExportRequest 

type GetSeqAndTxViaExportRequest struct {
	// This: ORPCTHIS structure that is used to send ORPC extension data to the server.
	This *dcom.ORPCThis `idl:"name:This" json:"this"`
	// ulKnownSeq: The caller's CurrentTSN value of the currently active transaction known
	// by the client.
	KnownSeq uint32 `idl:"name:ulKnownSeq" json:"known_seq"`
	// ulcbWhereabouts: The unsigned size, in bytes, of rgbWhereabouts.
	WhereaboutsLength uint32 `idl:"name:ulcbWhereabouts" json:"whereabouts_length"`
	// rgbWhereabouts: The SWhereabouts instance ([MS-DTCO] section 2.2.5.11) of the caller's
	// local DTCO transaction manager implementation.
	Whereabouts []byte `idl:"name:rgbWhereabouts;size_is:(ulcbWhereabouts)" json:"whereabouts"`
}

GetSeqAndTxViaExportRequest structure represents the GetSeqAndTxViaExport operation request

func (*GetSeqAndTxViaExportRequest) MarshalNDR 

func (o *GetSeqAndTxViaExportRequest) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*GetSeqAndTxViaExportRequest) UnmarshalNDR 

func (o *GetSeqAndTxViaExportRequest) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type GetSeqAndTxViaExportResponse 

type GetSeqAndTxViaExportResponse struct {
	// That: ORPCTHAT structure that is used to return ORPC extension data to the client.
	That *dcom.ORPCThat `idl:"name:That" json:"that"`
	// pulCurrentSeq: The TSN of the currently active transaction.
	CurrentSeq uint32 `idl:"name:pulCurrentSeq" json:"current_seq"`
	// pulcbExportCookie: The unsigned size, in bytes, of prgbExportCookie.
	ExportCookieLength uint32 `idl:"name:pulcbExportCookie" json:"export_cookie_length"`
	// prgbExportCookie: An STxInfo of the currently active transaction (as specified in
	// [MS-DTCO] section 2.2.5.10).
	ExportCookie []byte `idl:"name:prgbExportCookie;size_is:(, pulcbExportCookie)" json:"export_cookie"`
	// Return: The GetSeqAndTxViaExport return value.
	Return int32 `idl:"name:Return" json:"return"`
}

GetSeqAndTxViaExportResponse structure represents the GetSeqAndTxViaExport operation response

func (*GetSeqAndTxViaExportResponse) MarshalNDR 

func (o *GetSeqAndTxViaExportResponse) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*GetSeqAndTxViaExportResponse) UnmarshalNDR 

func (o *GetSeqAndTxViaExportResponse) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type GetSeqAndTxViaTransmitterRequest 

type GetSeqAndTxViaTransmitterRequest struct {
	// This: ORPCTHIS structure that is used to send ORPC extension data to the server.
	This *dcom.ORPCThis `idl:"name:This" json:"this"`
	// ulKnownSeq: The caller's CurrentTSN value of the currently active transaction.
	KnownSeq uint32 `idl:"name:ulKnownSeq" json:"known_seq"`
}

GetSeqAndTxViaTransmitterRequest structure represents the GetSeqAndTxViaTransmitter operation request

func (*GetSeqAndTxViaTransmitterRequest) MarshalNDR 

func (o *GetSeqAndTxViaTransmitterRequest) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*GetSeqAndTxViaTransmitterRequest) UnmarshalNDR 

func (o *GetSeqAndTxViaTransmitterRequest) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type GetSeqAndTxViaTransmitterResponse 

type GetSeqAndTxViaTransmitterResponse struct {
	// That: ORPCTHAT structure that is used to return ORPC extension data to the client.
	That *dcom.ORPCThat `idl:"name:That" json:"that"`
	// pulCurrentSeq: The TSN of the currently active transaction.
	CurrentSeq uint32 `idl:"name:pulCurrentSeq" json:"current_seq"`
	// pulcbTransmitterBuffer: The unsigned size, in bytes, of prgbTransmitterBuffer.
	TransmitterBufferLength uint32 `idl:"name:pulcbTransmitterBuffer" json:"transmitter_buffer_length"`
	// prgbTransmitterBuffer: A Propagation_Token of the currently active transaction.
	TransmitterBuffer []byte `idl:"name:prgbTransmitterBuffer;size_is:(, pulcbTransmitterBuffer)" json:"transmitter_buffer"`
	// Return: The GetSeqAndTxViaTransmitter return value.
	Return int32 `idl:"name:Return" json:"return"`
}

GetSeqAndTxViaTransmitterResponse structure represents the GetSeqAndTxViaTransmitter operation response

func (*GetSeqAndTxViaTransmitterResponse) MarshalNDR 

func (o *GetSeqAndTxViaTransmitterResponse) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*GetSeqAndTxViaTransmitterResponse) UnmarshalNDR 

func (o *GetSeqAndTxViaTransmitterResponse) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type GetTxViaExportRequest 

type GetTxViaExportRequest struct {
	// This: ORPCTHIS structure that is used to send ORPC extension data to the server.
	This *dcom.ORPCThis `idl:"name:This" json:"this"`
	// ulRequestSeq: The caller's CurrentTSN value of the currently active transaction.
	RequestSeq uint32 `idl:"name:ulRequestSeq" json:"request_seq"`
	// ulcbWhereabouts: The unsigned size, in bytes, of rgbWhereabouts.
	WhereaboutsLength uint32 `idl:"name:ulcbWhereabouts" json:"whereabouts_length"`
	// rgbWhereabouts: The SWhereabouts instance ([MS-DTCO] section 2.2.5.11) of the caller's
	// local DTCO transaction manager implementation.
	Whereabouts []byte `idl:"name:rgbWhereabouts;size_is:(ulcbWhereabouts)" json:"whereabouts"`
}

GetTxViaExportRequest structure represents the GetTxViaExport operation request

func (*GetTxViaExportRequest) MarshalNDR 

func (o *GetTxViaExportRequest) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*GetTxViaExportRequest) UnmarshalNDR 

func (o *GetTxViaExportRequest) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type GetTxViaExportResponse 

type GetTxViaExportResponse struct {
	// That: ORPCTHAT structure that is used to return ORPC extension data to the client.
	That *dcom.ORPCThat `idl:"name:That" json:"that"`
	// pulcbExportCookie: The unsigned size, in bytes, of prgbExportCookie.
	ExportCookieLength uint32 `idl:"name:pulcbExportCookie" json:"export_cookie_length"`
	// prgbExportCookie: An STxInfo instance of the currently active transaction (as specified
	// in [MS-DTCO] section 2.2.5.10).
	ExportCookie []byte `idl:"name:prgbExportCookie;size_is:(, pulcbExportCookie)" json:"export_cookie"`
	// Return: The GetTxViaExport return value.
	Return int32 `idl:"name:Return" json:"return"`
}

GetTxViaExportResponse structure represents the GetTxViaExport operation response

func (*GetTxViaExportResponse) MarshalNDR 

func (o *GetTxViaExportResponse) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*GetTxViaExportResponse) UnmarshalNDR 

func (o *GetTxViaExportResponse) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type GetTxViaTransmitterRequest 

type GetTxViaTransmitterRequest struct {
	// This: ORPCTHIS structure that is used to send ORPC extension data to the server.
	This *dcom.ORPCThis `idl:"name:This" json:"this"`
	// ulRequestSeq: The caller's TSN of the currently active transaction.
	RequestSeq uint32 `idl:"name:ulRequestSeq" json:"request_seq"`
}

GetTxViaTransmitterRequest structure represents the GetTxViaTransmitter operation request

func (*GetTxViaTransmitterRequest) MarshalNDR 

func (o *GetTxViaTransmitterRequest) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*GetTxViaTransmitterRequest) UnmarshalNDR 

func (o *GetTxViaTransmitterRequest) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type GetTxViaTransmitterResponse 

type GetTxViaTransmitterResponse struct {
	// That: ORPCTHAT structure that is used to return ORPC extension data to the client.
	That *dcom.ORPCThat `idl:"name:That" json:"that"`
	// pulcbTransmitterBuffer: The unsigned size, in bytes, of prgbTransmitterBuffer.
	TransmitterBufferLength uint32 `idl:"name:pulcbTransmitterBuffer" json:"transmitter_buffer_length"`
	// prgbTransmitterBuffer: A Propagation_Token of the currently active transaction.
	TransmitterBuffer []byte `idl:"name:prgbTransmitterBuffer;size_is:(, pulcbTransmitterBuffer)" json:"transmitter_buffer"`
	// Return: The GetTxViaTransmitter return value.
	Return int32 `idl:"name:Return" json:"return"`
}

GetTxViaTransmitterResponse structure represents the GetTxViaTransmitter operation response

func (*GetTxViaTransmitterResponse) MarshalNDR 

func (o *GetTxViaTransmitterResponse) MarshalNDR(ctx context.Context, w ndr.Writer) error

func (*GetTxViaTransmitterResponse) UnmarshalNDR 

func (o *GetTxViaTransmitterResponse) UnmarshalNDR(ctx context.Context, r ndr.Reader) error

type TransactionStreamClient 

type TransactionStreamClient interface {

	// IUnknown retrieval method.
	Unknown() iunknown.UnknownClient

	// This method returns the STxInfo ([MS-DTCO] section 2.2.5.10) of the currently active
	// transaction and the CurrentTSN value.
	//
	// Return Values: The method MUST return a positive value or zero, to indicate successful
	// completion, or a negative value to indicate failure. The client MUST treat any negative
	// return value as a fatal error.
	GetSeqAndTxViaExport(context.Context, *GetSeqAndTxViaExportRequest, ...dcerpc.CallOption) (*GetSeqAndTxViaExportResponse, error)

	// This method returns the Propagation_Token (as specified in [MS-DTCO] section 2.2.5.4)
	// of the currently active transaction and the CurrentTSN value.
	//
	// Return Values: The method MUST return a positive value or zero, to indicate successful
	// completion, or a negative value to indicate failure. The client MUST treat any negative
	// return value as a fatal error.
	GetSeqAndTxViaTransmitter(context.Context, *GetSeqAndTxViaTransmitterRequest, ...dcerpc.CallOption) (*GetSeqAndTxViaTransmitterResponse, error)

	// This method returns the STxInfo instance (as specified in [MS-DTCO] section 2.2.5.10)
	// of the currently active transaction or returns an error if the specified TSN is not
	// the same as the CurrentTSN value.
	//
	// Return Values: The method MUST return a positive value or zero to indicate successful
	// completion, or a negative value to indicate failure. The client MUST treat any negative
	// return value as a fatal error.
	GetTxViaExport(context.Context, *GetTxViaExportRequest, ...dcerpc.CallOption) (*GetTxViaExportResponse, error)

	// This method returns the Propagation_Token ([MS-DTCO] section 2.2.5.4) of the currently
	// active transaction, or returns an error if the specified TSN is not the same as the
	// CurrentTSN value.
	//
	// Return Values: The method MUST return a positive value or zero to indicate successful
	// completion, or a negative value to indicate failure. The client MUST treat any negative
	// return value as a fatal error.
	GetTxViaTransmitter(context.Context, *GetTxViaTransmitterRequest, ...dcerpc.CallOption) (*GetTxViaTransmitterResponse, error)

	// AlterContext alters the client context.
	AlterContext(context.Context, ...dcerpc.Option) error

	// IPID sets the object interface identifier.
	IPID(context.Context, *dcom.IPID) TransactionStreamClient
}

ITransactionStream interface.

func NewTransactionStreamClient 

func NewTransactionStreamClient(ctx context.Context, cc dcerpc.Conn, opts ...dcerpc.Option) (TransactionStreamClient, error)

type TransactionStreamServer 

type TransactionStreamServer interface {

	// IUnknown base class.
	iunknown.UnknownServer

	// This method returns the STxInfo ([MS-DTCO] section 2.2.5.10) of the currently active
	// transaction and the CurrentTSN value.
	//
	// Return Values: The method MUST return a positive value or zero, to indicate successful
	// completion, or a negative value to indicate failure. The client MUST treat any negative
	// return value as a fatal error.
	GetSeqAndTxViaExport(context.Context, *GetSeqAndTxViaExportRequest) (*GetSeqAndTxViaExportResponse, error)

	// This method returns the Propagation_Token (as specified in [MS-DTCO] section 2.2.5.4)
	// of the currently active transaction and the CurrentTSN value.
	//
	// Return Values: The method MUST return a positive value or zero, to indicate successful
	// completion, or a negative value to indicate failure. The client MUST treat any negative
	// return value as a fatal error.
	GetSeqAndTxViaTransmitter(context.Context, *GetSeqAndTxViaTransmitterRequest) (*GetSeqAndTxViaTransmitterResponse, error)

	// This method returns the STxInfo instance (as specified in [MS-DTCO] section 2.2.5.10)
	// of the currently active transaction or returns an error if the specified TSN is not
	// the same as the CurrentTSN value.
	//
	// Return Values: The method MUST return a positive value or zero to indicate successful
	// completion, or a negative value to indicate failure. The client MUST treat any negative
	// return value as a fatal error.
	GetTxViaExport(context.Context, *GetTxViaExportRequest) (*GetTxViaExportResponse, error)

	// This method returns the Propagation_Token ([MS-DTCO] section 2.2.5.4) of the currently
	// active transaction, or returns an error if the specified TSN is not the same as the
	// CurrentTSN value.
	//
	// Return Values: The method MUST return a positive value or zero to indicate successful
	// completion, or a negative value to indicate failure. The client MUST treat any negative
	// return value as a fatal error.
	GetTxViaTransmitter(context.Context, *GetTxViaTransmitterRequest) (*GetTxViaTransmitterResponse, error)
}

ITransactionStream server interface.

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.