helpers

Documentation

Overview

Licensed to Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. Apache Software Foundation (ASF) licenses this file to you under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Licensed to Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. Apache Software Foundation (ASF) licenses this file to you under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Licensed to Apache Software Foundation (ASF) under one or more contributor license agreements. See the NOTICE file distributed with this work for additional information regarding copyright ownership. Apache Software Foundation (ASF) licenses this file to you under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at

http://www.apache.org/licenses/LICENSE-2.0

Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.

Index

• Variables
• func HTTPHealthCheck(addr string) func() error
• func HealthCheck(addr string, connTimeout time.Duration, rpcTimeout time.Duration) func() error
• func TimeRange(args Args, shardContext SharedContext) *model_v1.TimeRange
• func UnmarshalYAML(ii []byte, m proto.Message)
• type Args
• type FailInterceptor
  • func NewFailInterceptor(fail types.GomegaFailHandler) *FailInterceptor
  • func (f *FailInterceptor) DidFail() bool
  • func (f *FailInterceptor) Fail(message string, callerSkip ...int)
  • func (f *FailInterceptor) Reset()
• type SharedContext

Variables

var (
	ErrServiceUnhealthy = errors.New("service is unhealthy")
)

Functions

func HTTPHealthCheck

func HTTPHealthCheck(addr string) func() error

func HealthCheck

func HealthCheck(addr string, connTimeout time.Duration, rpcTimeout time.Duration) func() error

func TimeRange

func TimeRange(args Args, shardContext SharedContext) *model_v1.TimeRange

func UnmarshalYAML

func UnmarshalYAML(ii []byte, m proto.Message)

Types

type Args

type Args struct {
	Input     string
	Offset    time.Duration
	Duration  time.Duration
	Begin     *timestamppb.Timestamp
	End       *timestamppb.Timestamp
	Want      string
	WantEmpty bool
	WantErr   bool
}

type FailInterceptor

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

func NewFailInterceptor

func NewFailInterceptor(fail types.GomegaFailHandler) *FailInterceptor

func (*FailInterceptor) DidFail

func (f *FailInterceptor) DidFail() bool

func (*FailInterceptor) Fail

func (f *FailInterceptor) Fail(message string, callerSkip ...int)

func (*FailInterceptor) Reset

func (f *FailInterceptor) Reset()

type SharedContext

type SharedContext struct {
	Connection *grpclib.ClientConn
	BaseTime   time.Time
}