Documentation
¶
Index ¶
- Variables
- func NewTransactionStreamServerHandle(o TransactionStreamServer) dcerpc.ServerHandle
- func RegisterTransactionStreamServer(conn dcerpc.Conn, o TransactionStreamServer, opts ...dcerpc.Option)
- func TransactionStreamServerHandle(ctx context.Context, o TransactionStreamServer, opNum int, r ndr.Reader) (dcerpc.Operation, error)
- type GetSeqAndTxViaExportRequest
- type GetSeqAndTxViaExportResponse
- type GetSeqAndTxViaTransmitterRequest
- type GetSeqAndTxViaTransmitterResponse
- type GetTxViaExportRequest
- type GetTxViaExportResponse
- type GetTxViaTransmitterRequest
- type GetTxViaTransmitterResponse
- type TransactionStreamClient
- type TransactionStreamServer
- type UnimplementedTransactionStreamServer
- func (UnimplementedTransactionStreamServer) GetSeqAndTxViaExport(context.Context, *GetSeqAndTxViaExportRequest) (*GetSeqAndTxViaExportResponse, error)
- func (UnimplementedTransactionStreamServer) GetSeqAndTxViaTransmitter(context.Context, *GetSeqAndTxViaTransmitterRequest) (*GetSeqAndTxViaTransmitterResponse, error)
- func (UnimplementedTransactionStreamServer) GetTxViaExport(context.Context, *GetTxViaExportRequest) (*GetTxViaExportResponse, error)
- func (UnimplementedTransactionStreamServer) GetTxViaTransmitter(context.Context, *GetTxViaTransmitterRequest) (*GetTxViaTransmitterResponse, error)
Constants ¶
This section is empty.
Variables ¶
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} )
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)
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 (*GetSeqAndTxViaExportRequest) UnmarshalNDR ¶
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 (*GetSeqAndTxViaExportResponse) UnmarshalNDR ¶
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 (*GetSeqAndTxViaTransmitterRequest) UnmarshalNDR ¶
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 (*GetSeqAndTxViaTransmitterResponse) UnmarshalNDR ¶
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 (*GetTxViaExportRequest) UnmarshalNDR ¶
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 (*GetTxViaExportResponse) UnmarshalNDR ¶
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 (*GetTxViaTransmitterRequest) UnmarshalNDR ¶
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 (*GetTxViaTransmitterResponse) UnmarshalNDR ¶
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
// Conn returns the client connection (unsafe)
Conn() dcerpc.Conn
// IPID sets the object interface identifier.
IPID(context.Context, *dcom.IPID) TransactionStreamClient
}
ITransactionStream interface.
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.
type UnimplementedTransactionStreamServer ¶ added in v1.1.5
type UnimplementedTransactionStreamServer struct {
iunknown.UnimplementedUnknownServer
}
Unimplemented ITransactionStream
func (UnimplementedTransactionStreamServer) GetSeqAndTxViaExport ¶ added in v1.1.5
func (UnimplementedTransactionStreamServer) GetSeqAndTxViaExport(context.Context, *GetSeqAndTxViaExportRequest) (*GetSeqAndTxViaExportResponse, error)
func (UnimplementedTransactionStreamServer) GetSeqAndTxViaTransmitter ¶ added in v1.1.5
func (UnimplementedTransactionStreamServer) GetSeqAndTxViaTransmitter(context.Context, *GetSeqAndTxViaTransmitterRequest) (*GetSeqAndTxViaTransmitterResponse, error)
func (UnimplementedTransactionStreamServer) GetTxViaExport ¶ added in v1.1.5
func (UnimplementedTransactionStreamServer) GetTxViaExport(context.Context, *GetTxViaExportRequest) (*GetTxViaExportResponse, error)
func (UnimplementedTransactionStreamServer) GetTxViaTransmitter ¶ added in v1.1.5
func (UnimplementedTransactionStreamServer) GetTxViaTransmitter(context.Context, *GetTxViaTransmitterRequest) (*GetTxViaTransmitterResponse, error)