session

package
v0.34.0 Latest Latest
Warning

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

 Go to latest Published: Apr 26, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ExportNotification_State_name = map[int32]string{
		0:  "UNKNOWN",
		1:  "PENDING",
		2:  "PUBLISHING",
		3:  "QUEUED",
		4:  "RUNNING",
		5:  "EXPORTED",
		6:  "RELEASED",
		7:  "CANCELLED",
		8:  "FAILED",
		9:  "DEPENDENCY_FAILED",
		10: "DEPENDENCY_NEVER_FOUND",
		11: "DEPENDENCY_CANCELLED",
		12: "DEPENDENCY_RELEASED",
	}
	ExportNotification_State_value = map[string]int32{
		"UNKNOWN":                0,
		"PENDING":                1,
		"PUBLISHING":             2,
		"QUEUED":                 3,
		"RUNNING":                4,
		"EXPORTED":               5,
		"RELEASED":               6,
		"CANCELLED":              7,
		"FAILED":                 8,
		"DEPENDENCY_FAILED":      9,
		"DEPENDENCY_NEVER_FOUND": 10,
		"DEPENDENCY_CANCELLED":   11,
		"DEPENDENCY_RELEASED":    12,
	}
)

Enum value maps for ExportNotification_State.

View Source 
var File_deephaven_proto_session_proto protoreflect.FileDescriptor
View Source 
var SessionService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "io.deephaven.proto.backplane.grpc.SessionService",
	HandlerType: (*SessionServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "NewSession",
			Handler:    _SessionService_NewSession_Handler,
		},
		{
			MethodName: "RefreshSessionToken",
			Handler:    _SessionService_RefreshSessionToken_Handler,
		},
		{
			MethodName: "CloseSession",
			Handler:    _SessionService_CloseSession_Handler,
		},
		{
			MethodName: "Release",
			Handler:    _SessionService_Release_Handler,
		},
		{
			MethodName: "ExportFromTicket",
			Handler:    _SessionService_ExportFromTicket_Handler,
		},
		{
			MethodName: "PublishFromTicket",
			Handler:    _SessionService_PublishFromTicket_Handler,
		},
		{
			MethodName: "TerminationNotification",
			Handler:    _SessionService_TerminationNotification_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "ExportNotifications",
			Handler:       _SessionService_ExportNotifications_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "deephaven/proto/session.proto",
}

SessionService_ServiceDesc is the grpc.ServiceDesc for SessionService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterSessionServiceServer 

func RegisterSessionServiceServer(s grpc.ServiceRegistrar, srv SessionServiceServer)

Types

type CloseSessionResponse 

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

func (*CloseSessionResponse) Descriptor deprecated 

func (*CloseSessionResponse) Descriptor() ([]byte, []int)

Deprecated: Use CloseSessionResponse.ProtoReflect.Descriptor instead.

func (*CloseSessionResponse) ProtoMessage 

func (*CloseSessionResponse) ProtoMessage()

func (*CloseSessionResponse) ProtoReflect 

func (x *CloseSessionResponse) ProtoReflect() protoreflect.Message

func (*CloseSessionResponse) Reset 

func (x *CloseSessionResponse) Reset()

func (*CloseSessionResponse) String 

func (x *CloseSessionResponse) String() string

type ExportNotification 

type ExportNotification struct {
	Ticket      *ticket.Ticket           `protobuf:"bytes,1,opt,name=ticket,proto3" json:"ticket,omitempty"`
	ExportState ExportNotification_State `` /* 159-byte string literal not displayed */
	//
	// any errors will include an id that can be used to find details of the error in the logs
	Context string `protobuf:"bytes,3,opt,name=context,proto3" json:"context,omitempty"`
	//
	// will be set to an identifier of the dependency that cascaded the error if applicable
	DependentHandle string `protobuf:"bytes,4,opt,name=dependent_handle,json=dependentHandle,proto3" json:"dependent_handle,omitempty"`
	// contains filtered or unexported fields
}

func (*ExportNotification) Descriptor deprecated 

func (*ExportNotification) Descriptor() ([]byte, []int)

Deprecated: Use ExportNotification.ProtoReflect.Descriptor instead.

func (*ExportNotification) GetContext 

func (x *ExportNotification) GetContext() string

func (*ExportNotification) GetDependentHandle 

func (x *ExportNotification) GetDependentHandle() string

func (*ExportNotification) GetExportState 

func (x *ExportNotification) GetExportState() ExportNotification_State

func (*ExportNotification) GetTicket 

func (x *ExportNotification) GetTicket() *ticket.Ticket

func (*ExportNotification) ProtoMessage 

func (*ExportNotification) ProtoMessage()

func (*ExportNotification) ProtoReflect 

func (x *ExportNotification) ProtoReflect() protoreflect.Message

func (*ExportNotification) Reset 

func (x *ExportNotification) Reset()

func (*ExportNotification) String 

func (x *ExportNotification) String() string

type ExportNotificationRequest 

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

func (*ExportNotificationRequest) Descriptor deprecated 

func (*ExportNotificationRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExportNotificationRequest.ProtoReflect.Descriptor instead.

func (*ExportNotificationRequest) ProtoMessage 

func (*ExportNotificationRequest) ProtoMessage()

func (*ExportNotificationRequest) ProtoReflect 

func (x *ExportNotificationRequest) ProtoReflect() protoreflect.Message

func (*ExportNotificationRequest) Reset 

func (x *ExportNotificationRequest) Reset()

func (*ExportNotificationRequest) String 

func (x *ExportNotificationRequest) String() string

type ExportNotification_State 

type ExportNotification_State int32
const (
	ExportNotification_UNKNOWN                ExportNotification_State = 0  // This item is a dependency, but hasn't been registered yet.
	ExportNotification_PENDING                ExportNotification_State = 1  // This item has pending dependencies.
	ExportNotification_PUBLISHING             ExportNotification_State = 2  // This item is a client-supplied dependency with no guarantee on timing to EXPORT state.
	ExportNotification_QUEUED                 ExportNotification_State = 3  // This item is eligible for resolution and has been submitted to the executor.
	ExportNotification_RUNNING                ExportNotification_State = 4  // This item is now executing.
	ExportNotification_EXPORTED               ExportNotification_State = 5  // This item was successfully exported and is currently being retained.
	ExportNotification_RELEASED               ExportNotification_State = 6  // This item was successfully released.
	ExportNotification_CANCELLED              ExportNotification_State = 7  //  CANCELLED: The user cancelled the item before it exported.
	ExportNotification_FAILED                 ExportNotification_State = 8  // This item had a specific error.
	ExportNotification_DEPENDENCY_FAILED      ExportNotification_State = 9  // One of this item's dependencies had an internal error before it exported.
	ExportNotification_DEPENDENCY_NEVER_FOUND ExportNotification_State = 10 // One of this item's dependencies was already released or never submitted within the out-of-order window.
	ExportNotification_DEPENDENCY_CANCELLED   ExportNotification_State = 11 // Dependency was cancelled, causing a cascading cancel that applies to this export.
	ExportNotification_DEPENDENCY_RELEASED    ExportNotification_State = 12 // Dependency was already released, causing a cascading failure that applies to this export.
)

func (ExportNotification_State) Descriptor 

func (ExportNotification_State) Descriptor() protoreflect.EnumDescriptor

func (ExportNotification_State) Enum 

func (x ExportNotification_State) Enum() *ExportNotification_State

func (ExportNotification_State) EnumDescriptor deprecated 

func (ExportNotification_State) EnumDescriptor() ([]byte, []int)

Deprecated: Use ExportNotification_State.Descriptor instead.

func (ExportNotification_State) Number 

func (x ExportNotification_State) Number() protoreflect.EnumNumber

func (ExportNotification_State) String 

func (x ExportNotification_State) String() string

func (ExportNotification_State) Type 

func (ExportNotification_State) Type() protoreflect.EnumType

type ExportRequest 

type ExportRequest struct {
	SourceId *ticket.Ticket `protobuf:"bytes,1,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`
	ResultId *ticket.Ticket `protobuf:"bytes,2,opt,name=result_id,json=resultId,proto3" json:"result_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ExportRequest) Descriptor deprecated 

func (*ExportRequest) Descriptor() ([]byte, []int)

Deprecated: Use ExportRequest.ProtoReflect.Descriptor instead.

func (*ExportRequest) GetResultId 

func (x *ExportRequest) GetResultId() *ticket.Ticket

func (*ExportRequest) GetSourceId 

func (x *ExportRequest) GetSourceId() *ticket.Ticket

func (*ExportRequest) ProtoMessage 

func (*ExportRequest) ProtoMessage()

func (*ExportRequest) ProtoReflect 

func (x *ExportRequest) ProtoReflect() protoreflect.Message

func (*ExportRequest) Reset 

func (x *ExportRequest) Reset()

func (*ExportRequest) String 

func (x *ExportRequest) String() string

type ExportResponse 

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

func (*ExportResponse) Descriptor deprecated 

func (*ExportResponse) Descriptor() ([]byte, []int)

Deprecated: Use ExportResponse.ProtoReflect.Descriptor instead.

func (*ExportResponse) ProtoMessage 

func (*ExportResponse) ProtoMessage()

func (*ExportResponse) ProtoReflect 

func (x *ExportResponse) ProtoReflect() protoreflect.Message

func (*ExportResponse) Reset 

func (x *ExportResponse) Reset()

func (*ExportResponse) String 

func (x *ExportResponse) String() string

type HandshakeRequest 

type HandshakeRequest struct {

	//
	// A defined protocol version.
	//
	// Deephaven's OSS protocols are as follows:
	// - protocol = 0: most recent HandshakeResponse payload
	// - protocol = 1: payload is BasicAuth
	//
	// Deprecated: Do not use.
	AuthProtocol int32 `protobuf:"zigzag32,1,opt,name=auth_protocol,json=authProtocol,proto3" json:"auth_protocol,omitempty"`
	//
	// Arbitrary auth/handshake info.
	//
	// Deprecated: Do not use.
	Payload []byte `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

The request that a client provides to a server on handshake.

func (*HandshakeRequest) Descriptor deprecated 

func (*HandshakeRequest) Descriptor() ([]byte, []int)

Deprecated: Use HandshakeRequest.ProtoReflect.Descriptor instead.

func (*HandshakeRequest) GetAuthProtocol deprecated 

func (x *HandshakeRequest) GetAuthProtocol() int32

Deprecated: Do not use.

func (*HandshakeRequest) GetPayload deprecated 

func (x *HandshakeRequest) GetPayload() []byte

Deprecated: Do not use.

func (*HandshakeRequest) ProtoMessage 

func (*HandshakeRequest) ProtoMessage()

func (*HandshakeRequest) ProtoReflect 

func (x *HandshakeRequest) ProtoReflect() protoreflect.Message

func (*HandshakeRequest) Reset 

func (x *HandshakeRequest) Reset()

func (*HandshakeRequest) String 

func (x *HandshakeRequest) String() string

type HandshakeResponse 

type HandshakeResponse struct {

	//
	// The metadata header to identify the session. This value is static and defined via configuration.
	//
	// Deprecated: Do not use.
	MetadataHeader []byte `protobuf:"bytes,1,opt,name=metadata_header,json=metadataHeader,proto3" json:"metadata_header,omitempty"`
	//
	// Arbitrary session_token to assign to the value to the provided metadata header.
	//
	// Deprecated: Do not use.
	SessionToken []byte `protobuf:"bytes,2,opt,name=session_token,json=sessionToken,proto3" json:"session_token,omitempty"`
	//
	// When this session_token will be considered invalid by the server.
	//
	// Deprecated: Do not use.
	TokenDeadlineTimeMillis int64 `` /* 137-byte string literal not displayed */
	//
	// The length of time that this token was intended to live. Note that `refreshSessionToken` may return the
	// existing token to reduce overhead and to prevent denial-of-service caused by refreshing too frequently.
	//
	// Deprecated: Do not use.
	TokenExpirationDelayMillis int64 `` /* 146-byte string literal not displayed */
	// contains filtered or unexported fields
}

Servers respond with information needed to make subsequent requests tied to this session. The session token should be refreshed prior to the deadline, which is represented as milliseconds since the epoch. Clients are encouraged to use the expiration delay and cookie deadline to determine a good time to refresh.

func (*HandshakeResponse) Descriptor deprecated 

func (*HandshakeResponse) Descriptor() ([]byte, []int)

Deprecated: Use HandshakeResponse.ProtoReflect.Descriptor instead.

func (*HandshakeResponse) GetMetadataHeader deprecated 

func (x *HandshakeResponse) GetMetadataHeader() []byte

Deprecated: Do not use.

func (*HandshakeResponse) GetSessionToken deprecated 

func (x *HandshakeResponse) GetSessionToken() []byte

Deprecated: Do not use.

func (*HandshakeResponse) GetTokenDeadlineTimeMillis deprecated 

func (x *HandshakeResponse) GetTokenDeadlineTimeMillis() int64

Deprecated: Do not use.

func (*HandshakeResponse) GetTokenExpirationDelayMillis deprecated 

func (x *HandshakeResponse) GetTokenExpirationDelayMillis() int64

Deprecated: Do not use.

func (*HandshakeResponse) ProtoMessage 

func (*HandshakeResponse) ProtoMessage()

func (*HandshakeResponse) ProtoReflect 

func (x *HandshakeResponse) ProtoReflect() protoreflect.Message

func (*HandshakeResponse) Reset 

func (x *HandshakeResponse) Reset()

func (*HandshakeResponse) String 

func (x *HandshakeResponse) String() string

type PublishRequest added in v0.26.0 

type PublishRequest struct {
	SourceId *ticket.Ticket `protobuf:"bytes,1,opt,name=source_id,json=sourceId,proto3" json:"source_id,omitempty"`
	ResultId *ticket.Ticket `protobuf:"bytes,2,opt,name=result_id,json=resultId,proto3" json:"result_id,omitempty"`
	// contains filtered or unexported fields
}

func (*PublishRequest) Descriptor deprecated added in v0.26.0 

func (*PublishRequest) Descriptor() ([]byte, []int)

Deprecated: Use PublishRequest.ProtoReflect.Descriptor instead.

func (*PublishRequest) GetResultId added in v0.26.0 

func (x *PublishRequest) GetResultId() *ticket.Ticket

func (*PublishRequest) GetSourceId added in v0.26.0 

func (x *PublishRequest) GetSourceId() *ticket.Ticket

func (*PublishRequest) ProtoMessage added in v0.26.0 

func (*PublishRequest) ProtoMessage()

func (*PublishRequest) ProtoReflect added in v0.26.0 

func (x *PublishRequest) ProtoReflect() protoreflect.Message

func (*PublishRequest) Reset added in v0.26.0 

func (x *PublishRequest) Reset()

func (*PublishRequest) String added in v0.26.0 

func (x *PublishRequest) String() string

type PublishResponse added in v0.26.0 

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

func (*PublishResponse) Descriptor deprecated added in v0.26.0 

func (*PublishResponse) Descriptor() ([]byte, []int)

Deprecated: Use PublishResponse.ProtoReflect.Descriptor instead.

func (*PublishResponse) ProtoMessage added in v0.26.0 

func (*PublishResponse) ProtoMessage()

func (*PublishResponse) ProtoReflect added in v0.26.0 

func (x *PublishResponse) ProtoReflect() protoreflect.Message

func (*PublishResponse) Reset added in v0.26.0 

func (x *PublishResponse) Reset()

func (*PublishResponse) String added in v0.26.0 

func (x *PublishResponse) String() string

type ReleaseRequest 

type ReleaseRequest struct {
	Id *ticket.Ticket `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

func (*ReleaseRequest) Descriptor deprecated 

func (*ReleaseRequest) Descriptor() ([]byte, []int)

Deprecated: Use ReleaseRequest.ProtoReflect.Descriptor instead.

func (*ReleaseRequest) GetId 

func (x *ReleaseRequest) GetId() *ticket.Ticket

func (*ReleaseRequest) ProtoMessage 

func (*ReleaseRequest) ProtoMessage()

func (*ReleaseRequest) ProtoReflect 

func (x *ReleaseRequest) ProtoReflect() protoreflect.Message

func (*ReleaseRequest) Reset 

func (x *ReleaseRequest) Reset()

func (*ReleaseRequest) String 

func (x *ReleaseRequest) String() string

type ReleaseResponse 

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

func (*ReleaseResponse) Descriptor deprecated 

func (*ReleaseResponse) Descriptor() ([]byte, []int)

Deprecated: Use ReleaseResponse.ProtoReflect.Descriptor instead.

func (*ReleaseResponse) ProtoMessage 

func (*ReleaseResponse) ProtoMessage()

func (*ReleaseResponse) ProtoReflect 

func (x *ReleaseResponse) ProtoReflect() protoreflect.Message

func (*ReleaseResponse) Reset 

func (x *ReleaseResponse) Reset()

func (*ReleaseResponse) String 

func (x *ReleaseResponse) String() string

type SessionServiceClient 

type SessionServiceClient interface {
	// Deprecated: Do not use.
	//
	// Handshake between client and server to create a new session. The response includes a metadata header name and the
	// token to send on every subsequent request. The auth mechanisms here are unary to best support grpc-web.
	//
	// Deprecated: Please use Flight's Handshake or http authorization headers instead.
	NewSession(ctx context.Context, in *HandshakeRequest, opts ...grpc.CallOption) (*HandshakeResponse, error)
	// Deprecated: Do not use.
	//
	// Keep-alive a given token to ensure that a session is not cleaned prematurely. The response may include an updated
	// token that should replace the existing token for subsequent requests.
	//
	// Deprecated: Please use Flight's Handshake with an empty payload.
	RefreshSessionToken(ctx context.Context, in *HandshakeRequest, opts ...grpc.CallOption) (*HandshakeResponse, error)
	//
	// Proactively close an open session. Sessions will automatically close on timeout. When a session is closed, all
	// unreleased exports will be automatically released.
	CloseSession(ctx context.Context, in *HandshakeRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error)
	//
	// Attempts to release an export by its ticket. Returns true if an existing export was found. It is the client's
	// responsibility to release all resources they no longer want the server to hold on to. Proactively cancels work; do
	// not release a ticket that is needed by dependent work that has not yet finished
	// (i.e. the dependencies that are staying around should first be in EXPORTED state).
	Release(ctx context.Context, in *ReleaseRequest, opts ...grpc.CallOption) (*ReleaseResponse, error)
	//
	// Makes a copy from a source ticket to a client managed result ticket. The source ticket does not need to be
	// a client managed ticket.
	ExportFromTicket(ctx context.Context, in *ExportRequest, opts ...grpc.CallOption) (*ExportResponse, error)
	//
	// Makes a copy from a source ticket and publishes to a result ticket. Neither the source ticket, nor the destination
	// ticket, need to be a client managed ticket.
	PublishFromTicket(ctx context.Context, in *PublishRequest, opts ...grpc.CallOption) (*PublishResponse, error)
	//
	// Establish a stream to manage all session exports, including those lost due to partially complete rpc calls.
	//
	// New streams will flush notifications for all un-released exports, prior to seeing any new or updated exports
	// for all live exports. After the refresh of existing state, subscribers will receive notifications of new and
	// updated exports. An export id of zero will be sent to indicate all pre-existing exports have been sent.
	ExportNotifications(ctx context.Context, in *ExportNotificationRequest, opts ...grpc.CallOption) (SessionService_ExportNotificationsClient, error)
	//
	// Receive a best-effort message on-exit indicating why this server is exiting. Reception of this message cannot be
	// guaranteed.
	TerminationNotification(ctx context.Context, in *TerminationNotificationRequest, opts ...grpc.CallOption) (*TerminationNotificationResponse, error)
}

SessionServiceClient is the client API for SessionService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewSessionServiceClient 

func NewSessionServiceClient(cc grpc.ClientConnInterface) SessionServiceClient

type SessionServiceServer 

type SessionServiceServer interface {
	// Deprecated: Do not use.
	//
	// Handshake between client and server to create a new session. The response includes a metadata header name and the
	// token to send on every subsequent request. The auth mechanisms here are unary to best support grpc-web.
	//
	// Deprecated: Please use Flight's Handshake or http authorization headers instead.
	NewSession(context.Context, *HandshakeRequest) (*HandshakeResponse, error)
	// Deprecated: Do not use.
	//
	// Keep-alive a given token to ensure that a session is not cleaned prematurely. The response may include an updated
	// token that should replace the existing token for subsequent requests.
	//
	// Deprecated: Please use Flight's Handshake with an empty payload.
	RefreshSessionToken(context.Context, *HandshakeRequest) (*HandshakeResponse, error)
	//
	// Proactively close an open session. Sessions will automatically close on timeout. When a session is closed, all
	// unreleased exports will be automatically released.
	CloseSession(context.Context, *HandshakeRequest) (*CloseSessionResponse, error)
	//
	// Attempts to release an export by its ticket. Returns true if an existing export was found. It is the client's
	// responsibility to release all resources they no longer want the server to hold on to. Proactively cancels work; do
	// not release a ticket that is needed by dependent work that has not yet finished
	// (i.e. the dependencies that are staying around should first be in EXPORTED state).
	Release(context.Context, *ReleaseRequest) (*ReleaseResponse, error)
	//
	// Makes a copy from a source ticket to a client managed result ticket. The source ticket does not need to be
	// a client managed ticket.
	ExportFromTicket(context.Context, *ExportRequest) (*ExportResponse, error)
	//
	// Makes a copy from a source ticket and publishes to a result ticket. Neither the source ticket, nor the destination
	// ticket, need to be a client managed ticket.
	PublishFromTicket(context.Context, *PublishRequest) (*PublishResponse, error)
	//
	// Establish a stream to manage all session exports, including those lost due to partially complete rpc calls.
	//
	// New streams will flush notifications for all un-released exports, prior to seeing any new or updated exports
	// for all live exports. After the refresh of existing state, subscribers will receive notifications of new and
	// updated exports. An export id of zero will be sent to indicate all pre-existing exports have been sent.
	ExportNotifications(*ExportNotificationRequest, SessionService_ExportNotificationsServer) error
	//
	// Receive a best-effort message on-exit indicating why this server is exiting. Reception of this message cannot be
	// guaranteed.
	TerminationNotification(context.Context, *TerminationNotificationRequest) (*TerminationNotificationResponse, error)
	// contains filtered or unexported methods
}

SessionServiceServer is the server API for SessionService service. All implementations must embed UnimplementedSessionServiceServer for forward compatibility

type SessionService_ExportNotificationsClient 

type SessionService_ExportNotificationsClient interface {
	Recv() (*ExportNotification, error)
	grpc.ClientStream
}

type SessionService_ExportNotificationsServer 

type SessionService_ExportNotificationsServer interface {
	Send(*ExportNotification) error
	grpc.ServerStream
}

type TerminationNotificationRequest 

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

func (*TerminationNotificationRequest) Descriptor deprecated 

func (*TerminationNotificationRequest) Descriptor() ([]byte, []int)

Deprecated: Use TerminationNotificationRequest.ProtoReflect.Descriptor instead.

func (*TerminationNotificationRequest) ProtoMessage 

func (*TerminationNotificationRequest) ProtoMessage()

func (*TerminationNotificationRequest) ProtoReflect 

func (x *TerminationNotificationRequest) ProtoReflect() protoreflect.Message

func (*TerminationNotificationRequest) Reset 

func (x *TerminationNotificationRequest) Reset()

func (*TerminationNotificationRequest) String 

func (x *TerminationNotificationRequest) String() string

type TerminationNotificationResponse 

type TerminationNotificationResponse struct {

	// whether or not this termination is expected
	AbnormalTermination bool `protobuf:"varint,1,opt,name=abnormal_termination,json=abnormalTermination,proto3" json:"abnormal_termination,omitempty"`
	// if additional information is available then provide it in this field
	Reason string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// if this is due to an exception, whether or not it was uncaught
	IsFromUncaughtException bool `` /* 135-byte string literal not displayed */
	// if applicable, the list of stack traces in reverse causal order
	StackTraces []*TerminationNotificationResponse_StackTrace `protobuf:"bytes,4,rep,name=stack_traces,json=stackTraces,proto3" json:"stack_traces,omitempty"`
	// contains filtered or unexported fields
}

func (*TerminationNotificationResponse) Descriptor deprecated 

func (*TerminationNotificationResponse) Descriptor() ([]byte, []int)

Deprecated: Use TerminationNotificationResponse.ProtoReflect.Descriptor instead.

func (*TerminationNotificationResponse) GetAbnormalTermination 

func (x *TerminationNotificationResponse) GetAbnormalTermination() bool

func (*TerminationNotificationResponse) GetIsFromUncaughtException 

func (x *TerminationNotificationResponse) GetIsFromUncaughtException() bool

func (*TerminationNotificationResponse) GetReason 

func (x *TerminationNotificationResponse) GetReason() string

func (*TerminationNotificationResponse) GetStackTraces 

func (x *TerminationNotificationResponse) GetStackTraces() []*TerminationNotificationResponse_StackTrace

func (*TerminationNotificationResponse) ProtoMessage 

func (*TerminationNotificationResponse) ProtoMessage()

func (*TerminationNotificationResponse) ProtoReflect 

func (x *TerminationNotificationResponse) ProtoReflect() protoreflect.Message

func (*TerminationNotificationResponse) Reset 

func (x *TerminationNotificationResponse) Reset()

func (*TerminationNotificationResponse) String 

func (x *TerminationNotificationResponse) String() string

type TerminationNotificationResponse_StackTrace 

type TerminationNotificationResponse_StackTrace struct {
	Type     string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Message  string   `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	Elements []string `protobuf:"bytes,3,rep,name=elements,proto3" json:"elements,omitempty"`
	// contains filtered or unexported fields
}

func (*TerminationNotificationResponse_StackTrace) Descriptor deprecated 

func (*TerminationNotificationResponse_StackTrace) Descriptor() ([]byte, []int)

Deprecated: Use TerminationNotificationResponse_StackTrace.ProtoReflect.Descriptor instead.

func (*TerminationNotificationResponse_StackTrace) GetElements 

func (x *TerminationNotificationResponse_StackTrace) GetElements() []string

func (*TerminationNotificationResponse_StackTrace) GetMessage 

func (x *TerminationNotificationResponse_StackTrace) GetMessage() string

func (*TerminationNotificationResponse_StackTrace) GetType 

func (x *TerminationNotificationResponse_StackTrace) GetType() string

func (*TerminationNotificationResponse_StackTrace) ProtoMessage 

func (*TerminationNotificationResponse_StackTrace) ProtoMessage()

func (*TerminationNotificationResponse_StackTrace) ProtoReflect 

func (x *TerminationNotificationResponse_StackTrace) ProtoReflect() protoreflect.Message

func (*TerminationNotificationResponse_StackTrace) Reset 

func (x *TerminationNotificationResponse_StackTrace) Reset()

func (*TerminationNotificationResponse_StackTrace) String 

func (x *TerminationNotificationResponse_StackTrace) String() string

type UnimplementedSessionServiceServer 

type UnimplementedSessionServiceServer struct {
}

UnimplementedSessionServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedSessionServiceServer) CloseSession 

func (UnimplementedSessionServiceServer) CloseSession(context.Context, *HandshakeRequest) (*CloseSessionResponse, error)

func (UnimplementedSessionServiceServer) ExportFromTicket 

func (UnimplementedSessionServiceServer) ExportFromTicket(context.Context, *ExportRequest) (*ExportResponse, error)

func (UnimplementedSessionServiceServer) ExportNotifications 

func (UnimplementedSessionServiceServer) ExportNotifications(*ExportNotificationRequest, SessionService_ExportNotificationsServer) error

func (UnimplementedSessionServiceServer) NewSession 

func (UnimplementedSessionServiceServer) NewSession(context.Context, *HandshakeRequest) (*HandshakeResponse, error)

func (UnimplementedSessionServiceServer) PublishFromTicket added in v0.26.0 

func (UnimplementedSessionServiceServer) PublishFromTicket(context.Context, *PublishRequest) (*PublishResponse, error)

func (UnimplementedSessionServiceServer) RefreshSessionToken 

func (UnimplementedSessionServiceServer) RefreshSessionToken(context.Context, *HandshakeRequest) (*HandshakeResponse, error)

func (UnimplementedSessionServiceServer) Release 

func (UnimplementedSessionServiceServer) Release(context.Context, *ReleaseRequest) (*ReleaseResponse, error)

func (UnimplementedSessionServiceServer) TerminationNotification 

func (UnimplementedSessionServiceServer) TerminationNotification(context.Context, *TerminationNotificationRequest) (*TerminationNotificationResponse, error)

type UnsafeSessionServiceServer 

type UnsafeSessionServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeSessionServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SessionServiceServer will result in compilation errors.

type WrappedAuthenticationRequest added in v0.17.0 

type WrappedAuthenticationRequest struct {

	//
	// The type of the protobuf the auth payload protobuf.
	Type string `protobuf:"bytes,4,opt,name=type,proto3" json:"type,omitempty"`
	//
	// The serialized payload of the protobuf instance.
	Payload []byte `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

func (*WrappedAuthenticationRequest) Descriptor deprecated added in v0.17.0 

func (*WrappedAuthenticationRequest) Descriptor() ([]byte, []int)

Deprecated: Use WrappedAuthenticationRequest.ProtoReflect.Descriptor instead.

func (*WrappedAuthenticationRequest) GetPayload added in v0.17.0 

func (x *WrappedAuthenticationRequest) GetPayload() []byte

func (*WrappedAuthenticationRequest) GetType added in v0.17.0 

func (x *WrappedAuthenticationRequest) GetType() string

func (*WrappedAuthenticationRequest) ProtoMessage added in v0.17.0 

func (*WrappedAuthenticationRequest) ProtoMessage()

func (*WrappedAuthenticationRequest) ProtoReflect added in v0.17.0 

func (x *WrappedAuthenticationRequest) ProtoReflect() protoreflect.Message

func (*WrappedAuthenticationRequest) Reset added in v0.17.0 

func (x *WrappedAuthenticationRequest) Reset()

func (*WrappedAuthenticationRequest) String added in v0.17.0 

func (x *WrappedAuthenticationRequest) String() string

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.