tests

Documentation

Index

• func FormatDebugInterceptorLog(value interface{}) (string, bool)
• type DebugInterceptorLog
  • func NewDebugInterceptorLog(t *testing.T) (*DebugInterceptorLog, error)
  • func (d *DebugInterceptorLog) Close() error
  • func (d *DebugInterceptorLog) Env() string
  • func (d *DebugInterceptorLog) ReadAll() (DebugInterceptorLogEntryList, error)
  • func (d *DebugInterceptorLog) Reset() error
• type DebugInterceptorLogEntry
  • func ReadDebugInterceptorLogFile(name string) ([]DebugInterceptorLogEntry, error)
• type DebugInterceptorLogEntryList
  • func (l DebugInterceptorLogEntryList) Invokes() InvokeList
  • func (l DebugInterceptorLogEntryList) ListRegisterResource() RegisterResourceList
• type Invoke
  • func ParseInvoke(entry DebugInterceptorLogEntry) (*Invoke, bool)
• type InvokeList
  • func (l InvokeList) ByProvider(providerUrn resource.URN) InvokeList
  • func (l InvokeList) Tok(tok string) InvokeList
• type RegisterResource
  • func ParseRegisterResource(entry DebugInterceptorLogEntry) (*RegisterResource, bool)
• type RegisterResourceList
  • func (l RegisterResourceList) Named(parent resource.URN, typ tokens.Type, name tokens.QName) RegisterResourceList

Functions

func FormatDebugInterceptorLog

func FormatDebugInterceptorLog(value interface{}) (string, bool)

Types

type DebugInterceptorLog

type DebugInterceptorLog struct {
	LogPath string
}

DebugInterceptorLog encapsulates the gRPC debug log file produced by the PULUMI_DEBUG_GRPC environment variable.

func NewDebugInterceptorLog

func NewDebugInterceptorLog(t *testing.T) (*DebugInterceptorLog, error)

func (*DebugInterceptorLog) Close

func (d *DebugInterceptorLog) Close() error

func (*DebugInterceptorLog) Env

func (d *DebugInterceptorLog) Env() string

func (*DebugInterceptorLog) ReadAll

func (d *DebugInterceptorLog) ReadAll() (DebugInterceptorLogEntryList, error)

func (*DebugInterceptorLog) Reset

func (d *DebugInterceptorLog) Reset() error

type DebugInterceptorLogEntry

type DebugInterceptorLogEntry struct {
	Method   string          `json:"method"`
	Request  json.RawMessage `json:"request,omitempty"`
	Response json.RawMessage `json:"response,omitempty"`
	Errors   []string        `json:"errors,omitempty"`
	Metadata interface{}     `json:"metadata,omitempty"`
}

JSON format for tracking gRPC conversations. Normal methods have one entry for each req-resp conversation, streaming methods have one entry per each request or response over the stream.

func ReadDebugInterceptorLogFile

func ReadDebugInterceptorLogFile(name string) ([]DebugInterceptorLogEntry, error)

ReadDebugInterceptorLogFile parses the gRPC log file produced by the PULUMI_DEBUG_GRPC environment variable.

type DebugInterceptorLogEntryList

type DebugInterceptorLogEntryList []DebugInterceptorLogEntry

func (DebugInterceptorLogEntryList) Invokes

func (l DebugInterceptorLogEntryList) Invokes() InvokeList

Invokes lists the Invoke calls in the log.

func (DebugInterceptorLogEntryList) ListRegisterResource

func (l DebugInterceptorLogEntryList) ListRegisterResource() RegisterResourceList

ListRegisterResource lists the RegisterResource calls in the log.

type Invoke

type Invoke struct {
	Request  pulumirpc.ResourceInvokeRequest
	Response pulumirpc.InvokeResponse
	Errors   []string    `json:"errors,omitempty"`
	Metadata interface{} `json:"metadata,omitempty"`
}

Invoke is a decoded "/pulumirpc.ResourceMonitor/Invoke" RPC call.

func ParseInvoke

func ParseInvoke(entry DebugInterceptorLogEntry) (*Invoke, bool)

ParseInvoke parses a log entry as a Invoke call.

type InvokeList

type InvokeList []Invoke

func (InvokeList) ByProvider

func (l InvokeList) ByProvider(providerUrn resource.URN) InvokeList

Lookup returns Invoke entries matching the given provider and token (operation).

func (InvokeList) Tok

func (l InvokeList) Tok(tok string) InvokeList

Lookup returns Invoke entries matching the given token (operation).

type RegisterResource

type RegisterResource struct {
	Request  pulumirpc.RegisterResourceRequest
	Response pulumirpc.RegisterResourceResponse
	Errors   []string    `json:"errors,omitempty"`
	Metadata interface{} `json:"metadata,omitempty"`
}

RegisterResource is a decoded "/pulumirpc.ResourceMonitor/RegisterResource" RPC call.

func ParseRegisterResource

func ParseRegisterResource(entry DebugInterceptorLogEntry) (*RegisterResource, bool)

ParseRegisterResource parses a log entry as a RegisterResource call.

type RegisterResourceList

type RegisterResourceList []RegisterResource

func (RegisterResourceList) Named

func (l RegisterResourceList) Named(parent resource.URN, typ tokens.Type, name tokens.QName) RegisterResourceList

Named returns RegisterResource entries matching the given resource type, name, and parent.