pb

package
v0.0.0-...-a4552ea Latest Latest
Warning

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

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

Documentation

Index

Constants

View Source 
const (
	BacktestServicer_ListBacktests_FullMethodName  = "/foreverbull.backtest.BacktestServicer/ListBacktests"
	BacktestServicer_CreateBacktest_FullMethodName = "/foreverbull.backtest.BacktestServicer/CreateBacktest"
	BacktestServicer_GetBacktest_FullMethodName    = "/foreverbull.backtest.BacktestServicer/GetBacktest"
	BacktestServicer_CreateSession_FullMethodName  = "/foreverbull.backtest.BacktestServicer/CreateSession"
	BacktestServicer_GetSession_FullMethodName     = "/foreverbull.backtest.BacktestServicer/GetSession"
	BacktestServicer_ListExecutions_FullMethodName = "/foreverbull.backtest.BacktestServicer/ListExecutions"
	BacktestServicer_GetExecution_FullMethodName   = "/foreverbull.backtest.BacktestServicer/GetExecution"
)
View Source 
const (
	Engine_DownloadIngestion_FullMethodName      = "/foreverbull.backtest.Engine/DownloadIngestion"
	Engine_Ingest_FullMethodName                 = "/foreverbull.backtest.Engine/Ingest"
	Engine_RunBacktest_FullMethodName            = "/foreverbull.backtest.Engine/RunBacktest"
	Engine_GetCurrentPeriod_FullMethodName       = "/foreverbull.backtest.Engine/GetCurrentPeriod"
	Engine_PlaceOrdersAndContinue_FullMethodName = "/foreverbull.backtest.Engine/PlaceOrdersAndContinue"
	Engine_GetResult_FullMethodName              = "/foreverbull.backtest.Engine/GetResult"
	Engine_Stop_FullMethodName                   = "/foreverbull.backtest.Engine/Stop"
)
View Source 
const (
	IngestionServicer_GetCurrentIngestion_FullMethodName = "/foreverbull.backtest.IngestionServicer/GetCurrentIngestion"
	IngestionServicer_UpdateIngestion_FullMethodName     = "/foreverbull.backtest.IngestionServicer/UpdateIngestion"
)
View Source 
const (
	SessionServicer_CreateExecution_FullMethodName = "/foreverbull.backtest.SessionServicer/CreateExecution"
	SessionServicer_RunExecution_FullMethodName    = "/foreverbull.backtest.SessionServicer/RunExecution"
	SessionServicer_StoreResult_FullMethodName     = "/foreverbull.backtest.SessionServicer/StoreResult"
	SessionServicer_StopServer_FullMethodName      = "/foreverbull.backtest.SessionServicer/StopServer"
)

Variables

View Source 
var (
	Backtest_Status_Status_name = map[int32]string{
		0: "CREATED",
		1: "READY",
		2: "ERROR",
	}
	Backtest_Status_Status_value = map[string]int32{
		"CREATED": 0,
		"READY":   1,
		"ERROR":   2,
	}
)

Enum value maps for Backtest_Status_Status.

View Source 
var (
	Execution_Status_Status_name = map[int32]string{
		0: "CREATED",
		1: "RUNNING",
		2: "COMPLETED",
		3: "FAILED",
	}
	Execution_Status_Status_value = map[string]int32{
		"CREATED":   0,
		"RUNNING":   1,
		"COMPLETED": 2,
		"FAILED":    3,
	}
)

Enum value maps for Execution_Status_Status.

View Source 
var (
	IngestionStatus_name = map[int32]string{
		0: "CREATED",
		1: "INGESTING",
		2: "READY",
	}
	IngestionStatus_value = map[string]int32{
		"CREATED":   0,
		"INGESTING": 1,
		"READY":     2,
	}
)

Enum value maps for IngestionStatus.

View Source 
var (
	Session_Status_Status_name = map[int32]string{
		0: "CREATED",
		1: "RUNNING",
		2: "COMPLETED",
		3: "FAILED",
	}
	Session_Status_Status_value = map[string]int32{
		"CREATED":   0,
		"RUNNING":   1,
		"COMPLETED": 2,
		"FAILED":    3,
	}
)

Enum value maps for Session_Status_Status.

View Source 
var BacktestServicer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "foreverbull.backtest.BacktestServicer",
	HandlerType: (*BacktestServicerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "ListBacktests",
			Handler:    _BacktestServicer_ListBacktests_Handler,
		},
		{
			MethodName: "CreateBacktest",
			Handler:    _BacktestServicer_CreateBacktest_Handler,
		},
		{
			MethodName: "GetBacktest",
			Handler:    _BacktestServicer_GetBacktest_Handler,
		},
		{
			MethodName: "CreateSession",
			Handler:    _BacktestServicer_CreateSession_Handler,
		},
		{
			MethodName: "GetSession",
			Handler:    _BacktestServicer_GetSession_Handler,
		},
		{
			MethodName: "ListExecutions",
			Handler:    _BacktestServicer_ListExecutions_Handler,
		},
		{
			MethodName: "GetExecution",
			Handler:    _BacktestServicer_GetExecution_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "foreverbull/backtest/backtest_service.proto",
}

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

View Source 
var Engine_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "foreverbull.backtest.Engine",
	HandlerType: (*EngineServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "DownloadIngestion",
			Handler:    _Engine_DownloadIngestion_Handler,
		},
		{
			MethodName: "Ingest",
			Handler:    _Engine_Ingest_Handler,
		},
		{
			MethodName: "RunBacktest",
			Handler:    _Engine_RunBacktest_Handler,
		},
		{
			MethodName: "GetCurrentPeriod",
			Handler:    _Engine_GetCurrentPeriod_Handler,
		},
		{
			MethodName: "PlaceOrdersAndContinue",
			Handler:    _Engine_PlaceOrdersAndContinue_Handler,
		},
		{
			MethodName: "GetResult",
			Handler:    _Engine_GetResult_Handler,
		},
		{
			MethodName: "Stop",
			Handler:    _Engine_Stop_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "foreverbull/backtest/engine_service.proto",
}

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

View Source 
var File_foreverbull_backtest_backtest_proto protoreflect.FileDescriptor
View Source 
var File_foreverbull_backtest_backtest_service_proto protoreflect.FileDescriptor
View Source 
var File_foreverbull_backtest_engine_service_proto protoreflect.FileDescriptor
View Source 
var File_foreverbull_backtest_execution_proto protoreflect.FileDescriptor
View Source 
var File_foreverbull_backtest_ingestion_proto protoreflect.FileDescriptor
View Source 
var File_foreverbull_backtest_ingestion_service_proto protoreflect.FileDescriptor
View Source 
var File_foreverbull_backtest_session_proto protoreflect.FileDescriptor
View Source 
var File_foreverbull_backtest_session_service_proto protoreflect.FileDescriptor
View Source 
var IngestionServicer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "foreverbull.backtest.IngestionServicer",
	HandlerType: (*IngestionServicerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetCurrentIngestion",
			Handler:    _IngestionServicer_GetCurrentIngestion_Handler,
		},
		{
			MethodName: "UpdateIngestion",
			Handler:    _IngestionServicer_UpdateIngestion_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "foreverbull/backtest/ingestion_service.proto",
}

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

View Source 
var SessionServicer_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "foreverbull.backtest.SessionServicer",
	HandlerType: (*SessionServicerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "CreateExecution",
			Handler:    _SessionServicer_CreateExecution_Handler,
		},
		{
			MethodName: "StoreResult",
			Handler:    _SessionServicer_StoreResult_Handler,
		},
		{
			MethodName: "StopServer",
			Handler:    _SessionServicer_StopServer_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "RunExecution",
			Handler:       _SessionServicer_RunExecution_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "foreverbull/backtest/session_service.proto",
}

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

Functions

func RegisterBacktestServicerServer 

func RegisterBacktestServicerServer(s grpc.ServiceRegistrar, srv BacktestServicerServer)

func RegisterEngineServer 

func RegisterEngineServer(s grpc.ServiceRegistrar, srv EngineServer)

func RegisterIngestionServicerServer 

func RegisterIngestionServicerServer(s grpc.ServiceRegistrar, srv IngestionServicerServer)

func RegisterSessionServicerServer 

func RegisterSessionServicerServer(s grpc.ServiceRegistrar, srv SessionServicerServer)

Types

type Backtest 

type Backtest struct {
	Name      string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	StartDate *pb.Date           `protobuf:"bytes,2,opt,name=start_date,json=startDate,proto3" json:"start_date,omitempty"`
	EndDate   *pb.Date           `protobuf:"bytes,3,opt,name=end_date,json=endDate,proto3" json:"end_date,omitempty"`
	Symbols   []string           `protobuf:"bytes,4,rep,name=symbols,proto3" json:"symbols,omitempty"`
	Benchmark *string            `protobuf:"bytes,5,opt,name=benchmark,proto3,oneof" json:"benchmark,omitempty"`
	Statuses  []*Backtest_Status `protobuf:"bytes,6,rep,name=statuses,proto3" json:"statuses,omitempty"`
	// contains filtered or unexported fields
}

func (*Backtest) Descriptor deprecated 

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

Deprecated: Use Backtest.ProtoReflect.Descriptor instead.

func (*Backtest) GetBenchmark 

func (x *Backtest) GetBenchmark() string

func (*Backtest) GetEndDate 

func (x *Backtest) GetEndDate() *pb.Date

func (*Backtest) GetName 

func (x *Backtest) GetName() string

func (*Backtest) GetStartDate 

func (x *Backtest) GetStartDate() *pb.Date

func (*Backtest) GetStatuses 

func (x *Backtest) GetStatuses() []*Backtest_Status

func (*Backtest) GetSymbols 

func (x *Backtest) GetSymbols() []string

func (*Backtest) ProtoMessage 

func (*Backtest) ProtoMessage()

func (*Backtest) ProtoReflect 

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

func (*Backtest) Reset 

func (x *Backtest) Reset()

func (*Backtest) String 

func (x *Backtest) String() string

type BacktestServicerClient 

type BacktestServicerClient interface {
	ListBacktests(ctx context.Context, in *ListBacktestsRequest, opts ...grpc.CallOption) (*ListBacktestsResponse, error)
	CreateBacktest(ctx context.Context, in *CreateBacktestRequest, opts ...grpc.CallOption) (*CreateBacktestResponse, error)
	GetBacktest(ctx context.Context, in *GetBacktestRequest, opts ...grpc.CallOption) (*GetBacktestResponse, error)
	CreateSession(ctx context.Context, in *CreateSessionRequest, opts ...grpc.CallOption) (*CreateSessionResponse, error)
	GetSession(ctx context.Context, in *GetSessionRequest, opts ...grpc.CallOption) (*GetSessionResponse, error)
	ListExecutions(ctx context.Context, in *ListExecutionsRequest, opts ...grpc.CallOption) (*ListExecutionsResponse, error)
	GetExecution(ctx context.Context, in *GetExecutionRequest, opts ...grpc.CallOption) (*GetExecutionResponse, error)
}

BacktestServicerClient is the client API for BacktestServicer 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 NewBacktestServicerClient 

func NewBacktestServicerClient(cc grpc.ClientConnInterface) BacktestServicerClient

type BacktestServicerServer 

type BacktestServicerServer interface {
	ListBacktests(context.Context, *ListBacktestsRequest) (*ListBacktestsResponse, error)
	CreateBacktest(context.Context, *CreateBacktestRequest) (*CreateBacktestResponse, error)
	GetBacktest(context.Context, *GetBacktestRequest) (*GetBacktestResponse, error)
	CreateSession(context.Context, *CreateSessionRequest) (*CreateSessionResponse, error)
	GetSession(context.Context, *GetSessionRequest) (*GetSessionResponse, error)
	ListExecutions(context.Context, *ListExecutionsRequest) (*ListExecutionsResponse, error)
	GetExecution(context.Context, *GetExecutionRequest) (*GetExecutionResponse, error)
	// contains filtered or unexported methods
}

BacktestServicerServer is the server API for BacktestServicer service. All implementations must embed UnimplementedBacktestServicerServer for forward compatibility.

type Backtest_Status 

type Backtest_Status struct {
	Status     Backtest_Status_Status `protobuf:"varint,1,opt,name=status,proto3,enum=foreverbull.backtest.Backtest_Status_Status" json:"status,omitempty"`
	Error      *string                `protobuf:"bytes,2,opt,name=error,proto3,oneof" json:"error,omitempty"`
	OccurredAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Backtest_Status) Descriptor deprecated 

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

Deprecated: Use Backtest_Status.ProtoReflect.Descriptor instead.

func (*Backtest_Status) GetError 

func (x *Backtest_Status) GetError() string

func (*Backtest_Status) GetOccurredAt 

func (x *Backtest_Status) GetOccurredAt() *timestamppb.Timestamp

func (*Backtest_Status) GetStatus 

func (x *Backtest_Status) GetStatus() Backtest_Status_Status

func (*Backtest_Status) ProtoMessage 

func (*Backtest_Status) ProtoMessage()

func (*Backtest_Status) ProtoReflect 

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

func (*Backtest_Status) Reset 

func (x *Backtest_Status) Reset()

func (*Backtest_Status) String 

func (x *Backtest_Status) String() string

type Backtest_Status_Status 

type Backtest_Status_Status int32
const (
	Backtest_Status_CREATED Backtest_Status_Status = 0
	Backtest_Status_READY   Backtest_Status_Status = 1
	Backtest_Status_ERROR   Backtest_Status_Status = 2
)

func (Backtest_Status_Status) Descriptor 

func (Backtest_Status_Status) Descriptor() protoreflect.EnumDescriptor

func (Backtest_Status_Status) Enum 

func (x Backtest_Status_Status) Enum() *Backtest_Status_Status

func (Backtest_Status_Status) EnumDescriptor deprecated 

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

Deprecated: Use Backtest_Status_Status.Descriptor instead.

func (Backtest_Status_Status) Number 

func (x Backtest_Status_Status) Number() protoreflect.EnumNumber

func (Backtest_Status_Status) String 

func (x Backtest_Status_Status) String() string

func (Backtest_Status_Status) Type 

func (Backtest_Status_Status) Type() protoreflect.EnumType

type CreateBacktestRequest 

type CreateBacktestRequest struct {
	Backtest *Backtest `protobuf:"bytes,1,opt,name=backtest,proto3" json:"backtest,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBacktestRequest) Descriptor deprecated 

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

Deprecated: Use CreateBacktestRequest.ProtoReflect.Descriptor instead.

func (*CreateBacktestRequest) GetBacktest 

func (x *CreateBacktestRequest) GetBacktest() *Backtest

func (*CreateBacktestRequest) ProtoMessage 

func (*CreateBacktestRequest) ProtoMessage()

func (*CreateBacktestRequest) ProtoReflect 

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

func (*CreateBacktestRequest) Reset 

func (x *CreateBacktestRequest) Reset()

func (*CreateBacktestRequest) String 

func (x *CreateBacktestRequest) String() string

type CreateBacktestResponse 

type CreateBacktestResponse struct {
	Backtest *Backtest `protobuf:"bytes,1,opt,name=backtest,proto3" json:"backtest,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateBacktestResponse) Descriptor deprecated 

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

Deprecated: Use CreateBacktestResponse.ProtoReflect.Descriptor instead.

func (*CreateBacktestResponse) GetBacktest 

func (x *CreateBacktestResponse) GetBacktest() *Backtest

func (*CreateBacktestResponse) ProtoMessage 

func (*CreateBacktestResponse) ProtoMessage()

func (*CreateBacktestResponse) ProtoReflect 

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

func (*CreateBacktestResponse) Reset 

func (x *CreateBacktestResponse) Reset()

func (*CreateBacktestResponse) String 

func (x *CreateBacktestResponse) String() string

type CreateExecutionRequest 

type CreateExecutionRequest struct {
	Backtest  *Backtest     `protobuf:"bytes,1,opt,name=backtest,proto3" json:"backtest,omitempty"`
	Algorithm *pb.Algorithm `protobuf:"bytes,2,opt,name=algorithm,proto3" json:"algorithm,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateExecutionRequest) Descriptor deprecated 

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

Deprecated: Use CreateExecutionRequest.ProtoReflect.Descriptor instead.

func (*CreateExecutionRequest) GetAlgorithm 

func (x *CreateExecutionRequest) GetAlgorithm() *pb.Algorithm

func (*CreateExecutionRequest) GetBacktest 

func (x *CreateExecutionRequest) GetBacktest() *Backtest

func (*CreateExecutionRequest) ProtoMessage 

func (*CreateExecutionRequest) ProtoMessage()

func (*CreateExecutionRequest) ProtoReflect 

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

func (*CreateExecutionRequest) Reset 

func (x *CreateExecutionRequest) Reset()

func (*CreateExecutionRequest) String 

func (x *CreateExecutionRequest) String() string

type CreateExecutionResponse 

type CreateExecutionResponse struct {
	Execution     *Execution                 `protobuf:"bytes,1,opt,name=execution,proto3" json:"execution,omitempty"`
	Configuration *pb.ExecutionConfiguration `protobuf:"bytes,2,opt,name=configuration,proto3" json:"configuration,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateExecutionResponse) Descriptor deprecated 

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

Deprecated: Use CreateExecutionResponse.ProtoReflect.Descriptor instead.

func (*CreateExecutionResponse) GetConfiguration 

func (x *CreateExecutionResponse) GetConfiguration() *pb.ExecutionConfiguration

func (*CreateExecutionResponse) GetExecution 

func (x *CreateExecutionResponse) GetExecution() *Execution

func (*CreateExecutionResponse) ProtoMessage 

func (*CreateExecutionResponse) ProtoMessage()

func (*CreateExecutionResponse) ProtoReflect 

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

func (*CreateExecutionResponse) Reset 

func (x *CreateExecutionResponse) Reset()

func (*CreateExecutionResponse) String 

func (x *CreateExecutionResponse) String() string

type CreateSessionRequest 

type CreateSessionRequest struct {
	BacktestName string `protobuf:"bytes,1,opt,name=backtest_name,json=backtestName,proto3" json:"backtest_name,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSessionRequest) Descriptor deprecated 

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

Deprecated: Use CreateSessionRequest.ProtoReflect.Descriptor instead.

func (*CreateSessionRequest) GetBacktestName 

func (x *CreateSessionRequest) GetBacktestName() string

func (*CreateSessionRequest) ProtoMessage 

func (*CreateSessionRequest) ProtoMessage()

func (*CreateSessionRequest) ProtoReflect 

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

func (*CreateSessionRequest) Reset 

func (x *CreateSessionRequest) Reset()

func (*CreateSessionRequest) String 

func (x *CreateSessionRequest) String() string

type CreateSessionResponse 

type CreateSessionResponse struct {
	Session *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateSessionResponse) Descriptor deprecated 

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

Deprecated: Use CreateSessionResponse.ProtoReflect.Descriptor instead.

func (*CreateSessionResponse) GetSession 

func (x *CreateSessionResponse) GetSession() *Session

func (*CreateSessionResponse) ProtoMessage 

func (*CreateSessionResponse) ProtoMessage()

func (*CreateSessionResponse) ProtoReflect 

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

func (*CreateSessionResponse) Reset 

func (x *CreateSessionResponse) Reset()

func (*CreateSessionResponse) String 

func (x *CreateSessionResponse) String() string

type DownloadIngestionRequest 

type DownloadIngestionRequest struct {
	Bucket string `protobuf:"bytes,1,opt,name=bucket,proto3" json:"bucket,omitempty"`
	Object string `protobuf:"bytes,2,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadIngestionRequest) Descriptor deprecated 

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

Deprecated: Use DownloadIngestionRequest.ProtoReflect.Descriptor instead.

func (*DownloadIngestionRequest) GetBucket 

func (x *DownloadIngestionRequest) GetBucket() string

func (*DownloadIngestionRequest) GetObject 

func (x *DownloadIngestionRequest) GetObject() string

func (*DownloadIngestionRequest) ProtoMessage 

func (*DownloadIngestionRequest) ProtoMessage()

func (*DownloadIngestionRequest) ProtoReflect 

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

func (*DownloadIngestionRequest) Reset 

func (x *DownloadIngestionRequest) Reset()

func (*DownloadIngestionRequest) String 

func (x *DownloadIngestionRequest) String() string

type DownloadIngestionResponse 

type DownloadIngestionResponse struct {
	Ingestion *Ingestion `protobuf:"bytes,1,opt,name=ingestion,proto3" json:"ingestion,omitempty"`
	// contains filtered or unexported fields
}

func (*DownloadIngestionResponse) Descriptor deprecated 

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

Deprecated: Use DownloadIngestionResponse.ProtoReflect.Descriptor instead.

func (*DownloadIngestionResponse) GetIngestion 

func (x *DownloadIngestionResponse) GetIngestion() *Ingestion

func (*DownloadIngestionResponse) ProtoMessage 

func (*DownloadIngestionResponse) ProtoMessage()

func (*DownloadIngestionResponse) ProtoReflect 

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

func (*DownloadIngestionResponse) Reset 

func (x *DownloadIngestionResponse) Reset()

func (*DownloadIngestionResponse) String 

func (x *DownloadIngestionResponse) String() string

type EngineClient 

type EngineClient interface {
	DownloadIngestion(ctx context.Context, in *DownloadIngestionRequest, opts ...grpc.CallOption) (*DownloadIngestionResponse, error)
	Ingest(ctx context.Context, in *IngestRequest, opts ...grpc.CallOption) (*IngestResponse, error)
	RunBacktest(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunResponse, error)
	GetCurrentPeriod(ctx context.Context, in *GetCurrentPeriodRequest, opts ...grpc.CallOption) (*GetCurrentPeriodResponse, error)
	PlaceOrdersAndContinue(ctx context.Context, in *PlaceOrdersAndContinueRequest, opts ...grpc.CallOption) (*PlaceOrdersAndContinueResponse, error)
	GetResult(ctx context.Context, in *GetResultRequest, opts ...grpc.CallOption) (*GetResultResponse, error)
	Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)
}

EngineClient is the client API for Engine 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 NewEngineClient 

func NewEngineClient(cc grpc.ClientConnInterface) EngineClient

type EngineServer 

type EngineServer interface {
	DownloadIngestion(context.Context, *DownloadIngestionRequest) (*DownloadIngestionResponse, error)
	Ingest(context.Context, *IngestRequest) (*IngestResponse, error)
	RunBacktest(context.Context, *RunRequest) (*RunResponse, error)
	GetCurrentPeriod(context.Context, *GetCurrentPeriodRequest) (*GetCurrentPeriodResponse, error)
	PlaceOrdersAndContinue(context.Context, *PlaceOrdersAndContinueRequest) (*PlaceOrdersAndContinueResponse, error)
	GetResult(context.Context, *GetResultRequest) (*GetResultResponse, error)
	Stop(context.Context, *StopRequest) (*StopResponse, error)
	// contains filtered or unexported methods
}

EngineServer is the server API for Engine service. All implementations must embed UnimplementedEngineServer for forward compatibility.

type Execution 

type Execution struct {
	Id        string              `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Backtest  string              `protobuf:"bytes,2,opt,name=backtest,proto3" json:"backtest,omitempty"`
	Session   string              `protobuf:"bytes,3,opt,name=session,proto3" json:"session,omitempty"`
	StartDate *pb.Date            `protobuf:"bytes,4,opt,name=start_date,json=startDate,proto3" json:"start_date,omitempty"`
	EndDate   *pb.Date            `protobuf:"bytes,5,opt,name=end_date,json=endDate,proto3" json:"end_date,omitempty"`
	Benchmark *string             `protobuf:"bytes,6,opt,name=benchmark,proto3,oneof" json:"benchmark,omitempty"`
	Symbols   []string            `protobuf:"bytes,7,rep,name=symbols,proto3" json:"symbols,omitempty"`
	Statuses  []*Execution_Status `protobuf:"bytes,8,rep,name=statuses,proto3" json:"statuses,omitempty"`
	Result    *Period             `protobuf:"bytes,9,opt,name=result,proto3,oneof" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*Execution) Descriptor deprecated 

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

Deprecated: Use Execution.ProtoReflect.Descriptor instead.

func (*Execution) GetBacktest 

func (x *Execution) GetBacktest() string

func (*Execution) GetBenchmark 

func (x *Execution) GetBenchmark() string

func (*Execution) GetEndDate 

func (x *Execution) GetEndDate() *pb.Date

func (*Execution) GetId 

func (x *Execution) GetId() string

func (*Execution) GetResult 

func (x *Execution) GetResult() *Period

func (*Execution) GetSession 

func (x *Execution) GetSession() string

func (*Execution) GetStartDate 

func (x *Execution) GetStartDate() *pb.Date

func (*Execution) GetStatuses 

func (x *Execution) GetStatuses() []*Execution_Status

func (*Execution) GetSymbols 

func (x *Execution) GetSymbols() []string

func (*Execution) ProtoMessage 

func (*Execution) ProtoMessage()

func (*Execution) ProtoReflect 

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

func (*Execution) Reset 

func (x *Execution) Reset()

func (*Execution) String 

func (x *Execution) String() string

type Execution_Status 

type Execution_Status struct {
	Status     Execution_Status_Status `protobuf:"varint,1,opt,name=status,proto3,enum=foreverbull.backtest.Execution_Status_Status" json:"status,omitempty"`
	Error      *string                 `protobuf:"bytes,2,opt,name=error,proto3,oneof" json:"error,omitempty"`
	OccurredAt *timestamppb.Timestamp  `protobuf:"bytes,3,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Execution_Status) Descriptor deprecated 

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

Deprecated: Use Execution_Status.ProtoReflect.Descriptor instead.

func (*Execution_Status) GetError 

func (x *Execution_Status) GetError() string

func (*Execution_Status) GetOccurredAt 

func (x *Execution_Status) GetOccurredAt() *timestamppb.Timestamp

func (*Execution_Status) GetStatus 

func (x *Execution_Status) GetStatus() Execution_Status_Status

func (*Execution_Status) ProtoMessage 

func (*Execution_Status) ProtoMessage()

func (*Execution_Status) ProtoReflect 

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

func (*Execution_Status) Reset 

func (x *Execution_Status) Reset()

func (*Execution_Status) String 

func (x *Execution_Status) String() string

type Execution_Status_Status 

type Execution_Status_Status int32
const (
	Execution_Status_CREATED   Execution_Status_Status = 0
	Execution_Status_RUNNING   Execution_Status_Status = 1
	Execution_Status_COMPLETED Execution_Status_Status = 2
	Execution_Status_FAILED    Execution_Status_Status = 3
)

func (Execution_Status_Status) Descriptor 

func (Execution_Status_Status) Descriptor() protoreflect.EnumDescriptor

func (Execution_Status_Status) Enum 

func (x Execution_Status_Status) Enum() *Execution_Status_Status

func (Execution_Status_Status) EnumDescriptor deprecated 

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

Deprecated: Use Execution_Status_Status.Descriptor instead.

func (Execution_Status_Status) Number 

func (x Execution_Status_Status) Number() protoreflect.EnumNumber

func (Execution_Status_Status) String 

func (x Execution_Status_Status) String() string

func (Execution_Status_Status) Type 

func (Execution_Status_Status) Type() protoreflect.EnumType

type GetBacktestRequest 

type GetBacktestRequest struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBacktestRequest) Descriptor deprecated 

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

Deprecated: Use GetBacktestRequest.ProtoReflect.Descriptor instead.

func (*GetBacktestRequest) GetName 

func (x *GetBacktestRequest) GetName() string

func (*GetBacktestRequest) ProtoMessage 

func (*GetBacktestRequest) ProtoMessage()

func (*GetBacktestRequest) ProtoReflect 

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

func (*GetBacktestRequest) Reset 

func (x *GetBacktestRequest) Reset()

func (*GetBacktestRequest) String 

func (x *GetBacktestRequest) String() string

type GetBacktestResponse 

type GetBacktestResponse struct {
	Name     string    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Backtest *Backtest `protobuf:"bytes,2,opt,name=backtest,proto3" json:"backtest,omitempty"`
	// contains filtered or unexported fields
}

func (*GetBacktestResponse) Descriptor deprecated 

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

Deprecated: Use GetBacktestResponse.ProtoReflect.Descriptor instead.

func (*GetBacktestResponse) GetBacktest 

func (x *GetBacktestResponse) GetBacktest() *Backtest

func (*GetBacktestResponse) GetName 

func (x *GetBacktestResponse) GetName() string

func (*GetBacktestResponse) ProtoMessage 

func (*GetBacktestResponse) ProtoMessage()

func (*GetBacktestResponse) ProtoReflect 

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

func (*GetBacktestResponse) Reset 

func (x *GetBacktestResponse) Reset()

func (*GetBacktestResponse) String 

func (x *GetBacktestResponse) String() string

type GetCurrentIngestionRequest 

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

func (*GetCurrentIngestionRequest) Descriptor deprecated 

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

Deprecated: Use GetCurrentIngestionRequest.ProtoReflect.Descriptor instead.

func (*GetCurrentIngestionRequest) ProtoMessage 

func (*GetCurrentIngestionRequest) ProtoMessage()

func (*GetCurrentIngestionRequest) ProtoReflect 

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

func (*GetCurrentIngestionRequest) Reset 

func (x *GetCurrentIngestionRequest) Reset()

func (*GetCurrentIngestionRequest) String 

func (x *GetCurrentIngestionRequest) String() string

type GetCurrentIngestionResponse 

type GetCurrentIngestionResponse struct {
	Ingestion *Ingestion      `protobuf:"bytes,1,opt,name=ingestion,proto3" json:"ingestion,omitempty"`
	Status    IngestionStatus `protobuf:"varint,2,opt,name=status,proto3,enum=foreverbull.backtest.IngestionStatus" json:"status,omitempty"`
	Size      int64           `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCurrentIngestionResponse) Descriptor deprecated 

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

Deprecated: Use GetCurrentIngestionResponse.ProtoReflect.Descriptor instead.

func (*GetCurrentIngestionResponse) GetIngestion 

func (x *GetCurrentIngestionResponse) GetIngestion() *Ingestion

func (*GetCurrentIngestionResponse) GetSize 

func (x *GetCurrentIngestionResponse) GetSize() int64

func (*GetCurrentIngestionResponse) GetStatus 

func (x *GetCurrentIngestionResponse) GetStatus() IngestionStatus

func (*GetCurrentIngestionResponse) ProtoMessage 

func (*GetCurrentIngestionResponse) ProtoMessage()

func (*GetCurrentIngestionResponse) ProtoReflect 

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

func (*GetCurrentIngestionResponse) Reset 

func (x *GetCurrentIngestionResponse) Reset()

func (*GetCurrentIngestionResponse) String 

func (x *GetCurrentIngestionResponse) String() string

type GetCurrentPeriodRequest 

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

func (*GetCurrentPeriodRequest) Descriptor deprecated 

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

Deprecated: Use GetCurrentPeriodRequest.ProtoReflect.Descriptor instead.

func (*GetCurrentPeriodRequest) ProtoMessage 

func (*GetCurrentPeriodRequest) ProtoMessage()

func (*GetCurrentPeriodRequest) ProtoReflect 

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

func (*GetCurrentPeriodRequest) Reset 

func (x *GetCurrentPeriodRequest) Reset()

func (*GetCurrentPeriodRequest) String 

func (x *GetCurrentPeriodRequest) String() string

type GetCurrentPeriodResponse 

type GetCurrentPeriodResponse struct {
	IsRunning bool          `protobuf:"varint,1,opt,name=is_running,json=isRunning,proto3" json:"is_running,omitempty"`
	Portfolio *pb.Portfolio `protobuf:"bytes,2,opt,name=portfolio,proto3,oneof" json:"portfolio,omitempty"`
	// contains filtered or unexported fields
}

func (*GetCurrentPeriodResponse) Descriptor deprecated 

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

Deprecated: Use GetCurrentPeriodResponse.ProtoReflect.Descriptor instead.

func (*GetCurrentPeriodResponse) GetIsRunning 

func (x *GetCurrentPeriodResponse) GetIsRunning() bool

func (*GetCurrentPeriodResponse) GetPortfolio 

func (x *GetCurrentPeriodResponse) GetPortfolio() *pb.Portfolio

func (*GetCurrentPeriodResponse) ProtoMessage 

func (*GetCurrentPeriodResponse) ProtoMessage()

func (*GetCurrentPeriodResponse) ProtoReflect 

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

func (*GetCurrentPeriodResponse) Reset 

func (x *GetCurrentPeriodResponse) Reset()

func (*GetCurrentPeriodResponse) String 

func (x *GetCurrentPeriodResponse) String() string

type GetExecutionRequest 

type GetExecutionRequest struct {
	ExecutionId string `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetExecutionRequest) Descriptor deprecated 

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

Deprecated: Use GetExecutionRequest.ProtoReflect.Descriptor instead.

func (*GetExecutionRequest) GetExecutionId 

func (x *GetExecutionRequest) GetExecutionId() string

func (*GetExecutionRequest) ProtoMessage 

func (*GetExecutionRequest) ProtoMessage()

func (*GetExecutionRequest) ProtoReflect 

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

func (*GetExecutionRequest) Reset 

func (x *GetExecutionRequest) Reset()

func (*GetExecutionRequest) String 

func (x *GetExecutionRequest) String() string

type GetExecutionResponse 

type GetExecutionResponse struct {
	Execution *Execution `protobuf:"bytes,1,opt,name=execution,proto3" json:"execution,omitempty"`
	Periods   []*Period  `protobuf:"bytes,2,rep,name=periods,proto3" json:"periods,omitempty"`
	// contains filtered or unexported fields
}

func (*GetExecutionResponse) Descriptor deprecated 

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

Deprecated: Use GetExecutionResponse.ProtoReflect.Descriptor instead.

func (*GetExecutionResponse) GetExecution 

func (x *GetExecutionResponse) GetExecution() *Execution

func (*GetExecutionResponse) GetPeriods 

func (x *GetExecutionResponse) GetPeriods() []*Period

func (*GetExecutionResponse) ProtoMessage 

func (*GetExecutionResponse) ProtoMessage()

func (*GetExecutionResponse) ProtoReflect 

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

func (*GetExecutionResponse) Reset 

func (x *GetExecutionResponse) Reset()

func (*GetExecutionResponse) String 

func (x *GetExecutionResponse) String() string

type GetResultRequest 

type GetResultRequest struct {
	Execution string `protobuf:"bytes,1,opt,name=execution,proto3" json:"execution,omitempty"`
	Upload    bool   `protobuf:"varint,2,opt,name=upload,proto3" json:"upload,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResultRequest) Descriptor deprecated 

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

Deprecated: Use GetResultRequest.ProtoReflect.Descriptor instead.

func (*GetResultRequest) GetExecution 

func (x *GetResultRequest) GetExecution() string

func (*GetResultRequest) GetUpload 

func (x *GetResultRequest) GetUpload() bool

func (*GetResultRequest) ProtoMessage 

func (*GetResultRequest) ProtoMessage()

func (*GetResultRequest) ProtoReflect 

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

func (*GetResultRequest) Reset 

func (x *GetResultRequest) Reset()

func (*GetResultRequest) String 

func (x *GetResultRequest) String() string

type GetResultResponse 

type GetResultResponse struct {
	Periods []*Period `protobuf:"bytes,1,rep,name=periods,proto3" json:"periods,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResultResponse) Descriptor deprecated 

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

Deprecated: Use GetResultResponse.ProtoReflect.Descriptor instead.

func (*GetResultResponse) GetPeriods 

func (x *GetResultResponse) GetPeriods() []*Period

func (*GetResultResponse) ProtoMessage 

func (*GetResultResponse) ProtoMessage()

func (*GetResultResponse) ProtoReflect 

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

func (*GetResultResponse) Reset 

func (x *GetResultResponse) Reset()

func (*GetResultResponse) String 

func (x *GetResultResponse) String() string

type GetSessionRequest 

type GetSessionRequest struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSessionRequest) Descriptor deprecated 

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

Deprecated: Use GetSessionRequest.ProtoReflect.Descriptor instead.

func (*GetSessionRequest) GetSessionId 

func (x *GetSessionRequest) GetSessionId() string

func (*GetSessionRequest) ProtoMessage 

func (*GetSessionRequest) ProtoMessage()

func (*GetSessionRequest) ProtoReflect 

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

func (*GetSessionRequest) Reset 

func (x *GetSessionRequest) Reset()

func (*GetSessionRequest) String 

func (x *GetSessionRequest) String() string

type GetSessionResponse 

type GetSessionResponse struct {
	Session *Session `protobuf:"bytes,1,opt,name=session,proto3" json:"session,omitempty"`
	// contains filtered or unexported fields
}

func (*GetSessionResponse) Descriptor deprecated 

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

Deprecated: Use GetSessionResponse.ProtoReflect.Descriptor instead.

func (*GetSessionResponse) GetSession 

func (x *GetSessionResponse) GetSession() *Session

func (*GetSessionResponse) ProtoMessage 

func (*GetSessionResponse) ProtoMessage()

func (*GetSessionResponse) ProtoReflect 

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

func (*GetSessionResponse) Reset 

func (x *GetSessionResponse) Reset()

func (*GetSessionResponse) String 

func (x *GetSessionResponse) String() string

type IngestRequest 

type IngestRequest struct {
	Ingestion *Ingestion `protobuf:"bytes,1,opt,name=ingestion,proto3" json:"ingestion,omitempty"`
	Bucket    *string    `protobuf:"bytes,2,opt,name=bucket,proto3,oneof" json:"bucket,omitempty"`
	Object    *string    `protobuf:"bytes,3,opt,name=object,proto3,oneof" json:"object,omitempty"`
	// contains filtered or unexported fields
}

func (*IngestRequest) Descriptor deprecated 

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

Deprecated: Use IngestRequest.ProtoReflect.Descriptor instead.

func (*IngestRequest) GetBucket 

func (x *IngestRequest) GetBucket() string

func (*IngestRequest) GetIngestion 

func (x *IngestRequest) GetIngestion() *Ingestion

func (*IngestRequest) GetObject 

func (x *IngestRequest) GetObject() string

func (*IngestRequest) ProtoMessage 

func (*IngestRequest) ProtoMessage()

func (*IngestRequest) ProtoReflect 

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

func (*IngestRequest) Reset 

func (x *IngestRequest) Reset()

func (*IngestRequest) String 

func (x *IngestRequest) String() string

type IngestResponse 

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

func (*IngestResponse) Descriptor deprecated 

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

Deprecated: Use IngestResponse.ProtoReflect.Descriptor instead.

func (*IngestResponse) ProtoMessage 

func (*IngestResponse) ProtoMessage()

func (*IngestResponse) ProtoReflect 

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

func (*IngestResponse) Reset 

func (x *IngestResponse) Reset()

func (*IngestResponse) String 

func (x *IngestResponse) String() string

type Ingestion 

type Ingestion struct {
	StartDate *pb.Date `protobuf:"bytes,1,opt,name=start_date,json=startDate,proto3" json:"start_date,omitempty"`
	EndDate   *pb.Date `protobuf:"bytes,2,opt,name=end_date,json=endDate,proto3" json:"end_date,omitempty"`
	Symbols   []string `protobuf:"bytes,3,rep,name=symbols,proto3" json:"symbols,omitempty"`
	// contains filtered or unexported fields
}

func (*Ingestion) Descriptor deprecated 

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

Deprecated: Use Ingestion.ProtoReflect.Descriptor instead.

func (*Ingestion) GetEndDate 

func (x *Ingestion) GetEndDate() *pb.Date

func (*Ingestion) GetStartDate 

func (x *Ingestion) GetStartDate() *pb.Date

func (*Ingestion) GetSymbols 

func (x *Ingestion) GetSymbols() []string

func (*Ingestion) ProtoMessage 

func (*Ingestion) ProtoMessage()

func (*Ingestion) ProtoReflect 

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

func (*Ingestion) Reset 

func (x *Ingestion) Reset()

func (*Ingestion) String 

func (x *Ingestion) String() string

type IngestionServicerClient 

type IngestionServicerClient interface {
	GetCurrentIngestion(ctx context.Context, in *GetCurrentIngestionRequest, opts ...grpc.CallOption) (*GetCurrentIngestionResponse, error)
	UpdateIngestion(ctx context.Context, in *UpdateIngestionRequest, opts ...grpc.CallOption) (*UpdateIngestionResponse, error)
}

IngestionServicerClient is the client API for IngestionServicer 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 NewIngestionServicerClient 

func NewIngestionServicerClient(cc grpc.ClientConnInterface) IngestionServicerClient

type IngestionServicerServer 

type IngestionServicerServer interface {
	GetCurrentIngestion(context.Context, *GetCurrentIngestionRequest) (*GetCurrentIngestionResponse, error)
	UpdateIngestion(context.Context, *UpdateIngestionRequest) (*UpdateIngestionResponse, error)
	// contains filtered or unexported methods
}

IngestionServicerServer is the server API for IngestionServicer service. All implementations must embed UnimplementedIngestionServicerServer for forward compatibility.

type IngestionStatus 

type IngestionStatus int32
const (
	IngestionStatus_CREATED   IngestionStatus = 0
	IngestionStatus_INGESTING IngestionStatus = 1
	IngestionStatus_READY     IngestionStatus = 2
)

func (IngestionStatus) Descriptor 

func (IngestionStatus) Descriptor() protoreflect.EnumDescriptor

func (IngestionStatus) Enum 

func (x IngestionStatus) Enum() *IngestionStatus

func (IngestionStatus) EnumDescriptor deprecated 

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

Deprecated: Use IngestionStatus.Descriptor instead.

func (IngestionStatus) Number 

func (x IngestionStatus) Number() protoreflect.EnumNumber

func (IngestionStatus) String 

func (x IngestionStatus) String() string

func (IngestionStatus) Type 

func (IngestionStatus) Type() protoreflect.EnumType

type ListBacktestsRequest 

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

func (*ListBacktestsRequest) Descriptor deprecated 

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

Deprecated: Use ListBacktestsRequest.ProtoReflect.Descriptor instead.

func (*ListBacktestsRequest) ProtoMessage 

func (*ListBacktestsRequest) ProtoMessage()

func (*ListBacktestsRequest) ProtoReflect 

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

func (*ListBacktestsRequest) Reset 

func (x *ListBacktestsRequest) Reset()

func (*ListBacktestsRequest) String 

func (x *ListBacktestsRequest) String() string

type ListBacktestsResponse 

type ListBacktestsResponse struct {
	Backtests []*Backtest `protobuf:"bytes,1,rep,name=backtests,proto3" json:"backtests,omitempty"`
	// contains filtered or unexported fields
}

func (*ListBacktestsResponse) Descriptor deprecated 

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

Deprecated: Use ListBacktestsResponse.ProtoReflect.Descriptor instead.

func (*ListBacktestsResponse) GetBacktests 

func (x *ListBacktestsResponse) GetBacktests() []*Backtest

func (*ListBacktestsResponse) ProtoMessage 

func (*ListBacktestsResponse) ProtoMessage()

func (*ListBacktestsResponse) ProtoReflect 

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

func (*ListBacktestsResponse) Reset 

func (x *ListBacktestsResponse) Reset()

func (*ListBacktestsResponse) String 

func (x *ListBacktestsResponse) String() string

type ListExecutionsRequest 

type ListExecutionsRequest struct {
	Backtest  string `protobuf:"bytes,1,opt,name=backtest,proto3" json:"backtest,omitempty"`
	SessionId string `protobuf:"bytes,2,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	// contains filtered or unexported fields
}

func (*ListExecutionsRequest) Descriptor deprecated 

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

Deprecated: Use ListExecutionsRequest.ProtoReflect.Descriptor instead.

func (*ListExecutionsRequest) GetBacktest 

func (x *ListExecutionsRequest) GetBacktest() string

func (*ListExecutionsRequest) GetSessionId 

func (x *ListExecutionsRequest) GetSessionId() string

func (*ListExecutionsRequest) ProtoMessage 

func (*ListExecutionsRequest) ProtoMessage()

func (*ListExecutionsRequest) ProtoReflect 

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

func (*ListExecutionsRequest) Reset 

func (x *ListExecutionsRequest) Reset()

func (*ListExecutionsRequest) String 

func (x *ListExecutionsRequest) String() string

type ListExecutionsResponse 

type ListExecutionsResponse struct {
	Executions []*Execution `protobuf:"bytes,1,rep,name=executions,proto3" json:"executions,omitempty"`
	// contains filtered or unexported fields
}

func (*ListExecutionsResponse) Descriptor deprecated 

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

Deprecated: Use ListExecutionsResponse.ProtoReflect.Descriptor instead.

func (*ListExecutionsResponse) GetExecutions 

func (x *ListExecutionsResponse) GetExecutions() []*Execution

func (*ListExecutionsResponse) ProtoMessage 

func (*ListExecutionsResponse) ProtoMessage()

func (*ListExecutionsResponse) ProtoReflect 

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

func (*ListExecutionsResponse) Reset 

func (x *ListExecutionsResponse) Reset()

func (*ListExecutionsResponse) String 

func (x *ListExecutionsResponse) String() string

type MockBacktestServicerClient 

type MockBacktestServicerClient struct {
	mock.Mock
}

MockBacktestServicerClient is an autogenerated mock type for the BacktestServicerClient type

func NewMockBacktestServicerClient 

func NewMockBacktestServicerClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockBacktestServicerClient

NewMockBacktestServicerClient creates a new instance of MockBacktestServicerClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockBacktestServicerClient) CreateBacktest 

func (_m *MockBacktestServicerClient) CreateBacktest(ctx context.Context, in *CreateBacktestRequest, opts ...grpc.CallOption) (*CreateBacktestResponse, error)

CreateBacktest provides a mock function with given fields: ctx, in, opts

func (*MockBacktestServicerClient) CreateSession 

func (_m *MockBacktestServicerClient) CreateSession(ctx context.Context, in *CreateSessionRequest, opts ...grpc.CallOption) (*CreateSessionResponse, error)

CreateSession provides a mock function with given fields: ctx, in, opts

func (*MockBacktestServicerClient) GetBacktest 

func (_m *MockBacktestServicerClient) GetBacktest(ctx context.Context, in *GetBacktestRequest, opts ...grpc.CallOption) (*GetBacktestResponse, error)

GetBacktest provides a mock function with given fields: ctx, in, opts

func (*MockBacktestServicerClient) GetExecution 

func (_m *MockBacktestServicerClient) GetExecution(ctx context.Context, in *GetExecutionRequest, opts ...grpc.CallOption) (*GetExecutionResponse, error)

GetExecution provides a mock function with given fields: ctx, in, opts

func (*MockBacktestServicerClient) GetSession 

func (_m *MockBacktestServicerClient) GetSession(ctx context.Context, in *GetSessionRequest, opts ...grpc.CallOption) (*GetSessionResponse, error)

GetSession provides a mock function with given fields: ctx, in, opts

func (*MockBacktestServicerClient) ListBacktests 

func (_m *MockBacktestServicerClient) ListBacktests(ctx context.Context, in *ListBacktestsRequest, opts ...grpc.CallOption) (*ListBacktestsResponse, error)

ListBacktests provides a mock function with given fields: ctx, in, opts

func (*MockBacktestServicerClient) ListExecutions 

func (_m *MockBacktestServicerClient) ListExecutions(ctx context.Context, in *ListExecutionsRequest, opts ...grpc.CallOption) (*ListExecutionsResponse, error)

ListExecutions provides a mock function with given fields: ctx, in, opts

type MockBacktestServicerServer 

type MockBacktestServicerServer struct {
	mock.Mock
}

MockBacktestServicerServer is an autogenerated mock type for the BacktestServicerServer type

func NewMockBacktestServicerServer 

func NewMockBacktestServicerServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockBacktestServicerServer

NewMockBacktestServicerServer creates a new instance of MockBacktestServicerServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockBacktestServicerServer) CreateBacktest 

func (_m *MockBacktestServicerServer) CreateBacktest(_a0 context.Context, _a1 *CreateBacktestRequest) (*CreateBacktestResponse, error)

CreateBacktest provides a mock function with given fields: _a0, _a1

func (*MockBacktestServicerServer) CreateSession 

func (_m *MockBacktestServicerServer) CreateSession(_a0 context.Context, _a1 *CreateSessionRequest) (*CreateSessionResponse, error)

CreateSession provides a mock function with given fields: _a0, _a1

func (*MockBacktestServicerServer) GetBacktest 

func (_m *MockBacktestServicerServer) GetBacktest(_a0 context.Context, _a1 *GetBacktestRequest) (*GetBacktestResponse, error)

GetBacktest provides a mock function with given fields: _a0, _a1

func (*MockBacktestServicerServer) GetExecution 

func (_m *MockBacktestServicerServer) GetExecution(_a0 context.Context, _a1 *GetExecutionRequest) (*GetExecutionResponse, error)

GetExecution provides a mock function with given fields: _a0, _a1

func (*MockBacktestServicerServer) GetSession 

func (_m *MockBacktestServicerServer) GetSession(_a0 context.Context, _a1 *GetSessionRequest) (*GetSessionResponse, error)

GetSession provides a mock function with given fields: _a0, _a1

func (*MockBacktestServicerServer) ListBacktests 

func (_m *MockBacktestServicerServer) ListBacktests(_a0 context.Context, _a1 *ListBacktestsRequest) (*ListBacktestsResponse, error)

ListBacktests provides a mock function with given fields: _a0, _a1

func (*MockBacktestServicerServer) ListExecutions 

func (_m *MockBacktestServicerServer) ListExecutions(_a0 context.Context, _a1 *ListExecutionsRequest) (*ListExecutionsResponse, error)

ListExecutions provides a mock function with given fields: _a0, _a1

type MockEngineClient 

type MockEngineClient struct {
	mock.Mock
}

MockEngineClient is an autogenerated mock type for the EngineClient type

func NewMockEngineClient 

func NewMockEngineClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockEngineClient

NewMockEngineClient creates a new instance of MockEngineClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockEngineClient) DownloadIngestion 

func (_m *MockEngineClient) DownloadIngestion(ctx context.Context, in *DownloadIngestionRequest, opts ...grpc.CallOption) (*DownloadIngestionResponse, error)

DownloadIngestion provides a mock function with given fields: ctx, in, opts

func (*MockEngineClient) GetCurrentPeriod 

func (_m *MockEngineClient) GetCurrentPeriod(ctx context.Context, in *GetCurrentPeriodRequest, opts ...grpc.CallOption) (*GetCurrentPeriodResponse, error)

GetCurrentPeriod provides a mock function with given fields: ctx, in, opts

func (*MockEngineClient) GetResult 

func (_m *MockEngineClient) GetResult(ctx context.Context, in *GetResultRequest, opts ...grpc.CallOption) (*GetResultResponse, error)

GetResult provides a mock function with given fields: ctx, in, opts

func (*MockEngineClient) Ingest 

func (_m *MockEngineClient) Ingest(ctx context.Context, in *IngestRequest, opts ...grpc.CallOption) (*IngestResponse, error)

Ingest provides a mock function with given fields: ctx, in, opts

func (*MockEngineClient) PlaceOrdersAndContinue 

func (_m *MockEngineClient) PlaceOrdersAndContinue(ctx context.Context, in *PlaceOrdersAndContinueRequest, opts ...grpc.CallOption) (*PlaceOrdersAndContinueResponse, error)

PlaceOrdersAndContinue provides a mock function with given fields: ctx, in, opts

func (*MockEngineClient) RunBacktest 

func (_m *MockEngineClient) RunBacktest(ctx context.Context, in *RunRequest, opts ...grpc.CallOption) (*RunResponse, error)

RunBacktest provides a mock function with given fields: ctx, in, opts

func (*MockEngineClient) Stop 

func (_m *MockEngineClient) Stop(ctx context.Context, in *StopRequest, opts ...grpc.CallOption) (*StopResponse, error)

Stop provides a mock function with given fields: ctx, in, opts

type MockEngineServer 

type MockEngineServer struct {
	mock.Mock
}

MockEngineServer is an autogenerated mock type for the EngineServer type

func NewMockEngineServer 

func NewMockEngineServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockEngineServer

NewMockEngineServer creates a new instance of MockEngineServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockEngineServer) DownloadIngestion 

func (_m *MockEngineServer) DownloadIngestion(_a0 context.Context, _a1 *DownloadIngestionRequest) (*DownloadIngestionResponse, error)

DownloadIngestion provides a mock function with given fields: _a0, _a1

func (*MockEngineServer) GetCurrentPeriod 

func (_m *MockEngineServer) GetCurrentPeriod(_a0 context.Context, _a1 *GetCurrentPeriodRequest) (*GetCurrentPeriodResponse, error)

GetCurrentPeriod provides a mock function with given fields: _a0, _a1

func (*MockEngineServer) GetResult 

func (_m *MockEngineServer) GetResult(_a0 context.Context, _a1 *GetResultRequest) (*GetResultResponse, error)

GetResult provides a mock function with given fields: _a0, _a1

func (*MockEngineServer) Ingest 

func (_m *MockEngineServer) Ingest(_a0 context.Context, _a1 *IngestRequest) (*IngestResponse, error)

Ingest provides a mock function with given fields: _a0, _a1

func (*MockEngineServer) PlaceOrdersAndContinue 

func (_m *MockEngineServer) PlaceOrdersAndContinue(_a0 context.Context, _a1 *PlaceOrdersAndContinueRequest) (*PlaceOrdersAndContinueResponse, error)

PlaceOrdersAndContinue provides a mock function with given fields: _a0, _a1

func (*MockEngineServer) RunBacktest 

func (_m *MockEngineServer) RunBacktest(_a0 context.Context, _a1 *RunRequest) (*RunResponse, error)

RunBacktest provides a mock function with given fields: _a0, _a1

func (*MockEngineServer) Stop 

func (_m *MockEngineServer) Stop(_a0 context.Context, _a1 *StopRequest) (*StopResponse, error)

Stop provides a mock function with given fields: _a0, _a1

type MockIngestionServicerClient 

type MockIngestionServicerClient struct {
	mock.Mock
}

MockIngestionServicerClient is an autogenerated mock type for the IngestionServicerClient type

func NewMockIngestionServicerClient 

func NewMockIngestionServicerClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockIngestionServicerClient

NewMockIngestionServicerClient creates a new instance of MockIngestionServicerClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockIngestionServicerClient) GetCurrentIngestion 

func (_m *MockIngestionServicerClient) GetCurrentIngestion(ctx context.Context, in *GetCurrentIngestionRequest, opts ...grpc.CallOption) (*GetCurrentIngestionResponse, error)

GetCurrentIngestion provides a mock function with given fields: ctx, in, opts

func (*MockIngestionServicerClient) UpdateIngestion 

func (_m *MockIngestionServicerClient) UpdateIngestion(ctx context.Context, in *UpdateIngestionRequest, opts ...grpc.CallOption) (*UpdateIngestionResponse, error)

UpdateIngestion provides a mock function with given fields: ctx, in, opts

type MockIngestionServicerServer 

type MockIngestionServicerServer struct {
	mock.Mock
}

MockIngestionServicerServer is an autogenerated mock type for the IngestionServicerServer type

func NewMockIngestionServicerServer 

func NewMockIngestionServicerServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockIngestionServicerServer

NewMockIngestionServicerServer creates a new instance of MockIngestionServicerServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockIngestionServicerServer) GetCurrentIngestion 

func (_m *MockIngestionServicerServer) GetCurrentIngestion(_a0 context.Context, _a1 *GetCurrentIngestionRequest) (*GetCurrentIngestionResponse, error)

GetCurrentIngestion provides a mock function with given fields: _a0, _a1

func (*MockIngestionServicerServer) UpdateIngestion 

func (_m *MockIngestionServicerServer) UpdateIngestion(_a0 context.Context, _a1 *UpdateIngestionRequest) (*UpdateIngestionResponse, error)

UpdateIngestion provides a mock function with given fields: _a0, _a1

type MockSessionServicerClient 

type MockSessionServicerClient struct {
	mock.Mock
}

MockSessionServicerClient is an autogenerated mock type for the SessionServicerClient type

func NewMockSessionServicerClient 

func NewMockSessionServicerClient(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockSessionServicerClient

NewMockSessionServicerClient creates a new instance of MockSessionServicerClient. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockSessionServicerClient) CreateExecution 

func (_m *MockSessionServicerClient) CreateExecution(ctx context.Context, in *CreateExecutionRequest, opts ...grpc.CallOption) (*CreateExecutionResponse, error)

CreateExecution provides a mock function with given fields: ctx, in, opts

func (*MockSessionServicerClient) RunExecution 

func (_m *MockSessionServicerClient) RunExecution(ctx context.Context, in *RunExecutionRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[RunExecutionResponse], error)

RunExecution provides a mock function with given fields: ctx, in, opts

func (*MockSessionServicerClient) StopServer 

func (_m *MockSessionServicerClient) StopServer(ctx context.Context, in *StopServerRequest, opts ...grpc.CallOption) (*StopServerResponse, error)

StopServer provides a mock function with given fields: ctx, in, opts

func (*MockSessionServicerClient) StoreResult 

func (_m *MockSessionServicerClient) StoreResult(ctx context.Context, in *StoreExecutionResultRequest, opts ...grpc.CallOption) (*StoreExecutionResultResponse, error)

StoreResult provides a mock function with given fields: ctx, in, opts

type MockSessionServicerServer 

type MockSessionServicerServer struct {
	mock.Mock
}

MockSessionServicerServer is an autogenerated mock type for the SessionServicerServer type

func NewMockSessionServicerServer 

func NewMockSessionServicerServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockSessionServicerServer

NewMockSessionServicerServer creates a new instance of MockSessionServicerServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*MockSessionServicerServer) CreateExecution 

func (_m *MockSessionServicerServer) CreateExecution(_a0 context.Context, _a1 *CreateExecutionRequest) (*CreateExecutionResponse, error)

CreateExecution provides a mock function with given fields: _a0, _a1

func (*MockSessionServicerServer) RunExecution 

func (_m *MockSessionServicerServer) RunExecution(_a0 *RunExecutionRequest, _a1 grpc.ServerStreamingServer[RunExecutionResponse]) error

RunExecution provides a mock function with given fields: _a0, _a1

func (*MockSessionServicerServer) StopServer 

func (_m *MockSessionServicerServer) StopServer(_a0 context.Context, _a1 *StopServerRequest) (*StopServerResponse, error)

StopServer provides a mock function with given fields: _a0, _a1

func (*MockSessionServicerServer) StoreResult 

func (_m *MockSessionServicerServer) StoreResult(_a0 context.Context, _a1 *StoreExecutionResultRequest) (*StoreExecutionResultResponse, error)

StoreResult provides a mock function with given fields: _a0, _a1

type MockUnsafeBacktestServicerServer 

type MockUnsafeBacktestServicerServer struct {
	mock.Mock
}

MockUnsafeBacktestServicerServer is an autogenerated mock type for the UnsafeBacktestServicerServer type

func NewMockUnsafeBacktestServicerServer 

func NewMockUnsafeBacktestServicerServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockUnsafeBacktestServicerServer

NewMockUnsafeBacktestServicerServer creates a new instance of MockUnsafeBacktestServicerServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

type MockUnsafeEngineServer 

type MockUnsafeEngineServer struct {
	mock.Mock
}

MockUnsafeEngineServer is an autogenerated mock type for the UnsafeEngineServer type

func NewMockUnsafeEngineServer 

func NewMockUnsafeEngineServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockUnsafeEngineServer

NewMockUnsafeEngineServer creates a new instance of MockUnsafeEngineServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

type MockUnsafeIngestionServicerServer 

type MockUnsafeIngestionServicerServer struct {
	mock.Mock
}

MockUnsafeIngestionServicerServer is an autogenerated mock type for the UnsafeIngestionServicerServer type

func NewMockUnsafeIngestionServicerServer 

func NewMockUnsafeIngestionServicerServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockUnsafeIngestionServicerServer

NewMockUnsafeIngestionServicerServer creates a new instance of MockUnsafeIngestionServicerServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

type MockUnsafeSessionServicerServer 

type MockUnsafeSessionServicerServer struct {
	mock.Mock
}

MockUnsafeSessionServicerServer is an autogenerated mock type for the UnsafeSessionServicerServer type

func NewMockUnsafeSessionServicerServer 

func NewMockUnsafeSessionServicerServer(t interface {
	mock.TestingT
	Cleanup(func())
}) *MockUnsafeSessionServicerServer

NewMockUnsafeSessionServicerServer creates a new instance of MockUnsafeSessionServicerServer. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

type Period 

type Period struct {
	Date                  *pb.Date        `protobuf:"bytes,1,opt,name=date,proto3" json:"date,omitempty"`
	PNL                   float64         `protobuf:"fixed64,2,opt,name=PNL,proto3" json:"PNL,omitempty"`
	Returns               float64         `protobuf:"fixed64,3,opt,name=returns,proto3" json:"returns,omitempty"`
	PortfolioValue        float64         `protobuf:"fixed64,4,opt,name=portfolio_value,json=portfolioValue,proto3" json:"portfolio_value,omitempty"`
	LongsCount            int32           `protobuf:"varint,5,opt,name=longs_count,json=longsCount,proto3" json:"longs_count,omitempty"`
	ShortsCount           int32           `protobuf:"varint,6,opt,name=shorts_count,json=shortsCount,proto3" json:"shorts_count,omitempty"`
	LongValue             float64         `protobuf:"fixed64,7,opt,name=long_value,json=longValue,proto3" json:"long_value,omitempty"`
	ShortValue            float64         `protobuf:"fixed64,8,opt,name=short_value,json=shortValue,proto3" json:"short_value,omitempty"`
	StartingExposure      float64         `protobuf:"fixed64,9,opt,name=starting_exposure,json=startingExposure,proto3" json:"starting_exposure,omitempty"`
	EndingExposure        float64         `protobuf:"fixed64,10,opt,name=ending_exposure,json=endingExposure,proto3" json:"ending_exposure,omitempty"`
	LongExposure          float64         `protobuf:"fixed64,11,opt,name=long_exposure,json=longExposure,proto3" json:"long_exposure,omitempty"`
	ShortExposure         float64         `protobuf:"fixed64,12,opt,name=short_exposure,json=shortExposure,proto3" json:"short_exposure,omitempty"`
	CapitalUsed           float64         `protobuf:"fixed64,13,opt,name=capital_used,json=capitalUsed,proto3" json:"capital_used,omitempty"`
	GrossLeverage         float64         `protobuf:"fixed64,14,opt,name=gross_leverage,json=grossLeverage,proto3" json:"gross_leverage,omitempty"`
	NetLeverage           float64         `protobuf:"fixed64,15,opt,name=net_leverage,json=netLeverage,proto3" json:"net_leverage,omitempty"`
	StartingValue         float64         `protobuf:"fixed64,16,opt,name=starting_value,json=startingValue,proto3" json:"starting_value,omitempty"`
	EndingValue           float64         `protobuf:"fixed64,17,opt,name=ending_value,json=endingValue,proto3" json:"ending_value,omitempty"`
	StartingCash          float64         `protobuf:"fixed64,18,opt,name=starting_cash,json=startingCash,proto3" json:"starting_cash,omitempty"`
	EndingCash            float64         `protobuf:"fixed64,19,opt,name=ending_cash,json=endingCash,proto3" json:"ending_cash,omitempty"`
	MaxDrawdown           float64         `protobuf:"fixed64,20,opt,name=max_drawdown,json=maxDrawdown,proto3" json:"max_drawdown,omitempty"`
	MaxLeverage           float64         `protobuf:"fixed64,21,opt,name=max_leverage,json=maxLeverage,proto3" json:"max_leverage,omitempty"`
	ExcessReturn          float64         `protobuf:"fixed64,22,opt,name=excess_return,json=excessReturn,proto3" json:"excess_return,omitempty"`
	TreasuryPeriodReturn  float64         `` /* 126-byte string literal not displayed */
	AlgorithmPeriodReturn float64         `` /* 129-byte string literal not displayed */
	AlgoVolatility        *float64        `protobuf:"fixed64,25,opt,name=algo_volatility,json=algoVolatility,proto3,oneof" json:"algo_volatility,omitempty"`
	Sharpe                *float64        `protobuf:"fixed64,26,opt,name=sharpe,proto3,oneof" json:"sharpe,omitempty"`
	Sortino               *float64        `protobuf:"fixed64,27,opt,name=sortino,proto3,oneof" json:"sortino,omitempty"`
	BenchmarkPeriodReturn *float64        `` /* 135-byte string literal not displayed */
	BenchmarkVolatility   *float64        `` /* 127-byte string literal not displayed */
	Alpha                 *float64        `protobuf:"fixed64,30,opt,name=alpha,proto3,oneof" json:"alpha,omitempty"`
	Beta                  *float64        `protobuf:"fixed64,31,opt,name=beta,proto3,oneof" json:"beta,omitempty"`
	Positions             []*pb1.Position `protobuf:"bytes,32,rep,name=positions,proto3" json:"positions,omitempty"`
	// contains filtered or unexported fields
}

func (*Period) Descriptor deprecated 

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

Deprecated: Use Period.ProtoReflect.Descriptor instead.

func (*Period) GetAlgoVolatility 

func (x *Period) GetAlgoVolatility() float64

func (*Period) GetAlgorithmPeriodReturn 

func (x *Period) GetAlgorithmPeriodReturn() float64

func (*Period) GetAlpha 

func (x *Period) GetAlpha() float64

func (*Period) GetBenchmarkPeriodReturn 

func (x *Period) GetBenchmarkPeriodReturn() float64

func (*Period) GetBenchmarkVolatility 

func (x *Period) GetBenchmarkVolatility() float64

func (*Period) GetBeta 

func (x *Period) GetBeta() float64

func (*Period) GetCapitalUsed 

func (x *Period) GetCapitalUsed() float64

func (*Period) GetDate 

func (x *Period) GetDate() *pb.Date

func (*Period) GetEndingCash 

func (x *Period) GetEndingCash() float64

func (*Period) GetEndingExposure 

func (x *Period) GetEndingExposure() float64

func (*Period) GetEndingValue 

func (x *Period) GetEndingValue() float64

func (*Period) GetExcessReturn 

func (x *Period) GetExcessReturn() float64

func (*Period) GetGrossLeverage 

func (x *Period) GetGrossLeverage() float64

func (*Period) GetLongExposure 

func (x *Period) GetLongExposure() float64

func (*Period) GetLongValue 

func (x *Period) GetLongValue() float64

func (*Period) GetLongsCount 

func (x *Period) GetLongsCount() int32

func (*Period) GetMaxDrawdown 

func (x *Period) GetMaxDrawdown() float64

func (*Period) GetMaxLeverage 

func (x *Period) GetMaxLeverage() float64

func (*Period) GetNetLeverage 

func (x *Period) GetNetLeverage() float64

func (*Period) GetPNL 

func (x *Period) GetPNL() float64

func (*Period) GetPortfolioValue 

func (x *Period) GetPortfolioValue() float64

func (*Period) GetPositions 

func (x *Period) GetPositions() []*pb1.Position

func (*Period) GetReturns 

func (x *Period) GetReturns() float64

func (*Period) GetSharpe 

func (x *Period) GetSharpe() float64

func (*Period) GetShortExposure 

func (x *Period) GetShortExposure() float64

func (*Period) GetShortValue 

func (x *Period) GetShortValue() float64

func (*Period) GetShortsCount 

func (x *Period) GetShortsCount() int32

func (*Period) GetSortino 

func (x *Period) GetSortino() float64

func (*Period) GetStartingCash 

func (x *Period) GetStartingCash() float64

func (*Period) GetStartingExposure 

func (x *Period) GetStartingExposure() float64

func (*Period) GetStartingValue 

func (x *Period) GetStartingValue() float64

func (*Period) GetTreasuryPeriodReturn 

func (x *Period) GetTreasuryPeriodReturn() float64

func (*Period) ProtoMessage 

func (*Period) ProtoMessage()

func (*Period) ProtoReflect 

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

func (*Period) Reset 

func (x *Period) Reset()

func (*Period) String 

func (x *Period) String() string

type PlaceOrdersAndContinueRequest 

type PlaceOrdersAndContinueRequest struct {
	Orders []*pb.Order `protobuf:"bytes,1,rep,name=orders,proto3" json:"orders,omitempty"`
	// contains filtered or unexported fields
}

func (*PlaceOrdersAndContinueRequest) Descriptor deprecated 

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

Deprecated: Use PlaceOrdersAndContinueRequest.ProtoReflect.Descriptor instead.

func (*PlaceOrdersAndContinueRequest) GetOrders 

func (x *PlaceOrdersAndContinueRequest) GetOrders() []*pb.Order

func (*PlaceOrdersAndContinueRequest) ProtoMessage 

func (*PlaceOrdersAndContinueRequest) ProtoMessage()

func (*PlaceOrdersAndContinueRequest) ProtoReflect 

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

func (*PlaceOrdersAndContinueRequest) Reset 

func (x *PlaceOrdersAndContinueRequest) Reset()

func (*PlaceOrdersAndContinueRequest) String 

func (x *PlaceOrdersAndContinueRequest) String() string

type PlaceOrdersAndContinueResponse 

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

func (*PlaceOrdersAndContinueResponse) Descriptor deprecated 

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

Deprecated: Use PlaceOrdersAndContinueResponse.ProtoReflect.Descriptor instead.

func (*PlaceOrdersAndContinueResponse) ProtoMessage 

func (*PlaceOrdersAndContinueResponse) ProtoMessage()

func (*PlaceOrdersAndContinueResponse) ProtoReflect 

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

func (*PlaceOrdersAndContinueResponse) Reset 

func (x *PlaceOrdersAndContinueResponse) Reset()

func (*PlaceOrdersAndContinueResponse) String 

func (x *PlaceOrdersAndContinueResponse) String() string

type RunExecutionRequest 

type RunExecutionRequest struct {
	ExecutionId string `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	// contains filtered or unexported fields
}

func (*RunExecutionRequest) Descriptor deprecated 

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

Deprecated: Use RunExecutionRequest.ProtoReflect.Descriptor instead.

func (*RunExecutionRequest) GetExecutionId 

func (x *RunExecutionRequest) GetExecutionId() string

func (*RunExecutionRequest) ProtoMessage 

func (*RunExecutionRequest) ProtoMessage()

func (*RunExecutionRequest) ProtoReflect 

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

func (*RunExecutionRequest) Reset 

func (x *RunExecutionRequest) Reset()

func (*RunExecutionRequest) String 

func (x *RunExecutionRequest) String() string

type RunExecutionResponse 

type RunExecutionResponse struct {
	Execution *Execution     `protobuf:"bytes,1,opt,name=execution,proto3" json:"execution,omitempty"`
	Portfolio *pb1.Portfolio `protobuf:"bytes,2,opt,name=portfolio,proto3" json:"portfolio,omitempty"`
	// contains filtered or unexported fields
}

func (*RunExecutionResponse) Descriptor deprecated 

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

Deprecated: Use RunExecutionResponse.ProtoReflect.Descriptor instead.

func (*RunExecutionResponse) GetExecution 

func (x *RunExecutionResponse) GetExecution() *Execution

func (*RunExecutionResponse) GetPortfolio 

func (x *RunExecutionResponse) GetPortfolio() *pb1.Portfolio

func (*RunExecutionResponse) ProtoMessage 

func (*RunExecutionResponse) ProtoMessage()

func (*RunExecutionResponse) ProtoReflect 

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

func (*RunExecutionResponse) Reset 

func (x *RunExecutionResponse) Reset()

func (*RunExecutionResponse) String 

func (x *RunExecutionResponse) String() string

type RunRequest 

type RunRequest struct {
	Backtest *Backtest `protobuf:"bytes,1,opt,name=backtest,proto3" json:"backtest,omitempty"`
	// contains filtered or unexported fields
}

func (*RunRequest) Descriptor deprecated 

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

Deprecated: Use RunRequest.ProtoReflect.Descriptor instead.

func (*RunRequest) GetBacktest 

func (x *RunRequest) GetBacktest() *Backtest

func (*RunRequest) ProtoMessage 

func (*RunRequest) ProtoMessage()

func (*RunRequest) ProtoReflect 

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

func (*RunRequest) Reset 

func (x *RunRequest) Reset()

func (*RunRequest) String 

func (x *RunRequest) String() string

type RunResponse 

type RunResponse struct {
	Backtest *Backtest `protobuf:"bytes,1,opt,name=backtest,proto3" json:"backtest,omitempty"`
	// contains filtered or unexported fields
}

func (*RunResponse) Descriptor deprecated 

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

Deprecated: Use RunResponse.ProtoReflect.Descriptor instead.

func (*RunResponse) GetBacktest 

func (x *RunResponse) GetBacktest() *Backtest

func (*RunResponse) ProtoMessage 

func (*RunResponse) ProtoMessage()

func (*RunResponse) ProtoReflect 

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

func (*RunResponse) Reset 

func (x *RunResponse) Reset()

func (*RunResponse) String 

func (x *RunResponse) String() string

type Session 

type Session struct {
	Id         string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Backtest   string            `protobuf:"bytes,2,opt,name=backtest,proto3" json:"backtest,omitempty"`
	Statuses   []*Session_Status `protobuf:"bytes,3,rep,name=statuses,proto3" json:"statuses,omitempty"`
	Executions int64             `protobuf:"varint,4,opt,name=executions,proto3" json:"executions,omitempty"`
	Port       *int64            `protobuf:"varint,5,opt,name=port,proto3,oneof" json:"port,omitempty"`
	// contains filtered or unexported fields
}

func (*Session) Descriptor deprecated 

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

Deprecated: Use Session.ProtoReflect.Descriptor instead.

func (*Session) GetBacktest 

func (x *Session) GetBacktest() string

func (*Session) GetExecutions 

func (x *Session) GetExecutions() int64

func (*Session) GetId 

func (x *Session) GetId() string

func (*Session) GetPort 

func (x *Session) GetPort() int64

func (*Session) GetStatuses 

func (x *Session) GetStatuses() []*Session_Status

func (*Session) ProtoMessage 

func (*Session) ProtoMessage()

func (*Session) ProtoReflect 

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

func (*Session) Reset 

func (x *Session) Reset()

func (*Session) String 

func (x *Session) String() string

type SessionServicerClient 

type SessionServicerClient interface {
	CreateExecution(ctx context.Context, in *CreateExecutionRequest, opts ...grpc.CallOption) (*CreateExecutionResponse, error)
	RunExecution(ctx context.Context, in *RunExecutionRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[RunExecutionResponse], error)
	StoreResult(ctx context.Context, in *StoreExecutionResultRequest, opts ...grpc.CallOption) (*StoreExecutionResultResponse, error)
	StopServer(ctx context.Context, in *StopServerRequest, opts ...grpc.CallOption) (*StopServerResponse, error)
}

SessionServicerClient is the client API for SessionServicer 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 NewSessionServicerClient 

func NewSessionServicerClient(cc grpc.ClientConnInterface) SessionServicerClient

type SessionServicerServer 

type SessionServicerServer interface {
	CreateExecution(context.Context, *CreateExecutionRequest) (*CreateExecutionResponse, error)
	RunExecution(*RunExecutionRequest, grpc.ServerStreamingServer[RunExecutionResponse]) error
	StoreResult(context.Context, *StoreExecutionResultRequest) (*StoreExecutionResultResponse, error)
	StopServer(context.Context, *StopServerRequest) (*StopServerResponse, error)
	// contains filtered or unexported methods
}

SessionServicerServer is the server API for SessionServicer service. All implementations must embed UnimplementedSessionServicerServer for forward compatibility.

type SessionServicer_RunExecutionClient 

type SessionServicer_RunExecutionClient = grpc.ServerStreamingClient[RunExecutionResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type SessionServicer_RunExecutionServer 

type SessionServicer_RunExecutionServer = grpc.ServerStreamingServer[RunExecutionResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Session_Status 

type Session_Status struct {
	Status     Session_Status_Status  `protobuf:"varint,1,opt,name=status,proto3,enum=foreverbull.backtest.Session_Status_Status" json:"status,omitempty"`
	Error      *string                `protobuf:"bytes,2,opt,name=error,proto3,oneof" json:"error,omitempty"`
	OccurredAt *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=occurred_at,json=occurredAt,proto3" json:"occurred_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Session_Status) Descriptor deprecated 

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

Deprecated: Use Session_Status.ProtoReflect.Descriptor instead.

func (*Session_Status) GetError 

func (x *Session_Status) GetError() string

func (*Session_Status) GetOccurredAt 

func (x *Session_Status) GetOccurredAt() *timestamppb.Timestamp

func (*Session_Status) GetStatus 

func (x *Session_Status) GetStatus() Session_Status_Status

func (*Session_Status) ProtoMessage 

func (*Session_Status) ProtoMessage()

func (*Session_Status) ProtoReflect 

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

func (*Session_Status) Reset 

func (x *Session_Status) Reset()

func (*Session_Status) String 

func (x *Session_Status) String() string

type Session_Status_Status 

type Session_Status_Status int32
const (
	Session_Status_CREATED   Session_Status_Status = 0
	Session_Status_RUNNING   Session_Status_Status = 1
	Session_Status_COMPLETED Session_Status_Status = 2
	Session_Status_FAILED    Session_Status_Status = 3
)

func (Session_Status_Status) Descriptor 

func (Session_Status_Status) Descriptor() protoreflect.EnumDescriptor

func (Session_Status_Status) Enum 

func (x Session_Status_Status) Enum() *Session_Status_Status

func (Session_Status_Status) EnumDescriptor deprecated 

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

Deprecated: Use Session_Status_Status.Descriptor instead.

func (Session_Status_Status) Number 

func (x Session_Status_Status) Number() protoreflect.EnumNumber

func (Session_Status_Status) String 

func (x Session_Status_Status) String() string

func (Session_Status_Status) Type 

func (Session_Status_Status) Type() protoreflect.EnumType

type StopRequest 

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

func (*StopRequest) Descriptor deprecated 

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

Deprecated: Use StopRequest.ProtoReflect.Descriptor instead.

func (*StopRequest) ProtoMessage 

func (*StopRequest) ProtoMessage()

func (*StopRequest) ProtoReflect 

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

func (*StopRequest) Reset 

func (x *StopRequest) Reset()

func (*StopRequest) String 

func (x *StopRequest) String() string

type StopResponse 

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

func (*StopResponse) Descriptor deprecated 

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

Deprecated: Use StopResponse.ProtoReflect.Descriptor instead.

func (*StopResponse) ProtoMessage 

func (*StopResponse) ProtoMessage()

func (*StopResponse) ProtoReflect 

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

func (*StopResponse) Reset 

func (x *StopResponse) Reset()

func (*StopResponse) String 

func (x *StopResponse) String() string

type StopServerRequest 

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

func (*StopServerRequest) Descriptor deprecated 

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

Deprecated: Use StopServerRequest.ProtoReflect.Descriptor instead.

func (*StopServerRequest) ProtoMessage 

func (*StopServerRequest) ProtoMessage()

func (*StopServerRequest) ProtoReflect 

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

func (*StopServerRequest) Reset 

func (x *StopServerRequest) Reset()

func (*StopServerRequest) String 

func (x *StopServerRequest) String() string

type StopServerResponse 

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

func (*StopServerResponse) Descriptor deprecated 

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

Deprecated: Use StopServerResponse.ProtoReflect.Descriptor instead.

func (*StopServerResponse) ProtoMessage 

func (*StopServerResponse) ProtoMessage()

func (*StopServerResponse) ProtoReflect 

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

func (*StopServerResponse) Reset 

func (x *StopServerResponse) Reset()

func (*StopServerResponse) String 

func (x *StopServerResponse) String() string

type StoreExecutionResultRequest 

type StoreExecutionResultRequest struct {
	ExecutionId string `protobuf:"bytes,1,opt,name=execution_id,json=executionId,proto3" json:"execution_id,omitempty"`
	// contains filtered or unexported fields
}

func (*StoreExecutionResultRequest) Descriptor deprecated 

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

Deprecated: Use StoreExecutionResultRequest.ProtoReflect.Descriptor instead.

func (*StoreExecutionResultRequest) GetExecutionId 

func (x *StoreExecutionResultRequest) GetExecutionId() string

func (*StoreExecutionResultRequest) ProtoMessage 

func (*StoreExecutionResultRequest) ProtoMessage()

func (*StoreExecutionResultRequest) ProtoReflect 

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

func (*StoreExecutionResultRequest) Reset 

func (x *StoreExecutionResultRequest) Reset()

func (*StoreExecutionResultRequest) String 

func (x *StoreExecutionResultRequest) String() string

type StoreExecutionResultResponse 

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

func (*StoreExecutionResultResponse) Descriptor deprecated 

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

Deprecated: Use StoreExecutionResultResponse.ProtoReflect.Descriptor instead.

func (*StoreExecutionResultResponse) ProtoMessage 

func (*StoreExecutionResultResponse) ProtoMessage()

func (*StoreExecutionResultResponse) ProtoReflect 

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

func (*StoreExecutionResultResponse) Reset 

func (x *StoreExecutionResultResponse) Reset()

func (*StoreExecutionResultResponse) String 

func (x *StoreExecutionResultResponse) String() string

type UnimplementedBacktestServicerServer 

type UnimplementedBacktestServicerServer struct{}

UnimplementedBacktestServicerServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedBacktestServicerServer) CreateBacktest 

func (UnimplementedBacktestServicerServer) CreateBacktest(context.Context, *CreateBacktestRequest) (*CreateBacktestResponse, error)

func (UnimplementedBacktestServicerServer) CreateSession 

func (UnimplementedBacktestServicerServer) CreateSession(context.Context, *CreateSessionRequest) (*CreateSessionResponse, error)

func (UnimplementedBacktestServicerServer) GetBacktest 

func (UnimplementedBacktestServicerServer) GetBacktest(context.Context, *GetBacktestRequest) (*GetBacktestResponse, error)

func (UnimplementedBacktestServicerServer) GetExecution 

func (UnimplementedBacktestServicerServer) GetExecution(context.Context, *GetExecutionRequest) (*GetExecutionResponse, error)

func (UnimplementedBacktestServicerServer) GetSession 

func (UnimplementedBacktestServicerServer) GetSession(context.Context, *GetSessionRequest) (*GetSessionResponse, error)

func (UnimplementedBacktestServicerServer) ListBacktests 

func (UnimplementedBacktestServicerServer) ListBacktests(context.Context, *ListBacktestsRequest) (*ListBacktestsResponse, error)

func (UnimplementedBacktestServicerServer) ListExecutions 

func (UnimplementedBacktestServicerServer) ListExecutions(context.Context, *ListExecutionsRequest) (*ListExecutionsResponse, error)

type UnimplementedEngineServer 

type UnimplementedEngineServer struct{}

UnimplementedEngineServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedEngineServer) DownloadIngestion 

func (UnimplementedEngineServer) DownloadIngestion(context.Context, *DownloadIngestionRequest) (*DownloadIngestionResponse, error)

func (UnimplementedEngineServer) GetCurrentPeriod 

func (UnimplementedEngineServer) GetCurrentPeriod(context.Context, *GetCurrentPeriodRequest) (*GetCurrentPeriodResponse, error)

func (UnimplementedEngineServer) GetResult 

func (UnimplementedEngineServer) GetResult(context.Context, *GetResultRequest) (*GetResultResponse, error)

func (UnimplementedEngineServer) Ingest 

func (UnimplementedEngineServer) Ingest(context.Context, *IngestRequest) (*IngestResponse, error)

func (UnimplementedEngineServer) PlaceOrdersAndContinue 

func (UnimplementedEngineServer) PlaceOrdersAndContinue(context.Context, *PlaceOrdersAndContinueRequest) (*PlaceOrdersAndContinueResponse, error)

func (UnimplementedEngineServer) RunBacktest 

func (UnimplementedEngineServer) RunBacktest(context.Context, *RunRequest) (*RunResponse, error)

func (UnimplementedEngineServer) Stop 

func (UnimplementedEngineServer) Stop(context.Context, *StopRequest) (*StopResponse, error)

type UnimplementedIngestionServicerServer 

type UnimplementedIngestionServicerServer struct{}

UnimplementedIngestionServicerServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedIngestionServicerServer) GetCurrentIngestion 

func (UnimplementedIngestionServicerServer) GetCurrentIngestion(context.Context, *GetCurrentIngestionRequest) (*GetCurrentIngestionResponse, error)

func (UnimplementedIngestionServicerServer) UpdateIngestion 

func (UnimplementedIngestionServicerServer) UpdateIngestion(context.Context, *UpdateIngestionRequest) (*UpdateIngestionResponse, error)

type UnimplementedSessionServicerServer 

type UnimplementedSessionServicerServer struct{}

UnimplementedSessionServicerServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedSessionServicerServer) CreateExecution 

func (UnimplementedSessionServicerServer) CreateExecution(context.Context, *CreateExecutionRequest) (*CreateExecutionResponse, error)

func (UnimplementedSessionServicerServer) RunExecution 

func (UnimplementedSessionServicerServer) RunExecution(*RunExecutionRequest, grpc.ServerStreamingServer[RunExecutionResponse]) error

func (UnimplementedSessionServicerServer) StopServer 

func (UnimplementedSessionServicerServer) StopServer(context.Context, *StopServerRequest) (*StopServerResponse, error)

func (UnimplementedSessionServicerServer) StoreResult 

func (UnimplementedSessionServicerServer) StoreResult(context.Context, *StoreExecutionResultRequest) (*StoreExecutionResultResponse, error)

type UnsafeBacktestServicerServer 

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

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

type UnsafeEngineServer 

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

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

type UnsafeIngestionServicerServer 

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

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

type UnsafeSessionServicerServer 

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

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

type UpdateIngestionRequest 

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

func (*UpdateIngestionRequest) Descriptor deprecated 

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

Deprecated: Use UpdateIngestionRequest.ProtoReflect.Descriptor instead.

func (*UpdateIngestionRequest) ProtoMessage 

func (*UpdateIngestionRequest) ProtoMessage()

func (*UpdateIngestionRequest) ProtoReflect 

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

func (*UpdateIngestionRequest) Reset 

func (x *UpdateIngestionRequest) Reset()

func (*UpdateIngestionRequest) String 

func (x *UpdateIngestionRequest) String() string

type UpdateIngestionResponse 

type UpdateIngestionResponse struct {
	Ingestion *Ingestion      `protobuf:"bytes,1,opt,name=ingestion,proto3" json:"ingestion,omitempty"`
	Status    IngestionStatus `protobuf:"varint,2,opt,name=status,proto3,enum=foreverbull.backtest.IngestionStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateIngestionResponse) Descriptor deprecated 

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

Deprecated: Use UpdateIngestionResponse.ProtoReflect.Descriptor instead.

func (*UpdateIngestionResponse) GetIngestion 

func (x *UpdateIngestionResponse) GetIngestion() *Ingestion

func (*UpdateIngestionResponse) GetStatus 

func (x *UpdateIngestionResponse) GetStatus() IngestionStatus

func (*UpdateIngestionResponse) ProtoMessage 

func (*UpdateIngestionResponse) ProtoMessage()

func (*UpdateIngestionResponse) ProtoReflect 

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

func (*UpdateIngestionResponse) Reset 

func (x *UpdateIngestionResponse) Reset()

func (*UpdateIngestionResponse) String 

func (x *UpdateIngestionResponse) 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.